Skip to content

force db sync button #1167

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
N2D4 merged 1 commit into from
Feb 9, 2026
Merged

force db sync button #1167

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 6 additions & 9 deletions apps/backend/src/app/api/latest/internal/external-db-sync/poller/route.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -53,11 +53,6 @@ function getPollerClaimLimit(): number {
return parsed;
}

function getLocalApiBaseUrl(): string {
const prefix = getEnvVariable("NEXT_PUBLIC_STACK_PORT_PREFIX", "81");
return `http://localhost:${prefix}02`;
}

export const GET = createSmartRouteHandler({
metadata: {
summary: "Poll outgoing requests and push to QStash",
Expand All @@ -70,7 +65,7 @@ export const GET = createSmartRouteHandler({
auth: yupObject({}).nullable().optional(),
method: yupString().oneOf(["GET"]).defined(),
headers: yupObject({
authorization: yupTuple([yupString().defined()]).defined(),
authorization: yupTuple([yupString().defined()]).optional(),
}).defined(),
query: yupObject({
maxDurationMs: yupString().optional(),
Expand All @@ -85,12 +80,14 @@ export const GET = createSmartRouteHandler({
requests_processed: yupNumber().defined(),
}).defined(),
}),
handler: async ({ headers, query }) => {
const authHeader = headers.authorization[0];
if (authHeader !== `Bearer ${getEnvVariable("CRON_SECRET")}`) {
handler: async ({ headers, query, auth }) => {
const isAdmin = auth?.type === "admin" && auth.project.id === "internal";
Comment thread
BilalG1 marked this conversation as resolved.
const authHeader = headers.authorization?.[0];
if (!isAdmin && authHeader !== `Bearer ${getEnvVariable("CRON_SECRET")}`) {
throw new StatusError(401, "Unauthorized");
}


Comment thread
BilalG1 marked this conversation as resolved.
return await traceSpan("external-db-sync.poller", async (span) => {
const startTime = performance.now();
const maxDurationMs = parseMaxDurationMs(query.maxDurationMs);
Expand Down
9 changes: 5 additions & 4 deletions apps/backend/src/app/api/latest/internal/external-db-sync/sequencer/route.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -165,7 +165,7 @@ export const GET = createSmartRouteHandler({
auth: yupObject({}).nullable().optional(),
method: yupString().oneOf(["GET"]).defined(),
headers: yupObject({
authorization: yupTuple([yupString().defined()]).defined(),
authorization: yupTuple([yupString().defined()]).optional(),
}).defined(),
query: yupObject({
maxDurationMs: yupString().optional(),
Expand All @@ -180,9 +180,10 @@ export const GET = createSmartRouteHandler({
iterations: yupNumber().defined(),
}).defined(),
}),
handler: async ({ headers, query }) => {
const authHeader = headers.authorization[0];
if (authHeader !== `Bearer ${getEnvVariable("CRON_SECRET")}`) {
handler: async ({ headers, query, auth }) => {
const isAdmin = auth?.type === "admin" && auth.project.id === "internal";
const authHeader = headers.authorization?.[0];
Comment thread
BilalG1 marked this conversation as resolved.
if (!isAdmin && authHeader !== `Bearer ${getEnvVariable("CRON_SECRET")}`) {
throw new StatusError(401, "Unauthorized");
}

Expand Down
142 changes: 102 additions & 40 deletions ...ashboard/src/app/(main)/(protected)/projects/[projectId]/external-db-sync/page-client.tsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -226,6 +226,8 @@ export default function PageClient() {
const [loading, setLoading] = useState(false);
const [autoRefresh, setAutoRefresh] = useState(true);
const [savingFusebox, setSavingFusebox] = useState(false);
const [forceSyncRunning, setForceSyncRunning] = useState(false);
const forceSyncAbortRef = useRef<AbortController | null>(null);
const inFlightRef = useRef(false);
const summarySamplesRef = useRef<Array<{
timestampMillis: number,
Expand Down Expand Up @@ -341,6 +343,41 @@ export default function PageClient() {
runAsynchronouslyWithAlert(loadStatus);
}, [loadStatus]);

const forceTriggerSync = useCallback(async () => {
const abortController = new AbortController();
forceSyncAbortRef.current = abortController;
setForceSyncRunning(true);
try {
const endpoints = [
"/internal/external-db-sync/sequencer",
"/internal/external-db-sync/poller",
];
await Promise.all(endpoints.map(async (endpoint) => {
const response = await adminApp[stackAppInternalsSymbol].sendRequest(
endpoint,
{ method: "GET", signal: abortController.signal },
"admin",
);
if (!response.ok) {
const body = await response.json().catch(() => null);
const message = typeof body?.error === "string" ? body.error : `Failed to trigger ${endpoint}: ${response.status}`;
throw new Error(message);
}
}));
await loadStatus();
} catch (err) {
if (err instanceof DOMException && err.name === "AbortError") return;
throw err;
} finally {
forceSyncAbortRef.current = null;
setForceSyncRunning(false);
}
}, [adminApp, loadStatus]);
Comment thread
BilalG1 marked this conversation as resolved.

const cancelForceSync = useCallback(() => {
forceSyncAbortRef.current?.abort();
}, []);

useEffect(() => {
runAsynchronously(loadStatus);
}, [loadStatus]);
Expand Down Expand Up @@ -682,50 +719,75 @@ export default function PageClient() {
</CardContent>
</Card>

<Card>
<CardHeader>
<CardTitle>Fusebox</CardTitle>
</CardHeader>
<CardContent className="space-y-4">
{!fusebox ? (
<div className="space-y-3">
<Skeleton className="h-6 w-40" />
<Skeleton className="h-6 w-40" />
<Skeleton className="h-6 w-48" />
<Skeleton className="h-9 w-24" />
</div>
) : (
<>
<div className="flex items-center justify-between gap-6">
<div>
<Typography type="p" className="text-sm font-medium">Sequencer</Typography>
<Typography type="p" className="text-xs text-muted-foreground">Assigns sequence IDs and queues sync work.</Typography>
</div>
<Switch
checked={fusebox.sequencerEnabled}
onCheckedChange={(checked) => setFusebox((current) => current ? { ...current, sequencerEnabled: checked } : current)}
/>
<div className="grid gap-4 lg:grid-cols-3">
<Card className="lg:col-span-2">
<CardHeader>
<CardTitle>Fusebox</CardTitle>
</CardHeader>
<CardContent className="space-y-4">
{!fusebox ? (
<div className="space-y-3">
<Skeleton className="h-6 w-40" />
<Skeleton className="h-6 w-40" />
<Skeleton className="h-6 w-48" />
<Skeleton className="h-9 w-24" />
</div>
<div className="flex items-center justify-between gap-6">
<div>
<Typography type="p" className="text-sm font-medium">Poller</Typography>
<Typography type="p" className="text-xs text-muted-foreground">Dispatches queued sync jobs to QStash.</Typography>
) : (
<>
<div className="flex items-center justify-between gap-6">
<div>
<Typography type="p" className="text-sm font-medium">Sequencer</Typography>
<Typography type="p" className="text-xs text-muted-foreground">Assigns sequence IDs and queues sync work.</Typography>
</div>
<Switch
checked={fusebox.sequencerEnabled}
onCheckedChange={(checked) => setFusebox((current) => current ? { ...current, sequencerEnabled: checked } : current)}
/>
</div>
<Switch
checked={fusebox.pollerEnabled}
onCheckedChange={(checked) => setFusebox((current) => current ? { ...current, pollerEnabled: checked } : current)}
/>
</div>
<div className="flex items-center justify-between gap-6">
<div>
<Typography type="p" className="text-sm font-medium">Poller</Typography>
<Typography type="p" className="text-xs text-muted-foreground">Dispatches queued sync jobs to QStash.</Typography>
</div>
<Switch
checked={fusebox.pollerEnabled}
onCheckedChange={(checked) => setFusebox((current) => current ? { ...current, pollerEnabled: checked } : current)}
/>
</div>

<div className="flex justify-end">
<Button onClick={saveFusebox} disabled={!fuseboxDirty || savingFusebox} loading={savingFusebox}>
Save
</Button>
</div>
</>
)}
</CardContent>
</Card>

<div className="flex justify-end">
<Button onClick={saveFusebox} disabled={!fuseboxDirty || savingFusebox} loading={savingFusebox}>
Save
<Card>
<CardHeader>
<CardTitle>Force Sync</CardTitle>
<CardDescription>Manually trigger sequencer and poller.</CardDescription>
</CardHeader>
<CardContent className="flex flex-col items-center gap-4">
<div className="flex items-center gap-2">
<div className={`h-2.5 w-2.5 rounded-full ${forceSyncRunning ? "bg-yellow-500 animate-pulse" : "bg-green-500"}`} />
<Typography type="p" className="text-sm">{forceSyncRunning ? "Running" : "Idle"}</Typography>
</div>
<div className="flex items-center gap-2">
<Button onClick={() => runAsynchronouslyWithAlert(forceTriggerSync)} disabled={forceSyncRunning} loading={forceSyncRunning}>
Run Now
</Button>
{forceSyncRunning && (
<Button onClick={cancelForceSync} variant="destructive" size="sm">
Cancel
</Button>
</div>
</>
)}
</CardContent>
</Card>
)}
</div>
</CardContent>
</Card>
</div>

</PageLayout>
);
Expand Down
Loading