kilocode/packages/kilo-vscode/tests/unit/session-activity.test.ts

import { describe, expect, it } from "bun:test"
import {
  activities,
  activity,
  isActivity,
  label,
  running,
  score,
  strongest,
  type Activity,
} from "../../webview-ui/src/utils/session-activity"
import { ancestry } from "../../webview-ui/src/context/session-utils"

describe("activity", () => {
  it("maps backend states", () => {
    expect(activity({})).toBe("idle")
    expect(activity({ status: "busy" })).toBe("busy")
    expect(activity({ status: "retry" })).toBe("retry")
    expect(activity({ status: "offline" })).toBe("error")
  })

  it("prioritizes waiting over terminal and running states", () => {
    expect(activity({ status: "busy", blocked: true, errored: true, finished: true })).toBe("waiting")
  })

  it("prioritizes errors over running and completed states", () => {
    expect(activity({ status: "retry", errored: true, finished: true })).toBe("error")
  })

  it("only reports done while idle", () => {
    expect(activity({ status: "busy", finished: true })).toBe("busy")
    expect(activity({ finished: true })).toBe("done")
  })
})

describe("activities", () => {
  const parents = new Map([
    ["child", "root"],
    ["nested", "child"],
  ])

  it("derives nested requests and active work without reading transcript pages", () => {
    const result = activities({
      parents,
      statuses: { root: { type: "idle" }, child: { type: "retry" }, other: { type: "busy" } },
      outcomes: {},
      blocked: ["nested"],
      disconnected: false,
    })
    expect(result).toEqual({ root: "waiting", child: "waiting", nested: "waiting", other: "busy" })
  })

  it("rolls up child work but leaves terminal outcomes with their owning sessions", () => {
    const input = {
      parents,
      statuses: {},
      outcomes: { child: { reason: "error" }, nested: { reason: "completed" } },
      blocked: [],
      disconnected: false,
    }
    expect(activities(input)).toEqual({ child: "error", nested: "done" })
    expect(activities({ ...input, submitting: ["nested"] })).toEqual({
      root: "busy",
      child: "error",
      nested: "busy",
    })
    expect(activities({ ...input, outcomes: { ...input.outcomes, root: { reason: "completed" } } }).root).toBe("done")
  })

  it("shows disconnected active sessions as errors without changing idle or completed sessions", () => {
    const input = {
      parents,
      statuses: { root: { type: "busy" as const }, other: { type: "idle" as const } },
      outcomes: { complete: { reason: "completed" } },
      blocked: ["nested"],
      disconnected: true,
    }
    expect(activities(input)).toEqual({
      root: "error",
      child: "error",
      nested: "error",
      other: "idle",
      complete: "done",
    })
    expect(activities({ ...input, disconnected: false }).root).toBe("waiting")
  })

  it("does not leak a parent request into child or sibling session indicators", () => {
    expect(
      activities({
        parents,
        statuses: { child: { type: "busy" }, nested: { type: "idle" } },
        outcomes: {},
        blocked: ["root"],
        disconnected: false,
      }),
    ).toEqual({ root: "waiting", child: "busy", nested: "idle" })
  })

  it("guards cycles and does not mutate its source state", () => {
    const parents = new Map([
      ["first", "second"],
      ["second", "first"],
    ])
    const statuses = { first: { type: "busy" as const } }
    const input = { parents, statuses, outcomes: {}, blocked: [], disconnected: false }
    expect(activities(input)).toEqual({ first: "busy", second: "busy" })
    expect(activities({ ...input, statuses: {} })).toEqual({})
    expect(statuses).toEqual({ first: { type: "busy" } })
  })
})

describe("ancestry", () => {
  it("prefers durable session metadata over task and close-event fallbacks", () => {
    const result = ancestry(
      { child: { parentID: "root" }, root: { parentID: null } },
      {
        other: [
          { type: "tool", tool: "task", metadata: { sessionId: "child" } },
          { type: "tool", tool: "task", state: { metadata: { sessionId: "fallback" } } },
        ],
      },
      { child: { parentID: "stale" }, missing: { parentID: "root" } },
    )
    expect(Object.fromEntries(result.parents)).toEqual({ child: "root", fallback: "other", missing: "root" })
    expect(result.children.get("root")).toEqual(["child", "missing"])
  })
})

describe("isActivity", () => {
  it("accepts only known presentation states", () => {
    expect(isActivity("waiting")).toBe(true)
    expect(isActivity("done")).toBe(true)
    expect(isActivity("idle")).toBe(true)
    expect(isActivity("unknown")).toBe(false)
    expect(isActivity({ state: "waiting" })).toBe(false)
    expect(isActivity(undefined)).toBe(false)
  })
})

describe("running", () => {
  it("matches spinner states", () => {
    expect(running("busy")).toBe(true)
    expect(running("retry")).toBe(true)
    expect(running("waiting")).toBe(false)
    expect(running("done")).toBe(false)
  })
})

describe("score", () => {
  it("preserves every activity priority with idle scoring zero", () => {
    const states: Activity[] = ["idle", "done", "busy", "retry", "error", "waiting"]
    expect(states.map(score)).toEqual([0, 1, 2, 3, 4, 5])
    for (const [index, state] of states.entries()) {
      for (const lower of states.slice(0, index + 1)) {
        expect(strongest([state, lower])).toBe(state)
        expect(strongest([lower, state])).toBe(state)
      }
    }
  })
})

describe("strongest", () => {
  it("returns the highest priority state", () => {
    expect(strongest(["busy", "waiting", "idle"])).toBe("waiting")
    expect(strongest(["done", "error", "retry"])).toBe("error")
    expect(strongest(["done", "busy"])).toBe("busy")
    expect(strongest([])).toBe("idle")
  })
})

describe("label", () => {
  it("returns existing translation keys", () => {
    const states: Activity[] = ["waiting", "error", "retry", "busy", "done", "idle"]
    expect(states.map(label)).toEqual([
      "task.backgroundAgents.needsInput",
      "task.backgroundAgents.status.error",
      "session.status.retry",
      "session.tabs.switcher.busy",
      "task.backgroundAgents.status.completed",
      "session.current",
    ])
  })
})