Leahnaya/sprites
1
0
Fork 0
mirror of https://github.com/smogon/sprites.git synced 2026-10-25 17:43:10 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Make the deploy layer and tool I/O async

Browse Source 
DeployCtx read/list/hash return promises (copy and write stay sync:
they only queue ops), the stamped copy helpers and buildfile deploy
blocks await them, ActionQueue materialization and packing use
fs/promises, and the CLI, config loaders, spritesheet writer, and
trim tool follow. Declaration-time globbing and the module-init data
reads stay sync: rules exist by the end of the import.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
This commit is contained in:
Christopher Monsanto
2026-08-17 19:10:49 -04:00
parent 1d7e52ca29
commit 40bd3052f5
14 changed files with 137 additions and 122 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
tools/deploy/queue.ts
View File

@@ -1,5 +1,6 @@
import * as fs from 'node:fs';
import * as fs from 'node:fs/promises';
import {createWriteStream} from 'node:fs';
import * as nodePath from 'node:path';
import tar from 'tar-stream';
@@ -134,25 +135,25 @@ export class ActionQueue {
continue;
let op = entry.op;
let dst = nodePath.join(dir, entry.dst);
fs.mkdirSync(nodePath.dirname(dst), {recursive: true});
await fs.mkdir(nodePath.dirname(dst), {recursive: true});
if (op.type === 'Copy'){
// Read-only sources are CAS objects; their mode must not
// leak into deploy trees (rsync -a would ship it), and a
// hardlink cannot carry its own mode, so copy those.
if (mode === 'link' && (fs.statSync(op.src).mode & 0o200) !== 0) {
fs.linkSync(op.src, dst);
if (mode === 'link' && ((await fs.stat(op.src)).mode & 0o200) !== 0) {
await fs.link(op.src, dst);
} else {
fs.copyFileSync(op.src, dst);
fs.chmodSync(dst, 0o644);
await fs.copyFile(op.src, dst);
await fs.chmod(dst, 0o644);
}
} else if (op.type === 'Write') {
fs.writeFileSync(dst, op.data);
await fs.writeFile(dst, op.data);
}
}
} else {
// In this case, I guess its a file rather than a dir.
let out = fs.createWriteStream(dir);
this.pack(filter).pipe(out);
let out = createWriteStream(dir);
(await this.pack(filter)).pipe(out);
return new Promise<void>((resolve, reject) => {
out.on('error', reject);
out.on('finish', () => resolve());
@@ -160,7 +161,7 @@ export class ActionQueue {
}
}
pack(filter?: (dst: string) => boolean): NodeJS.ReadableStream {
async pack(filter?: (dst: string) => boolean): Promise<NodeJS.ReadableStream> {
if (!this.valid)
throw new Error(`Invalid ActionQueue`);
let t = tar.pack();
@@ -168,7 +169,7 @@ export class ActionQueue {
if (entry.type !== 'Op' || (filter !== undefined && !filter(entry.dst)))
continue;
let op = entry.op;
let data = op.type === 'Copy' ? fs.readFileSync(op.src) : op.data;
let data = op.type === 'Copy' ? await fs.readFile(op.src) : op.data;
// A dying consumer destroys the pack and every pending entry
// sink, and each sink emits the error; the consumer is the one
// reporting the failure, so keep the sinks quiet.