Function runAutoCommit

services/cloud-agent-next/wrapper/src/auto-commit.ts:85–291

(opts: AutoCommitOptions)

export async function runAutoCommit(opts: AutoCommitOptions): Promise<AutoCommitResult> {
  const { workspacePath, onEvent, kiloClient, messageId, signal, env } = opts;
  const redact = createSecretRedactor(process.env, env ?? {});
  const logToFile = (message: string): void => writeLog(redact(message));
  const released = Promise.withResolvers<void>();
  const previous = worktreeAutoCommits.get(workspacePath) ?? Promise.resolve();
  const current = previous
    .then(() => released.promise)
    .finally(() => {
      if (worktreeAutoCommits.get(workspacePath) === current)
        worktreeAutoCommits.delete(workspacePath);
    });
  worktreeAutoCommits.set(workspacePath, current);

  logToFile(`auto-commit: starting workspacePath=${workspacePath}`);

  try {
    signal?.throwIfAborted();
    const cancelled = Promise.withResolvers<never>();
    const onAbort = () => cancelled.reject(signal?.reason);
    signal?.addEventListener('abort', onAbort, { once: true });
    try {
      await Promise.race([previous, cancelled.promise]);
    } finally {
      signal?.removeEventListener('abort', onAbort);
    }
    signal?.throwIfAborted();
    // Check current branch (agent may have switched branches during execution)
    const branch = await getCurrentBranch(workspacePath, GIT_LOCAL_TIMEOUT_MS, signal, env);
    logToFile(`auto-commit: branch=${branch || '(detached HEAD)'}`);
    if (!branch) {
      logToFile('auto-commit: skipping - detached HEAD state');
      emitCompleted(
        onEvent,
        {
          success: true,
          message: 'Skipped: detached HEAD state',
          skipped: true,
        },
        messageId
      );
      return { success: true, skipped: true };
    }

    // Branch protection: block auto-commit to main/master unless the user
    // explicitly targeted this exact branch via the upstreamBranch API param.
    if (branch === 'main' || branch === 'master') {
      if (opts.upstreamBranch !== branch) {
        logToFile(`auto-commit: skipping - protected branch ${branch}`);
        emitCompleted(
          onEvent,
          {
            success: true,
            message: `Skipped: cannot commit to ${branch}`,
            skipped: true,
          },
          messageId
        );
        return { success: true, skipped: true };