root/fusion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(FN-4522): complete Step 3 — verification and type compatibility

Browse Source 
Fusion-Task-Id: FN-4522
Fusion-Task-Lineage: fbaedf11-6bc6-4c77-91b0-6b1ef606d81f
This commit is contained in:
Fusion
2026-05-14 13:09:05 -07:00
committed by gsxdsm
parent a42cf485ee
commit 44c6b1a308
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
packages/dashboard/src/routes/register-session-diff-routes.ts
View File

@@ -1,5 +1,6 @@
import { access } from "node:fs/promises";
import type { Request, Router } from "express";
import type { RunAuditEvent, RunAuditEventFilter } from "@fusion/core";
import { ApiError, notFound, rethrowAsApiError } from "../api-error.js";
import { resolveDiffBase, runGitCommand } from "./resolve-diff-base.js";
import type { ProjectContext } from "./types.js";
@@ -236,12 +237,7 @@ type DoneTaskAggregationTask = {
type DoneTaskAggregationStore = {
getRootDir: () => string;
getTaskCommitAssociationsByLineageId: (lineageId: string) => Promise<Array<{ commitSha: string; authoredAt?: string | null }>>;
getRunAuditEvents?: (filter: {
taskId?: string;
domain?: string;
mutationType?: string;
limit?: number;
}) => Array<{ target?: unknown; metadata?: unknown; payload?: unknown; newValue?: unknown }> | Promise<Array<{ target?: unknown; metadata?: unknown; payload?: unknown; newValue?: unknown }>>;
getRunAuditEvents?: (options?: RunAuditEventFilter) => RunAuditEvent[] | Promise<RunAuditEvent[]>;
};
async function resolveCommitDiffSpec(sha: string, rootDir: string): Promise<
@@ -334,8 +330,9 @@ async function resolveAuditCommitSha(taskId: string, scopedStore: DoneTaskAggreg
const rootDir = scopedStore.getRootDir();
const mutationTypes = ["git:commit", "commit:create", "commit:amend"];
for (const mutationType of mutationTypes) {
const events = await Promise.resolve(scopedStore.getRunAuditEvents({ taskId, domain: "git", mutationType, limit: 5 }));
for (const event of events) {
const eventsRaw = await Promise.resolve(scopedStore.getRunAuditEvents({ taskId, domain: "git", mutationType: mutationType as RunAuditEventFilter["mutationType"], limit: 5 }));
const events = Array.isArray(eventsRaw) ? eventsRaw : [];
for (const event of events as Array<{ target?: unknown; metadata?: unknown; payload?: unknown; newValue?: unknown }>) {
const candidate = extractCommitShaCandidate(event);
if (!candidate) continue;
try {