Function dispatchGenericCommand

src/daemon/request-generic-dispatch.ts:40–128

(params: {
  req: DaemonRequest;
  session: SessionState;
  sessionName: string;
  logPath: string;
  sessionStore: SessionStore;
  contextFromFlags: (
    flags: CommandFlags | undefined,
    appBundleId?: string,
    traceLogPath?: string,
  ) => DaemonCommandContext;
})

};

export async function dispatchGenericCommand(params: {
  req: DaemonRequest;
  session: SessionState;
  sessionName: string;
  logPath: string;
  sessionStore: SessionStore;
  contextFromFlags: (
    flags: CommandFlags | undefined,
    appBundleId?: string,
    traceLogPath?: string,
  ) => DaemonCommandContext;
}): Promise<DaemonResponse> {
  const { req, session, logPath, sessionStore, contextFromFlags } = params;
  const commandResolution = resolveDispatchCommand(req);
  if (!commandResolution.ok) {
    return {
      ok: false,
      error: {
        code: 'INVALID_ARGS',
        message: commandResolution.message,
      },
    };
  }
  const { platformCommand, dispatchRequest, recordedCommand } = commandResolution;

  const readinessResponse = await ensureGenericCommandReady(session, platformCommand);
  if (readinessResponse) return readinessResponse;
  const preflightReadiness = await ensureNoAndroidBlockingDialogReady(session, platformCommand);
  if ('response' in preflightReadiness) return preflightReadiness.response;

  const { resolvedPositionals, resolvedOut, recordedPositionals, recordedFlags } =
    resolveCommandPositionals(dispatchRequest);

  const actionStartedAt = Date.now();
  const dispatchContext = {
    ...contextFromFlags(req.flags, session.appBundleId, session.trace?.outPath),
    surface: session.surface,
  };
  let data = await executeGenericPlatformCommand({
    session,
    sessionName: params.sessionName,
    logPath,
    command: platformCommand,
    request: dispatchRequest,
    positionals: resolvedPositionals,
    out: resolvedOut,
    dispatchContext,
  });
  const postflightReadiness = await ensureNoAndroidBlockingDialogReady(
    session,
    platformCommand,
    'after-command',
  );
  if ('response' in postflightReadiness) return postflightReadiness.response;
  if (
    'status' in preflightReadiness &&
    preflightReadiness.status === 'recovered' &&
    (!data || typeof data === 'object')