chore: generate

packages/core/src/location-layer.ts

@@ -86,17 +86,9 @@ export class LocationServiceMap extends LayerMap.Service<LocationServiceMap>()("
       Layer.provide(model),
       Layer.provide(skillGuidance),
     )
-    return Layer.mergeAll(
-      services,
-      commits,
-      searches,
-      resources,
-      todos,
-      questions,
-      model,
-      runner,
-      builtInTools,
-    ).pipe(Layer.fresh)
+    return Layer.mergeAll(services, commits, searches, resources, todos, questions, model, runner, builtInTools).pipe(
+      Layer.fresh,
+    )
   },
   idleTimeToLive: "60 minutes",
   dependencies: [

packages/core/src/session.ts

@@ -409,7 +409,8 @@ export const layer = Layer.effect(
               sessionID,
               timestamp: yield* DateTime.now,
             })
-            if (event.seq === undefined) return yield* Effect.die("Interrupt request event is missing aggregate sequence")
+            if (event.seq === undefined)
+              return yield* Effect.die("Interrupt request event is missing aggregate sequence")
             yield* execution.interrupt(sessionID, event.seq)
           }),
         ),

packages/core/src/session/run-coordinator.ts

@@ -95,7 +95,10 @@ export const make = <Key, A, E>(options: {
       // Initial work retains immediate-start behavior but cannot run before ownership is published.
       // Observer-started successors yield once so synchronous drains cannot recurse on the JS stack.
       const owner = fork(
-        (successor ? Effect.yieldNow.pipe(Effect.andThen(drain)) : Deferred.await(ready).pipe(Effect.andThen(drain))).pipe(
+        (successor
+          ? Effect.yieldNow.pipe(Effect.andThen(drain))
+          : Deferred.await(ready).pipe(Effect.andThen(drain))
+        ).pipe(
           Effect.onExit((exit) => Effect.sync(() => settle(key, entry, demand, exit))),
           Effect.exit,
           Effect.asVoid,
@@ -194,7 +197,12 @@ export const make = <Key, A, E>(options: {
           return entry?.stopping && entry.owner !== undefined ? Fiber.interrupt(entry.owner) : Effect.void
         if (seq !== undefined) interruptSeq.set(key, seq)
         if (entry?.owner === undefined) return Effect.void
-        if (seq !== undefined && entry.current._tag === "wake" && entry.current.seq !== undefined && entry.current.seq > seq)
+        if (
+          seq !== undefined &&
+          entry.current._tag === "wake" &&
+          entry.current.seq !== undefined &&
+          entry.current.seq > seq
+        )
           return Effect.void
         if (entry.stopping) {
           entry.interruptSeq = maxSeq(entry.interruptSeq, seq)
@@ -246,7 +254,12 @@ export const make = <Key, A, E>(options: {
     }
 
     function suppressPendingAtOrBefore(entry: Entry<A, E>, seq: number | undefined) {
-      if (entry.pending?._tag === "wake" && seq !== undefined && entry.pending.seq !== undefined && entry.pending.seq > seq)
+      if (
+        entry.pending?._tag === "wake" &&
+        seq !== undefined &&
+        entry.pending.seq !== undefined &&
+        entry.pending.seq > seq
+      )
         return
       entry.pending = undefined
     }

packages/core/test/session-prompt.test.ts

@@ -578,7 +578,11 @@ describe("SessionV2.prompt", () => {
       wakeCalls.length = 0
       wakeSeqs.length = 0
 
-      const admitted = yield* session.prompt({ sessionID, prompt: new Prompt({ text: "Run explicitly" }), resume: true })
+      const admitted = yield* session.prompt({
+        sessionID,
+        prompt: new Prompt({ text: "Run explicitly" }),
+        resume: true,
+      })
 
       expect(executionCalls).toEqual([])
       expect(wakeCalls).toEqual([sessionID])

packages/core/test/session-run-coordinator.test.ts

@@ -325,9 +325,7 @@ describe("SessionRunCoordinator", () => {
           drain: () =>
             Effect.sync(() => ++runs).pipe(
               Effect.flatMap((run) =>
-                run === 1
-                  ? Deferred.succeed(firstStarted, undefined).pipe(Effect.andThen(Effect.never))
-                  : Effect.void,
+                run === 1 ? Deferred.succeed(firstStarted, undefined).pipe(Effect.andThen(Effect.never)) : Effect.void,
               ),
             ),
         })

packages/core/test/session-runner-recorded.test.ts

@@ -81,7 +81,11 @@ const execution = Layer.effect(
   SessionExecution.Service,
   SessionRunCoordinator.Service.pipe(
     Effect.map((coordinator) =>
-      SessionExecution.Service.of({ resume: coordinator.run, wake: coordinator.wake, interrupt: coordinator.interrupt }),
+      SessionExecution.Service.of({
+        resume: coordinator.run,
+        wake: coordinator.wake,
+        interrupt: coordinator.interrupt,
+      }),
     ),
   ),
 ).pipe(Layer.provide(coordinator))

packages/core/test/session-runner.test.ts

@@ -221,7 +221,11 @@ const execution = Layer.effect(
   SessionExecution.Service,
   SessionRunCoordinator.Service.pipe(
     Effect.map((coordinator) =>
-      SessionExecution.Service.of({ resume: coordinator.run, wake: coordinator.wake, interrupt: coordinator.interrupt }),
+      SessionExecution.Service.of({
+        resume: coordinator.run,
+        wake: coordinator.wake,
+        interrupt: coordinator.interrupt,
+      }),
     ),
   ),
 ).pipe(Layer.provide(coordinator))