feat(schema,server,plugin): add subagent live events, global executor wiring, and v2 plugin hooks

Author: See U

packages/plugin/src/v2/effect/context.ts

@@ -3,10 +3,12 @@ import type { AgentHooks } from "./agent.js"
 import type { AISDKHooks } from "./aisdk.js"
 import type { CatalogHooks } from "./catalog.js"
 import type { CommandHooks } from "./command.js"
+import type { Event } from "./event.js"
 import type { IntegrationHooks } from "./integration.js"
 import type { PluginDomain } from "./plugin.js"
 import type { ReferenceHooks } from "./reference.js"
 import type { SkillHooks } from "./skill.js"
+import type { ToolHooks } from "./tool.js"
 import type { Reload } from "./registration.js"
 
 export interface PluginContext {
@@ -15,8 +17,10 @@ export interface PluginContext {
   readonly aisdk: AISDKHooks
   readonly catalog: CatalogHooks & Reload
   readonly command: CommandHooks & Reload
+  readonly event: Event
   readonly integration: IntegrationHooks & Reload
   readonly plugin: PluginDomain
   readonly reference: ReferenceHooks & Reload
   readonly skill: SkillHooks & Reload
+  readonly tool: ToolHooks
 }

packages/plugin/src/v2/effect/index.ts

@@ -1,3 +1,5 @@
 export type { PluginContext } from "./context.js"
+export type { Event, EventMap } from "./event.js"
+export type { ToolExecuteAfterEvent, ToolExecuteBeforeEvent, ToolHooks } from "./tool.js"
 export { define } from "./plugin.js"
 export type { Plugin } from "./plugin.js"

packages/plugin/src/v2/effect/tool.ts

@@ -0,0 +1,31 @@
+import type { Effect, Scope } from "effect"
+
+export interface ToolExecuteBeforeEvent {
+  readonly name: string
+  readonly input: unknown
+  readonly args: {
+    readonly update: (input: unknown) => void
+  }
+  readonly deny: (reason: string) => void
+  readonly skip: () => void
+}
+
+export interface ToolExecuteAfterEvent {
+  readonly name: string
+  readonly input: unknown
+  readonly output: unknown
+  readonly context: {
+    readonly add: (text: string) => void
+  }
+}
+
+export interface ToolHooks {
+  hook(
+    name: "execute.before",
+    callback: (event: ToolExecuteBeforeEvent) => Effect.Effect<void>,
+  ): Effect.Effect<void, never, Scope.Scope>
+  hook(
+    name: "execute.after",
+    callback: (event: ToolExecuteAfterEvent) => Effect.Effect<void>,
+  ): Effect.Effect<void, never, Scope.Scope>
+}

packages/schema/src/session-event.ts

@@ -561,6 +561,40 @@ export namespace Subagent {
     },
   })
   export type Completed = typeof Completed.Type
+
+  // Live coordination events for the event-decoupled subagent pipeline. The location-scoped
+  // requester publishes Requested; the global executor (which owns SessionV2) drives the child
+  // session and publishes Result. Keeping these live (non-durable) avoids a static dependency from
+  // the location tool graph back through global SessionV2 -> LocationServiceMap, which would form a
+  // layer cycle. Subagent restart recovery remains deferred with the rest of durable continuation.
+  export const Requested = Event.define({
+    type: "session.next.subagent.requested",
+    schema: {
+      ...Base,
+      subagentSessionID: SessionID,
+      agent: Schema.String,
+      task: Schema.String,
+      context: Schema.String.pipe(optional),
+      background: Schema.Boolean,
+      mode: Schema.Union([Schema.Literal("new"), Schema.Literal("resume"), Schema.Literal("fork")]),
+    },
+  })
+  export type Requested = typeof Requested.Type
+
+  export const Result = Event.define({
+    type: "session.next.subagent.result",
+    schema: {
+      ...Base,
+      subagentSessionID: SessionID,
+      status: Schema.Union([Schema.Literal("completed"), Schema.Literal("partial")]),
+      output: Schema.String,
+      tokens: Schema.Struct({
+        input: Schema.Finite,
+        output: Schema.Finite,
+      }),
+    },
+  })
+  export type Result = typeof Result.Type
 }
 
 export namespace WireSchema {

packages/server/src/routes.ts

@@ -7,6 +7,7 @@ import { Credential } from "@opencode-ai/core/credential"
 import { PermissionSaved } from "@opencode-ai/core/permission/saved"
 import { PtyTicket } from "@opencode-ai/core/pty/ticket"
 import { SessionV2 } from "@opencode-ai/core/session"
+import { SubagentExecutor } from "@opencode-ai/core/subagent/executor"
 import { SessionExecution } from "@opencode-ai/core/session/execution"
 import { LocationServiceMap } from "@opencode-ai/core/location-service-map"
 import { SessionExecutionLocal } from "@opencode-ai/core/session/execution/local"
@@ -29,6 +30,7 @@ const applicationServices = LayerNode.group([
   httpClient,
   ToolOutputStore.cleanupNode,
   SessionV2.node,
+  SubagentExecutor.node,
   PermissionSaved.node,
   PtyTicket.node,
   Credential.node,