AsgardEternal/SquadJSDocker
1
0
Fork 0
mirror of https://github.com/AsgardEternal/SquadJSDocker.git synced 2024-12-30 14:09:18 -06:00
Code Issues Packages Projects Releases Wiki Activity

add database repair for playertimes table

Browse Source
This commit is contained in:
Skillet 2023-03-01 13:32:18 -05:00 committed by GitHub
parent 1e7a41a950
commit 4f0612fab7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 46 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

69
squadjsPlugins/db-log-addOn.js
View File

@ -74,42 +74,65 @@ export default class DBLogPlayerTime extends DBLog {
async prepareToMount() {
await super.prepareToMount();
await this.models.PlayerTime.sync();
await this.models.PlayerTime.sync();
}
async mount() {
await super.mount();
this.server.on('PLAYER_CONNECTED', this.onPlayerConnected);
this.server.on('PLAYER_DISCONNECTED', this.onPlayerDisconnected);
this.server.on('PLAYER_CONNECTED', this.onPlayerConnected);
this.server.on('PLAYER_DISCONNECTED', this.onPlayerDisconnected);
}
async repairDB() {
await super.repairDB();
let lastTickTime = this.models.TickRate.findOne(
{ where: { server: this.options.overrideServerID || this.server.id},
order: [['id', 'DESC']]}
);
let lastServerTime = lastTickTime.time;
let playerOnlineID = [];
for (player of this.players){
playerOnlineID.push(player.steamID);
}
const {not} = Sequelize.Op;
this.models.PlayerTime.update(
{ leaveTime: lastServerTime },
{ where: {
leaveTime: null,
server: this.options.overrideServerID || this.server.id,
[not]: [{player: playerOnlineID}]
} }
);
}
async unmount() {
this.models.PlayerTime.update(
{ leaveTime: 0 },
{ where: { leaveTime: null , server: this.options.overrideServerID || this.server.id } }
);
this.models.PlayerTime.update(
{ leaveTime: 0 },
{ where: { leaveTime: null , server: this.options.overrideServerID || this.server.id } }
);
await super.unmount();
this.server.removeEventListener('PLAYER_CONNECTED', this.onPlayerConnected);
this.server.removeEventListener('PLAYER_DISCONNECTED', this.onPlayerDisconnected);
this.server.removeEventListener('PLAYER_CONNECTED', this.onPlayerConnected);
this.server.removeEventListener('PLAYER_DISCONNECTED', this.onPlayerDisconnected);
}
async onUpdatedA2SInformation(info) {
await super.onUpdatedA2SInformation(info);
if((this.seeding == true) && (info.a2sPlayerCount >= this.options.seedingThreshold)){
console.log('switching to Live');
this.seeding = false;
let curDateTime = new Date();
let timeNow = curDateTime.getFullYear() + '-' + (curDateTime.getMonth() + 1) + '-' + curDateTime.getDate()+' '+curDateTime.getHours()+':'+curDateTime.getMinutes()+':'+curDateTime.getSeconds();
console.log(timeNow);
await this.models.PlayerTime.update(
{ seedTime: timeNow },
{ where: { seedTime: null, joinedSeeding: 1, leaveTime: null, server: this.options.overrideServerID || this.server.id } }
);
}else if(this.seeding == false && (info.a2sPlayerCount-20) < this.options.seedingThreshold){
console.log('switching to seeding');
this.seeding = true;
}
if((this.seeding == true) && (info.a2sPlayerCount >= this.options.seedingThreshold)){
console.log('switching to Live');
this.seeding = false;
let curDateTime = new Date();
let timeNow = curDateTime.getFullYear() + '-' + (curDateTime.getMonth() + 1) + '-' + curDateTime.getDate()+' '+curDateTime.getHours()+':'+curDateTime.getMinutes()+':'+curDateTime.getSeconds();
console.log(timeNow);
await this.models.PlayerTime.update(
{ seedTime: timeNow },
{ where: { seedTime: null, joinedSeeding: 1, leaveTime: null, server: this.options.overrideServerID || this.server.id } }
);
}else if(this.seeding == false && (info.a2sPlayerCount-20) < this.options.seedingThreshold){
console.log('switching to seeding');
this.seeding = true;
}
}
async onPlayerConnected(info) {