diff options
| author | Dax <[email protected]> | 2026-04-25 10:59:17 -0400 |
|---|---|---|
| committer | GitHub <[email protected]> | 2026-04-25 10:59:17 -0400 |
| commit | 62ef2a220723a6d6cb050e523fcdfaa974dafdda (patch) | |
| tree | 214b03d016e18e4d8fe1bfc7209c1edd86547bbd /packages/shared/test/fixture | |
| parent | 37aa8442dc023fad250f2573c8235a544789900c (diff) | |
| download | opencode-62ef2a220723a6d6cb050e523fcdfaa974dafdda.tar.gz opencode-62ef2a220723a6d6cb050e523fcdfaa974dafdda.zip | |
refactor: rename shared package to core (#24309)
Diffstat (limited to 'packages/shared/test/fixture')
| -rw-r--r-- | packages/shared/test/fixture/effect-flock-worker.ts | 63 | ||||
| -rw-r--r-- | packages/shared/test/fixture/flock-worker.ts | 72 |
2 files changed, 0 insertions, 135 deletions
diff --git a/packages/shared/test/fixture/effect-flock-worker.ts b/packages/shared/test/fixture/effect-flock-worker.ts deleted file mode 100644 index c9116c2d5..000000000 --- a/packages/shared/test/fixture/effect-flock-worker.ts +++ /dev/null @@ -1,63 +0,0 @@ -import fs from "fs/promises" -import os from "os" -import { Effect, Layer } from "effect" -import { AppFileSystem } from "@opencode-ai/shared/filesystem" -import { EffectFlock } from "@opencode-ai/shared/util/effect-flock" -import { Global } from "@opencode-ai/shared/global" - -type Msg = { - key: string - dir: string - holdMs?: number - ready?: string - active?: string - done?: string -} - -function sleep(ms: number) { - return new Promise<void>((resolve) => setTimeout(resolve, ms)) -} - -const msg: Msg = JSON.parse(process.argv[2]!) - -const testGlobal = Layer.succeed( - Global.Service, - Global.Service.of({ - home: os.homedir(), - data: os.tmpdir(), - cache: os.tmpdir(), - config: os.tmpdir(), - state: os.tmpdir(), - bin: os.tmpdir(), - log: os.tmpdir(), - }), -) - -const testLayer = EffectFlock.layer.pipe(Layer.provide(testGlobal), Layer.provide(AppFileSystem.defaultLayer)) - -async function job() { - if (msg.ready) await fs.writeFile(msg.ready, String(process.pid)) - if (msg.active) await fs.writeFile(msg.active, String(process.pid), { flag: "wx" }) - - try { - if (msg.holdMs && msg.holdMs > 0) await sleep(msg.holdMs) - if (msg.done) await fs.appendFile(msg.done, "1\n") - } finally { - if (msg.active) await fs.rm(msg.active, { force: true }) - } -} - -await Effect.runPromise( - Effect.gen(function* () { - const flock = yield* EffectFlock.Service - yield* flock.withLock( - Effect.promise(() => job()), - msg.key, - msg.dir, - ) - }).pipe(Effect.provide(testLayer)), -).catch((err) => { - const text = err instanceof Error ? (err.stack ?? err.message) : String(err) - process.stderr.write(text) - process.exit(1) -}) diff --git a/packages/shared/test/fixture/flock-worker.ts b/packages/shared/test/fixture/flock-worker.ts deleted file mode 100644 index 9954d290c..000000000 --- a/packages/shared/test/fixture/flock-worker.ts +++ /dev/null @@ -1,72 +0,0 @@ -import fs from "fs/promises" -import { Flock } from "@opencode-ai/shared/util/flock" - -type Msg = { - key: string - dir: string - staleMs?: number - timeoutMs?: number - baseDelayMs?: number - maxDelayMs?: number - holdMs?: number - ready?: string - active?: string - done?: string -} - -function sleep(ms: number) { - return new Promise<void>((resolve) => { - setTimeout(resolve, ms) - }) -} - -function input() { - const raw = process.argv[2] - if (!raw) { - throw new Error("Missing flock worker input") - } - - return JSON.parse(raw) as Msg -} - -async function job(input: Msg) { - if (input.ready) { - await fs.writeFile(input.ready, String(process.pid)) - } - - if (input.active) { - await fs.writeFile(input.active, String(process.pid), { flag: "wx" }) - } - - try { - if (input.holdMs && input.holdMs > 0) { - await sleep(input.holdMs) - } - - if (input.done) { - await fs.appendFile(input.done, "1\n") - } - } finally { - if (input.active) { - await fs.rm(input.active, { force: true }) - } - } -} - -async function main() { - const msg = input() - - await Flock.withLock(msg.key, () => job(msg), { - dir: msg.dir, - staleMs: msg.staleMs, - timeoutMs: msg.timeoutMs, - baseDelayMs: msg.baseDelayMs, - maxDelayMs: msg.maxDelayMs, - }) -} - -await main().catch((err) => { - const text = err instanceof Error ? (err.stack ?? err.message) : String(err) - process.stderr.write(text) - process.exit(1) -}) |
