-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathindex.ts
122 lines (100 loc) · 3.48 KB
/
index.ts
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
import * as fs from 'node:fs'
import * as http from 'node:http'
import { fileURLToPath } from 'node:url'
import express from 'express'
import { WebSocketServer } from 'ws'
import compression from 'compression'
import morgan from 'morgan'
import { createRequestHandler, type RequestHandler } from '@remix-run/express'
import { broadcastDevReady, installGlobals, ServerBuild } from '@remix-run/node'
import sourceMapSupport from 'source-map-support'
import { Game } from './Game.js'
// patch in Remix runtime globals
installGlobals()
sourceMapSupport.install()
const BUILD_PATH =
process.env.BUILD_PATH ||
fileURLToPath(new URL('../build/index.js', import.meta.url))
const WATCH_PATH =
process.env.WATCH_PATH ||
fileURLToPath(new URL('../build/version.txt', import.meta.url))
// Initial build.
let build: ServerBuild = await import(BUILD_PATH)
// We'll make chokidar a dev dependency so it doesn't get bundled in production.
const chokidar =
process.env.NODE_ENV === 'development' ? await import('chokidar') : null
const app = express()
const server = http.createServer(app)
app.use(compression())
// http://expressjs.com/en/advanced/best-practice-security.html#at-a-minimum-disable-x-powered-by-header
app.disable('x-powered-by')
// Remix fingerprints its assets so we can cache forever.
app.use(
'/build',
express.static('public/build', { immutable: true, maxAge: '1y' }),
)
// Everything else (like favicon.ico) is cached for an hour. You may want to be
// more aggressive with this caching.
app.use(express.static('public', { maxAge: '1h' }))
app.use(morgan('tiny'))
// Create a request handler that watches for changes to the server build during development.
function createDevRequestHandler(): RequestHandler {
async function handleServerUpdate() {
// 1. re-import the server build
build = await reimportServer()
// Add debugger to assist in v2 dev debugging
if (build?.assets === undefined) {
console.log(build.assets)
debugger
}
// 2. tell dev server that this app server is now up-to-date and ready
await broadcastDevReady(build)
}
chokidar
?.watch(WATCH_PATH, { ignoreInitial: true })
.on('add', handleServerUpdate)
.on('change', handleServerUpdate)
// wrap request handler to make sure its recreated with the latest build for every request
return async (req, res, next) => {
try {
return createRequestHandler({
build,
mode: 'development',
})(req, res, next)
} catch (error) {
next(error)
}
}
}
// ESM import cache busting
async function reimportServer(): Promise<ServerBuild> {
const stat = fs.statSync(BUILD_PATH)
// use a timestamp query parameter to bust the import cache
return import(BUILD_PATH + '?t=' + stat.mtimeMs)
}
app.get('/state', (req, res) => {
res.json(game.getState())
})
app.get('/clients-count', (req, res) => {
res.json(game.clientsCount)
})
const wss = new WebSocketServer({ server })
const game = new Game(wss)
// Check if the server is running in development mode and use the devBuild to reflect realtime changes in the codebase.
app.all(
'*',
process.env.NODE_ENV === 'development'
? createDevRequestHandler()
: createRequestHandler({
build,
mode: process.env.NODE_ENV,
}),
)
const port = process.env.PORT || 3000
server.listen(port, async () => {
console.log(`Server is running at http://localhost:${port}`)
// send "ready" message to dev server
if (process.env.NODE_ENV === 'development') {
await broadcastDevReady(build)
}
})