Function prepareLockedRequestScope

src/daemon/request-execution-scope.ts:179–255

(params: {
  scope: RequestExecutionScope;
  sessionStore: SessionStore;
  trackDownloadableArtifact: (opts: {
    artifactPath: string;
    tenantId?: string;
    fileName?: string;
  }) => string;
})

}

export function prepareLockedRequestScope(params: {
  scope: RequestExecutionScope;
  sessionStore: SessionStore;
  trackDownloadableArtifact: (opts: {
    artifactPath: string;
    tenantId?: string;
    fileName?: string;
  }) => string;
}): LockedRequestScopeResult {
  const { scope, sessionStore, trackDownloadableArtifact } = params;
  const logPath = scope.runnerLogPath;
  scope.throwIfCanceled();
  let existingSession = sessionStore.get(scope.sessionName);
  if (existingSession) {
    // Called under runLocked: refreshRecordingHealth may mutate session recording state.
    refreshRecordingHealth(existingSession);
    sessionStore.set(scope.sessionName, existingSession);
  }
  const binding = prepareLockedRequestBinding({
    req: scope.req,
    sessionName: scope.sessionName,
    sessionStore,
  });
  const lockedReq = binding.req;
  existingSession = binding.existingSession;
  const finalize = (response: DaemonResponse): DaemonResponse =>
    finalizeDaemonResponse(lockedReq, response, trackDownloadableArtifact);

  if (
    existingSession?.recording?.invalidatedReason &&
    shouldBlockForInvalidRecording(scope.command)
  ) {
    return {
      type: 'response',
      response: finalize({
        ok: false,
        error: {
          code: 'COMMAND_FAILED',
          message: existingSession.recording.invalidatedReason,
        },
      }),
    };
  }

  if (
    existingSession &&
    !lockedReq.meta?.lockPolicy &&
    shouldValidateSessionSelector(scope.command)
  ) {
    assertSessionSelectorMatches(existingSession, lockedReq.flags);
  }

  const contextFromFlags = (
    flags: CommandFlags | undefined,
    appBundleId?: string,
    traceLogPath?: string,
  ): DaemonCommandContext =>
    contextFromRequestFlags(logPath, flags, appBundleId, traceLogPath, lockedReq.meta);