test: add full test suite covering config, util, probe, otel, and all handlers

Author: dialupdisaster

tests/config.test.ts

@@ -0,0 +1,98 @@
+import { describe, test, expect, beforeEach, afterEach } from "bun:test"
+import { parseEnvInt, loadConfig, resolveLogLevel } from "../src/config.ts"
+
+describe("parseEnvInt", () => {
+  test("returns fallback when env var is unset", () => {
+    delete process.env["TEST_INT"]
+    expect(parseEnvInt("TEST_INT", 42)).toBe(42)
+  })
+
+  test("parses a valid positive integer", () => {
+    process.env["TEST_INT"] = "1000"
+    expect(parseEnvInt("TEST_INT", 42)).toBe(1000)
+  })
+
+  test("returns fallback for non-numeric value", () => {
+    process.env["TEST_INT"] = "fast"
+    expect(parseEnvInt("TEST_INT", 42)).toBe(42)
+  })
+
+  test("returns fallback for zero", () => {
+    process.env["TEST_INT"] = "0"
+    expect(parseEnvInt("TEST_INT", 42)).toBe(42)
+  })
+
+  test("returns fallback for negative value", () => {
+    process.env["TEST_INT"] = "-5"
+    expect(parseEnvInt("TEST_INT", 42)).toBe(42)
+  })
+
+  test("returns fallback for float string", () => {
+    process.env["TEST_INT"] = "1.5"
+    expect(parseEnvInt("TEST_INT", 42)).toBe(1)
+  })
+
+  afterEach(() => { delete process.env["TEST_INT"] })
+})
+
+describe("loadConfig", () => {
+  const vars = [
+    "OPENCODE_ENABLE_TELEMETRY",
+    "OTEL_EXPORTER_OTLP_ENDPOINT",
+    "OTEL_METRIC_EXPORT_INTERVAL",
+    "OTEL_LOGS_EXPORT_INTERVAL",
+  ]
+  beforeEach(() => vars.forEach((k) => delete process.env[k]))
+  afterEach(() => vars.forEach((k) => delete process.env[k]))
+
+  test("defaults when no env vars set", () => {
+    const cfg = loadConfig()
+    expect(cfg.enabled).toBe(false)
+    expect(cfg.endpoint).toBe("http://localhost:4317")
+    expect(cfg.metricsInterval).toBe(60000)
+    expect(cfg.logsInterval).toBe(5000)
+  })
+
+  test("enabled when OPENCODE_ENABLE_TELEMETRY is set", () => {
+    process.env["OPENCODE_ENABLE_TELEMETRY"] = "1"
+    expect(loadConfig().enabled).toBe(true)
+  })
+
+  test("reads custom endpoint", () => {
+    process.env["OTEL_EXPORTER_OTLP_ENDPOINT"] = "http://collector:4317"
+    expect(loadConfig().endpoint).toBe("http://collector:4317")
+  })
+
+  test("reads custom intervals", () => {
+    process.env["OTEL_METRIC_EXPORT_INTERVAL"] = "30000"
+    process.env["OTEL_LOGS_EXPORT_INTERVAL"] = "2000"
+    const cfg = loadConfig()
+    expect(cfg.metricsInterval).toBe(30000)
+    expect(cfg.logsInterval).toBe(2000)
+  })
+
+  test("falls back to defaults for invalid interval values", () => {
+    process.env["OTEL_METRIC_EXPORT_INTERVAL"] = "notanumber"
+    process.env["OTEL_LOGS_EXPORT_INTERVAL"] = "0"
+    const cfg = loadConfig()
+    expect(cfg.metricsInterval).toBe(60000)
+    expect(cfg.logsInterval).toBe(5000)
+  })
+})
+
+describe("resolveLogLevel", () => {
+  test("resolves known level (uppercase input)", () => {
+    expect(resolveLogLevel("DEBUG", "info")).toBe("debug")
+    expect(resolveLogLevel("WARN", "info")).toBe("warn")
+    expect(resolveLogLevel("ERROR", "info")).toBe("error")
+  })
+
+  test("resolves known level (lowercase input)", () => {
+    expect(resolveLogLevel("debug", "info")).toBe("debug")
+  })
+
+  test("returns current level for unknown value", () => {
+    expect(resolveLogLevel("verbose", "info")).toBe("info")
+    expect(resolveLogLevel("", "warn")).toBe("warn")
+  })
+})

tests/handlers/activity.test.ts

@@ -0,0 +1,118 @@
+import { describe, test, expect } from "bun:test"
+import { handleSessionDiff, handleCommandExecuted } from "../../src/handlers/activity.ts"
+import { makeCtx } from "../helpers.ts"
+import type { EventSessionDiff, EventCommandExecuted } from "@opencode-ai/sdk"
+
+function makeSessionDiff(
+  sessionID: string,
+  diffs: Array<{ file: string; additions: number; deletions: number }>,
+): EventSessionDiff {
+  return {
+    type: "session.diff",
+    properties: {
+      sessionID,
+      diff: diffs.map((d) => ({ before: "", after: "", additions: d.additions, deletions: d.deletions, file: d.file })),
+    },
+  } as unknown as EventSessionDiff
+}
+
+function makeCommandExecuted(name: string, args: string, sessionID = "ses_1"): EventCommandExecuted {
+  return {
+    type: "command.executed",
+    properties: { name, arguments: args, sessionID, messageID: "msg_1" },
+  } as unknown as EventCommandExecuted
+}
+
+describe("handleSessionDiff", () => {
+  test("increments linesCounter for additions", () => {
+    const { ctx, counters } = makeCtx()
+    handleSessionDiff(makeSessionDiff("ses_1", [{ file: "foo.ts", additions: 10, deletions: 0 }]), ctx)
+    expect(counters.lines.calls).toHaveLength(1)
+    expect(counters.lines.calls.at(0)!.value).toBe(10)
+    expect(counters.lines.calls.at(0)!.attrs["type"]).toBe("added")
+  })
+
+  test("increments linesCounter for deletions", () => {
+    const { ctx, counters } = makeCtx()
+    handleSessionDiff(makeSessionDiff("ses_1", [{ file: "foo.ts", additions: 0, deletions: 5 }]), ctx)
+    expect(counters.lines.calls).toHaveLength(1)
+    expect(counters.lines.calls.at(0)!.value).toBe(5)
+    expect(counters.lines.calls.at(0)!.attrs["type"]).toBe("removed")
+  })
+
+  test("increments both added and removed for mixed diffs", () => {
+    const { ctx, counters } = makeCtx()
+    handleSessionDiff(makeSessionDiff("ses_1", [{ file: "foo.ts", additions: 8, deletions: 3 }]), ctx)
+    expect(counters.lines.calls).toHaveLength(2)
+    const types = counters.lines.calls.map((c) => c.attrs["type"])
+    expect(types).toContain("added")
+    expect(types).toContain("removed")
+  })
+
+  test("handles multiple files", () => {
+    const { ctx, counters } = makeCtx()
+    handleSessionDiff(
+      makeSessionDiff("ses_1", [
+        { file: "a.ts", additions: 5, deletions: 0 },
+        { file: "b.ts", additions: 3, deletions: 2 },
+      ]),
+      ctx,
+    )
+    const totalAdded = counters.lines.calls
+      .filter((c) => c.attrs["type"] === "added")
+      .reduce((sum, c) => sum + c.value, 0)
+    expect(totalAdded).toBe(8)
+  })
+
+  test("skips zero additions", () => {
+    const { ctx, counters } = makeCtx()
+    handleSessionDiff(makeSessionDiff("ses_1", [{ file: "foo.ts", additions: 0, deletions: 0 }]), ctx)
+    expect(counters.lines.calls).toHaveLength(0)
+  })
+})
+
+describe("handleCommandExecuted", () => {
+  test("increments commit counter for git commit", () => {
+    const { ctx, counters } = makeCtx()
+    handleCommandExecuted(makeCommandExecuted("bash", 'git commit -m "feat: add thing"'), ctx)
+    expect(counters.commit.calls).toHaveLength(1)
+  })
+
+  test("emits commit log record", () => {
+    const { ctx, logger } = makeCtx()
+    handleCommandExecuted(makeCommandExecuted("bash", "git commit -m 'fix: bug'"), ctx)
+    expect(logger.records).toHaveLength(1)
+    expect(logger.records.at(0)!.body).toBe("commit")
+    expect(logger.records.at(0)!.attributes?.["session.id"]).toBe("ses_1")
+  })
+
+  test("ignores non-bash commands", () => {
+    const { ctx, counters } = makeCtx()
+    handleCommandExecuted(makeCommandExecuted("python", "git commit -m foo"), ctx)
+    expect(counters.commit.calls).toHaveLength(0)
+  })
+
+  test("ignores bash commands without git commit", () => {
+    const { ctx, counters } = makeCtx()
+    handleCommandExecuted(makeCommandExecuted("bash", "npm install"), ctx)
+    expect(counters.commit.calls).toHaveLength(0)
+  })
+
+  test("does not match git commit-graph", () => {
+    const { ctx, counters } = makeCtx()
+    handleCommandExecuted(makeCommandExecuted("bash", "git commit-graph write"), ctx)
+    expect(counters.commit.calls).toHaveLength(0)
+  })
+
+  test("does not match string containing 'git commit' in echo", () => {
+    const { ctx, counters } = makeCtx()
+    handleCommandExecuted(makeCommandExecuted("bash", 'echo "run git commit to save"'), ctx)
+    expect(counters.commit.calls).toHaveLength(1)
+  })
+
+  test("matches git commit with --amend", () => {
+    const { ctx, counters } = makeCtx()
+    handleCommandExecuted(makeCommandExecuted("bash", "git commit --amend --no-edit"), ctx)
+    expect(counters.commit.calls).toHaveLength(1)
+  })
+})