Method createHeartbeat

packages/jstack-shared/src/socket.ts:109–134

(room: string)

  }

  private createHeartbeat(room: string) {
    const heartbeat = {
      sender: setInterval(async () => {
        
        await fetch(`${this.redisUrl}/publish/${room}`, {
          method: 'POST',
          headers: {
            'Authorization': `Bearer ${this.redisToken}`,
            'Content-Type': 'application/json'
          },
          body: JSON.stringify(["ping", null])
        })
      }, 30000),

      monitor: setInterval(() => {
        const lastPingTime = this.lastPingTimes.get(room) ?? 0

        if (Date.now() - lastPingTime > 45000) {
          logger.warn("Heartbeat timeout detected")
          this.unsubscribe(room).then(() => this.subscribe(room))
        }
      }, 5000),
    }

    this.heartbeatTimers.set(room, heartbeat)
  }

  private async subscribe(room: string): Promise<void> {
    return new Promise(async (resolve, reject) => {