refactor(replay): move dispatch projections into replay-port

Author: thymikee

packages/replay-port/package.json

@@ -10,6 +10,7 @@
     "@agent-device/capture-kit": "workspace:*",
     "@agent-device/contracts": "workspace:*",
     "@agent-device/kernel": "workspace:*",
+    "@agent-device/maestro": "workspace:*",
     "@agent-device/replay-test": "workspace:*",
     "@agent-device/selectors": "workspace:*"
   },
@@ -29,6 +30,14 @@
     "./session-replay-vars": {
       "types": "./src/session-replay-vars.ts",
       "default": "./src/session-replay-vars.ts"
+    },
+    "./replay-dispatch-envelope": {
+      "types": "./src/daemon-port/replay-dispatch-envelope.ts",
+      "default": "./src/daemon-port/replay-dispatch-envelope.ts"
+    },
+    "./session-replay-maestro-request": {
+      "types": "./src/daemon-port/session-replay-maestro-request.ts",
+      "default": "./src/daemon-port/session-replay-maestro-request.ts"
     }
   }
 }

…tests__/replay-dispatch-envelope.test.ts …tests__/replay-dispatch-envelope.test.tssrc/daemon/replay/internal/__tests__/replay-dispatch-envelope.test.ts renamed to packages/replay-port/src/daemon-port/__tests__/replay-dispatch-envelope.test.ts src/daemon/replay/internal/__tests__/replay-dispatch-envelope.test.ts renamed to packages/replay-port/src/daemon-port/__tests__/replay-dispatch-envelope.test.ts

@@ -1,9 +1,12 @@
 import { expect, test } from 'vitest';
-import type { DaemonRequest } from '../../../daemon-request.ts';
+import type { ReplayDispatchOptions } from '@agent-device/contracts/replay';
+import type { ReplayPrivateAdmission, ReplayRequest } from '../replay-dispatch-envelope.ts';
 import { replayInvokeOverDispatch } from '../replay-dispatch-envelope.ts';
 
+type TestRequest = ReplayRequest<ReplayPrivateAdmission & ReplayDispatchOptions>;
+
 test('replayInvokeOverDispatch re-attaches the originating private half, then folds the dispatch bag over it', async () => {
-  const base: DaemonRequest = {
+  const base: TestRequest = {
     token: 'token',
     session: 'default',
     command: 'replay',
@@ -16,7 +19,7 @@ test('replayInvokeOverDispatch re-attaches the originating private half, then fo
       },
     },
   };
-  const invoked: DaemonRequest[] = [];
+  const invoked: TestRequest[] = [];
   const invoke = replayInvokeOverDispatch(async (request) => {
     invoked.push(request);
     return { ok: true, data: {} };
@@ -50,7 +53,7 @@ test('replayInvokeOverDispatch re-attaches the originating private half, then fo
 });
 
 test('replayInvokeOverDispatch sends no private half when neither side carries one', async () => {
-  const invoked: DaemonRequest[] = [];
+  const invoked: TestRequest[] = [];
   const invoke = replayInvokeOverDispatch(
     async (request) => {
       invoked.push(request);

…_/session-replay-maestro-request.test.ts …_/session-replay-maestro-request.test.tssrc/daemon/replay/internal/__tests__/session-replay-maestro-request.test.ts renamed to packages/replay-port/src/daemon-port/__tests__/session-replay-maestro-request.test.ts src/daemon/replay/internal/__tests__/session-replay-maestro-request.test.ts renamed to packages/replay-port/src/daemon-port/__tests__/session-replay-maestro-request.test.ts

@@ -20,10 +20,8 @@ const DAEMON_REPLAY_FACADE = {
     'buildReplayScriptPlatformFlags',
     'healedScriptSiblingPath',
     'readScriptReplaySelection',
-    'replayInvokeOverDispatch',
     'runReplayCommand',
     'runReplayTestCommand',
-    'splitReplayCommandRequest',
   ],
 } as const;
 

…lay/internal/replay-dispatch-envelope.ts …/daemon-port/replay-dispatch-envelope.tssrc/daemon/replay/internal/replay-dispatch-envelope.ts renamed to packages/replay-port/src/daemon-port/replay-dispatch-envelope.ts src/daemon/replay/internal/replay-dispatch-envelope.ts renamed to packages/replay-port/src/daemon-port/replay-dispatch-envelope.ts

@@ -6,13 +6,11 @@ import { bindInternalObservationAuthority } from '../internal-observation.ts';
 import type { LeaseRegistry } from '../lease-registry.ts';
 import type { BindDeviceRuntime, InspectDeviceRuntimeFacts } from '../request-runtime-binding.ts';
 import type { PlatformResourceCleanup } from '../platform-resource-cleanup.ts';
+import { bindReplaySession, runReplayCommand, runReplayTestCommand } from '../replay/index.ts';
 import {
-  bindReplaySession,
   replayInvokeOverDispatch,
-  runReplayCommand,
-  runReplayTestCommand,
   splitReplayCommandRequest,
-} from '../replay/index.ts';
+} from '@agent-device/replay-port/replay-dispatch-envelope';
 import type {
   ReplayDaemonDependencies,
   ReplaySession,

…ternal/session-replay-maestro-request.ts …n-port/session-replay-maestro-request.tssrc/daemon/replay/internal/session-replay-maestro-request.ts renamed to packages/replay-port/src/daemon-port/session-replay-maestro-request.ts src/daemon/replay/internal/session-replay-maestro-request.ts renamed to packages/replay-port/src/daemon-port/session-replay-maestro-request.ts

@@ -17,12 +17,11 @@ import {
   createReplaySession,
   replayDaemonDependencies,
 } from '../../handlers/session-replay-command.ts';
+import { runReplayCommand, runReplayTestCommand } from '../index.ts';
 import {
   replayInvokeOverDispatch,
-  runReplayCommand,
-  runReplayTestCommand,
   splitReplayCommandRequest,
-} from '../index.ts';
+} from '@agent-device/replay-port/replay-dispatch-envelope';
 import type { ReplayCommand, ReplayTestCommand } from '@agent-device/replay-port/command-types';
 import { captureSnapshotWithInteractor } from '../../snapshot-interactor-capture.ts';
 import {

pnpm-lock.yaml

@@ -5,7 +5,11 @@ import {
   createReplaySession,
   replayDaemonDependencies,
 } from '../../handlers/session-replay-command.ts';
-import { replayInvokeOverDispatch, runReplayCommand, splitReplayCommandRequest } from '../index.ts';
+import { runReplayCommand } from '../index.ts';
+import {
+  replayInvokeOverDispatch,
+  splitReplayCommandRequest,
+} from '@agent-device/replay-port/replay-dispatch-envelope';
 import type { ReplayCommand } from '@agent-device/replay-port/command-types';
 
 export type ReplayCommandTestInput = Readonly<{