|
|
|
@ -9,14 +9,20 @@ import os from 'os';
|
|
|
|
import anonymize from 'ip-anonymize';
|
|
|
|
import anonymize from 'ip-anonymize';
|
|
|
|
import { importTrigger, importStatus } from './import.mjs'
|
|
|
|
import { importTrigger, importStatus } from './import.mjs'
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** Preloaded games. The keys refer to the docker tags of the virtual machines.
|
|
|
|
|
|
|
|
* The number `queueLength` determines how many instances of the docker container
|
|
|
|
|
|
|
|
* get started before any user shows up to have them up and running immediately.
|
|
|
|
|
|
|
|
* The values `name`, `module`, and `dir` are just used for development where we
|
|
|
|
|
|
|
|
* use a project directory instead of a docker container.
|
|
|
|
|
|
|
|
*/
|
|
|
|
const games = {
|
|
|
|
const games = {
|
|
|
|
adam: {
|
|
|
|
"github-hhu-adam:Robo": {
|
|
|
|
name: "Adam",
|
|
|
|
name: "Adam",
|
|
|
|
module: "Adam",
|
|
|
|
module: "Adam",
|
|
|
|
dir: "../../../../Robo",
|
|
|
|
dir: "../../../../Robo",
|
|
|
|
queueLength: 5
|
|
|
|
queueLength: 5
|
|
|
|
},
|
|
|
|
},
|
|
|
|
nng: {
|
|
|
|
"github-hhu-adam:NNG4": {
|
|
|
|
name: "NNG",
|
|
|
|
name: "NNG",
|
|
|
|
module: "NNG",
|
|
|
|
module: "NNG",
|
|
|
|
dir: "../../../../NNG4",
|
|
|
|
dir: "../../../../NNG4",
|
|
|
|
@ -50,17 +56,18 @@ const isDevelopment = environment === 'development'
|
|
|
|
|
|
|
|
|
|
|
|
/** We keep queues of started Lean Server processes to be ready when a user arrives */
|
|
|
|
/** We keep queues of started Lean Server processes to be ready when a user arrives */
|
|
|
|
const queue = {}
|
|
|
|
const queue = {}
|
|
|
|
const queueLength = 5
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
function startServerProcess(gameId) {
|
|
|
|
function startServerProcess(tag) {
|
|
|
|
const serverProcess = isDevelopment
|
|
|
|
let serverProcess
|
|
|
|
? cp.spawn("./gameserver",
|
|
|
|
if (isDevelopment && games[tag]?.dir) {
|
|
|
|
["--server", games[gameId].dir, games[gameId].module, games[gameId].name],
|
|
|
|
serverProcess = cp.spawn("./gameserver",
|
|
|
|
|
|
|
|
["--server", games[tag].dir, games[tag].module, games[tag].name],
|
|
|
|
{ cwd: "./build/bin/" })
|
|
|
|
{ cwd: "./build/bin/" })
|
|
|
|
: cp.spawn("docker",
|
|
|
|
} else {
|
|
|
|
["run", "--runtime=runsc", "--network=none", "--rm", "-i", `${gameId}:latest`,
|
|
|
|
serverProcess = cp.spawn("docker",
|
|
|
|
"./gameserver", "--server", "/game/", games[gameId].module, games[gameId].name],
|
|
|
|
["run", "--runtime=runsc", "--network=none", "--rm", "-i", `${tag}`],
|
|
|
|
{ cwd: "." })
|
|
|
|
{ cwd: "." })
|
|
|
|
|
|
|
|
}
|
|
|
|
serverProcess.on('error', error =>
|
|
|
|
serverProcess.on('error', error =>
|
|
|
|
console.error(`Launching Lean Server failed: ${error}`)
|
|
|
|
console.error(`Launching Lean Server failed: ${error}`)
|
|
|
|
);
|
|
|
|
);
|
|
|
|
@ -73,32 +80,35 @@ function startServerProcess(gameId) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/** start Lean Server processes to refill the queue */
|
|
|
|
/** start Lean Server processes to refill the queue */
|
|
|
|
function fillQueue(gameId) {
|
|
|
|
function fillQueue(tag) {
|
|
|
|
while (queue[gameId].length < games[gameId].queueLength) {
|
|
|
|
while (queue[tag].length < games[tag].queueLength) {
|
|
|
|
const serverProcess = startServerProcess(gameId)
|
|
|
|
const serverProcess = startServerProcess(tag)
|
|
|
|
queue[gameId].push(serverProcess)
|
|
|
|
queue[tag].push(serverProcess)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
for (let gameId in games) {
|
|
|
|
if (!isDevelopment) { // Don't use queue in development
|
|
|
|
queue[gameId] = []
|
|
|
|
for (let tag in games) {
|
|
|
|
fillQueue(gameId)
|
|
|
|
queue[tag] = []
|
|
|
|
|
|
|
|
fillQueue(tag)
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
const urlRegEx = new RegExp("^/websocket/(.*)$")
|
|
|
|
const urlRegEx = /^\/websocket\/g\/([\w.-]+)\/([\w.-]+)$/
|
|
|
|
|
|
|
|
|
|
|
|
wss.addListener("connection", function(ws, req) {
|
|
|
|
wss.addListener("connection", function(ws, req) {
|
|
|
|
const reRes = urlRegEx.exec(req.url)
|
|
|
|
const reRes = urlRegEx.exec(req.url)
|
|
|
|
if (!reRes) { console.error(`Connection refused because of invalid URL: ${req.url}`); return; }
|
|
|
|
if (!reRes) { console.error(`Connection refused because of invalid URL: ${req.url}`); return; }
|
|
|
|
const gameId = reRes[1]
|
|
|
|
const owner = reRes[1]
|
|
|
|
if (!games[gameId]) { console.error(`Unknown game: ${gameId}`); return; }
|
|
|
|
const repo = reRes[2]
|
|
|
|
|
|
|
|
const tag = `github-${owner}:${repo}`
|
|
|
|
|
|
|
|
|
|
|
|
let ps;
|
|
|
|
let ps;
|
|
|
|
if (isDevelopment) { // Don't use queue in development
|
|
|
|
if (!queue[tag] || queue[tag].length == 0) {
|
|
|
|
ps = startServerProcess(gameId)
|
|
|
|
ps = startServerProcess(tag)
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
ps = queue[gameId].shift() // Pick the first Lean process; it's likely to be ready immediately
|
|
|
|
ps = queue[tag].shift() // Pick the first Lean process; it's likely to be ready immediately
|
|
|
|
fillQueue(gameId)
|
|
|
|
fillQueue(tag)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
socketCounter += 1;
|
|
|
|
socketCounter += 1;
|
|
|
|
|
Alexander Bentkamp
3 years ago