/** * 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 {RepeatedPhrase} from './chat-plugins/repeats'; 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'; import {modlog, ModlogEntry} from './modlog'; /********************************************************* * 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?: ID | 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}; repeats?: RepeatedPhrase[]; 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 | 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 | 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 | null; constructor(roomid: RoomID, title?: string, options: Partial = {}) { 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(entry: ModlogEntry) { const override = this.tour ? `${this.roomid} tournament: ${this.tour.roomid}` : undefined; this.log.modlog(entry, 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(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|
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 += `
`; if (this.settings.introMessage) { message += `\n|raw|
` + this.settings.introMessage.replace(/\n/g, '') + `
`; } 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|
(Staff intro:)
` + this.settings.staffMessage.replace(/\n/g, '') + `
`; } if (this.pendingApprovals?.size) { message += `\n|raw|
`; message += `
(Pending media requests: ${this.pendingApprovals.size})`; for (const [userid, entry] of this.pendingApprovals) { message += `
`; message += `Requester ID: ${userid}
`; if (entry.dimensions) { const [width, height, resized] = entry.dimensions; message += `Link:

`; if (resized) message += `(Resized)
`; } else { message += `Link:
Link
`; } message += `Comment: ${entry.comment ? entry.comment : 'None.'}
`; message += `` + `
`; message += `
`; } message += `
`; } 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' as ID, 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(entry: ModlogEntry, overrideID?: string) { void Rooms.Modlog.write('global', entry, 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(`
`) : ``); for (const [id, curRoom] of Rooms.rooms) { if (err) { if (id === 'staff' || id === 'development' || (!devRoom && id === 'lobby')) { curRoom.addRaw(`
The server needs to restart because of a crash: ${stack}
Please restart the server.
`); curRoom.addRaw(`
You will not be able to start new battles until the server restarts.
`); curRoom.update(); } else { curRoom.addRaw(`
The server needs to restart because of a crash.
No new battles can be started until the server is done restarting.
`).update(); } } else { curRoom.addRaw(`
The server is restarting soon.
Please finish your battles quickly. No new battles can be started until the server resets in a few minutes.
`).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(`
Moderated chat was set to +!
Only users of rank + and higher can talk.
`).update(); } } } for (const user of Users.users.values()) { user.send(`|pm|&|${user.tempGroup}${user.name}|/raw
The server is restarting soon.
Please finish your battles quickly. No new battles can be started until the server resets in a few minutes.
`); } 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|
Automatic server lockdown kill canceled.

The server tried to automatically kill itself upon the final battle finishing, but the server was updating while trying to kill itself.
` ); return; } // final warning this.notifyRooms( notifyPlaces, `|html|
The server is about to automatically kill itself in 10 seconds.
` ); // 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|
Automatic server lockdown kill canceled.

In the last final seconds, the automatic lockdown was manually disabled.
` ); } }, 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|
${crasher} crashed: ${stackLines[0]}${stackLines.slice(1).join('
')}
`; 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|
${crasher} crashed in private code Read more
`; } else { crashMessage = `|html|
${crasher} crashed in private code
`; } } 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 & 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: 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(), aliases: new Map(), 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(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|
This battle is required to be public due to a player having a name starting with '${battle.forcePublic}'.
`); } 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|
This battle is invite-only!
Users must be invited with /invite (or be staff) to join
`); } } } 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, };