Function createStatusRouter

src/main/lib/git/status.ts:14–186

()

import { gitCache } from "./cache";

export const createStatusRouter = () => {
	return router({
		getStatus: publicProcedure
			.input(
				z.object({
					worktreePath: z.string(),
					defaultBranch: z.string().optional(),
				}),
			)
			.query(async ({ input }): Promise<GitChangesStatus> => {
				assertRegisteredWorktree(input.worktreePath);

				// Check cache first
				const cached = gitCache.getStatus<GitChangesStatus>(input.worktreePath);
				if (cached) {
					console.log("[getStatus] Cache hit for:", input.worktreePath);
					return cached;
				}

				console.log("[getStatus] Cache miss, fetching:", input.worktreePath);
				const git = simpleGit(input.worktreePath);
				const defaultBranch = input.defaultBranch || "main";

				const status = await git.status();
				const parsed = parseGitStatus(status);

				// Run independent git operations in parallel (VS Code style)
				const [branchComparison, trackingStatus] = await Promise.all([
					getBranchComparison(git, defaultBranch),
					getTrackingBranchStatus(git),
				]);

				// Run numstat operations in parallel
				await Promise.all([
					applyNumstatToFiles(git, parsed.staged, [
						"diff",
						"--cached",
						"--numstat",
					]),
					applyNumstatToFiles(git, parsed.unstaged, ["diff", "--numstat"]),
					applyUntrackedLineCount(input.worktreePath, parsed.untracked),
				]);

				const result: GitChangesStatus = {
					branch: parsed.branch,
					defaultBranch,
					againstBase: branchComparison.againstBase,
					commits: branchComparison.commits,
					staged: parsed.staged,
					unstaged: parsed.unstaged,
					untracked: parsed.untracked,
					ahead: branchComparison.ahead,
					behind: branchComparison.behind,
					pushCount: trackingStatus.pushCount,
					pullCount: trackingStatus.pullCount,
					hasUpstream: trackingStatus.hasUpstream,
				};