Method startJob

ui/src/job/browserJobService.ts:190–849

(message: JobMessage)

  }

  async startJob(message: JobMessage): Promise<JobStream> {
    // Server-mode indexing (Fix #6): when the store is backed by an
    // `opentrace serve` agent, ask the agent to do the work instead of
    // running tree-sitter in the browser. The agent owns its own DB
    // and the browser pipeline's writes would no-op against the
    // read-only ServerGraphStore.
    if (
      (message.type === 'index-repo' || message.type === 'reindex-repo') &&
      this.store instanceof ServerGraphStore
    ) {
      return this.startServerIndexUrlJob(message);
    }

    let input: LoaderInput;
    const isReindex = message.type === 'reindex-repo';
    if (message.type === 'index-repo' || message.type === 'reindex-repo') {
      input = {
        kind: 'url',
        url: message.repoUrl,
        token: message.token,
        ref: message.ref,
      };
    } else if (message.type === 'index-directory') {
      input = {
        kind: 'directory',
        files: message.files,
        name: message.name,
      };
    } else if (message.type === 'import-file') {
      return this.startImportFileJob(message.file, message.name);
    } else {
      throw new Error(
        `Unsupported job type: ${(message as { type: string }).type}`,
      );
    }

    const channel = new EventChannel<JobEvent>();
    const abortController = new AbortController();
    let cancelled = false;

    // Debug log — attached to window for console access
    const debug = new PipelineDebugLog({ enabled: true });
    (globalThis as Record<string, unknown>).__pipelineDebug = debug;

    // Hoisted so the catch handler can report partial progress
    let persistedNodes = 0;
    let persistedRels = 0;
    let storeStage: StoreStage | undefined;

    const run = async () => {
      const pipelineStartTime = performance.now();
      debug.start();

      // 1. Initialize parsers + DB in parallel
      debug.log('init', 'loading tree-sitter parsers + DB');
      channel.push({
        ...emptyEvent(),
        kind: JobEventKind.JOB_EVENT_KIND_PROGRESS,