-
Notifications
You must be signed in to change notification settings - Fork 1
/
index.js
75 lines (63 loc) · 1.92 KB
/
index.js
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
72
73
74
75
import wisp from 'wisp-server-node';
import { createBareServer } from '@tomphttp/bare-server-node';
import { uvPath } from '@titaniumnetwork-dev/ultraviolet';
import { epoxyPath } from '@mercuryworkshop/epoxy-transport';
import { bareModulePath } from '@mercuryworkshop/bare-as-module3';
import { baremuxPath } from '@mercuryworkshop/bare-mux/node';
import express from 'express';
import { createServer } from 'node:http';
import { join } from 'node:path';
import { fileURLToPath } from 'node:url';
const bare = createBareServer('/bare/');
const __dirname = join(fileURLToPath(import.meta.url), '..');
const app = express();
const publicPath = 'dist';
app.use(express.static(publicPath));
app.use('/uv/', express.static(uvPath));
app.use('/epoxy/', express.static(epoxyPath));
app.use('/baremux/', express.static(baremuxPath));
app.use('/baremod/', express.static(bareModulePath));
app.use((req, res) => {
res.status(404);
res.sendFile(join(__dirname, publicPath, '404.html'));
});
const server = createServer();
server.on('request', (req, res) => {
if (bare.shouldRoute(req)) {
bare.routeRequest(req, res);
} else {
app(req, res);
}
});
server.on('upgrade', (req, socket, head) => {
if (req.url.endsWith('/wisp/')) {
wisp.routeRequest(req, socket, head);
} else if (bare.shouldRoute(req)) {
bare.routeUpgrade(req, socket, head);
} else {
socket.end();
}
});
let port = parseInt(process.env.PORT || '');
if (isNaN(port)) port = 8080;
server.on('listening', () => {
const address = server.address();
console.log('Listening on:');
console.log(`\thttp://localhost:${address.port}`);
console.log(
`\thttp://${
address.family === 'IPv6' ? `[${address.address}]` : address.address
}:${address.port}`
);
});
process.on('SIGINT', shutdown);
process.on('SIGTERM', shutdown);
function shutdown() {
console.log('SIGTERM signal received: closing HTTP server');
server.close();
bare.close();
process.exit(0);
}
server.listen({
port
});