e61263cff0
* fix(deps): update [backend] update dependencies * fix(backend/types): ensure to use nodejs-provided stream api --------- Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com> Co-authored-by: kakkokari-gtyih <67428053+kakkokari-gtyih@users.noreply.github.com>
38 lines
819 B
TypeScript
38 lines
819 B
TypeScript
/*
|
|
* SPDX-FileCopyrightText: syuilo and misskey-project
|
|
* SPDX-License-Identifier: AGPL-3.0-only
|
|
*/
|
|
|
|
import * as fs from 'node:fs/promises';
|
|
import { WritableStream } from 'node:stream/web';
|
|
import type { PathLike } from 'node:fs';
|
|
|
|
/**
|
|
* `fs.createWriteStream()`相当のことを行う`WritableStream` (Web標準)
|
|
*/
|
|
export class FileWriterStream extends WritableStream<Uint8Array> {
|
|
constructor(path: PathLike) {
|
|
let file: fs.FileHandle | null = null;
|
|
|
|
super({
|
|
start: async () => {
|
|
file = await fs.open(path, 'a');
|
|
},
|
|
write: async (chunk, controller) => {
|
|
if (file === null) {
|
|
controller.error();
|
|
throw new Error();
|
|
}
|
|
|
|
await file.write(chunk);
|
|
},
|
|
close: async () => {
|
|
await file?.close();
|
|
},
|
|
abort: async () => {
|
|
await file?.close();
|
|
},
|
|
});
|
|
}
|
|
}
|