refactor: split daemon server runtime into daemon/server/ — Phase 5

fallow-baselines/health.json

@@ -330,7 +330,7 @@
         "count": 1
       }
     },
-    "src/daemon/http-server.ts": {
+    "src/daemon/server/http-server.ts": {
       "complexity_critical": {
         "count": 1
       },

src/__tests__/daemon-entrypoint.test.ts

@@ -4,7 +4,7 @@ import os from 'node:os';
 import path from 'node:path';
 import { test } from 'vitest';
 import { resolveDaemonPaths } from '../daemon/config.ts';
-import { startDaemonRuntime } from '../daemon-runtime.ts';
+import { startDaemonRuntime } from '../daemon/server/daemon-runtime.ts';
 import { runCmdBackground } from '../utils/exec.ts';
 import { isProcessAlive, waitForProcessExit } from '../utils/process-identity.ts';
 import { waitForHttpOk } from './test-utils/index.ts';

src/daemon.ts

@@ -1,4 +1,4 @@
-import { startDaemonRuntime } from './daemon-runtime.ts';
+import { startDaemonRuntime } from './daemon/server/daemon-runtime.ts';
 import { asAppError } from './kernel/errors.ts';
 
 void startDaemonRuntime().catch((error) => {

src/daemon/__tests__/http-server-rpc-validation.test.ts

@@ -1,6 +1,6 @@
 import { test } from 'vitest';
 import assert from 'node:assert/strict';
-import { createDaemonHttpServer } from '../http-server.ts';
+import { createDaemonHttpServer } from '../server/http-server.ts';
 import type { DaemonRequest, DaemonResponse } from '../types.ts';
 import {
   closeLoopbackServer,

src/daemon/__tests__/server-shutdown.test.ts

@@ -1,7 +1,7 @@
 import { test } from 'vitest';
 import assert from 'node:assert/strict';
-import type { DaemonServer } from '../transport.ts';
-import { closeDaemonServers } from '../server-shutdown.ts';
+import type { DaemonServer } from '../server/transport.ts';
+import { closeDaemonServers } from '../server/server-shutdown.ts';
 
 test('closeDaemonServers forces stuck servers after timeout', async () => {
   let destroyed = false;

src/daemon-runtime.ts → src/daemon/server/daemon-runtime.ts

@@ -1,20 +1,20 @@
 import crypto from 'node:crypto';
-import { asAppError, AppError } from './kernel/errors.ts';
-import { SessionStore } from './daemon/session-store.ts';
-import { cleanupStaleAppLogProcesses } from './daemon/app-log-process.ts';
-import { resolveDaemonPaths, resolveDaemonServerMode } from './daemon/config.ts';
-import { createDaemonHttpServer } from './daemon/http-server.ts';
-import { trackDownloadableArtifact } from './daemon/artifact-tracking.ts';
-import { LeaseRegistry } from './daemon/lease-registry.ts';
-import { createRequestHandler } from './daemon/request-router.ts';
-import { teardownSessionResources } from './daemon/session-teardown.ts';
-import { closeDaemonServers } from './daemon/server-shutdown.ts';
-import type { SessionState } from './daemon/types.ts';
+import { asAppError, AppError } from '../../kernel/errors.ts';
+import { SessionStore } from '../session-store.ts';
+import { cleanupStaleAppLogProcesses } from '../app-log-process.ts';
+import { resolveDaemonPaths, resolveDaemonServerMode } from '../config.ts';
+import { createDaemonHttpServer } from './http-server.ts';
+import { trackDownloadableArtifact } from '../artifact-tracking.ts';
+import { LeaseRegistry } from '../lease-registry.ts';
+import { createRequestHandler } from '../request-router.ts';
+import { teardownSessionResources } from '../session-teardown.ts';
+import { closeDaemonServers } from './server-shutdown.ts';
+import type { SessionState } from '../types.ts';
 import {
   emitDiagnostic,
   flushDiagnosticsToSessionFile,
   withDiagnosticsScope,
-} from './utils/diagnostics.ts';
+} from '../../utils/diagnostics.ts';
 import {
   acquireDaemonLock,
   parseIntegerEnv,
@@ -24,16 +24,16 @@ import {
   removeInfo,
   resolveDaemonCodeSignature,
   writeInfo,
-} from './daemon/server-lifecycle.ts';
+} from './server-lifecycle.ts';
 import {
   createSocketServer,
   listenHttpServer,
   listenNetServer,
   type DaemonServer,
-} from './daemon/transport.ts';
-import { prewarmPngWorker, terminatePngWorker } from './utils/png-worker-client.ts';
-import { sleep } from './utils/timeouts.ts';
-import { setRunnerLeaseOwnerStateDir } from './platforms/apple/core/runner/runner-lease.ts';
+} from './transport.ts';
+import { prewarmPngWorker, terminatePngWorker } from '../../utils/png-worker-client.ts';
+import { sleep } from '../../utils/timeouts.ts';
+import { setRunnerLeaseOwnerStateDir } from '../../platforms/apple/core/runner/runner-lease.ts';
 
 const DAEMON_SESSION_TEARDOWN_TIMEOUT_MS = 5_000;
 const DAEMON_PNG_WORKER_TERMINATE_TIMEOUT_MS = 1_000;
@@ -224,7 +224,7 @@ export async function startDaemonRuntime(
     await closeDaemonServers(servers);
     await teardownDaemonSessions();
     const { stopAllIosRunnerSessions } =
-      await import('./platforms/apple/core/runner/runner-client.ts');
+      await import('../../platforms/apple/core/runner/runner-client.ts');
     await stopAllIosRunnerSessions();
     // Best effort: stop the PNG worker so an in-flight job cannot delay exit.
     await Promise.race([

src/daemon/http-server.ts → src/daemon/server/http-server.ts

@@ -1,37 +1,37 @@
 import http, { type IncomingHttpHeaders } from 'node:http';
 import fs from 'node:fs';
-import { AppError, normalizeError, toAppErrorCode } from '../kernel/errors.ts';
-import { emitDiagnostic } from '../utils/diagnostics.ts';
-import { timingSafeStringEqual } from '../utils/timing-safe-equal.ts';
+import { AppError, normalizeError, toAppErrorCode } from '../../kernel/errors.ts';
+import { emitDiagnostic } from '../../utils/diagnostics.ts';
+import { timingSafeStringEqual } from '../../utils/timing-safe-equal.ts';
 import type {
   CommandRpcParams,
   JsonRpcId,
   JsonRpcRequestEnvelope,
   LeaseBackend,
-} from '../kernel/contracts.ts';
-import { commandRpcParamsSchema } from '../kernel/contracts.ts';
-import type { DaemonInstallSource, DaemonInvokeFn, DaemonRequest } from './types.ts';
-import { normalizeTenantId } from './config.ts';
+} from '../../kernel/contracts.ts';
+import { commandRpcParamsSchema } from '../../kernel/contracts.ts';
+import type { DaemonInstallSource, DaemonInvokeFn, DaemonRequest } from '../types.ts';
+import { normalizeTenantId } from '../config.ts';
 import {
   clearRequestCanceled,
   isRequestCanceled,
   markRequestCanceled,
   registerRequestAbort,
   resolveRequestTrackingId,
-} from './request-cancel.ts';
+} from '../request-cancel.ts';
 import path from 'node:path';
 import { pathToFileURL } from 'node:url';
-import { sleep } from '../utils/timeouts.ts';
-import { cleanupDownloadableArtifact, prepareDownloadableArtifact } from './artifact-tracking.ts';
-import { type RequestProgressEvent, withRequestProgressSink } from './request-progress.ts';
+import { sleep } from '../../utils/timeouts.ts';
+import { cleanupDownloadableArtifact, prepareDownloadableArtifact } from '../artifact-tracking.ts';
+import { type RequestProgressEvent, withRequestProgressSink } from '../request-progress.ts';
 import {
   serializeDaemonProgressEnvelope,
   serializeDaemonRpcResponseEnvelope,
   shouldStreamRequestProgress,
-} from './request-progress-protocol.ts';
-import { buildDaemonHealthPayload } from './http-health.ts';
-import { sendRestJsonError, statusCodeForNormalizedError } from './http-errors.ts';
-import { tryHandleUploadHttpRoute } from './upload-http.ts';
+} from '../request-progress-protocol.ts';
+import { buildDaemonHealthPayload } from '../http-health.ts';
+import { sendRestJsonError, statusCodeForNormalizedError } from '../http-errors.ts';
+import { tryHandleUploadHttpRoute } from '../upload-http.ts';
 
 type JsonRpcRequest = JsonRpcRequestEnvelope;
 
@@ -795,7 +795,7 @@ async function abortInFlightIosRunnerSessionsWhileDisconnected(
     const deadline = Date.now() + CLIENT_DISCONNECT_ABORT_MAX_WINDOW_MS;
     while (isRequestCanceled(requestId) && Date.now() < deadline) {
       const { abortAllIosRunnerSessions } =
-        await import('../platforms/apple/core/runner/runner-client.ts');
+        await import('../../platforms/apple/core/runner/runner-client.ts');
       await abortAllIosRunnerSessions();
       if (!isRequestCanceled(requestId)) break;
       await sleep(CLIENT_DISCONNECT_ABORT_POLL_INTERVAL_MS);

src/daemon/server-lifecycle.ts → src/daemon/server/server-lifecycle.ts

@@ -1,9 +1,9 @@
 import fs from 'node:fs';
-import { isAgentDeviceDaemonProcess } from '../utils/process-identity.ts';
+import { isAgentDeviceDaemonProcess } from '../../utils/process-identity.ts';
 
-export { readVersion } from '../utils/version.ts';
-export { readProcessStartTime } from '../utils/process-identity.ts';
-export { resolveDaemonCodeSignature } from './code-signature.ts';
+export { readVersion } from '../../utils/version.ts';
+export { readProcessStartTime } from '../../utils/process-identity.ts';
+export { resolveDaemonCodeSignature } from '../code-signature.ts';
 
 export type DaemonLockInfo = {
   pid: number;

src/daemon/transport.ts → src/daemon/server/transport.ts

@@ -1,24 +1,24 @@
 import net from 'node:net';
 import type { Server as HttpServer } from 'node:http';
-import { AppError, normalizeError } from '../kernel/errors.ts';
-import type { DaemonInvokeFn, DaemonRequest, DaemonResponse } from './types.ts';
+import { AppError, normalizeError } from '../../kernel/errors.ts';
+import type { DaemonInvokeFn, DaemonRequest, DaemonResponse } from '../types.ts';
 import {
   clearRequestCanceled,
   createRequestCanceledError,
   isRequestCanceled,
   markRequestCanceled,
   registerRequestAbort,
   resolveRequestTrackingId,
-} from './request-cancel.ts';
-import { emitDiagnostic } from '../utils/diagnostics.ts';
-import { consumeTextLines } from '../utils/line-stream.ts';
-import { sleep } from '../utils/timeouts.ts';
-import { withRequestProgressSink } from './request-progress.ts';
+} from '../request-cancel.ts';
+import { emitDiagnostic } from '../../utils/diagnostics.ts';
+import { consumeTextLines } from '../../utils/line-stream.ts';
+import { sleep } from '../../utils/timeouts.ts';
+import { withRequestProgressSink } from '../request-progress.ts';
 import {
   serializeDaemonProgressEnvelope,
   serializeDaemonResponseEnvelope,
   shouldStreamRequestProgress,
-} from './request-progress-protocol.ts';
+} from '../request-progress-protocol.ts';
 
 const disconnectAbortPollIntervalMs = 200;
 const disconnectAbortMaxWindowMs = 15_000;
@@ -54,7 +54,7 @@ export function createSocketServer(handleRequest: DaemonInvokeFn): DaemonServer
           const deadline = Date.now() + disconnectAbortMaxWindowMs;
           while (inFlightRequests > 0 && Date.now() < deadline) {
             const { abortAllIosRunnerSessions } =
-              await import('../platforms/apple/core/runner/runner-client.ts');
+              await import('../../platforms/apple/core/runner/runner-client.ts');
             await abortAllIosRunnerSessions();
             if (inFlightRequests <= 0) break;
             await sleep(disconnectAbortPollIntervalMs);

test/integration/provider-scenarios/daemon-http-server.test.ts

@@ -12,7 +12,7 @@ import {
   trackDownloadableArtifact,
 } from '../../../src/daemon/artifact-tracking.ts';
 import { DAEMON_RPC_PROTOCOL_VERSION } from '../../../src/daemon/http-health.ts';
-import { createDaemonHttpServer } from '../../../src/daemon/http-server.ts';
+import { createDaemonHttpServer } from '../../../src/daemon/server/http-server.ts';
 import { emitRequestProgress } from '../../../src/daemon/request-progress.ts';
 import { getRequestSignal, isRequestCanceled } from '../../../src/daemon/request-cancel.ts';
 import type { DaemonRequest, DaemonResponse } from '../../../src/daemon/types.ts';

test/integration/provider-scenarios/daemon-lifecycle.test.ts

@@ -9,7 +9,7 @@ import {
   releaseDaemonLock,
   removeInfo,
   writeInfo,
-} from '../../../src/daemon/server-lifecycle.ts';
+} from '../../../src/daemon/server/server-lifecycle.ts';
 
 test('Provider-backed integration daemon lifecycle writes metadata and protects process-owned locks', () => {
   const root = fs.mkdtempSync(path.join(os.tmpdir(), 'agent-device-daemon-lifecycle-'));

test/integration/provider-scenarios/daemon-transport.test.ts

@@ -7,7 +7,7 @@ import {
   createSocketServer,
   listenHttpServer,
   listenNetServer,
-} from '../../../src/daemon/transport.ts';
+} from '../../../src/daemon/server/transport.ts';
 import {
   closeLoopbackServer,
   skipWhenLoopbackUnavailable,