Repository navigation
Expand file tree
/
Copy pathworker.ts
More file actions
45 lines (44 loc) · 1.32 KB
/
Copy pathworker.ts
File metadata and controls
45 lines (44 loc) · 1.32 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
import handler from "./.open-next/worker.js";
import {
runCurate,
runTriage,
runPrReview,
runStale,
runDupes,
runDigest,
type AgentEnv,
} from "./lib/community-agent-tasks";
import { runFactsDrift } from "./lib/facts-drift";
import { runLinkCheck, runSemanticDrift } from "./lib/content-watch";
import { fetchWithStaticInstaller } from "./lib/static-installer";
export default {
fetch(request, env, ctx) {
return fetchWithStaticInstaller(
request,
env,
ctx,
(nextRequest, nextEnv, nextCtx) => handler.fetch(nextRequest, nextEnv, nextCtx),
);
},
async scheduled(event: ScheduledEvent, env: Record<string, unknown>, ctx: ExecutionContext) {
const expr = event.cron;
ctx.waitUntil((async () => {
const agentEnv = env as unknown as AgentEnv;
if (expr === "0 */6 * * *") {
await runCurate(agentEnv);
await runFactsDrift(agentEnv);
}
else if (expr === "*/30 * * * *") {
await runTriage(agentEnv);
await runPrReview(agentEnv);
}
else if (expr === "0 0 * * *") {
await runStale(agentEnv);
await runDupes(agentEnv);
await runLinkCheck(agentEnv);
await runSemanticDrift(agentEnv);
}
else if (expr === "0 9 * * 1") await runDigest(agentEnv);
})());
},
} satisfies ExportedHandler;