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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
import { join } from "@std/path";
import { toFileNameString } from "./date.ts";
export interface ExternalLogStream extends Disposable {
stream: WritableStream;
}
export class Logger {
#externalLogDir?: string;
get externalLogDir() {
return this.#externalLogDir;
}
set externalLogDir(value: string | undefined) {
this.#externalLogDir = value;
if (value != null) {
Deno.mkdirSync(value, {
recursive: true,
});
}
}
async createExternalLogStream(
name: string,
options?: {
noTime?: boolean;
},
): Promise<ExternalLogStream> {
if (name.includes("/")) {
throw new Error(`External log stream's name (${name}) contains '/'.`);
}
if (this.#externalLogDir == null) {
throw new Error("External log directory is not set.");
}
const logPath = join(
this.#externalLogDir,
options?.noTime === true
? name
: `${name}-${toFileNameString(new Date())}`,
);
const file = await Deno.open(logPath, {
read: false,
write: true,
append: true,
create: true,
});
return {
stream: file.writable,
[Symbol.dispose]: file[Symbol.dispose].bind(file),
};
}
async createExternalLogStreamsForProgram(
program: string,
): Promise<{ stdout: WritableStream; stderr: WritableStream } & Disposable> {
const stdout = await this.createExternalLogStream(`${program}-stdout`);
const stderr = await this.createExternalLogStream(`${program}-stderr`);
return {
stdout: stdout.stream,
stderr: stderr.stream,
[Symbol.dispose]: () => {
stdout[Symbol.dispose]();
stderr[Symbol.dispose]();
},
};
}
}
|
