74 lines
1.8 KiB
TypeScript
74 lines
1.8 KiB
TypeScript
import { describe, expect, test } from "bun:test"
|
|
import { Scheduler } from "../src/scheduler"
|
|
import { Instance } from "../src/project/instance"
|
|
import { tmpdir } from "./fixture/fixture"
|
|
|
|
describe("Scheduler.register", () => {
|
|
const hour = 60 * 60 * 1000
|
|
|
|
test("defaults to instance scope per directory", async () => {
|
|
await using one = await tmpdir({ git: true })
|
|
await using two = await tmpdir({ git: true })
|
|
const runs = { count: 0 }
|
|
const id = "scheduler.instance." + Math.random().toString(36).slice(2)
|
|
const task = {
|
|
id,
|
|
interval: hour,
|
|
run: async () => {
|
|
runs.count += 1
|
|
},
|
|
}
|
|
|
|
await Instance.provide({
|
|
directory: one.path,
|
|
fn: async () => {
|
|
Scheduler.register(task)
|
|
await Instance.dispose()
|
|
},
|
|
})
|
|
expect(runs.count).toBe(1)
|
|
|
|
await Instance.provide({
|
|
directory: two.path,
|
|
fn: async () => {
|
|
Scheduler.register(task)
|
|
await Instance.dispose()
|
|
},
|
|
})
|
|
expect(runs.count).toBe(2)
|
|
})
|
|
|
|
test("global scope runs once across instances", async () => {
|
|
await using one = await tmpdir({ git: true })
|
|
await using two = await tmpdir({ git: true })
|
|
const runs = { count: 0 }
|
|
const id = "scheduler.global." + Math.random().toString(36).slice(2)
|
|
const task = {
|
|
id,
|
|
interval: hour,
|
|
run: async () => {
|
|
runs.count += 1
|
|
},
|
|
scope: "global" as const,
|
|
}
|
|
|
|
await Instance.provide({
|
|
directory: one.path,
|
|
fn: async () => {
|
|
Scheduler.register(task)
|
|
await Instance.dispose()
|
|
},
|
|
})
|
|
expect(runs.count).toBe(1)
|
|
|
|
await Instance.provide({
|
|
directory: two.path,
|
|
fn: async () => {
|
|
Scheduler.register(task)
|
|
await Instance.dispose()
|
|
},
|
|
})
|
|
expect(runs.count).toBe(1)
|
|
})
|
|
})
|