Function dispatchSnapshotRuntimeCommand

src/daemon/snapshot-runtime.ts:108–162

(
  params: SnapshotRuntimeCommandParams,
)

    };

async function dispatchSnapshotRuntimeCommand(
  params: SnapshotRuntimeCommandParams,
): Promise<DaemonResponse> {
  const { req, sessionName, logPath, sessionStore } = params;
  const { session, device } = await resolveSessionDevice(sessionStore, sessionName, req.flags);
  const unsupported = requireCommandSupported(params.command, device, {
    message: params.unsupportedMessage,
  });
  if (unsupported) return unsupported;
  const resolvedScope = resolveSnapshotScope(req.flags?.snapshotScope, session);
  if (!resolvedScope.ok) return resolvedScope;
  const iosAppSessionGuard = requireIosAppSessionForSnapshot(params.command, session, device);
  if (iosAppSessionGuard) return iosAppSessionGuard;

  return await withSessionlessRunnerCleanup(session, device, async () => {
    const runtime = createSnapshotRuntime({
      req,
      sessionName,
      logPath,
      sessionStore,
      session,
      device,
      snapshotScope: resolvedScope.scope,
    });
    let result: Awaited<ReturnType<SnapshotRuntimeCommandParams['execute']>>;
    try {
      result = await params.execute({
        runtime,
        sessionName,
        req,
        snapshotScope: resolvedScope.scope,
      });
    } catch (error) {
      const timeoutResponse = await maybeBuildAndroidSnapshotTimeoutFailure({
        error,
        command: params.command,
        logPath,
        session,
        device,
      });
      if (!timeoutResponse) throw error;
      return timeoutResponse;
    }
    recordSnapshotRuntimeAction({
      req,
      sessionName,
      sessionStore,
      result: result.record,
    });
    return {
      ok: true,
      data: result.data,
    };
  });
}

function requireIosAppSessionForSnapshot(
  command: 'snapshot' | 'diff',