Bingle/bingle-arbiter
Bingle
/
bingle-arbiter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'master' into crapblox

This commit is contained in:
I-Have-An-Issue 2023-02-16 22:00:16 -05:00
parent 4d056e9f81 ded459f503
commit 5e897f89c9
No known key found for this signature in database
GPG Key ID: E55435DEA0825091
11 changed files with 148 additions and 159 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.env.example → example.env
View File

@ -1,10 +1,10 @@
RCCSERVICE= RCCSERVICE=
ARBITER_TOKEN= ARBITER_TOKEN=
ARBITER_PASSWORD=
BASE_URL=https://sitetest.unexp.xyz BASE_URL=https://sitetest.unexp.xyz
RENDER_FORMAT=PNG RENDER_FORMAT=PNG
RENDER_BASE64=
RENDER_USER_WIDTH=720 RENDER_USER_WIDTH=720
RENDER_USER_HEIGHT=720 RENDER_USER_HEIGHT=720

51
src/index.js
View File

@ -1,40 +1,37 @@
require("dotenv").config() require("dotenv").config();
const express = require("express") const express = require("express");
const app = express() const app = express();
const logger = require("./lib/logger.js") const logger = require("./lib/logger.js");
if (process.platform == "linux") logger.warn("Game hosting might not be fully compatible with Linux") if (process.platform == "linux") logger.warn("Game hosting might not be fully compatible with Linux");
global.games = new Map() global.games = new Map();
setInterval(() => { setInterval(() => {
global.games.forEach(async (value, key) => { global.games.forEach(async (value, key) => {
if (!(await value.Running())) value.Stop() if (!(await value.Running())) value.Stop();
}) });
}, 15000) }, 15000);
app.use("/game/start", require("./routes/game/start.js")) app.use("/game/start", require("./routes/game/start.js"));
app.use("/game/stop", require("./routes/game/stop.js")) app.use("/game/stop", require("./routes/game/stop.js"));
app.use("/game/running", require("./routes/game/running.js")) app.use("/game/running", require("./routes/game/running.js"));
app.use("/game/renew", require("./routes/game/renew.js")) app.use("/game/renew", require("./routes/game/renew.js"));
app.use("/game/status", require("./routes/game/status.js")) app.use("/game/status", require("./routes/game/status.js"));
app.use("/game/execute", require("./routes/game/execute.js")) app.use("/game/execute", require("./routes/game/execute.js"));
app.use("/render/asset", require("./routes/render/asset.js")) app.use("/render/asset", require("./routes/render/asset.js"));
app.use("/render/game", require("./routes/render/game.js")) //app.use("/render/game", require("./routes/render/game.js"))
app.use("/render/headshot", require("./routes/render/headshot.js")) //app.use("/render/texture", require("./routes/render/texture.js"))
app.use("/render/bodyshot", require("./routes/render/bodyshot.js")) app.use("/render/user", require("./routes/render/user.js"));
app.use("/render/3d/asset", require("./routes/render/3d/asset.js")) app.use("*", require("./routes/index.js"));
app.use("/render/3d/user", require("./routes/render/3d/user.js"))
app.use("*", require("./routes/index.js"))
app.listen(process.env.PORT || 64989, () => { app.listen(process.env.PORT || 64989, () => {
logger.boot(`Listening on http://127.0.0.1:${process.env.PORT || 64989}/`) logger.boot(`Listening on http://127.0.0.1:${process.env.PORT || 64989}/`);
}) });
process.on("uncaughtException", (err) => { process.on("uncaughtException", (err) => {
logger.error(err.message) logger.error(err.message);
}) });

15
src/lib/classes/RCCService.js
View File

@ -5,6 +5,8 @@ const waitPort = require("wait-port")
const logger = require("../../lib/logger.js") const logger = require("../../lib/logger.js")
const randport = require("../../lib/randport.js") const randport = require("../../lib/randport.js")
const chalk = require("chalk")
class RCCService extends EventEmitter { class RCCService extends EventEmitter {
constructor() { constructor() {
super() super()
@ -16,16 +18,17 @@ class RCCService extends EventEmitter {
this.port = await randport.tcp() this.port = await randport.tcp()
if (process.platform == "win32") { if (process.platform == "win32") {
this.proc = child_process.spawn("RCCService.exe", ["-Console", "-PlaceId:-1", `-Port`, this.port], { cwd: process.env.RCCSERVICE }) this.proc = child_process.spawn("RCCService.exe", ["-Console", "-PlaceId:-1", `-Port`, this.port], { cwd: process.env.RCCSERVICE, stdio: "inherit" })
} else { } else {
this.proc = child_process.spawn("wine", ["RCCService.exe", "-Console", "-PlaceId:-1", `-Port`, this.port], { cwd: process.env.RCCSERVICE }) this.proc = child_process.spawn("wine", ["RCCService.exe", "-Console", "-PlaceId:-1", `-Port`, this.port], { cwd: process.env.RCCSERVICE, stdio: "inherit" })
} }
this.proc.once("spawn", async () => { this.proc.once("spawn", async () => {
logger.info(`[${this.port}] RCCService instance spawned`) logger.info(`${chalk.gray(`[${this.port}]`)} RCCService instance spawned`)
const { open } = await waitPort({ host: "127.0.0.1", port: this.port, timeout: 5000, output: "silent" }).catch((e) => console.log(e)) const { open } = await waitPort({ host: "127.0.0.1", port: this.port, timeout: 5000, output: "silent" }).catch((e) => console.log(e))
if (!open || this.proc.exitCode !== null) { if (!open || this.proc.exitCode !== null) {
logger.error(`[${this.port}] RCCService could not listen`) this.proc.kill()
logger.error(`${chalk.gray(`[${this.port}]`)} RCCService could not listen`)
return resolve(false) return resolve(false)
} }
@ -33,8 +36,8 @@ class RCCService extends EventEmitter {
}) })
this.proc.once("exit", () => { this.proc.once("exit", () => {
this.proc = null this.proc.kill()
logger.info(`[${this.port}] RCCService instance exited`) logger.info(`${chalk.gray(`[${this.port}]`)} RCCService instance exited`)
}) })
} catch (_) { } catch (_) {
resolve(false) resolve(false)

108
src/lib/classes/RenderJob.js
View File

@ -1,19 +1,19 @@
const { readFile } = require("fs/promises") const { readFile } = require("fs/promises");
const Job = require("./Job.js") const Job = require("./Job.js");
const logger = require("../logger.js") const logger = require("../logger.js");
class RenderJob extends Job { class RenderJob extends Job {
constructor() { constructor() {
super() super();
} }
async RenderHeadshot(id, base64 = false) { async RenderHeadshot(id) {
const started = await this.Start() const started = await this.Start();
if (!started) throw new Error("RCCService failed to start") if (!started) throw new Error("RCCService failed to start");
if (!this.client) await this.CreateClient() if (!this.client) await this.CreateClient();
logger.info(`[${this.id}] Headshot RenderJob started for ${id}`) logger.info(`[${this.id}] Headshot RenderJob started for ${id}`);
const result = await this.OpenJobEx({ const result = await this.OpenJobEx({
name: this.id, name: this.id,
@ -32,24 +32,21 @@ class RenderJob extends Job {
{ type: "LUA_TNUMBER", value: id }, { type: "LUA_TNUMBER", value: id },
], ],
}, },
}).catch((e) => false) }).catch((e) => false);
logger.info(`[${this.id}] Headshot RenderJob finished for ${id}`) logger.info(`[${this.id}] Headshot RenderJob finished for ${id}`);
await this.Stop() if (!result) return false;
return result[0]?.OpenJobExResult?.LuaValue[0]?.value;
if (!result) return false
if (base64) return result[0].OpenJobExResult.LuaValue[0].value
return Buffer.from(result[0]?.OpenJobExResult?.LuaValue[0]?.value, "base64")
} }
async RenderBodyshot(id, base64 = false, three_d = false) { async RenderBodyshot(id, three_d = false) {
const started = await this.Start() const started = await this.Start();
if (!started) throw new Error("RCCService failed to start") if (!started) throw new Error("RCCService failed to start");
if (!this.client) await this.CreateClient() if (!this.client) await this.CreateClient();
if (three_d) logger.info(`[${this.id}] 3D Bodyshot RenderJob started for ${id}`) if (three_d) logger.info(`[${this.id}] 3D Bodyshot RenderJob started for ${id}`);
else logger.info(`[${this.id}] Bodyshot RenderJob started for ${id}`) else logger.info(`[${this.id}] Bodyshot RenderJob started for ${id}`);
const result = await this.OpenJobEx({ const result = await this.OpenJobEx({
name: this.id, name: this.id,
@ -68,25 +65,22 @@ class RenderJob extends Job {
{ type: "LUA_TNUMBER", value: id }, { type: "LUA_TNUMBER", value: id },
], ],
}, },
}).catch((e) => false) }).catch((e) => false);
if (three_d) logger.info(`[${this.id}] 3D Bodyshot RenderJob finished for ${id}`) if (three_d) logger.info(`[${this.id}] 3D Bodyshot RenderJob finished for ${id}`);
else logger.info(`[${this.id}] Bodyshot RenderJob finished for ${id}`) else logger.info(`[${this.id}] Bodyshot RenderJob finished for ${id}`);
await this.Stop() if (!result) return false;
return result[0]?.OpenJobExResult?.LuaValue[0]?.value;
if (!result) return false
if (base64 || three_d) return result[0].OpenJobExResult.LuaValue[0].value
return Buffer.from(result[0]?.OpenJobExResult?.LuaValue[0]?.value, "base64")
} }
async RenderAsset(id, base64 = false, three_d = false) { async RenderAsset(id, three_d = false) {
const started = await this.Start() const started = await this.Start();
if (!started) throw new Error("RCCService failed to start") if (!started) throw new Error("RCCService failed to start");
if (!this.client) await this.CreateClient() if (!this.client) await this.CreateClient();
if (three_d) logger.info(`[${this.id}] 3D Asset RenderJob started for ${id}`) if (three_d) logger.info(`[${this.id}] 3D Asset RenderJob started for ${id}`);
else logger.info(`[${this.id}] Asset RenderJob started for ${id}`) else logger.info(`[${this.id}] Asset RenderJob started for ${id}`);
const result = await this.OpenJobEx({ const result = await this.OpenJobEx({
name: this.id, name: this.id,
@ -106,29 +100,26 @@ class RenderJob extends Job {
{ type: "LUA_TBOOLEAN", value: "true" }, { type: "LUA_TBOOLEAN", value: "true" },
], ],
}, },
}).catch((e) => false) }).catch((e) => false);
if (three_d) logger.info(`[${this.id}] 3D Asset RenderJob finished for ${id}`) if (three_d) logger.info(`[${this.id}] 3D Asset RenderJob finished for ${id}`);
else logger.info(`[${this.id}] Asset RenderJob finished for ${id}`) else logger.info(`[${this.id}] Asset RenderJob finished for ${id}`);
await this.Stop() if (!result) return false;
return result[0]?.OpenJobExResult?.LuaValue[0]?.value;
if (!result) return false
if (base64 || three_d) return result[0].OpenJobExResult.LuaValue[0].value
return Buffer.from(result[0]?.OpenJobExResult?.LuaValue[0]?.value, "base64")
} }
async RenderPlace(id, base64 = false) { async RenderPlace(id) {
const response = await axios(`${process.env.BASE_URL}/API/Game/${id}?t=${process.env.ARBITER_TOKEN}`).catch((_) => reject(_)) const response = await axios(`${process.env.BASE_URL}/API/Game/${id}?t=${process.env.ARBITER_TOKEN}`).catch((_) => reject(_));
const { server_token, server_port, server_owner_id } = response.data const { server_token, server_port, server_owner_id } = response.data;
this.id = server_token this.id = server_token;
const started = await this.Start() const started = await this.Start();
if (!started) throw new Error("RCCService failed to start") if (!started) throw new Error("RCCService failed to start");
if (!this.client) await this.CreateClient() if (!this.client) await this.CreateClient();
logger.info(`[${this.id}] Place RenderJob started for ${id}`) logger.info(`[${this.id}] Place RenderJob started for ${id}`);
const result = await this.OpenJobEx({ const result = await this.OpenJobEx({
name: this.id, name: this.id,
@ -147,16 +138,13 @@ class RenderJob extends Job {
{ type: "LUA_TNUMBER", value: id }, { type: "LUA_TNUMBER", value: id },
], ],
}, },
}).catch((e) => false) }).catch((e) => false);
logger.info(`[${this.id}] Place RenderJob finished for ${id}`) logger.info(`[${this.id}] Place RenderJob finished for ${id}`);
await this.Stop() if (!result) return false;
return result[0]?.OpenJobExResult?.LuaValue[0]?.value;
if (!result) return false
if (base64) return result[0].OpenJobExResult.LuaValue[0].value
return Buffer.from(result[0]?.OpenJobExResult?.LuaValue[0]?.value, "base64")
} }
} }
module.exports = RenderJob module.exports = RenderJob;

14
src/routes/render/3d/asset.js
View File

@ -1,14 +0,0 @@
const express = require("express")
const app = express.Router()
const RenderJob = require("../../../lib/classes/RenderJob.js")
app.get("/:id", async (request, response) => {
const job = new RenderJob()
const result = await job.RenderAsset(request.params.id, process.env.RENDER_BASE64, true).catch((_) => _)
if (result?.message) return response.status(500).json({ error: result.message })
else return response.end(result)
})
module.exports = app

14
src/routes/render/3d/user.js
View File

@ -1,14 +0,0 @@
const express = require("express")
const app = express.Router()
const RenderJob = require("../../../lib/classes/RenderJob.js")
app.get("/:id", async (request, response) => {
const job = new RenderJob()
const result = await job.RenderBodyshot(request.params.id, process.env.RENDER_BASE64, true).catch((_) => _)
if (result?.message) return response.status(500).json({ error: result.message })
else return response.end(result)
})
module.exports = app

36
src/routes/render/asset.js
View File

@ -1,14 +1,32 @@
const express = require("express") const express = require("express");
const app = express.Router() const app = express.Router();
const RenderJob = require("../../lib/classes/RenderJob.js") const RenderJob = require("../../lib/classes/RenderJob.js");
app.get("/:id", async (request, response) => { app.get("/:id", async (request, response) => {
const job = new RenderJob() const { params, query } = request;
const result = await job.RenderAsset(request.params.id, process.env.RENDER_BASE64).catch((_) => _) const job = new RenderJob();
let body = {};
if (result?.message) return response.status(500).json({ error: result.message }) const aseet = await job.RenderAsset(params.id).catch((_) => _);
else return response.end(result) if (aseet?.message) {
}) job.Stop();
return response.status(500).json({ error: aseet.message });
}
body.aseet = aseet;
module.exports = app if (query.three_d) {
const three_d = await job.RenderAsset(params.id, true).catch((_) => _);
if (three_d?.message) {
job.Stop();
return response.status(500).json({ error: three_d.message });
}
body.three_d = three_d;
}
job.Stop();
return response.json(body);
});
module.exports = app;

14
src/routes/render/bodyshot.js
View File

@ -1,14 +0,0 @@
const express = require("express")
const app = express.Router()
const RenderJob = require("../../lib/classes/RenderJob.js")
app.get("/:id", async (request, response) => {
const job = new RenderJob()
const result = await job.RenderBodyshot(request.params.id, process.env.RENDER_BASE64).catch((_) => _)
if (result?.message) return response.status(500).json({ error: result.message })
else return response.end(result)
})
module.exports = app

14
src/routes/render/headshot.js
View File

@ -1,14 +0,0 @@
const express = require("express")
const app = express.Router()
const RenderJob = require("../../lib/classes/RenderJob.js")
app.get("/:id", async (request, response) => {
const job = new RenderJob()
const result = await job.RenderHeadshot(request.params.id, process.env.RENDER_BASE64).catch((_) => _)
if (result?.message) return response.status(500).json({ error: result.message })
else return response.end(result)
})
module.exports = app

0
src/routes/render/texture.js Normal file
View File

39
src/routes/render/user.js Normal file
View File

@ -0,0 +1,39 @@
const express = require("express");
const app = express.Router();
const RenderJob = require("../../lib/classes/RenderJob.js");
app.get("/:id", async (request, response) => {
const { params, query } = request;
const job = new RenderJob();
let body = {};
const headshot = await job.RenderHeadshot(params.id).catch((_) => _);
if (headshot?.message) {
job.Stop();
return response.status(500).json({ error: headshot.message });
}
body.headshot = headshot;
const bodyshot = await job.RenderBodyshot(params.id).catch((_) => _);
if (bodyshot?.message) {
job.Stop();
return response.status(500).json({ error: bodyshot.message });
}
body.bodyshot = bodyshot;
if (query.three_d) {
const three_d = await job.RenderBodyshot(params.id, true).catch((_) => _);
if (three_d?.message) {
job.Stop();
return response.status(500).json({ error: three_d.message });
}
body.three_d = three_d;
}
job.Stop();
return response.json(body);
});
module.exports = app;