Function connectCommand

src/cli/commands/connection.ts:41–87

({ positionals, flags, client })

import type { ClientCommandHandler } from './router-types.ts';

export const connectCommand: ClientCommandHandler = async ({ positionals, flags, client }) => {
  const stateDir = resolveDaemonPaths(flags.stateDir).baseDir;
  const provider = readConnectProvider(positionals);
  assertConnectProviderUsage(provider, flags);
  const resolved = await resolveConnectProfile({ provider, flags, stateDir });
  const connectFlags = resolved.flags;
  const connectionMetadata = readRemoteConfigConnectionMetadata(resolved.remoteConfigPath);
  const scope = readRequiredConnectScope(connectFlags, connectionMetadata);
  const context = resolveConnectContext({
    stateDir,
    flags: connectFlags,
    remoteConfigPath: resolved.remoteConfigPath,
  });
  assertCompatibleConnectionOrForce(context.previous, {
    flags: connectFlags,
    session: context.session,
    remoteConfigPath: resolved.remoteConfigPath,
    remoteConfigHash: context.remoteConfigHash,
    desiredLeaseBackend: resolveRequestedLeaseBackend(connectFlags),
    connection: connectionMetadata,
    daemon: context.daemon,
  });
  const state = buildConnectedState({
    flags: connectFlags,
    scope,
    connectionMetadata,
    context,
    remoteConfigPath: resolved.remoteConfigPath,
  });
  writeRemoteConnectionState({ stateDir, state });
  await cleanupForcedPreviousConnection(client, stateDir, connectFlags, context.previous);
  const leasePreparation = buildLeasePreparationNotice(state);
  const runtimePreparation = buildRuntimePreparationNotice(connectFlags, state);

  writeCommandOutput(connectFlags, serializeConnectionState(state, runtimePreparation), () =>
    [
      `Connected remote session "${context.session}" tenant "${scope.tenant}" run "${scope.runId}" ${
        state.leaseId ? `lease ${state.leaseId}` : 'lease pending'
      }`,
      leasePreparation?.message,
      runtimePreparation?.message,
    ]
      .filter((line): line is string => Boolean(line))
      .join('\n'),
  );
  return true;
};

async function resolveConnectProfile(options: {
  provider?: ConnectProvider;