Autofix all files for the game server

This commit is contained in:
Telokis
2023-10-28 16:23:57 +02:00
parent 5fea13946a
commit 8099f31e4c
8 changed files with 18788 additions and 12956 deletions
+1 -1
View File
@@ -10,6 +10,7 @@
"rules": { "rules": {
"no-constant-condition": "off", "no-constant-condition": "off",
"no-dupe-else-if": "off", "no-dupe-else-if": "off",
"indent": "off",
"no-empty": "warn", "no-empty": "warn",
"no-inner-declarations": "warn", "no-inner-declarations": "warn",
"no-unreachable": "warn", "no-unreachable": "warn",
@@ -17,7 +18,6 @@
"no-unused-vars": "warn", "no-unused-vars": "warn",
"no-redeclare": "warn", "no-redeclare": "warn",
"curly": "error", "curly": "error",
"indent": ["error", 2],
"prettier/prettier": "error", "prettier/prettier": "error",
"one-var": ["error", "never"], "one-var": ["error", "never"],
"no-sequences": "error" "no-sequences": "error"
+33 -25
View File
@@ -1,27 +1,35 @@
var is_game=0,is_server=0,is_code=0; var is_game = 0;
var variables=require('./variables'); var is_server = 0;
var is_sdk=variables.is_sdk; var is_code = 0;
var fs=require('fs'); var variables = require("./variables");
var precomputed=null; var is_sdk = variables.is_sdk;
eval(""+fs.readFileSync(variables.cfunctions_path)); var fs = require("fs");
eval(""+fs.readFileSync(variables.functions_path)); var precomputed = null;
var mode={},server_id='precompute',server_auth="123456",base_url=variables.base_url; eval("" + fs.readFileSync(variables.cfunctions_path));
eval("" + fs.readFileSync(variables.functions_path));
var mode = {};
var server_id = "precompute";
var server_auth = "123456";
var base_url = variables.base_url;
appengine_call("reload_server",{keyword:variables.keyword},function(result){ appengine_call("reload_server", { keyword: variables.keyword }, function (result) {
if(result.failed) return; if (result.failed) {
G=result.game; return;
var start=new Date(); }
for(var mname in G.maps) G = result.game;
{ var start = new Date();
if(G.maps[mname].ignore) continue; for (var mname in G.maps) {
var cstart=new Date(); if (G.maps[mname].ignore) {
server_bfs(mname); continue;
console.log("Precomputed: "+mname+" in "+mssince(cstart)+"ms"); }
} var cstart = new Date();
console.log("Done: "+mssince(start)+"ms"); server_bfs(mname);
var precomputed={}; console.log("Precomputed: " + mname + " in " + mssince(cstart) + "ms");
precomputed.version=G.version; }
precomputed.amap_data=amap_data; console.log("Done: " + mssince(start) + "ms");
precomputed.smap_data=smap_data; var precomputed = {};
fs.writeFileSync(variables.data_path,'var precomputed='+JSON.stringify(precomputed)+';'); precomputed.version = G.version;
precomputed.amap_data = amap_data;
precomputed.smap_data = smap_data;
fs.writeFileSync(variables.data_path, "var precomputed=" + JSON.stringify(precomputed) + ";");
}); });
+13583 -9245
View File
File diff suppressed because it is too large Load Diff
+4958 -3503
View File
File diff suppressed because it is too large Load Diff
+25 -20
View File
@@ -1,23 +1,28 @@
var is_game=0,is_server=1,is_code=0; var is_game = 0;
var variables=require('./variables'); var is_server = 1;
var is_sdk=variables.is_sdk; var is_code = 0;
var fs=require('fs'); var variables = require("./variables");
eval(""+fs.readFileSync(variables.cfunctions_path)); var is_sdk = variables.is_sdk;
eval(""+fs.readFileSync(variables.functions_path)); var fs = require("fs");
var {workerData,parentPort}=require('worker_threads'); eval("" + fs.readFileSync(variables.cfunctions_path));
var G=workerData.G,smap_data=workerData.smap_data,amap_data=workerData.amap_data; eval("" + fs.readFileSync(variables.functions_path));
var { workerData, parentPort } = require("worker_threads");
var G = workerData.G;
var smap_data = workerData.smap_data;
var amap_data = workerData.amap_data;
parentPort.on("message",function(data){ parentPort.on("message", function (data) {
try{ try {
//console.log(data); //console.log(data);
if(data.type=="fast_astar") if (data.type == "fast_astar") {
parentPort.postMessage({type:"monster_move",move:fast_astar(data),id:data.id,in:data.in}); parentPort.postMessage({ type: "monster_move", move: fast_astar(data), id: data.id, in: data.in });
if(data.type=="exit") process.exit(); }
}catch(e){ if (data.type == "exit") {
console.log(e); process.exit();
} }
} catch (e) {
console.log(e);
}
}); });
setInterval(function(){ setInterval(function () {}, 10);
},10);
+143 -117
View File
@@ -1,150 +1,176 @@
var crypto=require('crypto'); var crypto = require("crypto");
var protobuf=require('protobufjs'),ByteBuffer=require('bytebuffer'); var protobuf = require("protobufjs");
var ByteBuffer = require("bytebuffer");
function symmetricDecrypt(input, key, checkHmac) { function symmetricDecrypt(input, key, checkHmac) {
var aesIv = crypto.createDecipheriv('aes-256-ecb', key, ''); var aesIv = crypto.createDecipheriv("aes-256-ecb", key, "");
aesIv.setAutoPadding(false); aesIv.setAutoPadding(false);
aesIv.end(input.slice(0, 16)); aesIv.end(input.slice(0, 16));
var iv = aesIv.read(); var iv = aesIv.read();
var aesData = crypto.createDecipheriv('aes-256-cbc', key, iv); var aesData = crypto.createDecipheriv("aes-256-cbc", key, iv);
aesData.end(input.slice(16)); aesData.end(input.slice(16));
var plaintext = aesData.read(); var plaintext = aesData.read();
if (checkHmac) { if (checkHmac) {
// The last 3 bytes of the IV are a random value, and the remainder are a partial HMAC // The last 3 bytes of the IV are a random value, and the remainder are a partial HMAC
var remotePartialHmac = iv.slice(0, iv.length - 3); var remotePartialHmac = iv.slice(0, iv.length - 3);
var random = iv.slice(iv.length - 3, iv.length); var random = iv.slice(iv.length - 3, iv.length);
var hmac = crypto.createHmac("sha1", key.slice(0, 16)); var hmac = crypto.createHmac("sha1", key.slice(0, 16));
hmac.update(random); hmac.update(random);
hmac.update(plaintext); hmac.update(plaintext);
if (!remotePartialHmac.equals(hmac.digest().slice(0, remotePartialHmac.length))) { if (!remotePartialHmac.equals(hmac.digest().slice(0, remotePartialHmac.length))) {
throw new Error("Received invalid HMAC from remote host."); throw new Error("Received invalid HMAC from remote host.");
} }
} }
return plaintext; return plaintext;
}; }
function parseAppTicket(ticket) { function parseAppTicket(ticket) {
// https://github.com/SteamRE/SteamKit/blob/master/Resources/Structs/steam3_appticket.hsl // https://github.com/SteamRE/SteamKit/blob/master/Resources/Structs/steam3_appticket.hsl
console.log(ticket); console.log(ticket);
if (!ByteBuffer.isByteBuffer(ticket)) { if (!ByteBuffer.isByteBuffer(ticket)) {
ticket = ByteBuffer.wrap(ticket, ByteBuffer.LITTLE_ENDIAN); ticket = ByteBuffer.wrap(ticket, ByteBuffer.LITTLE_ENDIAN);
} }
let details = {}; let details = {};
try { try {
let initialLength = ticket.readUint32(); let initialLength = ticket.readUint32();
console.log(initialLength); console.log(initialLength);
if (initialLength == 20) { if (initialLength == 20) {
// This is a full appticket, with a GC token and session header (in addition to ownership ticket) // This is a full appticket, with a GC token and session header (in addition to ownership ticket)
details.authTicket = ticket.slice(ticket.offset - 4, ticket.offset - 4 + 52).toBuffer(); // this is the part that's passed back to Steam for validation details.authTicket = ticket.slice(ticket.offset - 4, ticket.offset - 4 + 52).toBuffer(); // this is the part that's passed back to Steam for validation
details.gcToken = ticket.readUint64().toString(); details.gcToken = ticket.readUint64().toString();
//details.steamID = new SteamID(ticket.readUint64().toString()); //details.steamID = new SteamID(ticket.readUint64().toString());
ticket.skip(8); // the SteamID gets read later on ticket.skip(8); // the SteamID gets read later on
details.tokenGenerated = new Date(ticket.readUint32() * 1000); details.tokenGenerated = new Date(ticket.readUint32() * 1000);
if (ticket.readUint32() != 24) { if (ticket.readUint32() != 24) {
// SESSIONHEADER should be 24 bytes. // SESSIONHEADER should be 24 bytes.
return null; return null;
} }
ticket.skip(8); // unknown 1 and unknown 2 ticket.skip(8); // unknown 1 and unknown 2
details.sessionExternalIP = Helpers.ipIntToString(ticket.readUint32()); details.sessionExternalIP = Helpers.ipIntToString(ticket.readUint32());
ticket.skip(4); // filler ticket.skip(4); // filler
details.clientConnectionTime = ticket.readUint32(); // time the client has been connected to Steam in ms details.clientConnectionTime = ticket.readUint32(); // time the client has been connected to Steam in ms
details.clientConnectionCount = ticket.readUint32(); // how many servers the client has connected to details.clientConnectionCount = ticket.readUint32(); // how many servers the client has connected to
if (ticket.readUint32() + ticket.offset != ticket.limit) { if (ticket.readUint32() + ticket.offset != ticket.limit) {
// OWNERSHIPSECTIONWITHSIGNATURE sectlength // OWNERSHIPSECTIONWITHSIGNATURE sectlength
return null; return null;
} }
} else { } else {
ticket.skip(-4); ticket.skip(-4);
} }
// Start reading the ownership ticket // Start reading the ownership ticket
let ownershipTicketOffset = ticket.offset; let ownershipTicketOffset = ticket.offset;
let ownershipTicketLength = ticket.readUint32(); // including itself, for some reason let ownershipTicketLength = ticket.readUint32(); // including itself, for some reason
if (ownershipTicketOffset + ownershipTicketLength != ticket.limit && ownershipTicketOffset + ownershipTicketLength + 128 != ticket.limit) { if (
return null; ownershipTicketOffset + ownershipTicketLength != ticket.limit &&
} ownershipTicketOffset + ownershipTicketLength + 128 != ticket.limit
) {
return null;
}
let i, j, dlc; let i;
let j;
let dlc;
details.version = ticket.readUint32(); details.version = ticket.readUint32();
details.steamID = ticket.readUint64().toString(); details.steamID = ticket.readUint64().toString();
details.appID = ticket.readUint32(); details.appID = ticket.readUint32();
details.ownershipTicketExternalIP = ticket.readUint32(); details.ownershipTicketExternalIP = ticket.readUint32();
details.ownershipTicketInternalIP = ticket.readUint32(); // Helpers.ipIntToString( details.ownershipTicketInternalIP = ticket.readUint32(); // Helpers.ipIntToString(
details.ownershipFlags = ticket.readUint32(); details.ownershipFlags = ticket.readUint32();
details.ownershipTicketGenerated = new Date(ticket.readUint32() * 1000); details.ownershipTicketGenerated = new Date(ticket.readUint32() * 1000);
details.ownershipTicketExpires = new Date(ticket.readUint32() * 1000); details.ownershipTicketExpires = new Date(ticket.readUint32() * 1000);
details.licenses = []; details.licenses = [];
// return details; // return details;
let licenseCount = ticket.readUint16(); let licenseCount = ticket.readUint16();
for (i = 0; i < licenseCount; i++) { for (i = 0; i < licenseCount; i++) {
details.licenses.push(ticket.readUint32()); details.licenses.push(ticket.readUint32());
} }
details.dlc = []; details.dlc = [];
let dlcCount = ticket.readUint16(); let dlcCount = ticket.readUint16();
for (i = 0; i < dlcCount; i++) { for (i = 0; i < dlcCount; i++) {
dlc = {}; dlc = {};
dlc.appID = ticket.readUint32(); dlc.appID = ticket.readUint32();
dlc.licenses = []; dlc.licenses = [];
licenseCount = ticket.readUint16(); licenseCount = ticket.readUint16();
for (j = 0; j < licenseCount; j++) { for (j = 0; j < licenseCount; j++) {
dlc.licenses.push(ticket.readUint32()); dlc.licenses.push(ticket.readUint32());
} }
details.dlc.push(dlc); details.dlc.push(dlc);
} }
ticket.readUint16(); // reserved ticket.readUint16(); // reserved
if (ticket.offset + 128 == ticket.limit) { if (ticket.offset + 128 == ticket.limit) {
// Has signature // Has signature
details.signature = ticket.slice(ticket.offset, ticket.offset + 128).toBuffer(); details.signature = ticket.slice(ticket.offset, ticket.offset + 128).toBuffer();
} }
let date = new Date(); let date = new Date();
details.isExpired = details.ownershipTicketExpires < date; details.isExpired = details.ownershipTicketExpires < date;
details.hasValidSignature = !!details.signature && SteamCrypto.verifySignature(ticket.slice(ownershipTicketOffset, ownershipTicketOffset + ownershipTicketLength).toBuffer(), details.signature); details.hasValidSignature =
details.isValid = !details.isExpired && (!details.signature || details.hasValidSignature); !!details.signature &&
} catch (ex) { SteamCrypto.verifySignature(
console.log("parseAppTicket: "+ex); ticket.slice(ownershipTicketOffset, ownershipTicketOffset + ownershipTicketLength).toBuffer(),
return details; details.signature,
return null; // not a valid ticket );
} details.isValid = !details.isExpired && (!details.signature || details.hasValidSignature);
} catch (ex) {
console.log("parseAppTicket: " + ex);
return details;
return null; // not a valid ticket
}
return details; return details;
}
var proto = {
nested: {
EncryptedAppTicket: {
fields: {
ticketVersionNo: { type: "uint32", id: 1 },
crcEncryptedticket: { type: "uint32", id: 2 },
cbEncrypteduserdata: { type: "uint32", id: 3 },
cbEncryptedAppownershipticket: { type: "uint32", id: 4 },
encryptedTicket: { type: "bytes", id: 5 },
},
},
},
}; };
var proto_root = protobuf.Root.fromJSON(proto);
var EncryptedAppTicket = proto_root.lookupType("EncryptedAppTicket");
var proto={ "nested": {EncryptedAppTicket: { fields: var outer = EncryptedAppTicket.decode(
{ ticketVersionNo: { type: 'uint32', id: 1 }, new Buffer(
crcEncryptedticket: { type: 'uint32', id: 2 }, "080110a7e59890031815204f2a80014527ad8cccd8cd9b7d3260529556004ddf0454a1c2e8543495b1eb72b3dff44d9d67555798ef44b7e3f97cf86d3bf1bc3f84a91de415c382b0d96033c8e5398f2b775bcb004f5487c651d81ef410d7d2917cbb407713397d2c29a455b6852eac7db1a0e52248585bd5440ef07de54b7519f67eefbad5420d97b77ef7e35450af",
cbEncrypteduserdata: { type: 'uint32', id: 3 }, "hex",
cbEncryptedAppownershipticket: { type: 'uint32', id: 4 }, ),
encryptedTicket: { type: 'bytes', id: 5 } } }}}; );
var proto_root=protobuf.Root.fromJSON(proto); var decrypted = symmetricDecrypt(
var EncryptedAppTicket=proto_root.lookupType("EncryptedAppTicket"); outer.encryptedTicket,
new Buffer("8af5c487af6c7709ef1a4e6e2275fcc0a90f57ae4319de793fca3d7ed8655520", "hex"),
);
var outer=EncryptedAppTicket.decode(new Buffer("080110a7e59890031815204f2a80014527ad8cccd8cd9b7d3260529556004ddf0454a1c2e8543495b1eb72b3dff44d9d67555798ef44b7e3f97cf86d3bf1bc3f84a91de415c382b0d96033c8e5398f2b775bcb004f5487c651d81ef410d7d2917cbb407713397d2c29a455b6852eac7db1a0e52248585bd5440ef07de54b7519f67eefbad5420d97b77ef7e35450af","hex"));
var decrypted=symmetricDecrypt(outer.encryptedTicket,new Buffer("8af5c487af6c7709ef1a4e6e2275fcc0a90f57ae4319de793fca3d7ed8655520","hex"));
let userData = decrypted.slice(0, outer.cbEncrypteduserdata); let userData = decrypted.slice(0, outer.cbEncrypteduserdata);
let ownershipTicketLength = decrypted.readUInt32LE(outer.cbEncrypteduserdata); let ownershipTicketLength = decrypted.readUInt32LE(outer.cbEncrypteduserdata);
let ownershipTicket = parseAppTicket(decrypted.slice(outer.cbEncrypteduserdata, outer.cbEncrypteduserdata + ownershipTicketLength)); let ownershipTicket = parseAppTicket(
decrypted.slice(outer.cbEncrypteduserdata, outer.cbEncrypteduserdata + ownershipTicketLength),
);
if (ownershipTicket) { if (ownershipTicket) {
ownershipTicket.userData = userData.toString(); ownershipTicket.userData = userData.toString();
} }
console.log(ownershipTicket); console.log(ownershipTicket);
+18 -18
View File
@@ -1,18 +1,18 @@
module.exports={ module.exports = {
"cfunctions_path":"./server/common_functions.js", cfunctions_path: "./server/common_functions.js",
"functions_path":"./server/server_functions.js", functions_path: "./server/server_functions.js",
"worker_path":"./server/server_worker.js", worker_path: "./server/server_worker.js",
"data_path":"./server/data.js", data_path: "./server/data.js",
"base_url":"https://yourappspoturldontincludedashes.appspot.com", base_url: "https://yourappspoturldontincludedashes.appspot.com",
"keyword":"123", keyword: "123",
"access_master":"123", access_master: "123",
"bot_key":"123", bot_key: "123",
"discord_token":"NDXXXXXXXXXXX...", discord_token: "NDXXXXXXXXXXX...",
"apple_token":"acXXXXXXXX...", apple_token: "acXXXXXXXX...",
"steam_key":"8aXXXXXXXXX...", steam_key: "8aXXXXXXXXX...",
"steam_web_key":"B4XXXXXXX...", steam_web_key: "B4XXXXXXX...",
"steam_partner_key":"F9XXXXXXX...", steam_partner_key: "F9XXXXXXX...",
"close_timeout":24000, close_timeout: 24000,
"ip_limit":3, ip_limit: 3,
"character_limit":3, character_limit: 3,
} };
+21 -21
View File
@@ -1,22 +1,22 @@
const path = require("node:path") const path = require("node:path");
module.exports={ module.exports = {
"cfunctions_path":path.resolve(__dirname, "../js/common_functions.js"), cfunctions_path: path.resolve(__dirname, "../js/common_functions.js"),
"functions_path":path.resolve(__dirname, "server_functions.js"), functions_path: path.resolve(__dirname, "server_functions.js"),
"worker_path":path.resolve(__dirname, "server_worker.js"), worker_path: path.resolve(__dirname, "server_worker.js"),
"data_path":path.resolve(__dirname, "data.js"), data_path: path.resolve(__dirname, "data.js"),
"base_url":"http://thegame.com", base_url: "http://thegame.com",
"keyword":"123", keyword: "123",
"access_master":"123", access_master: "123",
"bot_key":"123", bot_key: "123",
"discord_token":"NDXXXXXXXXXXX...", discord_token: "NDXXXXXXXXXXX...",
"apple_token":"acXXXXXXXX...", apple_token: "acXXXXXXXX...",
"steam_key":"8aXXXXXXXXX...", steam_key: "8aXXXXXXXXX...",
"steam_web_key":"B4XXXXXXX...", steam_web_key: "B4XXXXXXX...",
"steam_partner_key":"F9XXXXXXX...", steam_partner_key: "F9XXXXXXX...",
"is_sdk":1, is_sdk: 1,
"close_timeout":4000, close_timeout: 4000,
"ip_limit":3, ip_limit: 3,
"character_limit":3, character_limit: 3,
"fast_sdk":0, fast_sdk: 0,
} };