cocos-nodejs-io-game/apps/server/src/biz/Room.ts

import { ApiMsgEnum, EntityTypeEnum, IClientInput, InputTypeEnum, IState, toFixed } from '../Common'
import type Player from './Player'
import PlayerManager from './PlayerManager'
import RoomManager from './RoomManager'

export default class Room {
  id: number
  players: Set<Player> = new Set()
  lastSyncTime?: number

  private timers: NodeJS.Timer[] = []
  private inputs: Array<IClientInput> = []

  constructor(rid: number) {
    this.id = rid
  }

  join(uid: number) {
    const player = PlayerManager.Instance.getPlayerById(uid)
    if (player) {
      player.rid = this.id
      this.players.add(player)
    }
  }

  leave(uid: number) {
    const player = PlayerManager.Instance.getPlayerById(uid)
    if (player) {
      player.rid = -1
      player.connection.unlistenMsg(ApiMsgEnum.MsgClientSync, this.getInput, this)
      this.players.delete(player)
      if (!this.players.size) {
        RoomManager.Instance.closeRoom(this.id)
      }
    }
  }

  close() {
    this.timers.forEach(t => clearInterval(t))
    for (const player of this.players) {
      player.connection.sendMsg(ApiMsgEnum.MsgGameEnd, {})
      player.connection.unlistenMsg(ApiMsgEnum.MsgClientSync, this.getInput, this)
    }
    this.players.clear()
  }

  sync() {
    for (const player of this.players) {
      player.connection.sendMsg(ApiMsgEnum.MsgRoom, {
        room: RoomManager.Instance.getRoomView(this)
      })
    }
  }

  start() {
    const state: IState = {
      players: [...this.players].map((player, index) => ({
        id: player.id,
        nickname: player.nickname,
        position: {
          x: -150 + index * 300,
          y: -150 + index * 300,
        },
        direction: {
          x: 1,
          y: 0
        },
        hp: 100,
        type: EntityTypeEnum.Actor2,
        weaponType: EntityTypeEnum.Weapon2,
        bulletType: EntityTypeEnum.Bullet2,
      })),
      bullets: [],
      nextBulletId: 1
    }

    for (const player of this.players) {
      player.connection.sendMsg(ApiMsgEnum.MsgGameStart, {
        state
      })
      player.connection.listenMsg(ApiMsgEnum.MsgClientSync, this.getInput, this)
    }
    let t1 = setInterval(() => {
      this.sendInput()
    }, 100)
    let t2 = setInterval(() => {
      this.timePast()
    }, 16)
    this.timers = [t1, t2]
  }

  getInput(input: IClientInput) {
    this.inputs.push(input)
  }

  sendInput() {
    const inputs = this.inputs
    this.inputs = []

    for (const player of this.players) {
      player.connection.sendMsg(ApiMsgEnum.MsgServerSync, inputs)
    }
  }

  timePast() {
    let now = process.uptime();
    const dt = now - (this.lastSyncTime ?? now)
    this.inputs.push({
      type: InputTypeEnum.TimePast,
      dt: toFixed(dt)
    })
    this.lastSyncTime = now;
  }
}