123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152
import { Client } from "./client.ts"import { Packet } from "./packet.ts"
/** * Class with static methods that handles messages from WebSocket connections. */export class EventHandler {  constructor(){    return;  }  /**   * Sends a message to each Client object in the same channel as client   * @param { Packet } packet - Message received from client   * @param { Client } client - Client sending message packet   * @param { [key: string]: Record<string, Client> } channelsList - Object containing all channels in Sono server   */  handleMessage(packet: Packet, client: Client, channelsList: {[key: string]: Record<string, Client>}){    const { message } = packet.payload;    const currentClientId = client.id.toString(); //1001
    const channelName = client.channel;    const ids = Object.keys(channelsList[channelName])

    ids.forEach((id)=>{
      channelsList[channelName][id].socket.send(JSON.stringify({        protocol: packet.event,        payload: {          message,          from: currentClientId        }      }));    })
    }

  /**   * Changes the channel client is in   * @param { Packet } packet - Message containing channel to change client to   * @param { Client } client - Client to change channel   * @param { [key: string]: Record<string, Client> } channelsList - Object containing all channels in Sono server   */  changeChannel(packet: Packet, client: Client, channelsList: {[key: string]: Record<string, Client>}): {[key: string]: Record<string, Client>}{    const { to } = packet.payload;

    const channel = client.channel;
    delete channelsList[channel][client.id];    client.channel = to;    channelsList[to][client.id] = client;    return channelsList;  }
  /**   * Broadcast data to all clients except for the cliet sending the data   * @param { Packet } packet - Message containing channel to change client to   * @param { Client } client - Client to change channel   * @param { [key: string]: Record<string, Client> } channelsList - Object containing all channels in Sono server   */  broadcast(packet: Packet, client: Client, channelsList: {[key: string]: Record<string, Client>}){    const { message } = packet.payload;    const channelName = client.channel; //'home'    const currentClientId = client.id.toString(); //1001    const ids = Object.keys(channelsList[channelName]);    ids.forEach((id)=>{      console.log('broadcasting', id, 'channelsList', channelsList)      if(id !== currentClientId) channelsList[channelName][id].socket.send(JSON.stringify({        protocol: packet.event,        payload: {          message,          from: currentClientId        },      }));    });  }
  /**   * Direct messages to a specific client   * @param { Packet } packet - Message containing channel to change client to   * @param { Client } client - Client to change channel   * @param { [key: string]: Record<string, Client> } clients - Object containing all channels in Sono server   */  directMessage(packet: Packet, client: Client, clients: {[key: string]: Client}){    const { message, to } = packet.payload;    const currentClientId = client.id;    // console.log(clients)    Object.values(clients).forEach(client => {      if(client.id.toString() == to.toString()){        client.socket.send(JSON.stringify({          protocol: packet.event,          payload: {            message,            from: currentClientId          },        }))      }    })  }
  /**   * Provides the list of clients that are connected to the server   * @param packet - Message containing channel to change client to   * @param client   * @param clients   */  grab(packet: Packet, client: Client, clients: {[key: string]: Client}, channelsList: {[key: string]: Record<string, Client>}){
    const currentClientId = client.id.toString();    const results: Array<string> = [];
    const { message } = packet.payload;    if(message === 'myid'){      results.push(currentClientId)    }    else if(message === 'clients'){      Object.keys(clients).forEach(clientId => {        results.push(clientId)      })    }    else if (message === 'channels'){      Object.keys(channelsList).forEach(channel => {        results.push(channel);      });    }    else if (message === 'mychannelclients'){      // console.log('channelsList', channelsList)      Object.keys(channelsList[client.channel]).forEach(id => {        results.push(id)      })      // Object.keys(channelsList).forEach(channel => {      //   results.push(channel);      // });    }    else if (message === 'mychannel'){      results.push(client.channel)    }    else {      results.push('invalid grab request')    }
    client.socket.send(JSON.stringify({      protocol: packet.event,      payload: {        message: results,        type: message      }    }))  }}