test(server): migrate session select to effect runner (#27203)

packages/opencode/test/server/session-select.test.ts

@@ -1,101 +1,87 @@
-import { afterEach, describe, expect, test } from "bun:test"
+import { describe, expect } from "bun:test"
 import { Effect } from "effect"
-import { Session as SessionNs } from "@/session/session"
+import { Session } from "@/session/session"
-import type { SessionID } from "../../src/session/schema"
 import * as Log from "@opencode-ai/core/util/log"
-import { Instance } from "../../src/project/instance"
-import { WithInstance } from "../../src/project/with-instance"
 import { Server } from "../../src/server/server"
-import { disposeAllInstances, tmpdir } from "../fixture/fixture"
+import { TestInstance } from "../fixture/fixture"
+import { testEffect } from "../lib/effect"
 
 void Log.init({ print: false })
 
-function run<A, E>(fx: Effect.Effect<A, E, SessionNs.Service>) {
+const it = testEffect(Session.defaultLayer)
-  return Effect.runPromise(fx.pipe(Effect.provide(SessionNs.defaultLayer)))
-}
-
-const svc = {
-  ...SessionNs,
-  create(input?: SessionNs.CreateInput) {
-    return run(SessionNs.Service.use((svc) => svc.create(input)))
-  },
-  remove(id: SessionID) {
-    return run(SessionNs.Service.use((svc) => svc.remove(id)))
-  },
-}
-
-afterEach(async () => {
-  await disposeAllInstances()
-})
 
 describe("tui.selectSession endpoint", () => {
-  test("should return 200 when called with valid session", async () => {
+  it.instance("should return 200 when called with valid session", () =>
-    await using tmp = await tmpdir({ git: true })
+    Effect.gen(function* () {
-    await WithInstance.provide({
+      const tmp = yield* TestInstance
-      directory: tmp.path,
+      const session = yield* Session.Service.use((svc) => svc.create({}))
-      fn: async () => {
-        // #given
-        const session = await svc.create({})
 
-        // #when
       const app = Server.Default().app
-        const response = await app.request("/tui/select-session", {
+      const response = yield* Effect.promise(() =>
+        Promise.resolve(
+          app.request("/tui/select-session", {
             method: "POST",
-          headers: { "Content-Type": "application/json" },
+            headers: {
-          body: JSON.stringify({ sessionID: session.id }),
+              "Content-Type": "application/json",
-        })
+              "x-opencode-directory": tmp.directory,
-
-        // #then
-        expect(response.status).toBe(200)
-        const body = await response.json()
-        expect(body).toBe(true)
-
-        await svc.remove(session.id)
             },
-    })
+            body: JSON.stringify({ sessionID: session.id }),
-  })
+          }),
+        ),
+      )
 
-  test("should return 404 when session does not exist", async () => {
+      expect(response.status).toBe(200)
-    await using tmp = await tmpdir({ git: true })
+      const body = yield* Effect.promise(() => response.json())
-    await WithInstance.provide({
+      expect(body).toBe(true)
-      directory: tmp.path,
+    }),
-      fn: async () => {
+    { git: true },
-        // #given
+  )
+
+  it.instance("should return 404 when session does not exist", () =>
+    Effect.gen(function* () {
+      const tmp = yield* TestInstance
       const nonExistentSessionID = "ses_nonexistent123"
 
-        // #when
       const app = Server.Default().app
-        const response = await app.request("/tui/select-session", {
+      const response = yield* Effect.promise(() =>
+        Promise.resolve(
+          app.request("/tui/select-session", {
             method: "POST",
-          headers: { "Content-Type": "application/json" },
+            headers: {
-          body: JSON.stringify({ sessionID: nonExistentSessionID }),
+              "Content-Type": "application/json",
-        })
+              "x-opencode-directory": tmp.directory,
-
-        // #then
-        expect(response.status).toBe(404)
             },
-    })
+            body: JSON.stringify({ sessionID: nonExistentSessionID }),
-  })
+          }),
+        ),
+      )
 
-  test("should return 400 when session ID format is invalid", async () => {
+      expect(response.status).toBe(404)
-    await using tmp = await tmpdir({ git: true })
+    }),
-    await WithInstance.provide({
+    { git: true },
-      directory: tmp.path,
+  )
-      fn: async () => {
+
-        // #given
+  it.instance("should return 400 when session ID format is invalid", () =>
+    Effect.gen(function* () {
+      const tmp = yield* TestInstance
       const invalidSessionID = "invalid_session_id"
 
-        // #when
       const app = Server.Default().app
-        const response = await app.request("/tui/select-session", {
+      const response = yield* Effect.promise(() =>
+        Promise.resolve(
+          app.request("/tui/select-session", {
             method: "POST",
-          headers: { "Content-Type": "application/json" },
+            headers: {
-          body: JSON.stringify({ sessionID: invalidSessionID }),
+              "Content-Type": "application/json",
-        })
+              "x-opencode-directory": tmp.directory,
-
-        // #then
-        expect(response.status).toBe(400)
             },
-    })
+            body: JSON.stringify({ sessionID: invalidSessionID }),
-  })
+          }),
+        ),
+      )
+
+      expect(response.status).toBe(400)
+    }),
+    { git: true },
+  )
 })