mirror of
https://github.com/smogon/pokemon-showdown.git
synced 2026-03-21 17:25:10 -05:00
`room.settings.autojoin` and `room.settings.staffAutojoin` are now merged. Staff autojoin rooms are now simply regular autojoin rooms with a modjoin setting. You simply autojoin all autojoin modjoin rooms that you're allowed to join. Fixes #7413
1812 lines
55 KiB
TypeScript
1812 lines
55 KiB
TypeScript
/**
|
|
* Rooms
|
|
* Pokemon Showdown - http://pokemonshowdown.com/
|
|
*
|
|
* Every chat room and battle is a room, and what they do is done in
|
|
* rooms.ts. There's also a global room which every user is in, and
|
|
* handles miscellaneous things like welcoming the user.
|
|
*
|
|
* `Rooms.rooms` is the global table of all rooms, a `Map` of `RoomID:Room`.
|
|
* Rooms should normally be accessed with `Rooms.get(roomid)`.
|
|
*
|
|
* All rooms extend `BasicRoom`, whose important properties like `.users`
|
|
* and `.game` are documented near the the top of its class definition.
|
|
*
|
|
* @license MIT
|
|
*/
|
|
|
|
const TIMEOUT_EMPTY_DEALLOCATE = 10 * 60 * 1000;
|
|
const TIMEOUT_INACTIVE_DEALLOCATE = 40 * 60 * 1000;
|
|
const REPORT_USER_STATS_INTERVAL = 10 * 60 * 1000;
|
|
const MAX_CHATROOM_ID_LENGTH = 225;
|
|
|
|
const CRASH_REPORT_THROTTLE = 60 * 60 * 1000;
|
|
|
|
const LAST_BATTLE_WRITE_THROTTLE = 10;
|
|
|
|
const RETRY_AFTER_LOGIN = null;
|
|
|
|
import {FS} from '../lib/fs';
|
|
import {Utils} from '../lib/utils';
|
|
import {WriteStream} from '../lib/streams';
|
|
import {GTSGiveaway, LotteryGiveaway, QuestionGiveaway} from './chat-plugins/wifi';
|
|
import {QueuedHunt} from './chat-plugins/scavengers';
|
|
import {ScavengerGameTemplate} from './chat-plugins/scavenger-games';
|
|
import {PM as RoomBattlePM, RoomBattle, RoomBattlePlayer, RoomBattleTimer} from "./room-battle";
|
|
import {RoomGame, RoomGamePlayer} from './room-game';
|
|
import {Roomlogs} from './roomlogs';
|
|
import * as crypto from 'crypto';
|
|
import {RoomAuth} from './user-groups';
|
|
|
|
/*********************************************************
|
|
* the Room object.
|
|
*********************************************************/
|
|
|
|
interface MuteEntry {
|
|
userid: ID;
|
|
time: number;
|
|
guestNum: number;
|
|
autoconfirmed: string;
|
|
}
|
|
|
|
interface ChatRoomTable {
|
|
title: string;
|
|
desc: string;
|
|
userCount: number;
|
|
subRooms?: string[];
|
|
}
|
|
|
|
interface ShowRequest {
|
|
name: string;
|
|
link: string;
|
|
comment: string;
|
|
dimensions?: [number, number, boolean];
|
|
}
|
|
|
|
interface BattleRoomTable {
|
|
p1?: string;
|
|
p2?: string;
|
|
minElo?: 'tour' | number;
|
|
}
|
|
|
|
interface UserTable {
|
|
[userid: string]: User;
|
|
}
|
|
|
|
export interface RoomSettings {
|
|
title: string;
|
|
auth: {[userid: string]: GroupSymbol};
|
|
creationTime: number;
|
|
|
|
readonly autojoin?: boolean;
|
|
aliases?: string[];
|
|
banwords?: string[];
|
|
isPrivate?: boolean | 'hidden' | 'voice';
|
|
modjoin?: AuthLevel | true | null;
|
|
modchat?: AuthLevel | null;
|
|
staffRoom?: boolean;
|
|
language?: string | false;
|
|
slowchat?: number | false;
|
|
events?: {[k: string]: RoomEvent | RoomEventAlias | RoomEventCategory};
|
|
filterStretching?: boolean;
|
|
filterEmojis?: boolean;
|
|
filterCaps?: boolean;
|
|
jeopardyDisabled?: boolean;
|
|
mafiaDisabled?: boolean;
|
|
unoDisabled?: boolean;
|
|
blackjackDisabled?: boolean;
|
|
hangmanDisabled?: boolean;
|
|
tourAnnouncements?: boolean;
|
|
gameNumber?: number;
|
|
highTraffic?: boolean;
|
|
isOfficial?: boolean;
|
|
pspl?: boolean;
|
|
parentid?: string | null;
|
|
desc?: string | null;
|
|
introMessage?: string | null;
|
|
staffMessage?: string | null;
|
|
rulesLink?: string | null;
|
|
dataCommandTierDisplay?: 'tiers' | 'doubles tiers' | 'numbers';
|
|
requestShowEnabled?: boolean | null;
|
|
showEnabled?: GroupSymbol | true;
|
|
permissions?: {[k: string]: GroupSymbol};
|
|
|
|
scavSettings?: AnyObject;
|
|
scavQueue?: QueuedHunt[];
|
|
|
|
// should not ever be saved because they're inapplicable to persistent rooms
|
|
/** This includes groupchats, battles, and help-ticket rooms. */
|
|
isPersonal?: boolean;
|
|
isHelp?: boolean;
|
|
noLogTimes?: boolean;
|
|
noAutoTruncate?: boolean;
|
|
isMultichannel?: boolean;
|
|
}
|
|
export type Room = GameRoom | ChatRoom;
|
|
import type {Poll} from './chat-plugins/poll';
|
|
import type {Announcement} from './chat-plugins/announcements';
|
|
import type {RoomEvent, RoomEventAlias, RoomEventCategory} from './chat-plugins/room-events';
|
|
import type {Tournament} from './tournaments/index';
|
|
|
|
export abstract class BasicRoom {
|
|
roomid: RoomID;
|
|
title: string;
|
|
readonly type: 'chat' | 'battle';
|
|
readonly users: UserTable;
|
|
/**
|
|
* Scrollback log. This is the log that's sent to users when
|
|
* joining the room. Should roughly match what's on everyone's
|
|
* screen.
|
|
*/
|
|
readonly log: Roomlog;
|
|
/**
|
|
* The room's current RoomGame, if it exists. Each room can have 0 to 2
|
|
* `RoomGame`s, and `this.game.room === this`.
|
|
* Rooms may also have an additional game in `this.subGame`.
|
|
* However, `subGame`s do not update `user.game`.
|
|
*/
|
|
game: RoomGame | null;
|
|
subGame: RoomGame | null;
|
|
/**
|
|
* The room's current battle. Battles are a type of RoomGame, so in battle
|
|
* rooms (which can only be `GameRoom`s), `this.battle === this.game`.
|
|
* In all other rooms, `this.battle` is `null`.
|
|
*/
|
|
battle: RoomBattle | null;
|
|
/**
|
|
* The game room's current tournament. If the room is a battle room whose
|
|
* battle is part of a tournament, `this.tour === this.parent.game`.
|
|
* In all other rooms, `this.tour` is `null`.
|
|
*/
|
|
tour: Tournament | null;
|
|
|
|
auth: RoomAuth;
|
|
parent: Room | null;
|
|
subRooms: Map<string, Room> | null;
|
|
|
|
readonly muteQueue: MuteEntry[];
|
|
userCount: number;
|
|
active: boolean;
|
|
muteTimer: NodeJS.Timer | null;
|
|
lastUpdate: number;
|
|
lastBroadcast: string;
|
|
lastBroadcastTime: number;
|
|
settings: RoomSettings;
|
|
/** If true, this room's settings will be saved in config/chatrooms.json, allowing it to stay past restarts. */
|
|
persist: boolean;
|
|
|
|
scavgame: ScavengerGameTemplate | null;
|
|
scavLeaderboard: AnyObject;
|
|
giveaway?: QuestionGiveaway | LotteryGiveaway | null;
|
|
gtsga?: GTSGiveaway | null;
|
|
privacySetter?: Set<ID> | null;
|
|
hideReplay: boolean;
|
|
|
|
reportJoins: boolean;
|
|
batchJoins: number;
|
|
reportJoinsInterval: NodeJS.Timer | null;
|
|
|
|
minorActivity: Poll | Announcement | null;
|
|
minorActivityQueue: Poll[] | null;
|
|
banwordRegex: RegExp | true | null;
|
|
logUserStatsInterval: NodeJS.Timer | null;
|
|
expireTimer: NodeJS.Timer | null;
|
|
userList: string;
|
|
pendingApprovals: Map<string, ShowRequest> | null;
|
|
|
|
constructor(roomid: RoomID, title?: string, options: Partial<RoomSettings> = {}) {
|
|
this.users = Object.create(null);
|
|
this.type = 'chat';
|
|
this.muteQueue = [];
|
|
|
|
this.battle = null;
|
|
this.game = null;
|
|
this.subGame = null;
|
|
this.tour = null;
|
|
|
|
this.roomid = roomid;
|
|
this.title = (title || roomid);
|
|
this.parent = null;
|
|
|
|
this.userCount = 0;
|
|
|
|
this.game = null;
|
|
this.active = false;
|
|
|
|
this.muteTimer = null;
|
|
|
|
this.lastUpdate = 0;
|
|
this.lastBroadcast = '';
|
|
this.lastBroadcastTime = 0;
|
|
|
|
// room settings
|
|
|
|
this.settings = {
|
|
title: this.title,
|
|
auth: Object.create(null),
|
|
creationTime: Date.now(),
|
|
};
|
|
this.persist = false;
|
|
this.hideReplay = false;
|
|
this.subRooms = null;
|
|
this.scavgame = null;
|
|
this.scavLeaderboard = {};
|
|
this.auth = new RoomAuth(this);
|
|
|
|
this.reportJoins = true;
|
|
this.batchJoins = 0;
|
|
this.reportJoinsInterval = null;
|
|
|
|
options.title = this.title;
|
|
if (options.isHelp) options.noAutoTruncate = true;
|
|
this.reportJoins = !!(Config.reportjoins || options.isPersonal);
|
|
this.batchJoins = options.isPersonal ? 0 : Config.reportjoinsperiod || 0;
|
|
if (!options.auth) options.auth = {};
|
|
|
|
this.log = Roomlogs.create(this, options);
|
|
|
|
this.banwordRegex = null;
|
|
|
|
this.settings = options as RoomSettings;
|
|
if (!this.settings.creationTime) this.settings.creationTime = Date.now();
|
|
this.auth.load();
|
|
|
|
if (!options.isPersonal) this.persist = true;
|
|
|
|
this.minorActivity = null;
|
|
this.minorActivityQueue = null;
|
|
if (options.parentid) {
|
|
const parent = Rooms.get(options.parentid);
|
|
|
|
if (parent) {
|
|
if (!parent.subRooms) parent.subRooms = new Map();
|
|
parent.subRooms.set(this.roomid, this as ChatRoom);
|
|
this.parent = parent;
|
|
}
|
|
}
|
|
|
|
this.subRooms = null;
|
|
|
|
this.active = false;
|
|
this.muteTimer = null;
|
|
|
|
this.logUserStatsInterval = null;
|
|
this.expireTimer = null;
|
|
if (Config.logchat) {
|
|
this.roomlog('NEW CHATROOM: ' + this.roomid);
|
|
if (Config.loguserstats) {
|
|
this.logUserStatsInterval = setInterval(() => this.logUserStats(), Config.loguserstats);
|
|
}
|
|
}
|
|
|
|
this.userList = '';
|
|
if (this.batchJoins) {
|
|
this.userList = this.getUserList();
|
|
}
|
|
this.pendingApprovals = null;
|
|
this.tour = null;
|
|
this.game = null;
|
|
this.battle = null;
|
|
this.validateTitle(this.title, this.roomid);
|
|
}
|
|
|
|
toString() {
|
|
return this.roomid;
|
|
}
|
|
|
|
/**
|
|
* Send a room message to all users in the room, without recording it
|
|
* in the scrollback log.
|
|
*/
|
|
send(message: string) {
|
|
if (this.roomid !== 'lobby') message = '>' + this.roomid + '\n' + message;
|
|
if (this.userCount) Sockets.roomBroadcast(this.roomid, message);
|
|
}
|
|
sendMods(data: string) {
|
|
this.sendRankedUsers(data, '%');
|
|
}
|
|
sendRankedUsers(data: string, minRank: GroupSymbol = '+') {
|
|
if (this.settings.staffRoom) {
|
|
if (!this.log) throw new Error(`Staff room ${this.roomid} has no log`);
|
|
this.log.add(data);
|
|
return;
|
|
}
|
|
|
|
for (const i in this.users) {
|
|
const user = this.users[i];
|
|
// hardcoded for performance reasons (this is an inner loop)
|
|
if (user.isStaff || this.auth.atLeast(user, minRank)) {
|
|
user.sendTo(this, data);
|
|
}
|
|
}
|
|
}
|
|
/**
|
|
* Send a room message to a single user.
|
|
*/
|
|
sendUser(user: User | Connection, message: string) {
|
|
user.sendTo(this, message);
|
|
}
|
|
/**
|
|
* Add a room message to the room log, so it shows up in the room
|
|
* for everyone, and appears in the scrollback for new users who
|
|
* join.
|
|
*/
|
|
add(message: string) {
|
|
this.log.add(message);
|
|
return this;
|
|
}
|
|
roomlog(message: string) {
|
|
this.log.roomlog(message);
|
|
return this;
|
|
}
|
|
modlog(message: string) {
|
|
const override = this.tour ? `${this.roomid} tournament: ${this.tour.roomid}` : undefined;
|
|
this.log.modlog(message, override);
|
|
return this;
|
|
}
|
|
uhtmlchange(name: string, message: string) {
|
|
this.log.uhtmlchange(name, message);
|
|
}
|
|
attributedUhtmlchange(user: User, name: string, message: string) {
|
|
this.log.attributedUhtmlchange(user, name, message);
|
|
}
|
|
hideText(userids: ID[], lineCount = 0, hideRevealButton?: boolean) {
|
|
const cleared = this.log.clearText(userids, lineCount);
|
|
for (const userid of cleared) {
|
|
this.send(`|hidelines|${hideRevealButton ? 'delete' : 'hide'}|${userid}|${lineCount}`);
|
|
}
|
|
this.update();
|
|
}
|
|
/**
|
|
* Inserts (sanitized) HTML into the room log.
|
|
*/
|
|
addRaw(message: string) {
|
|
return this.add('|raw|' + message);
|
|
}
|
|
/**
|
|
* Inserts some text into the room log, attributed to user. The
|
|
* attribution will not appear, and is used solely as a hint not to
|
|
* highlight the user.
|
|
*/
|
|
addByUser(user: User, text: string): this {
|
|
return this.add('|c|' + user.getIdentity(this.roomid) + '|/log ' + text);
|
|
}
|
|
/**
|
|
* Like addByUser, but without logging
|
|
*/
|
|
sendByUser(user: User | null, text: string) {
|
|
this.send('|c|' + (user ? user.getIdentity(this.roomid) : '&') + '|/log ' + text);
|
|
}
|
|
/**
|
|
* Like addByUser, but sends to mods only.
|
|
*/
|
|
sendModsByUser(user: User, text: string) {
|
|
this.sendMods('|c|' + user.getIdentity(this.roomid) + '|/log ' + text);
|
|
}
|
|
update() {
|
|
if (!this.log.broadcastBuffer.length) return;
|
|
if (this.reportJoinsInterval) {
|
|
clearInterval(this.reportJoinsInterval);
|
|
this.reportJoinsInterval = null;
|
|
this.userList = this.getUserList();
|
|
}
|
|
this.send(this.log.broadcastBuffer.join('\n'));
|
|
this.log.broadcastBuffer = [];
|
|
this.log.truncate();
|
|
|
|
this.pokeExpireTimer();
|
|
}
|
|
|
|
getUserList() {
|
|
let buffer = '';
|
|
let counter = 0;
|
|
for (const i in this.users) {
|
|
if (!this.users[i].named) {
|
|
continue;
|
|
}
|
|
counter++;
|
|
buffer += ',' + this.users[i].getIdentityWithStatus(this.roomid);
|
|
}
|
|
const msg = `|users|${counter}${buffer}`;
|
|
return msg;
|
|
}
|
|
|
|
nextGameNumber() {
|
|
const gameNumber = (this.settings.gameNumber || 0) + 1;
|
|
this.settings.gameNumber = gameNumber;
|
|
return gameNumber;
|
|
}
|
|
|
|
// mute handling
|
|
|
|
runMuteTimer(forceReschedule = false) {
|
|
if (forceReschedule && this.muteTimer) {
|
|
clearTimeout(this.muteTimer);
|
|
this.muteTimer = null;
|
|
}
|
|
if (this.muteTimer || this.muteQueue.length === 0) return;
|
|
|
|
const timeUntilExpire = this.muteQueue[0].time - Date.now();
|
|
if (timeUntilExpire <= 1000) { // one second of leeway
|
|
this.unmute(this.muteQueue[0].userid, "Your mute in '" + this.title + "' has expired.");
|
|
// runMuteTimer() is called again in unmute() so this function instance should be closed
|
|
return;
|
|
}
|
|
this.muteTimer = setTimeout(() => {
|
|
this.muteTimer = null;
|
|
this.runMuteTimer(true);
|
|
}, timeUntilExpire);
|
|
}
|
|
isMuted(user: User): ID | undefined {
|
|
if (!user) return;
|
|
if (this.muteQueue) {
|
|
for (const entry of this.muteQueue) {
|
|
if (user.id === entry.userid ||
|
|
user.guestNum === entry.guestNum ||
|
|
(user.autoconfirmed && user.autoconfirmed === entry.autoconfirmed)) {
|
|
if (entry.time - Date.now() < 0) {
|
|
this.unmute(user.id);
|
|
return;
|
|
} else {
|
|
return entry.userid;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (this.parent) return this.parent.isMuted(user);
|
|
}
|
|
getMuteTime(user: User): number | undefined {
|
|
const userid = this.isMuted(user);
|
|
if (!userid) return;
|
|
for (const entry of this.muteQueue) {
|
|
if (userid === entry.userid) {
|
|
return entry.time - Date.now();
|
|
}
|
|
}
|
|
if (this.parent) return this.parent.getMuteTime(user);
|
|
}
|
|
// I think putting the `new` before the signature is confusing the linter
|
|
// eslint-disable-next-line @typescript-eslint/type-annotation-spacing
|
|
getGame<T extends RoomGame>(constructor: new (...args: any[]) => T): T | null {
|
|
// TODO: switch to `static readonly gameid` when all game files are TypeScripted
|
|
if (this.game && this.game.constructor.name === constructor.name) return this.game as T;
|
|
return null;
|
|
}
|
|
saveSettings() {
|
|
if (!this.persist) return null;
|
|
Rooms.global.writeChatRoomData();
|
|
}
|
|
checkModjoin(user: User) {
|
|
if (user.id in this.users) return true;
|
|
if (!this.settings.modjoin) return true;
|
|
// users with a room rank can always join
|
|
if (this.auth.has(user.id)) return true;
|
|
|
|
const modjoinSetting = this.settings.modjoin !== true ? this.settings.modjoin : this.settings.modchat;
|
|
if (!modjoinSetting) return true;
|
|
if (!Users.Auth.isAuthLevel(modjoinSetting)) {
|
|
Monitor.error(`Invalid modjoin setting in ${this.roomid}: ${modjoinSetting}`);
|
|
}
|
|
return Users.globalAuth.atLeast(user, modjoinSetting);
|
|
}
|
|
mute(user: User, setTime?: number) {
|
|
const userid = user.id;
|
|
|
|
if (!setTime) setTime = 7 * 60000; // default time: 7 minutes
|
|
if (setTime > 90 * 60000) setTime = 90 * 60000; // limit 90 minutes
|
|
|
|
// If the user is already muted, the existing queue position for them should be removed
|
|
if (this.isMuted(user)) this.unmute(userid);
|
|
|
|
// Place the user in a queue for the unmute timer
|
|
for (let i = 0; i <= this.muteQueue.length; i++) {
|
|
const time = Date.now() + setTime;
|
|
if (i === this.muteQueue.length || time < this.muteQueue[i].time) {
|
|
const entry = {
|
|
userid,
|
|
time,
|
|
guestNum: user.guestNum,
|
|
autoconfirmed: user.autoconfirmed,
|
|
};
|
|
this.muteQueue.splice(i, 0, entry);
|
|
// The timer needs to be switched to the new entry if it is to be unmuted
|
|
// before the entry the timer is currently running for
|
|
if (i === 0 && this.muteTimer) {
|
|
clearTimeout(this.muteTimer);
|
|
this.muteTimer = null;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
this.runMuteTimer();
|
|
|
|
user.updateIdentity();
|
|
|
|
if (!(this.settings.isPrivate === true || this.settings.isPersonal)) {
|
|
void Punishments.monitorRoomPunishments(user);
|
|
}
|
|
|
|
return userid;
|
|
}
|
|
unmute(userid: string, notifyText?: string) {
|
|
let successUserid = '';
|
|
const user = Users.get(userid);
|
|
let autoconfirmed = '';
|
|
if (user) {
|
|
userid = user.id;
|
|
autoconfirmed = user.autoconfirmed;
|
|
}
|
|
|
|
for (const [i, entry] of this.muteQueue.entries()) {
|
|
if (entry.userid === userid ||
|
|
(user && entry.guestNum === user.guestNum) ||
|
|
(autoconfirmed && entry.autoconfirmed === autoconfirmed)) {
|
|
if (i === 0) {
|
|
this.muteQueue.splice(0, 1);
|
|
this.runMuteTimer(true);
|
|
} else {
|
|
this.muteQueue.splice(i, 1);
|
|
}
|
|
successUserid = entry.userid;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (user && successUserid && userid in this.users) {
|
|
user.updateIdentity();
|
|
if (notifyText) user.popup(notifyText);
|
|
}
|
|
return successUserid;
|
|
}
|
|
|
|
logUserStats() {
|
|
let total = 0;
|
|
let guests = 0;
|
|
const groups: {[k: string]: number} = {};
|
|
for (const group of Config.groupsranking) {
|
|
groups[group] = 0;
|
|
}
|
|
for (const i in this.users) {
|
|
const user = this.users[i];
|
|
++total;
|
|
if (!user.named) {
|
|
++guests;
|
|
}
|
|
++groups[this.auth.get(user.id)];
|
|
}
|
|
let entry = '|userstats|total:' + total + '|guests:' + guests;
|
|
for (const i in groups) {
|
|
entry += '|' + i + ':' + groups[i];
|
|
}
|
|
this.roomlog(entry);
|
|
}
|
|
|
|
pokeExpireTimer() {
|
|
if (this.expireTimer) clearTimeout(this.expireTimer);
|
|
if (this.settings.isPersonal) {
|
|
this.expireTimer = setTimeout(() => this.expire(), TIMEOUT_INACTIVE_DEALLOCATE);
|
|
} else {
|
|
this.expireTimer = null;
|
|
}
|
|
}
|
|
expire() {
|
|
this.send('|expire|');
|
|
this.destroy();
|
|
}
|
|
reportJoin(type: 'j' | 'l' | 'n', entry: string, user: User) {
|
|
const canTalk = this.auth.atLeast(user, this.settings.modchat ?? 'unlocked') && !this.isMuted(user);
|
|
if (this.reportJoins && (canTalk || this.auth.has(user.id))) {
|
|
this.add(`|${type}|${entry}`).update();
|
|
return;
|
|
}
|
|
let ucType = '';
|
|
switch (type) {
|
|
case 'j': ucType = 'J'; break;
|
|
case 'l': ucType = 'L'; break;
|
|
case 'n': ucType = 'N'; break;
|
|
}
|
|
entry = `|${ucType}|${entry}`;
|
|
if (this.batchJoins) {
|
|
this.log.broadcastBuffer.push(entry);
|
|
|
|
if (!this.reportJoinsInterval) {
|
|
this.reportJoinsInterval = setTimeout(
|
|
() => this.update(), this.batchJoins
|
|
);
|
|
}
|
|
} else {
|
|
this.send(entry);
|
|
}
|
|
this.roomlog(entry);
|
|
}
|
|
getIntroMessage(user: User) {
|
|
let message = Utils.html`\n|raw|<div class="infobox"> You joined ${this.title}`;
|
|
if (this.settings.modchat) {
|
|
message += ` [${this.settings.modchat} or higher to talk]`;
|
|
}
|
|
if (this.settings.modjoin) {
|
|
const modjoin = this.settings.modjoin === true ? this.settings.modchat : this.settings.modjoin;
|
|
message += ` [${modjoin} or higher to join]`;
|
|
}
|
|
if (this.settings.slowchat) {
|
|
message += ` [Slowchat ${this.settings.slowchat}s]`;
|
|
}
|
|
message += `</div>`;
|
|
if (this.settings.introMessage) {
|
|
message += `\n|raw|<div class="infobox infobox-roomintro"><div ${(!this.settings.isOfficial ? 'class="infobox-limited"' : '')}>` +
|
|
this.settings.introMessage.replace(/\n/g, '') +
|
|
`</div></div>`;
|
|
}
|
|
const staffIntro = this.getStaffIntroMessage(user);
|
|
if (staffIntro) message += `\n${staffIntro}`;
|
|
return message;
|
|
}
|
|
getStaffIntroMessage(user: User) {
|
|
if (!user.can('mute', null, this)) return ``;
|
|
let message = ``;
|
|
if (this.settings.staffMessage) {
|
|
message += `\n|raw|<div class="infobox">(Staff intro:)<br /><div>` +
|
|
this.settings.staffMessage.replace(/\n/g, '') +
|
|
`</div>`;
|
|
}
|
|
if (this.pendingApprovals?.size) {
|
|
message += `\n|raw|<div class="infobox">`;
|
|
message += `<details open><summary>(Pending media requests: ${this.pendingApprovals.size})</summary>`;
|
|
for (const [userid, entry] of this.pendingApprovals) {
|
|
message += `<div class="infobox">`;
|
|
message += `<strong>Requester ID:</strong> ${userid}<br />`;
|
|
if (entry.dimensions) {
|
|
const [width, height, resized] = entry.dimensions;
|
|
message += `<strong>Link:</strong><br /> <img src="${entry.link}" width="${width}" height="${height}"><br />`;
|
|
if (resized) message += `(Resized)<br />`;
|
|
} else {
|
|
message += `<strong>Link:</strong><br /> <a href="${entry.link}"">Link</a><br />`;
|
|
}
|
|
message += `<strong>Comment:</strong> ${entry.comment ? entry.comment : 'None.'}<br />`;
|
|
message += `<button class="button" name="send" value="/approveshow ${userid}">Approve</button>` +
|
|
`<button class="button" name="send" value="/denyshow ${userid}">Deny</button></div>`;
|
|
message += `<hr />`;
|
|
}
|
|
message += `</details></div>`;
|
|
}
|
|
return message ? `|raw|${message}` : ``;
|
|
}
|
|
getSubRooms(includeSecret = false) {
|
|
if (!this.subRooms) return [];
|
|
return [...this.subRooms.values()].filter(
|
|
room => !room.settings.isPrivate || includeSecret
|
|
);
|
|
}
|
|
validateTitle(newTitle: string, newID?: string) {
|
|
if (!newID) newID = toID(newTitle);
|
|
// `,` is a delimiter used by a lot of /commands
|
|
// `|` and `[` are delimiters used by the protocol
|
|
// `-` has special meaning in roomids
|
|
if (newTitle.includes(',') || newTitle.includes('|')) {
|
|
throw new Chat.ErrorMessage(`Room title "${newTitle}" can't contain any of: ,|`);
|
|
}
|
|
if ((!newID.includes('-') || newID.startsWith('groupchat-')) && newTitle.includes('-')) {
|
|
throw new Chat.ErrorMessage(`Room title "${newTitle}" can't contain -`);
|
|
}
|
|
if (newID.length > MAX_CHATROOM_ID_LENGTH) throw new Chat.ErrorMessage("The given room title is too long.");
|
|
if (Rooms.search(newTitle)) throw new Chat.ErrorMessage(`The room '${newTitle}' already exists.`);
|
|
}
|
|
|
|
getReplayData() {
|
|
if (!this.roomid.endsWith('pw')) return {id: this.roomid.slice(7)};
|
|
const end = this.roomid.length - 2;
|
|
const lastHyphen = this.roomid.lastIndexOf('-', end);
|
|
return {id: this.roomid.slice(7, lastHyphen), password: this.roomid.slice(lastHyphen, end)};
|
|
}
|
|
|
|
/**
|
|
* @param newID Add this param if the roomid is different from `toID(newTitle)`
|
|
* @param noAlias Set this param to true to not redirect aliases and the room's old name to its new name.
|
|
*/
|
|
async rename(newTitle: string, newID?: RoomID, noAlias?: boolean) {
|
|
if (!newID) newID = toID(newTitle) as RoomID;
|
|
this.validateTitle(newTitle, newID);
|
|
if (this.type === 'chat' && this.game) {
|
|
throw new Chat.ErrorMessage(`Please finish your game (${this.game.title}) before renaming ${this.roomid}.`);
|
|
}
|
|
const oldID = this.roomid;
|
|
this.roomid = newID;
|
|
this.title = newTitle;
|
|
Rooms.rooms.delete(oldID);
|
|
Rooms.rooms.set(newID, this as Room);
|
|
|
|
if (oldID === 'lobby') {
|
|
Rooms.lobby = null;
|
|
} else if (newID === 'lobby') {
|
|
Rooms.lobby = this as ChatRoom;
|
|
}
|
|
|
|
if (!noAlias) {
|
|
for (const [alias, roomid] of Rooms.aliases.entries()) {
|
|
if (roomid === oldID) {
|
|
Rooms.aliases.set(alias, newID);
|
|
}
|
|
}
|
|
|
|
// add an alias from the old id
|
|
Rooms.aliases.set(oldID, newID);
|
|
if (!this.settings.aliases) this.settings.aliases = [];
|
|
// resolve an old (fixed) bug in /renameroom
|
|
if (!this.settings.aliases.includes(oldID)) this.settings.aliases.push(oldID);
|
|
} else {
|
|
// clear aliases
|
|
for (const [alias, roomid] of Rooms.aliases.entries()) {
|
|
if (roomid === oldID) {
|
|
Rooms.aliases.delete(alias);
|
|
}
|
|
}
|
|
this.settings.aliases = undefined;
|
|
}
|
|
this.saveSettings();
|
|
|
|
for (const user of Object.values(this.users)) {
|
|
user.moveConnections(oldID, newID);
|
|
user.send(`>${oldID}\n|noinit|rename|${newID}|${newTitle}`);
|
|
}
|
|
|
|
if (this.parent && this.parent.subRooms) {
|
|
this.parent.subRooms.delete(oldID);
|
|
this.parent.subRooms.set(newID, this as ChatRoom);
|
|
}
|
|
|
|
if (this.subRooms) {
|
|
for (const subRoom of this.subRooms.values()) {
|
|
subRoom.parent = this as ChatRoom;
|
|
}
|
|
}
|
|
|
|
this.settings.title = newTitle;
|
|
this.saveSettings();
|
|
|
|
return this.log.rename(newID);
|
|
}
|
|
|
|
onConnect(user: User, connection: Connection) {
|
|
const userList = this.userList ? this.userList : this.getUserList();
|
|
this.sendUser(
|
|
connection,
|
|
'|init|chat\n|title|' + this.title + '\n' + userList + '\n' + this.log.getScrollback() + this.getIntroMessage(user)
|
|
);
|
|
if (this.minorActivity) this.minorActivity.onConnect(user, connection);
|
|
if (this.game && this.game.onConnect) this.game.onConnect(user, connection);
|
|
}
|
|
onJoin(user: User, connection: Connection) {
|
|
if (!user) return false; // ???
|
|
if (this.users[user.id]) return false;
|
|
|
|
if (user.named) {
|
|
this.reportJoin('j', user.getIdentityWithStatus(this.roomid), user);
|
|
}
|
|
|
|
const staffIntro = this.getStaffIntroMessage(user);
|
|
if (staffIntro) this.sendUser(user, staffIntro);
|
|
|
|
this.users[user.id] = user;
|
|
this.userCount++;
|
|
|
|
if (this.minorActivity) this.minorActivity.onConnect(user, connection);
|
|
if (this.game && this.game.onJoin) this.game.onJoin(user, connection);
|
|
return true;
|
|
}
|
|
onRename(user: User, oldid: ID, joining: boolean) {
|
|
if (user.id === oldid) {
|
|
return this.onUpdateIdentity(user);
|
|
}
|
|
if (!this.users[oldid]) {
|
|
Monitor.crashlog(new Error(`user ${oldid} not in room ${this.roomid}`));
|
|
}
|
|
if (this.users[user.id]) {
|
|
Monitor.crashlog(new Error(`user ${user.id} already in room ${this.roomid}`));
|
|
}
|
|
delete this.users[oldid];
|
|
this.users[user.id] = user;
|
|
if (joining) {
|
|
this.reportJoin('j', user.getIdentityWithStatus(this.roomid), user);
|
|
const staffIntro = this.getStaffIntroMessage(user);
|
|
if (staffIntro) this.sendUser(user, staffIntro);
|
|
} else if (!user.named) {
|
|
this.reportJoin('l', oldid, user);
|
|
} else {
|
|
this.reportJoin('n', user.getIdentityWithStatus(this.roomid) + '|' + oldid, user);
|
|
}
|
|
if (this.minorActivity && 'voters' in this.minorActivity) {
|
|
if (user.id in this.minorActivity.voters) this.minorActivity.updateFor(user);
|
|
}
|
|
return true;
|
|
}
|
|
/**
|
|
* onRename, but without a userid change
|
|
*/
|
|
onUpdateIdentity(user: User) {
|
|
if (user?.connected) {
|
|
if (!this.users[user.id]) return false;
|
|
if (user.named) {
|
|
this.reportJoin('n', user.getIdentityWithStatus(this.roomid) + '|' + user.id, user);
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
onLeave(user: User) {
|
|
if (!user) return false; // ...
|
|
|
|
if (!(user.id in this.users)) {
|
|
Monitor.crashlog(new Error(`user ${user.id} already left`));
|
|
return false;
|
|
}
|
|
delete this.users[user.id];
|
|
this.userCount--;
|
|
|
|
if (user.named) {
|
|
this.reportJoin('l', user.getIdentity(this.roomid), user);
|
|
}
|
|
if (this.game && this.game.onLeave) this.game.onLeave(user);
|
|
return true;
|
|
}
|
|
|
|
destroy(): void {
|
|
// deallocate ourself
|
|
|
|
if (this.battle && this.tour) {
|
|
// resolve state of the tournament;
|
|
if (!this.battle.ended) this.tour.onBattleWin(this as any as GameRoom, '');
|
|
this.tour = null;
|
|
}
|
|
|
|
// remove references to ourself
|
|
for (const i in this.users) {
|
|
this.users[i].leaveRoom(this as Room, null);
|
|
delete this.users[i];
|
|
}
|
|
|
|
if (this.parent && this.parent.subRooms) {
|
|
this.parent.subRooms.delete(this.roomid);
|
|
if (!this.parent.subRooms.size) this.parent.subRooms = null;
|
|
}
|
|
|
|
Rooms.global.deregisterChatRoom(this.roomid);
|
|
Rooms.global.delistChatRoom(this.roomid);
|
|
|
|
if (this.settings.aliases) {
|
|
for (const alias of this.settings.aliases) {
|
|
Rooms.aliases.delete(alias);
|
|
}
|
|
}
|
|
|
|
if (this.game) {
|
|
this.game.destroy();
|
|
this.game = null;
|
|
this.battle = null;
|
|
}
|
|
this.active = false;
|
|
|
|
// Ensure there aren't any pending messages that could restart the expire timer
|
|
this.update();
|
|
|
|
// Clear any active timers for the room
|
|
if (this.muteTimer) {
|
|
clearTimeout(this.muteTimer);
|
|
this.muteTimer = null;
|
|
}
|
|
if (this.expireTimer) {
|
|
clearTimeout(this.expireTimer);
|
|
this.expireTimer = null;
|
|
}
|
|
if (this.reportJoinsInterval) {
|
|
clearInterval(this.reportJoinsInterval);
|
|
}
|
|
this.reportJoinsInterval = null;
|
|
if (this.logUserStatsInterval) {
|
|
clearInterval(this.logUserStatsInterval);
|
|
}
|
|
this.logUserStatsInterval = null;
|
|
|
|
void this.log.destroy(true);
|
|
|
|
// get rid of some possibly-circular references
|
|
Rooms.rooms.delete(this.roomid);
|
|
}
|
|
tr(strings: string | TemplateStringsArray, ...keys: any[]) {
|
|
return Chat.tr(this.settings.language || 'english', strings, ...keys);
|
|
}
|
|
}
|
|
|
|
export class GlobalRoomState {
|
|
readonly settingsList: RoomSettings[];
|
|
readonly chatRooms: ChatRoom[];
|
|
/**
|
|
* Rooms that users autojoin upon connecting
|
|
*/
|
|
readonly autojoinList: RoomID[];
|
|
/**
|
|
* Rooms that users autojoin upon logging in
|
|
*/
|
|
readonly modjoinedAutojoinList: RoomID[];
|
|
readonly ladderIpLog: WriteStream;
|
|
readonly reportUserStatsInterval: NodeJS.Timeout;
|
|
lockdown: boolean | 'pre' | 'ddos';
|
|
battleCount: number;
|
|
lastReportedCrash: number;
|
|
lastBattle: number;
|
|
lastWrittenBattle: number;
|
|
maxUsers: number;
|
|
maxUsersDate: number;
|
|
formatList: string;
|
|
|
|
constructor() {
|
|
this.settingsList = [];
|
|
try {
|
|
this.settingsList = require('../config/chatrooms.json');
|
|
if (!Array.isArray(this.settingsList)) this.settingsList = [];
|
|
} catch (e) {} // file doesn't exist [yet]
|
|
|
|
if (!this.settingsList.length) {
|
|
this.settingsList = [{
|
|
title: 'Lobby',
|
|
auth: {},
|
|
creationTime: Date.now(),
|
|
isOfficial: true,
|
|
autojoin: true,
|
|
}, {
|
|
title: 'Staff',
|
|
auth: {},
|
|
creationTime: Date.now(),
|
|
isPrivate: 'hidden',
|
|
modjoin: '%',
|
|
autojoin: true,
|
|
}];
|
|
}
|
|
|
|
this.chatRooms = [];
|
|
|
|
this.autojoinList = [];
|
|
this.modjoinedAutojoinList = [];
|
|
for (const [i, settings] of this.settingsList.entries()) {
|
|
if (!settings || !settings.title) {
|
|
Monitor.warn(`ERROR: Room number ${i} has no data and could not be loaded.`);
|
|
continue;
|
|
}
|
|
if ((settings as any).staffAutojoin) {
|
|
// convert old staffAutojoin format
|
|
delete (settings as any).staffAutojoin;
|
|
(settings as any).autojoin = true;
|
|
if (!settings.modjoin) settings.modjoin = '%';
|
|
if (settings.isPrivate === true) settings.isPrivate = 'hidden';
|
|
}
|
|
|
|
// We're okay with assinging type `ID` to `RoomID` here
|
|
// because the hyphens in chatrooms don't have any special
|
|
// meaning, unlike in helptickets, groupchats, battles etc
|
|
// where they are used for shared modlogs and the like
|
|
const id = toID(settings.title) as RoomID;
|
|
Monitor.notice("RESTORE CHATROOM: " + id);
|
|
const room = Rooms.createChatRoom(id, settings.title, settings);
|
|
if (room.settings.aliases) {
|
|
for (const alias of room.settings.aliases) {
|
|
Rooms.aliases.set(alias, id);
|
|
}
|
|
}
|
|
|
|
this.chatRooms.push(room);
|
|
if (room.settings.autojoin) {
|
|
if (room.settings.modjoin) {
|
|
this.modjoinedAutojoinList.push(id);
|
|
} else {
|
|
this.autojoinList.push(id);
|
|
}
|
|
}
|
|
}
|
|
Rooms.lobby = Rooms.rooms.get('lobby') as ChatRoom;
|
|
|
|
// init battle room logging
|
|
if (Config.logladderip) {
|
|
this.ladderIpLog = FS('logs/ladderip/ladderip.txt').createAppendStream();
|
|
} else {
|
|
// Prevent there from being two possible hidden classes an instance
|
|
// of GlobalRoom can have.
|
|
this.ladderIpLog = new WriteStream({write() { return undefined; }});
|
|
}
|
|
// Create writestream for modlog
|
|
Rooms.Modlog.initialize('global');
|
|
|
|
this.reportUserStatsInterval = setInterval(
|
|
() => this.reportUserStats(),
|
|
REPORT_USER_STATS_INTERVAL
|
|
);
|
|
|
|
// init users
|
|
this.maxUsers = 0;
|
|
this.maxUsersDate = 0;
|
|
this.lockdown = false;
|
|
|
|
this.battleCount = 0;
|
|
this.lastReportedCrash = 0;
|
|
|
|
this.formatList = '';
|
|
|
|
let lastBattle;
|
|
try {
|
|
lastBattle = FS('logs/lastbattle.txt').readSync('utf8');
|
|
} catch (e) {}
|
|
this.lastBattle = Number(lastBattle) || 0;
|
|
this.lastWrittenBattle = this.lastBattle;
|
|
}
|
|
|
|
modlog(message: string, overrideID?: string) {
|
|
void Rooms.Modlog.write('global', message, overrideID);
|
|
}
|
|
|
|
writeChatRoomData() {
|
|
FS('config/chatrooms.json').writeUpdate(() => (
|
|
JSON.stringify(this.settingsList)
|
|
.replace(/\{"title":/g, '\n{"title":')
|
|
.replace(/\]$/, '\n]')
|
|
));
|
|
}
|
|
|
|
writeNumRooms() {
|
|
if (this.lockdown) {
|
|
if (this.lastBattle === this.lastWrittenBattle) return;
|
|
this.lastWrittenBattle = this.lastBattle;
|
|
} else {
|
|
// batch writes so we don't have to write them every new battle
|
|
// very probably premature optimization, considering by default we
|
|
// write significantly larger log files every new battle
|
|
if (this.lastBattle < this.lastWrittenBattle) return;
|
|
this.lastWrittenBattle = this.lastBattle + LAST_BATTLE_WRITE_THROTTLE;
|
|
}
|
|
FS('logs/lastbattle.txt').writeUpdate(
|
|
() => `${this.lastWrittenBattle}`
|
|
);
|
|
}
|
|
|
|
reportUserStats() {
|
|
if (this.maxUsersDate) {
|
|
void LoginServer.request('updateuserstats', {
|
|
date: this.maxUsersDate,
|
|
users: this.maxUsers,
|
|
});
|
|
this.maxUsersDate = 0;
|
|
}
|
|
void LoginServer.request('updateuserstats', {
|
|
date: Date.now(),
|
|
users: Users.onlineCount,
|
|
});
|
|
}
|
|
|
|
get formatListText() {
|
|
if (this.formatList) {
|
|
return this.formatList;
|
|
}
|
|
this.formatList = '|formats' + (Ladders.formatsListPrefix || '');
|
|
let section = '';
|
|
let prevSection = '';
|
|
let curColumn = 1;
|
|
for (const i in Dex.formats) {
|
|
const format = Dex.formats[i];
|
|
if (format.section) section = format.section;
|
|
if (format.column) curColumn = format.column;
|
|
if (!format.name) continue;
|
|
if (!format.challengeShow && !format.searchShow && !format.tournamentShow) continue;
|
|
|
|
if (section !== prevSection) {
|
|
prevSection = section;
|
|
this.formatList += '|,' + curColumn + '|' + section;
|
|
}
|
|
this.formatList += '|' + format.name;
|
|
let displayCode = 0;
|
|
if (format.team) displayCode |= 1;
|
|
if (format.searchShow) displayCode |= 2;
|
|
if (format.challengeShow) displayCode |= 4;
|
|
if (format.tournamentShow) displayCode |= 8;
|
|
const level = format.maxLevel || format.maxForcedLevel || format.forcedLevel;
|
|
if (level === 50) displayCode |= 16;
|
|
this.formatList += ',' + displayCode.toString(16);
|
|
}
|
|
return this.formatList;
|
|
}
|
|
get configRankList() {
|
|
if (Config.nocustomgrouplist) return '';
|
|
|
|
// putting the resultant object in Config would enable this to be run again should config.js be reloaded.
|
|
if (Config.rankList) {
|
|
return Config.rankList;
|
|
}
|
|
let rankList = [];
|
|
|
|
for (const rank in Config.groups) {
|
|
if (!Config.groups[rank] || !rank) continue;
|
|
|
|
const tarGroup = Config.groups[rank];
|
|
const groupType = tarGroup.id === 'bot' || (!tarGroup.mute && !tarGroup.root) ?
|
|
'normal' : (tarGroup.root || tarGroup.declare) ? 'leadership' : 'staff';
|
|
|
|
rankList.push({
|
|
symbol: rank,
|
|
name: (Config.groups[rank].name || null),
|
|
type: groupType}); // send the first character in the rank, incase they put a string several characters long
|
|
}
|
|
|
|
const typeOrder = ['punishment', 'normal', 'staff', 'leadership'];
|
|
|
|
rankList = rankList.sort((a, b) => typeOrder.indexOf(b.type) - typeOrder.indexOf(a.type));
|
|
|
|
// add the punishment types at the very end.
|
|
for (const rank in Config.punishgroups) {
|
|
rankList.push({symbol: Config.punishgroups[rank].symbol, name: Config.punishgroups[rank].name, type: 'punishment'});
|
|
}
|
|
|
|
Config.rankList = '|customgroups|' + JSON.stringify(rankList) + '\n';
|
|
return Config.rankList;
|
|
}
|
|
|
|
getBattles(/** formatfilter, elofilter, usernamefilter */ filter: string) {
|
|
const rooms: GameRoom[] = [];
|
|
const [formatFilter, eloFilterString, usernameFilter] = filter.split(',');
|
|
const eloFilter = +eloFilterString;
|
|
for (const room of Rooms.rooms.values()) {
|
|
if (!room || !room.active || room.settings.isPrivate) continue;
|
|
if (room.type !== 'battle') continue;
|
|
if (formatFilter && formatFilter !== room.format) continue;
|
|
if (eloFilter && (!room.rated || room.rated < eloFilter)) continue;
|
|
if (usernameFilter && room.battle) {
|
|
const p1userid = room.battle.p1.id;
|
|
const p2userid = room.battle.p2.id;
|
|
if (!p1userid || !p2userid) continue;
|
|
if (!p1userid.startsWith(usernameFilter) && !p2userid.startsWith(usernameFilter)) continue;
|
|
}
|
|
rooms.push(room);
|
|
}
|
|
|
|
const roomTable: {[roomid: string]: BattleRoomTable} = {};
|
|
for (let i = rooms.length - 1; i >= rooms.length - 100 && i >= 0; i--) {
|
|
const room = rooms[i];
|
|
const roomData: BattleRoomTable = {};
|
|
if (room.active && room.battle) {
|
|
if (room.battle.p1) roomData.p1 = room.battle.p1.name;
|
|
if (room.battle.p2) roomData.p2 = room.battle.p2.name;
|
|
if (room.tour) roomData.minElo = 'tour';
|
|
if (room.rated) roomData.minElo = Math.floor(room.rated);
|
|
}
|
|
if (!roomData.p1 || !roomData.p2) continue;
|
|
roomTable[room.roomid] = roomData;
|
|
}
|
|
return roomTable;
|
|
}
|
|
getRooms(user: User) {
|
|
const roomsData: {
|
|
official: ChatRoomTable[], pspl: ChatRoomTable[], chat: ChatRoomTable[], userCount: number, battleCount: number,
|
|
} = {
|
|
official: [],
|
|
pspl: [],
|
|
chat: [],
|
|
userCount: Users.onlineCount,
|
|
battleCount: this.battleCount,
|
|
};
|
|
for (const room of this.chatRooms) {
|
|
if (!room) continue;
|
|
if (room.parent) continue;
|
|
if (room.settings.isPrivate && !(room.settings.isPrivate === 'voice' && user.tempGroup !== ' ')) continue;
|
|
const roomData: ChatRoomTable = {
|
|
title: room.title,
|
|
desc: room.settings.desc || '',
|
|
userCount: room.userCount,
|
|
};
|
|
const subrooms = room.getSubRooms().map(r => r.title);
|
|
if (subrooms.length) roomData.subRooms = subrooms;
|
|
|
|
if (room.settings.isOfficial) {
|
|
roomsData.official.push(roomData);
|
|
// @ts-ignore
|
|
} else if (room.pspl) {
|
|
roomsData.pspl.push(roomData);
|
|
} else {
|
|
roomsData.chat.push(roomData);
|
|
}
|
|
}
|
|
return roomsData;
|
|
}
|
|
sendAll(message: string) {
|
|
Sockets.roomBroadcast('', message);
|
|
}
|
|
addChatRoom(title: string) {
|
|
const id = toID(title) as RoomID;
|
|
if (['battles', 'rooms', 'ladder', 'teambuilder', 'home', 'all', 'public'].includes(id)) {
|
|
return false;
|
|
}
|
|
if (Rooms.rooms.has(id)) return false;
|
|
|
|
const settings = {
|
|
title,
|
|
auth: {},
|
|
creationTime: Date.now(),
|
|
};
|
|
const room = Rooms.createChatRoom(id, title, settings);
|
|
if (id === 'lobby') Rooms.lobby = room;
|
|
this.settingsList.push(settings);
|
|
this.chatRooms.push(room);
|
|
this.writeChatRoomData();
|
|
return true;
|
|
}
|
|
|
|
prepBattleRoom(format: string) {
|
|
// console.log('BATTLE START BETWEEN: ' + p1.id + ' ' + p2.id);
|
|
const roomPrefix = `battle-${toID(Dex.getFormat(format).name)}-`;
|
|
let battleNum = this.lastBattle;
|
|
let roomid: RoomID;
|
|
do {
|
|
roomid = `${roomPrefix}${++battleNum}` as RoomID;
|
|
} while (Rooms.rooms.has(roomid));
|
|
|
|
this.lastBattle = battleNum;
|
|
this.writeNumRooms();
|
|
return roomid;
|
|
}
|
|
|
|
onCreateBattleRoom(players: User[], room: GameRoom, options: AnyObject) {
|
|
players.forEach(player => {
|
|
if (player.statusType === 'idle') {
|
|
player.setStatusType('online');
|
|
}
|
|
});
|
|
if (Config.reportbattles) {
|
|
const reportRoom = Rooms.get(Config.reportbattles === true ? 'lobby' : Config.reportbattles);
|
|
if (reportRoom) {
|
|
const reportPlayers = players.map(p => p.getIdentity()).join('|');
|
|
reportRoom
|
|
.add(`|b|${room.roomid}|${reportPlayers}`)
|
|
.update();
|
|
}
|
|
}
|
|
if (Config.logladderip && options.rated) {
|
|
const ladderIpLogString = players.map(p => `${p.id}: ${p.latestIp}\n`).join('');
|
|
void this.ladderIpLog.write(ladderIpLogString);
|
|
}
|
|
}
|
|
|
|
deregisterChatRoom(id: string) {
|
|
id = toID(id);
|
|
const room = Rooms.get(id);
|
|
if (!room) return false; // room doesn't exist
|
|
if (!room.persist) return false; // room isn't registered
|
|
// deregister from global settings
|
|
// looping from the end is a pretty trivial optimization, but the
|
|
// assumption is that more recently added rooms are more likely to
|
|
// be deleted
|
|
for (let i = this.settingsList.length - 1; i >= 0; i--) {
|
|
if (id === toID(this.settingsList[i].title)) {
|
|
this.settingsList.splice(i, 1);
|
|
this.writeChatRoomData();
|
|
break;
|
|
}
|
|
}
|
|
room.persist = false;
|
|
return true;
|
|
}
|
|
delistChatRoom(id: RoomID) {
|
|
id = toID(id) as RoomID;
|
|
if (!Rooms.rooms.has(id)) return false; // room doesn't exist
|
|
for (let i = this.chatRooms.length - 1; i >= 0; i--) {
|
|
if (id === this.chatRooms[i].roomid) {
|
|
this.chatRooms.splice(i, 1);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
removeChatRoom(id: string) {
|
|
id = toID(id);
|
|
const room = Rooms.get(id);
|
|
if (!room) return false; // room doesn't exist
|
|
room.destroy();
|
|
return true;
|
|
}
|
|
autojoinRooms(user: User, connection: Connection) {
|
|
// we only autojoin regular rooms if the client requests it with /autojoin
|
|
// note that this restriction doesn't apply to modjoined autojoin rooms
|
|
let includesLobby = false;
|
|
for (const roomName of this.autojoinList) {
|
|
user.joinRoom(roomName, connection);
|
|
if (roomName === 'lobby') includesLobby = true;
|
|
}
|
|
if (!includesLobby && Config.serverid !== 'showdown') user.send(`>lobby\n|deinit`);
|
|
}
|
|
checkAutojoin(user: User, connection?: Connection) {
|
|
if (!user.named) return;
|
|
for (let [i, roomid] of this.modjoinedAutojoinList.entries()) {
|
|
const room = Rooms.get(roomid);
|
|
if (!room) {
|
|
this.modjoinedAutojoinList.splice(i, 1);
|
|
i--;
|
|
continue;
|
|
}
|
|
if (room.checkModjoin(user)) {
|
|
user.joinRoom(room.roomid, connection);
|
|
}
|
|
}
|
|
for (const conn of user.connections) {
|
|
if (conn.autojoins) {
|
|
const autojoins = conn.autojoins.split(',') as RoomID[];
|
|
for (const roomName of autojoins) {
|
|
void user.tryJoinRoom(roomName, conn);
|
|
}
|
|
conn.autojoins = '';
|
|
}
|
|
}
|
|
}
|
|
handleConnect(user: User, connection: Connection) {
|
|
connection.send(user.getUpdateuserText() + '\n' + this.configRankList + this.formatListText);
|
|
if (Users.users.size > this.maxUsers) {
|
|
this.maxUsers = Users.users.size;
|
|
this.maxUsersDate = Date.now();
|
|
}
|
|
}
|
|
startLockdown(err: Error | null = null, slow = false) {
|
|
if (this.lockdown && err) return;
|
|
const devRoom = Rooms.get('development');
|
|
// @ts-ignore
|
|
const stack = (err ? Utils.escapeHTML(err.stack).split(`\n`).slice(0, 2).join(`<br />`) : ``);
|
|
for (const [id, curRoom] of Rooms.rooms) {
|
|
if (err) {
|
|
if (id === 'staff' || id === 'development' || (!devRoom && id === 'lobby')) {
|
|
curRoom.addRaw(`<div class="broadcast-red"><b>The server needs to restart because of a crash:</b> ${stack}<br />Please restart the server.</div>`);
|
|
curRoom.addRaw(`<div class="broadcast-red">You will not be able to start new battles until the server restarts.</div>`);
|
|
curRoom.update();
|
|
} else {
|
|
curRoom.addRaw(`<div class="broadcast-red"><b>The server needs to restart because of a crash.</b><br />No new battles can be started until the server is done restarting.</div>`).update();
|
|
}
|
|
} else {
|
|
curRoom.addRaw(`<div class="broadcast-red"><b>The server is restarting soon.</b><br />Please finish your battles quickly. No new battles can be started until the server resets in a few minutes.</div>`).update();
|
|
}
|
|
const game = curRoom.game;
|
|
// @ts-ignore TODO: revisit when game.timer is standardized
|
|
if (!slow && game && game.timer && typeof game.timer.start === 'function' && !game.ended) {
|
|
// @ts-ignore
|
|
game.timer.start();
|
|
if (curRoom.settings.modchat !== '+') {
|
|
curRoom.settings.modchat = '+';
|
|
curRoom.addRaw(`<div class="broadcast-red"><b>Moderated chat was set to +!</b><br />Only users of rank + and higher can talk.</div>`).update();
|
|
}
|
|
}
|
|
}
|
|
for (const user of Users.users.values()) {
|
|
user.send(`|pm|&|${user.tempGroup}${user.name}|/raw <div class="broadcast-red"><b>The server is restarting soon.</b><br />Please finish your battles quickly. No new battles can be started until the server resets in a few minutes.</div>`);
|
|
}
|
|
|
|
this.lockdown = true;
|
|
this.writeNumRooms();
|
|
this.lastReportedCrash = Date.now();
|
|
}
|
|
automaticKillRequest() {
|
|
const notifyPlaces: RoomID[] = ['development', 'staff', 'upperstaff'];
|
|
if (Config.autolockdown === undefined) Config.autolockdown = true; // on by default
|
|
|
|
if (Config.autolockdown && Rooms.global.lockdown === true && Rooms.global.battleCount === 0) {
|
|
// The server is in lockdown, the final battle has finished, and the option is set
|
|
// so we will now automatically kill the server here if it is not updating.
|
|
if (Monitor.updateServerLock) {
|
|
this.notifyRooms(
|
|
notifyPlaces,
|
|
`|html|<div class="broadcast-red"><b>Automatic server lockdown kill canceled.</b><br /><br />The server tried to automatically kill itself upon the final battle finishing, but the server was updating while trying to kill itself.</div>`
|
|
);
|
|
return;
|
|
}
|
|
|
|
// final warning
|
|
this.notifyRooms(
|
|
notifyPlaces,
|
|
`|html|<div class="broadcast-red"><b>The server is about to automatically kill itself in 10 seconds.</b></div>`
|
|
);
|
|
|
|
// kill server in 10 seconds if it's still set to
|
|
setTimeout(() => {
|
|
if (Config.autolockdown && Rooms.global.lockdown === true) {
|
|
// finally kill the server
|
|
process.exit();
|
|
} else {
|
|
this.notifyRooms(
|
|
notifyPlaces,
|
|
`|html|<div class="broadcsat-red"><b>Automatic server lockdown kill canceled.</b><br /><br />In the last final seconds, the automatic lockdown was manually disabled.</div>`
|
|
);
|
|
}
|
|
}, 10 * 1000);
|
|
}
|
|
}
|
|
notifyRooms(rooms: RoomID[], message: string) {
|
|
if (!rooms || !message) return;
|
|
for (const roomid of rooms) {
|
|
const curRoom = Rooms.get(roomid);
|
|
if (curRoom) curRoom.add(message).update();
|
|
}
|
|
}
|
|
reportCrash(err: Error, crasher = "The server") {
|
|
const time = Date.now();
|
|
if (time - this.lastReportedCrash < CRASH_REPORT_THROTTLE) {
|
|
return;
|
|
}
|
|
this.lastReportedCrash = time;
|
|
|
|
const stack = (err && (err.stack || err.message || err.name)) || '';
|
|
const stackLines = Utils.escapeHTML(stack).split(`\n`);
|
|
|
|
let crashMessage = `|html|<div class="broadcast-red"><details class="readmore"><summary><b>${crasher} crashed:</b> ${stackLines[0]}</summary>${stackLines.slice(1).join('<br />')}</details></div>`;
|
|
let privateCrashMessage = null;
|
|
|
|
const upperStaffRoom = Rooms.get('upperstaff');
|
|
|
|
let hasPrivateTerm = stack.includes('private');
|
|
for (const term of (Config.privatecrashterms || [])) {
|
|
if (typeof term === 'string' ? stack.includes(term) : term.test(stack)) {
|
|
hasPrivateTerm = true;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (hasPrivateTerm) {
|
|
if (upperStaffRoom) {
|
|
privateCrashMessage = crashMessage;
|
|
crashMessage = `|html|<div class="broadcast-red"><b>${crasher} crashed in private code</b> <a href="/upperstaff">Read more</a></div>`;
|
|
} else {
|
|
crashMessage = `|html|<div class="broadcast-red"><b>${crasher} crashed in private code</b></div>`;
|
|
}
|
|
}
|
|
const devRoom = Rooms.get('development');
|
|
if (devRoom) {
|
|
devRoom.add(crashMessage).update();
|
|
} else {
|
|
Rooms.lobby?.add(crashMessage).update();
|
|
Rooms.get('staff')?.add(crashMessage).update();
|
|
}
|
|
if (privateCrashMessage) {
|
|
upperStaffRoom!.add(privateCrashMessage).update();
|
|
}
|
|
}
|
|
/**
|
|
* Destroys personal rooms of a (punished) user
|
|
* Returns a list of the user's remaining public auth
|
|
*/
|
|
destroyPersonalRooms(userid: ID) {
|
|
const roomauth = [];
|
|
for (const [id, curRoom] of Rooms.rooms) {
|
|
if (curRoom.settings.isPersonal && curRoom.auth.get(userid) === Users.HOST_SYMBOL) {
|
|
curRoom.destroy();
|
|
} else {
|
|
if (curRoom.settings.isPrivate || curRoom.battle || !curRoom.persist) {
|
|
continue;
|
|
}
|
|
|
|
if (curRoom.auth.has(userid)) {
|
|
let oldGroup = curRoom.auth.get(userid) as string;
|
|
if (oldGroup === ' ') oldGroup = 'whitelist in ';
|
|
roomauth.push(`${oldGroup}${id}`);
|
|
}
|
|
}
|
|
}
|
|
return roomauth;
|
|
}
|
|
}
|
|
|
|
export class ChatRoom extends BasicRoom {
|
|
// This is not actually used, this is just a fake class to keep
|
|
// TypeScript happy
|
|
battle: null;
|
|
active: false;
|
|
type: 'chat';
|
|
parent: ChatRoom | null;;
|
|
constructor() {
|
|
super('');
|
|
this.battle = null;
|
|
this.active = false;
|
|
this.type = 'chat';
|
|
this.parent = null;
|
|
}
|
|
}
|
|
|
|
export class GameRoom extends BasicRoom {
|
|
readonly type: 'battle';
|
|
readonly format: string;
|
|
p1: AnyObject | null;
|
|
p2: AnyObject | null;
|
|
p3: AnyObject | null;
|
|
p4: AnyObject | null;
|
|
/**
|
|
* The lower player's rating, for searching purposes.
|
|
* 0 for unrated battles. 1 for unknown ratings.
|
|
*/
|
|
rated: number;
|
|
battle: RoomBattle | null;
|
|
game: RoomGame;
|
|
modchatUser: string;
|
|
active: boolean;
|
|
parent: ChatRoom | null;
|
|
constructor(roomid: RoomID, title?: string, options: Partial<RoomSettings> & AnyObject = {}) {
|
|
options.noLogTimes = true;
|
|
options.noAutoTruncate = true;
|
|
options.isMultichannel = true;
|
|
options.batchJoins = 0;
|
|
super(roomid, title, options);
|
|
this.reportJoins = !!Config.reportbattlejoins;
|
|
this.settings.modchat = (Config.battlemodchat || null);
|
|
|
|
this.type = 'battle';
|
|
|
|
this.format = options.format || '';
|
|
// console.log("NEW BATTLE");
|
|
|
|
this.tour = options.tour || null;
|
|
this.parent = options.parent || (this.tour && this.tour.room) || null;
|
|
|
|
this.p1 = options.p1 || null;
|
|
this.p2 = options.p2 || null;
|
|
this.p3 = options.p3 || null;
|
|
this.p4 = options.p4 || null;
|
|
|
|
this.rated = options.rated || 0;
|
|
|
|
this.battle = null;
|
|
this.game = null!;
|
|
|
|
this.modchatUser = '';
|
|
|
|
this.active = false;
|
|
}
|
|
/**
|
|
* - logNum = 0 : spectator log (no exact HP)
|
|
* - logNum = 1, 2, 3, 4 : player log (exact HP for that player)
|
|
* - logNum = -1 : debug log (exact HP for all players)
|
|
*/
|
|
getLog(channel: -1 | 0 | 1 | 2 | 3 | 4 = 0) {
|
|
return this.log.getScrollback(channel);
|
|
}
|
|
getLogForUser(user: User) {
|
|
if (!(user.id in this.game.playerTable)) return this.getLog();
|
|
// @ts-ignore
|
|
return this.getLog(this.game.playerTable[user.id].num);
|
|
}
|
|
update(excludeUser: User | null = null) {
|
|
if (!this.log.broadcastBuffer.length) return;
|
|
|
|
if (this.userCount) {
|
|
Sockets.channelBroadcast(this.roomid, `>${this.roomid}\n${this.log.broadcastBuffer.join('\n')}`);
|
|
}
|
|
this.log.broadcastBuffer = [];
|
|
|
|
this.pokeExpireTimer();
|
|
}
|
|
pokeExpireTimer() {
|
|
// empty rooms time out after ten minutes
|
|
if (!this.userCount) {
|
|
if (this.expireTimer) clearTimeout(this.expireTimer);
|
|
this.expireTimer = setTimeout(() => this.expire(), TIMEOUT_EMPTY_DEALLOCATE);
|
|
} else {
|
|
if (this.expireTimer) clearTimeout(this.expireTimer);
|
|
this.expireTimer = setTimeout(() => this.expire(), TIMEOUT_INACTIVE_DEALLOCATE);
|
|
}
|
|
}
|
|
sendPlayer(num: 0 | 1, message: string) {
|
|
const player = this.getPlayer(num);
|
|
if (!player) return false;
|
|
player.sendRoom(message);
|
|
}
|
|
getPlayer(num: 0 | 1) {
|
|
// @ts-ignore
|
|
return this.game['p' + (num + 1)];
|
|
}
|
|
requestModchat(user: User | null) {
|
|
if (!user) {
|
|
this.modchatUser = '';
|
|
return;
|
|
} else if (!this.modchatUser || this.modchatUser === user.id || this.auth.get(user.id) !== Users.PLAYER_SYMBOL) {
|
|
this.modchatUser = user.id;
|
|
return;
|
|
} else {
|
|
return "Modchat can only be changed by the user who turned it on, or by staff";
|
|
}
|
|
}
|
|
onConnect(user: User, connection: Connection) {
|
|
this.sendUser(connection, '|init|battle\n|title|' + this.title + '\n' + this.getLogForUser(user));
|
|
if (this.game && this.game.onConnect) this.game.onConnect(user, connection);
|
|
}
|
|
async uploadReplay(user: User, connection: Connection, options?: 'forpunishment' | 'silent') {
|
|
const battle = this.battle;
|
|
if (!battle) return;
|
|
|
|
// retrieve spectator log (0) if there are privacy concerns
|
|
const format = Dex.getFormat(this.format, true);
|
|
|
|
// custom games always show full details
|
|
// random-team battles show full details if the battle is ended
|
|
// otherwise, don't show full details
|
|
let hideDetails = !format.id.includes('customgame');
|
|
if (format.team && battle.ended) hideDetails = false;
|
|
|
|
const data = this.getLog(hideDetails ? 0 : -1);
|
|
const datahash = crypto.createHash('md5').update(data.replace(/[^(\x20-\x7F)]+/g, '')).digest('hex');
|
|
let rating = 0;
|
|
if (battle.ended && this.rated) rating = this.rated;
|
|
const [success] = await LoginServer.request('prepreplay', {
|
|
id: this.roomid.substr(7),
|
|
loghash: datahash,
|
|
p1: battle.p1.name,
|
|
p2: battle.p2.name,
|
|
format: format.id,
|
|
rating,
|
|
hidden: options === 'forpunishment' || (this as any).unlistReplay ?
|
|
'2' : this.settings.isPrivate || this.hideReplay ? '1' : '',
|
|
inputlog: battle.inputLog?.join('\n') || null,
|
|
});
|
|
if (success) battle.replaySaved = true;
|
|
if (success?.errorip) {
|
|
connection.popup(`This server's request IP ${success.errorip} is not a registered server.`);
|
|
return;
|
|
}
|
|
connection.send('|queryresponse|savereplay|' + JSON.stringify({
|
|
log: data,
|
|
id: this.roomid.substr(7),
|
|
silent: options === 'forpunishment' || options === 'silent',
|
|
}));
|
|
}
|
|
}
|
|
|
|
function getRoom(roomid?: string | BasicRoom) {
|
|
if (typeof roomid === 'string') return Rooms.rooms.get(roomid as RoomID);
|
|
return roomid as Room;
|
|
}
|
|
|
|
export const Rooms = {
|
|
Modlog: require('./modlog').modlog,
|
|
/**
|
|
* The main roomid:Room table. Please do not hold a reference to a
|
|
* room long-term; just store the roomid and grab it from here (with
|
|
* the Rooms.get(roomid) accessor) when necessary.
|
|
*/
|
|
rooms: new Map<RoomID, Room>(),
|
|
aliases: new Map<string, RoomID>(),
|
|
|
|
get: getRoom,
|
|
search(name: string): Room | undefined {
|
|
return getRoom(name) || getRoom(toID(name)) || getRoom(Rooms.aliases.get(toID(name)));
|
|
},
|
|
|
|
createGameRoom(roomid: RoomID, title: string, options: AnyObject) {
|
|
if (Rooms.rooms.has(roomid)) throw new Error(`Room ${roomid} already exists`);
|
|
Monitor.debug("NEW BATTLE ROOM: " + roomid);
|
|
const room = new GameRoom(roomid, title, options);
|
|
Rooms.rooms.set(roomid, room);
|
|
return room;
|
|
},
|
|
createChatRoom(roomid: RoomID, title: string, options: AnyObject) {
|
|
if (Rooms.rooms.has(roomid)) throw new Error(`Room ${roomid} already exists`);
|
|
const room: ChatRoom = new (BasicRoom as any)(roomid, title, options);
|
|
Rooms.rooms.set(roomid, room);
|
|
return room;
|
|
},
|
|
createBattle(formatid: string, options: AnyObject) {
|
|
const players: (User & {specialNextBattle?: string })[] =
|
|
[options.p1, options.p2, options.p3, options.p4].filter(user => user);
|
|
const gameType = Dex.getFormat(formatid).gameType;
|
|
if (gameType !== 'multi' && gameType !== 'free-for-all') {
|
|
if (players.length > 2) {
|
|
throw new Error(`Four players were provided, but the format is a two-player format.`);
|
|
}
|
|
}
|
|
if (new Set(players).size < players.length) {
|
|
throw new Error(`Players can't battle themselves`);
|
|
}
|
|
|
|
for (const user of players) {
|
|
Ladders.cancelSearches(user);
|
|
}
|
|
|
|
if (Rooms.global.lockdown === true) {
|
|
for (const user of players) {
|
|
user.popup("The server is restarting. Battles will be available again in a few minutes.");
|
|
}
|
|
return;
|
|
}
|
|
|
|
const p1Special = players.length ? players[0].specialNextBattle : undefined;
|
|
let mismatch = `"${p1Special}"`;
|
|
for (const user of players) {
|
|
if (user.specialNextBattle !== p1Special) {
|
|
mismatch += ` vs. "${user.specialNextBattle}"`;
|
|
}
|
|
user.specialNextBattle = undefined;
|
|
}
|
|
|
|
if (mismatch !== `"${p1Special}"`) {
|
|
for (const user of players) {
|
|
user.popup(`Your special battle settings don't match: ${mismatch}`);
|
|
}
|
|
return;
|
|
} else if (p1Special) {
|
|
options.ratedMessage = p1Special;
|
|
}
|
|
|
|
const roomid = Rooms.global.prepBattleRoom(formatid);
|
|
options.format = formatid;
|
|
// options.rated is a number representing the lowest player rating, for searching purposes
|
|
// options.rated < 0 or falsy means "unrated", and will be converted to 0 here
|
|
// options.rated === true is converted to 1 (used in tests sometimes)
|
|
options.rated = Math.max(+options.rated || 0, 0);
|
|
const p1 = players[0];
|
|
const p2 = players[1];
|
|
const p1name = p1 ? p1.name : "Player 1";
|
|
const p2name = p2 ? p2.name : "Player 2";
|
|
let roomTitle;
|
|
if (gameType === 'multi') {
|
|
roomTitle = `Team ${p1name} vs. Team ${p2name}`;
|
|
} else if (gameType === 'free-for-all') {
|
|
// p1 vs. p2 vs. p3 vs. p4 is too long of a title
|
|
roomTitle = `${p1name} and friends`;
|
|
} else {
|
|
roomTitle = `${p1name} vs. ${p2name}`;
|
|
}
|
|
options.isPersonal = true;
|
|
const room = Rooms.createGameRoom(roomid, roomTitle, options);
|
|
const battle = new Rooms.RoomBattle(room, formatid, options);
|
|
room.game = battle;
|
|
// Special battles have modchat set to Player from the beginning
|
|
if (p1Special) room.settings.modchat = '\u2606';
|
|
|
|
let inviteOnly = false;
|
|
const privacySetter = new Set<ID>(options.inviteOnly || []);
|
|
for (const p of ['p1', 'p2', 'p3', 'p4']) {
|
|
if (options[`${p}inviteOnly`]) {
|
|
inviteOnly = true;
|
|
privacySetter.add(options[p].id);
|
|
} else if (options[`${p}hidden`]) {
|
|
privacySetter.add(options[p].id);
|
|
}
|
|
}
|
|
|
|
if (privacySetter.size) {
|
|
if (battle.forcePublic) {
|
|
room.settings.isPrivate = false;
|
|
room.settings.modjoin = null;
|
|
room.add(`|raw|<div class="broadcast-blue"><strong>This battle is required to be public due to a player having a name starting with '${battle.forcePublic}'.</div>`);
|
|
} else if (!options.tour || (room.tour && room.tour.modjoin)) {
|
|
room.settings.isPrivate = 'hidden';
|
|
if (inviteOnly) room.settings.modjoin = '%';
|
|
room.privacySetter = privacySetter;
|
|
if (inviteOnly) {
|
|
room.settings.modjoin = '%';
|
|
room.add(`|raw|<div class="broadcast-red"><strong>This battle is invite-only!</strong><br />Users must be invited with <code>/invite</code> (or be staff) to join</div>`);
|
|
}
|
|
}
|
|
}
|
|
|
|
for (const p of players) {
|
|
if (p) {
|
|
p.joinRoom(room);
|
|
Monitor.countBattle(p.latestIp, p.name);
|
|
}
|
|
}
|
|
|
|
return room;
|
|
},
|
|
|
|
global: null! as GlobalRoomState,
|
|
lobby: null as ChatRoom | null,
|
|
|
|
BasicRoom,
|
|
GlobalRoomState,
|
|
GameRoom,
|
|
ChatRoom: BasicRoom as typeof ChatRoom,
|
|
|
|
RoomGame,
|
|
RoomGamePlayer,
|
|
|
|
RETRY_AFTER_LOGIN,
|
|
|
|
Roomlogs,
|
|
|
|
RoomBattle,
|
|
RoomBattlePlayer,
|
|
RoomBattleTimer,
|
|
PM: RoomBattlePM,
|
|
};
|