mirror of
https://github.com/gamedig/node-gamedig.git
synced 2024-09-28 21:31:29 +02:00
Clean up imports to make Intellij code analysis happy
This commit is contained in:
parent
68ee06ef11
commit
a054557f10
@ -1,4 +1,5 @@
|
|||||||
class HexUtil {
|
class HexUtil {
|
||||||
|
/** @param {Buffer} buffer */
|
||||||
static debugDump(buffer) {
|
static debugDump(buffer) {
|
||||||
let hexLine = '';
|
let hexLine = '';
|
||||||
let chrLine = '';
|
let chrLine = '';
|
||||||
|
@ -101,5 +101,7 @@ class Gamedig {
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
Gamedig.debug = false;
|
||||||
|
Gamedig.isCommandLine = false;
|
||||||
|
|
||||||
module.exports = Gamedig;
|
module.exports = Gamedig;
|
||||||
|
@ -126,6 +126,7 @@ class Reader {
|
|||||||
return r;
|
return r;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/** @returns Buffer */
|
||||||
part(bytes) {
|
part(bytes) {
|
||||||
let r;
|
let r;
|
||||||
if(this.remaining() >= bytes) {
|
if(this.remaining() >= bytes) {
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class AmericasArmy extends require('./gamespy2') {
|
const Gamespy2 = require('./gamespy2');
|
||||||
|
|
||||||
|
class AmericasArmy extends Gamespy2 {
|
||||||
finalizeState(state) {
|
finalizeState(state) {
|
||||||
super.finalizeState(state);
|
super.finalizeState(state);
|
||||||
state.name = this.stripColor(state.name);
|
state.name = this.stripColor(state.name);
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Armagetron extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class Armagetron extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.encoding = 'latin1';
|
this.encoding = 'latin1';
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Ase extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class Ase extends Core {
|
||||||
run(state) {
|
run(state) {
|
||||||
this.udpSend('s',(buffer) => {
|
this.udpSend('s',(buffer) => {
|
||||||
const reader = this.reader(buffer);
|
const reader = this.reader(buffer);
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const async = require('async');
|
const async = require('async'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Battlefield extends require('./core') {
|
class Battlefield extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.encoding = 'latin1';
|
this.encoding = 'latin1';
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const request = require('request');
|
const request = require('request'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class BuildAndShoot extends require('./core') {
|
class BuildAndShoot extends Core {
|
||||||
run(state) {
|
run(state) {
|
||||||
request({
|
request({
|
||||||
uri: 'http://'+this.options.address+':'+this.options.port_query+'/',
|
uri: 'http://'+this.options.address+':'+this.options.port_query+'/',
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Doom3 extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class Doom3 extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.pretty = 'Doom 3';
|
this.pretty = 'Doom 3';
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Ffow extends require('./valve') {
|
const Valve = require('./valve');
|
||||||
|
|
||||||
|
class Ffow extends Valve {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.byteorder = 'be';
|
this.byteorder = 'be';
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const request = require('request');
|
const request = require('request'),
|
||||||
|
Quake2 = require('./quake2');
|
||||||
|
|
||||||
class FiveM extends require('./quake2') {
|
class FiveM extends Quake2 {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.sendHeader = 'getinfo xxx';
|
this.sendHeader = 'getinfo xxx';
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const async = require('async');
|
const async = require('async'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Gamespy1 extends require('./core') {
|
class Gamespy1 extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.sessionId = 1;
|
this.sessionId = 1;
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Gamespy2 extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class Gamespy2 extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.sessionId = 1;
|
this.sessionId = 1;
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const async = require('async');
|
const async = require('async'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Gamespy3 extends require('./core') {
|
class Gamespy3 extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.sessionId = 1;
|
this.sessionId = 1;
|
||||||
@ -12,7 +13,10 @@ class Gamespy3 extends require('./core') {
|
|||||||
}
|
}
|
||||||
|
|
||||||
run(state) {
|
run(state) {
|
||||||
let challenge,packets;
|
let challenge;
|
||||||
|
|
||||||
|
/** @type Buffer[] */
|
||||||
|
let packets;
|
||||||
|
|
||||||
async.series([
|
async.series([
|
||||||
(c) => {
|
(c) => {
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const request = require('request');
|
const request = require('request'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class GeneShift extends require('./core') {
|
class GeneShift extends Core {
|
||||||
run(state) {
|
run(state) {
|
||||||
request({
|
request({
|
||||||
uri: 'http://geneshift.net/game/receiveLobby.php',
|
uri: 'http://geneshift.net/game/receiveLobby.php',
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Hexen2 extends require('./quake1') {
|
const Quake1 = require('./quake1');
|
||||||
|
|
||||||
|
class Hexen2 extends Quake1 {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.sendHeader = '\xFFstatus\x0a';
|
this.sendHeader = '\xFFstatus\x0a';
|
||||||
|
@ -1,6 +1,8 @@
|
|||||||
|
const Gamespy3 = require('./gamespy3');
|
||||||
|
|
||||||
// supposedly, gamespy3 is the "official" query protocol for jcmp,
|
// supposedly, gamespy3 is the "official" query protocol for jcmp,
|
||||||
// but it's broken (requires useOnlySingleSplit), and doesn't include player names
|
// but it's broken (requires useOnlySingleSplit), and doesn't include player names
|
||||||
class Jc2mp extends require('./gamespy3') {
|
class Jc2mp extends Gamespy3 {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.useOnlySingleSplit = true;
|
this.useOnlySingleSplit = true;
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class KillingFloor extends require('./unreal2') {
|
const Unreal2 = require('./unreal2');
|
||||||
|
|
||||||
|
class KillingFloor extends Unreal2 {
|
||||||
readExtraInfo(reader,state) {
|
readExtraInfo(reader,state) {
|
||||||
state.raw.wavecurrent = reader.uint(4);
|
state.raw.wavecurrent = reader.uint(4);
|
||||||
state.raw.wavetotal = reader.uint(4);
|
state.raw.wavetotal = reader.uint(4);
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const request = require('request');
|
const request = require('request'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Kspdmp extends require('./core') {
|
class Kspdmp extends Core {
|
||||||
run(state) {
|
run(state) {
|
||||||
request({
|
request({
|
||||||
uri: 'http://'+this.options.address+':'+this.options.port_query,
|
uri: 'http://'+this.options.address+':'+this.options.port_query,
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class M2mp extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class M2mp extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.encoding = 'latin1';
|
this.encoding = 'latin1';
|
||||||
|
@ -1,5 +1,6 @@
|
|||||||
const varint = require('varint'),
|
const varint = require('varint'),
|
||||||
async = require('async');
|
async = require('async'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
function varIntBuffer(num) {
|
function varIntBuffer(num) {
|
||||||
return Buffer.from(varint.encode(num));
|
return Buffer.from(varint.encode(num));
|
||||||
@ -14,8 +15,9 @@ function buildPacket(id,data) {
|
|||||||
]);
|
]);
|
||||||
}
|
}
|
||||||
|
|
||||||
class Minecraft extends require('./core') {
|
class Minecraft extends Core {
|
||||||
run(state) {
|
run(state) {
|
||||||
|
/** @type Buffer */
|
||||||
let receivedData;
|
let receivedData;
|
||||||
|
|
||||||
async.series([
|
async.series([
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Mumble extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class Mumble extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.options.socketTimeout = 5000;
|
this.options.socketTimeout = 5000;
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class MumblePing extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class MumblePing extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.byteorder = 'be';
|
this.byteorder = 'be';
|
||||||
|
@ -1,7 +1,8 @@
|
|||||||
const gbxremote = require('gbxremote'),
|
const gbxremote = require('gbxremote'),
|
||||||
async = require('async');
|
async = require('async'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Nadeo extends require('./core') {
|
class Nadeo extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.options.port = 2350;
|
this.options.port = 2350;
|
||||||
|
@ -1,7 +1,8 @@
|
|||||||
const async = require('async'),
|
const async = require('async'),
|
||||||
moment = require('moment');
|
moment = require('moment'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class OpenTtd extends require('./core') {
|
class OpenTtd extends Core {
|
||||||
run(state) {
|
run(state) {
|
||||||
async.series([
|
async.series([
|
||||||
(c) => {
|
(c) => {
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Quake1 extends require('./quake2') {
|
const Quake2 = require('./quake2');
|
||||||
|
|
||||||
|
class Quake1 extends Quake2 {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.responseHeader = 'n';
|
this.responseHeader = 'n';
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Quake2 extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class Quake2 extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.encoding = 'latin1';
|
this.encoding = 'latin1';
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Quake3 extends require('./quake2') {
|
const Quake2 = require('./quake2');
|
||||||
|
|
||||||
|
class Quake3 extends Quake2 {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.sendHeader = 'getstatus';
|
this.sendHeader = 'getstatus';
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Starmade extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class Starmade extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.encoding = 'latin1';
|
this.encoding = 'latin1';
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const async = require('async');
|
const async = require('async'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Teamspeak2 extends require('./core') {
|
class Teamspeak2 extends Core {
|
||||||
run(state) {
|
run(state) {
|
||||||
async.series([
|
async.series([
|
||||||
(c) => {
|
(c) => {
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const async = require('async');
|
const async = require('async'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Teamspeak3 extends require('./core') {
|
class Teamspeak3 extends Core {
|
||||||
run(state) {
|
run(state) {
|
||||||
async.series([
|
async.series([
|
||||||
(c) => {
|
(c) => {
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const request = require('request');
|
const request = require('request'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Terraria extends require('./core') {
|
class Terraria extends Core {
|
||||||
run(state) {
|
run(state) {
|
||||||
request({
|
request({
|
||||||
uri: 'http://'+this.options.address+':'+this.options.port_query+'/v2/server/status',
|
uri: 'http://'+this.options.address+':'+this.options.port_query+'/v2/server/status',
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Tribes1 extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class Tribes1 extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.encoding = 'latin1';
|
this.encoding = 'latin1';
|
||||||
|
@ -1,6 +1,8 @@
|
|||||||
|
const Core = require('./core');
|
||||||
|
|
||||||
/** Unsupported -- use at your own risk!! */
|
/** Unsupported -- use at your own risk!! */
|
||||||
|
|
||||||
class Tribes1Master extends require('./core') {
|
class Tribes1Master extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.encoding = 'latin1';
|
this.encoding = 'latin1';
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
const async = require('async');
|
const async = require('async'),
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Unreal2 extends require('./core') {
|
class Unreal2 extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.encoding = 'latin1';
|
this.encoding = 'latin1';
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Ut2004 extends require('./unreal2') {
|
const Unreal2 = require('./unreal2');
|
||||||
|
|
||||||
|
class Ut2004 extends Unreal2 {
|
||||||
readExtraInfo(reader,state) {
|
readExtraInfo(reader,state) {
|
||||||
state.raw.ping = reader.uint(4);
|
state.raw.ping = reader.uint(4);
|
||||||
state.raw.flags = reader.uint(4);
|
state.raw.flags = reader.uint(4);
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Ut3 extends require('./gamespy3') {
|
const Gamespy3 = require('./gamespy3');
|
||||||
|
|
||||||
|
class Ut3 extends Gamespy3 {
|
||||||
finalizeState(state) {
|
finalizeState(state) {
|
||||||
super.finalizeState(state);
|
super.finalizeState(state);
|
||||||
|
|
||||||
|
@ -1,7 +1,8 @@
|
|||||||
const async = require('async'),
|
const async = require('async'),
|
||||||
Bzip2 = require('compressjs').Bzip2;
|
Bzip2 = require('compressjs').Bzip2,
|
||||||
|
Core = require('./core');
|
||||||
|
|
||||||
class Valve extends require('./core') {
|
class Valve extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
|
|
||||||
@ -128,7 +129,7 @@ class Valve extends require('./core') {
|
|||||||
|
|
||||||
queryChallenge(state,c) {
|
queryChallenge(state,c) {
|
||||||
if(this.legacyChallenge) {
|
if(this.legacyChallenge) {
|
||||||
this.sendPacket(0x57,false,false,0x41,(b) => {
|
this.sendPacket(0x57,false,null,0x41,(b) => {
|
||||||
// sendPacket will catch the response packet and
|
// sendPacket will catch the response packet and
|
||||||
// save the challenge for us
|
// save the challenge for us
|
||||||
c();
|
c();
|
||||||
@ -140,7 +141,7 @@ class Valve extends require('./core') {
|
|||||||
|
|
||||||
queryPlayers(state,c) {
|
queryPlayers(state,c) {
|
||||||
state.raw.players = [];
|
state.raw.players = [];
|
||||||
this.sendPacket(0x55,true,false,0x44,(b) => {
|
this.sendPacket(0x55,true,null,0x44,(b) => {
|
||||||
const reader = this.reader(b);
|
const reader = this.reader(b);
|
||||||
const num = reader.uint(1);
|
const num = reader.uint(1);
|
||||||
for(let i = 0; i < num; i++) {
|
for(let i = 0; i < num; i++) {
|
||||||
@ -175,7 +176,7 @@ class Valve extends require('./core') {
|
|||||||
|
|
||||||
queryRules(state,c) {
|
queryRules(state,c) {
|
||||||
state.raw.rules = {};
|
state.raw.rules = {};
|
||||||
this.sendPacket(0x56,true,false,0x45,(b) => {
|
this.sendPacket(0x56,true,null,0x45,(b) => {
|
||||||
const reader = this.reader(b);
|
const reader = this.reader(b);
|
||||||
const num = reader.uint(2);
|
const num = reader.uint(2);
|
||||||
for(let i = 0; i < num; i++) {
|
for(let i = 0; i < num; i++) {
|
||||||
@ -237,7 +238,22 @@ class Valve extends require('./core') {
|
|||||||
c();
|
c();
|
||||||
}
|
}
|
||||||
|
|
||||||
sendPacket(type,sendChallenge,payload,expect,callback,ontimeout) {
|
/**
|
||||||
|
* @param {number} type
|
||||||
|
* @param {boolean} sendChallenge
|
||||||
|
* @param {?string|Buffer} payload
|
||||||
|
* @param {number} expect
|
||||||
|
* @param {function(Buffer)} callback
|
||||||
|
* @param {(function():boolean)=} ontimeout
|
||||||
|
**/
|
||||||
|
sendPacket(
|
||||||
|
type,
|
||||||
|
sendChallenge,
|
||||||
|
payload,
|
||||||
|
expect,
|
||||||
|
callback,
|
||||||
|
ontimeout
|
||||||
|
) {
|
||||||
const packetStorage = {};
|
const packetStorage = {};
|
||||||
|
|
||||||
const receivedFull = (reader) => {
|
const receivedFull = (reader) => {
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Ventrilo extends require('./core') {
|
const Core = require('./core');
|
||||||
|
|
||||||
|
class Ventrilo extends Core {
|
||||||
constructor() {
|
constructor() {
|
||||||
super();
|
super();
|
||||||
this.byteorder = 'be';
|
this.byteorder = 'be';
|
||||||
|
@ -1,4 +1,6 @@
|
|||||||
class Warsow extends require('./quake3') {
|
const Quake3 = require('./quake3');
|
||||||
|
|
||||||
|
class Warsow extends Quake3 {
|
||||||
finalizeState(state) {
|
finalizeState(state) {
|
||||||
super.finalizeState(state);
|
super.finalizeState(state);
|
||||||
if(state.players) {
|
if(state.players) {
|
||||||
|
Loading…
Reference in New Issue
Block a user