openAgent

1import { afterEach, describe, expect, test } from "bun:test"
2import { NodeFileSystem } from "@effect/platform-node"
3import { Effect, Layer, Logger } from "effect"
4import fs from "fs/promises"
5import os from "os"
6import path from "path"
7import { fileLogger } from "../../src/observability/logging"
8import { resource } from "../../src/observability/otlp"
9 
10const otelResourceAttributes = process.env.OTEL_RESOURCE_ATTRIBUTES
11const opencodeClient = process.env.OPENCODE_CLIENT
12 
13afterEach(() => {
14  if (otelResourceAttributes === undefined) delete process.env.OTEL_RESOURCE_ATTRIBUTES
15  else process.env.OTEL_RESOURCE_ATTRIBUTES = otelResourceAttributes
16 
17  if (opencodeClient === undefined) delete process.env.OPENCODE_CLIENT
18  else process.env.OPENCODE_CLIENT = opencodeClient
19})
20 
21describe("resource", () => {
22  test("parses and decodes OTEL resource attributes", () => {
23    process.env.OTEL_RESOURCE_ATTRIBUTES =
24      "service.namespace=anomalyco,team=platform%2Cobservability,label=hello%3Dworld,key%2Fname=value%20here"
25 
26    expect(resource().attributes).toMatchObject({
27      "service.namespace": "anomalyco",
28      team: "platform,observability",
29      label: "hello=world",
30      "key/name": "value here",
31    })
32  })
33 
34  test("drops OTEL resource attributes when any entry is invalid", () => {
35    process.env.OTEL_RESOURCE_ATTRIBUTES = "service.namespace=anomalyco,broken"
36 
37    expect(resource().attributes["service.namespace"]).toBeUndefined()
38    expect(resource().attributes["opencode.client"]).toBeDefined()
39  })
40 
41  test("keeps built-in attributes when env values conflict", () => {
42    process.env.OPENCODE_CLIENT = "cli"
43    process.env.OTEL_RESOURCE_ATTRIBUTES =
44      "opencode.client=web,service.instance.id=override,service.namespace=anomalyco"
45 
46    expect(resource().attributes).toMatchObject({
47      "opencode.client": "cli",
48      "service.namespace": "anomalyco",
49    })
50    expect(resource().attributes["service.instance.id"]).not.toBe("override")
51    expect(resource().attributes["opencode.run"]).toMatch(/^[0-9a-f]{8}$/)
52  })
53})
54 
55test("file logger appends concurrent runs with a run on every line", async () => {
56  const dir = await fs.mkdtemp(path.join(os.tmpdir(), "opencode-log-test-"))
57  await using _ = {
58    async [Symbol.asyncDispose]() {
59      await fs.rm(dir, { recursive: true, force: true })
60    },
61  }
62  const file = path.join(dir, "opencode.log")
63  const write = (runID: string) =>
64    Effect.forEach(
65      Array.from({ length: 50 }, (_, index) => index),
66      (index) => Effect.logInfo(`entry-${index}`),
67    ).pipe(
68      Effect.provide(Logger.layer([fileLogger(file, runID)]).pipe(Layer.provide(NodeFileSystem.layer), Layer.orDie)),
69      Effect.scoped,
70    )
71 
72  await Effect.runPromise(Effect.all([write("run-a"), write("run-b")], { concurrency: "unbounded" }))
73 
74  const lines = (await Bun.file(file).text()).trim().split("\n")
75  expect(lines).toHaveLength(100)
76  expect(lines.filter((line) => line.includes("run=run-a"))).toHaveLength(50)
77  expect(lines.filter((line) => line.includes("run=run-b"))).toHaveLength(50)
78  expect(lines.every((line) => line.startsWith("timestamp=") && line.includes(" level=INFO "))).toBe(true)
79  expect(lines.every((line) => !line.includes(" fiber="))).toBe(true)
80  expect(lines.every((line) => !line.startsWith("{"))).toBe(true)
81})
82 
83test("file logger flattens nested objects", async () => {
84  const dir = await fs.mkdtemp(path.join(os.tmpdir(), "opencode-log-test-"))
85  await using _ = {
86    async [Symbol.asyncDispose]() {
87      await fs.rm(dir, { recursive: true, force: true })
88    },
89  }
90  const file = path.join(dir, "opencode.log")
91 
92  await Effect.logInfo("request complete", {
93    request: { method: "GET", timing: { duration: 42 } },
94    tags: ["api", "test"],
95  }).pipe(
96    Effect.annotateLogs({ session: { id: "session-1" } }),
97    Effect.provide(Logger.layer([fileLogger(file, "run-a")]).pipe(Layer.provide(NodeFileSystem.layer), Layer.orDie)),
98    Effect.scoped,
99    Effect.runPromise,
100  )
101 
102  const line = (await Bun.file(file).text()).trim()
103  expect(line).toContain('message="request complete"')
104  expect(line).toContain("request.method=GET")
105  expect(line).toContain("request.timing.duration=42")
106  expect(line).toContain('tags="[\\\"api\\\",\\\"test\\\"]"')
107  expect(line).toContain("session.id=session-1")
108  expect(line).not.toContain("request={")
109})
110