mirror of
https://github.com/gamedig/node-gamedig.git
synced 2024-10-07 01:13:52 +02:00
ad9adff06c
* Redo imports and exports for lib * Redo imports and exports for bim * Redo imports and exports for games * Remove remaining module.exports * Use export default in lib * Use export default in protocols * Fix import in genreadme.js * Make package module and solve __dirname * Fix minecraft protocol imports * Fix imports on games and make binary runnable * Renamed protocol class exports to lowercase * Export promises class as default * Update README.md to use imports instead of require * Update CHANGELOG to mention the changes. * Remove Valve unused imports * Fix iconv import
86 lines
3.1 KiB
JavaScript
86 lines
3.1 KiB
JavaScript
import Core from './core.js';
|
|
import Promises from "../lib/Promises.js";
|
|
import * as gbxremote from 'gbxremote';
|
|
|
|
export default class nadeo extends Core {
|
|
async run(state) {
|
|
await this.withClient(async client => {
|
|
const start = Date.now();
|
|
await this.query(client, 'Authenticate', this.options.login, this.options.password);
|
|
this.registerRtt(Date.now()-start);
|
|
|
|
//const data = this.methodCall(client, 'GetStatus');
|
|
|
|
{
|
|
const results = await this.query(client, 'GetServerOptions');
|
|
state.name = this.stripColors(results.Name);
|
|
state.password = (results.Password !== 'No password');
|
|
state.maxplayers = results.CurrentMaxPlayers;
|
|
state.raw.maxspectators = results.CurrentMaxSpectators;
|
|
}
|
|
|
|
{
|
|
const results = await this.query(client, 'GetCurrentMapInfo');
|
|
state.map = this.stripColors(results.Name);
|
|
state.raw.mapUid = results.UId;
|
|
}
|
|
|
|
{
|
|
const results = await this.query(client, 'GetCurrentGameInfo');
|
|
let gamemode = '';
|
|
const igm = results.GameMode;
|
|
if(igm === 0) gamemode="Rounds";
|
|
if(igm === 1) gamemode="Time Attack";
|
|
if(igm === 2) gamemode="Team";
|
|
if(igm === 3) gamemode="Laps";
|
|
if(igm === 4) gamemode="Stunts";
|
|
if(igm === 5) gamemode="Cup";
|
|
state.raw.gametype = gamemode;
|
|
state.raw.mapcount = results.NbChallenge;
|
|
}
|
|
|
|
{
|
|
const results = await this.query(client, 'GetNextMapInfo');
|
|
state.raw.nextmapName = this.stripColors(results.Name);
|
|
state.raw.nextmapUid = results.UId;
|
|
}
|
|
|
|
if (this.options.port === 5000) {
|
|
state.gamePort = 2350;
|
|
}
|
|
|
|
state.raw.players = await this.query(client, 'GetPlayerList', 10000, 0);
|
|
for (const player of state.raw.players) {
|
|
state.players.push({
|
|
name:this.stripColors(player.Name || player.NickName)
|
|
});
|
|
}
|
|
});
|
|
}
|
|
|
|
async withClient(fn) {
|
|
const socket = new gbxremote.Client(this.options.port, this.options.host);
|
|
try {
|
|
const connectPromise = socket.connect();
|
|
const timeoutPromise = Promises.createTimeout(this.options.socketTimeout, 'GBX Remote Opening');
|
|
await Promise.race([connectPromise, timeoutPromise, this.abortedPromise]);
|
|
return await fn(socket);
|
|
} finally {
|
|
socket.terminate();
|
|
}
|
|
}
|
|
|
|
async query(client, ...cmdset) {
|
|
const cmd = cmdset[0];
|
|
const params = cmdset.slice(1);
|
|
|
|
const sentPromise = client.query(cmd, params);
|
|
const timeoutPromise = Promises.createTimeout(this.options.socketTimeout, 'GBX Method Call');
|
|
return await Promise.race([sentPromise, timeoutPromise, this.abortedPromise]);
|
|
}
|
|
|
|
stripColors(str) {
|
|
return str.replace(/\$([0-9a-f]{3}|[a-z])/gi,'');
|
|
}
|
|
}
|