fix(server): restore contract methods used by perf latency test (#4)

* fix(server): restore contract methods used by perf latency test

The serverLatency.perf.test.ts cherry-pick referenced WS methods that
weren't present in this fork, causing typecheck failures:

- Adds subscribeOrchestrationDomainEvents streaming RPC so the perf
  harness can observe orchestration domain events end-to-end
- Switches the git RPC latency probes to gitRefreshStatus, the existing
  equivalent of upstream's git.status unary RPC

* fix(perf): rename git.status latency series to git.refreshStatus

Keeps the perf artifact/metric labels consistent with the RPC method
actually being measured, addressing review feedback on #4.

---------

Co-authored-by: Claude <noreply@anthropic.com>

Author: Berkay2002

apps/server/integration/perf/serverLatency.perf.test.ts

@@ -774,12 +774,12 @@ describe("server perf latency", () => {
       const gitLatencyIdle = await Promise.all([
         measureRpcLatencySeries({
           harness,
-          name: "git.status",
+          name: "git.refreshStatus",
           loadProfile: "idle-repo-pressure",
           iterations: GIT_RPC_SAMPLE_COUNT,
           execute: () =>
             harness!.rpc.request((client) =>
-              client[WS_METHODS.gitStatus]({
+              client[WS_METHODS.gitRefreshStatus]({
                 cwd: harness!.seededState.workspaceRoot,
               }),
             ),
@@ -850,12 +850,12 @@ describe("server perf latency", () => {
       const gitLatencyMixed = await Promise.all([
         measureRpcLatencySeries({
           harness,
-          name: "git.status",
+          name: "git.refreshStatus",
           loadProfile: "mixed-stream-terminal-git",
           iterations: GIT_RPC_SAMPLE_COUNT,
           execute: () =>
             harness!.rpc.request((client) =>
-              client[WS_METHODS.gitStatus]({
+              client[WS_METHODS.gitRefreshStatus]({
                 cwd: harness!.seededState.workspaceRoot,
               }),
             ),

apps/server/src/ws.ts

@@ -1044,6 +1044,12 @@ const makeWsRpcLayer = (currentSessionId: AuthSessionId) =>
             }),
             { "rpc.aggregate": "auth" },
           ),
+        [WS_METHODS.subscribeOrchestrationDomainEvents]: (_input) =>
+          observeRpcStream(
+            WS_METHODS.subscribeOrchestrationDomainEvents,
+            orchestrationEngine.streamDomainEvents,
+            { "rpc.aggregate": "orchestration" },
+          ),
       });
     }),
   );

packages/contracts/src/rpc.ts

@@ -35,6 +35,7 @@ import {
   ClientOrchestrationCommand,
   ORCHESTRATION_WS_METHODS,
   OrchestrationDispatchCommandError,
+  OrchestrationEvent,
   OrchestrationGetFullThreadDiffError,
   OrchestrationGetFullThreadDiffInput,
   OrchestrationGetSnapshotError,
@@ -121,6 +122,7 @@ export const WS_METHODS = {
   subscribeServerConfig: "subscribeServerConfig",
   subscribeServerLifecycle: "subscribeServerLifecycle",
   subscribeAuthAccess: "subscribeAuthAccess",
+  subscribeOrchestrationDomainEvents: "subscribeOrchestrationDomainEvents",
 } as const;
 
 export const WsServerUpsertKeybindingRpc = Rpc.make(WS_METHODS.serverUpsertKeybinding, {
@@ -351,6 +353,15 @@ export const WsSubscribeAuthAccessRpc = Rpc.make(WS_METHODS.subscribeAuthAccess,
   stream: true,
 });
 
+export const WsSubscribeOrchestrationDomainEventsRpc = Rpc.make(
+  WS_METHODS.subscribeOrchestrationDomainEvents,
+  {
+    payload: Schema.Struct({}),
+    success: OrchestrationEvent,
+    stream: true,
+  },
+);
+
 export const WsRpcGroup = RpcGroup.make(
   WsServerGetConfigRpc,
   WsServerRefreshProvidersRpc,
@@ -389,4 +400,5 @@ export const WsRpcGroup = RpcGroup.make(
   WsOrchestrationReplayEventsRpc,
   WsOrchestrationSubscribeShellRpc,
   WsOrchestrationSubscribeThreadRpc,
+  WsSubscribeOrchestrationDomainEventsRpc,
 );