Function prepareRuntimeHostRunInput

packages/cli/src/runtime-host-run-command.ts:184–219

(
  connection: RuntimeHostConnection,
  catalog: RuntimeHostCliConnectionContext['catalog'],
  profile: RuntimeHostProfile,
  input: Parameters<MakaRunDeps['createContext']>[0],
  cliCommand: string,
)

}

async function prepareRuntimeHostRunInput(
  connection: RuntimeHostConnection,
  catalog: RuntimeHostCliConnectionContext['catalog'],
  profile: RuntimeHostProfile,
  input: Parameters<MakaRunDeps['createContext']>[0],
  cliCommand: string,
): Promise<Parameters<MakaRunDeps['createContext']>[0]> {
  let projectId = input.projectId;
  if (profile.kind === 'remote' && !input.resumeSessionId) {
    if (!projectId) {
      throw new Error(`Runtime Host profile ${profile.id} requires --project for a new Session`);
    }
    const project = findProjectByIdentity(await readRuntimeHostProjects(connection), projectId);
    if (!project || project.archivedAt !== null || !project.available) {
      throw new Error(`Runtime Host Project is unavailable: ${projectId}`);
    }
    projectId = project.id;
  }
  const preparedInput = projectId === input.projectId ? input : { ...input, projectId };
  const snapshot = await readRuntimeHostCliTaskReadiness({
    connection,
    catalog,
    cwd: preparedInput.cwd,
    ...(profile.kind === 'remote' ? { workspaceState: 'ready' as const } : {}),
    ...(preparedInput.requestedConnectionSlug
      ? { connectionSlug: preparedInput.requestedConnectionSlug }
      : {}),
    ...(preparedInput.requestedModel ? { model: preparedInput.requestedModel } : {}),
  });
  if (isRuntimeHostCliTaskBlocked(snapshot)) {
    throw new Error(
      `Task is not ready:\n${formatRuntimeHostCliTaskBlockers(snapshot, cliCommand)}`,
    );
  }
  return preparedInput;
}

class RuntimeHostRunRuntime implements MakaRunRuntime {
  readonly #connection: RuntimeHostConnection;