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

feat(FN-4763): complete Step 7 — finalize reclaim wiring and docs

Browse Source 
Fusion-Task-Id: FN-4763
Fusion-Task-Lineage: b3628e63-682b-4a39-9a7d-2c96278c5366
This commit is contained in:
Fusion (runfusion.ai)
2026-05-17 13:45:25 -07:00
committed by gsxdsm
parent 412ee29a24
commit bba945c8be
5 changed files with 22 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
packages/dashboard/src/routes/register-git-github.ts
View File

@@ -3333,12 +3333,7 @@ export function registerGitGitHubRoutes(ctx: ApiRoutesContext): void {
// Trigger background refresh if stale (don't await, let it run)
if (isStale) {
const selfHealingManager = engine?.getSelfHealingManager?.();
refreshPrInBackground(scopedStore, task.id, task.prInfo, githubToken, {
onConflictDetected: async (taskId) => {
await selfHealingManager?.reclaimPrConflictForTask(taskId);
},
});
refreshPrInBackground(scopedStore, task.id, task.prInfo, githubToken);
}
} catch (err: unknown) {
if (err instanceof ApiError) {
@@ -3427,7 +3422,11 @@ export function registerGitGitHubRoutes(ctx: ApiRoutesContext): void {
let conflictReclaimQueued = false;
if (prInfo.mergeable === "conflicting" && task.branch && task.worktree) {
const selfHealingManager = engine?.getSelfHealingManager?.();
const selfHealingManager =
(engine as { getSelfHealingManager?: () => { reclaimPrConflictForTask: (taskId: string) => Promise<unknown> } } | undefined)?.getSelfHealingManager?.() ??
(engine as { getRuntime?: () => { getSelfHealingManager?: () => { reclaimPrConflictForTask: (taskId: string) => Promise<unknown> } } } | undefined)
?.getRuntime?.()
?.getSelfHealingManager?.();
if (selfHealingManager) {
await selfHealingManager.reclaimPrConflictForTask(task.id);
conflictReclaimQueued = true;
@@ -3483,7 +3482,11 @@ export function registerGitGitHubRoutes(ctx: ApiRoutesContext): void {
throw conflict("Task has no branch/worktree to reclaim");
}
const selfHealingManager = engine?.getSelfHealingManager?.();
const selfHealingManager =
(engine as { getSelfHealingManager?: () => { reclaimPrConflictForTask: (taskId: string) => Promise<unknown> } } | undefined)?.getSelfHealingManager?.() ??
(engine as { getRuntime?: () => { getSelfHealingManager?: () => { reclaimPrConflictForTask: (taskId: string) => Promise<unknown> } } } | undefined)
?.getRuntime?.()
?.getSelfHealingManager?.();
if (!selfHealingManager) {
return res.json({ queued: false, reason: "engine-unavailable" });
}