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
|
import { readableStreamFromReader, fromFileUrl } from './deps.js';
const dir = new URL('./', import.meta.url);
export async function runBuild(fixturePath) {
let proc = Deno.run({
cmd: ['node', '../../../../../astro/astro.js', 'build', '--silent'],
cwd: fromFileUrl(new URL(fixturePath, dir)),
});
await proc.status();
return async () => await proc.close();
}
export async function startModFromImport(baseUrl) {
const entryUrl = new URL('./dist/server/entry.mjs', baseUrl);
const mod = await import(entryUrl);
if (!mod.running()) {
mod.start();
}
return () => mod.stop();
}
export async function startModFromSubprocess(baseUrl) {
const entryUrl = new URL('./dist/server/entry.mjs', baseUrl);
let proc = Deno.run({
cmd: ['deno', 'run', '--allow-env', '--allow-net', fromFileUrl(entryUrl)],
cwd: fromFileUrl(baseUrl),
stderr: 'piped'
});
const stderr = readableStreamFromReader(proc.stderr);
const dec = new TextDecoder();
for await(let bytes of stderr) {
let msg = dec.decode(bytes);
if(msg.includes(`Server running`)) {
break;
}
}
return () => proc.close();
}
export async function runBuildAndStartApp(fixturePath, cb) {
const url = new URL(fixturePath, dir);
const close = await runBuild(fixturePath);
const stop = await startModFromImport(url);
await cb();
await stop();
await close();
}
export async function runBuildAndStartAppFromSubprocess(fixturePath, cb) {
const url = new URL(fixturePath, dir);
const close = await runBuild(fixturePath);
const stop = await startModFromSubprocess(url);
await cb();
await stop();
await close();
}
|
