erp/msg/vendor/workerman/phpsocket.io/src/DefaultAdapter.php

<?php
namespace PHPSocketIO;
class DefaultAdapter
{

    public $nsp = null;
    public $rooms = array();
    public $sids = array();
    public $encoder = null;
    public function __construct($nsp)
    {
         $this->nsp = $nsp;
         $this->encoder = new Parser\Encoder();
         Debug::debug('DefaultAdapter __construct');
    }
    
    public function __destruct()
    {
        Debug::debug('DefaultAdapter __destruct');
    }
    
    public function add($id, $room)
    {
        $this->sids[$id][$room] = true;
        $this->rooms[$room][$id] = true;
    }
     
    public function del($id, $room)
    {
        unset($this->sids[$id][$room]);
        unset($this->rooms[$room][$id]);
        if(empty($this->rooms[$room]))
        {
            unset($this->rooms[$room]);
        }
    }

    public function delAll($id)
    {
        $rooms = array_keys(isset($this->sids[$id]) ? $this->sids[$id] : array());
        foreach($rooms as $room)
        {
            $this->del($id, $room);
        }
        unset($this->sids[$id]);
    }

    public function broadcast($packet, $opts, $remote = false)
    {
        $rooms = isset($opts['rooms']) ? $opts['rooms'] : array();
        $except = isset($opts['except']) ? $opts['except'] : array();
        $flags = isset($opts['flags']) ? $opts['flags'] : array();
        $packetOpts = array(
            'preEncoded' => true,
            'volatile' => isset($flags['volatile']) ?  $flags['volatile'] : null,
            'compress' => isset($flags['compress']) ? $flags['compress'] : null
        );
        $packet['nsp'] = $this->nsp->name;
        $encodedPackets = $this->encoder->encode($packet);
        if($rooms) 
        {
             $ids = array();
             foreach($rooms as $i=>$room) 
             {
                 if(!isset($this->rooms[$room]))
                 {
                     continue;
                 }
                   
                 $room = $this->rooms[$room];
                 foreach($room as $id=>$item)
                 {
                    if(isset($ids[$id]) || isset($except[$id]))
                    {
                         continue;
                    }
                    if(isset($this->nsp->connected[$id]))
                    {
                         $ids[$id] = true;
                         $this->nsp->connected[$id]->packet($encodedPackets, $packetOpts);
                     }
                 }
             }
         } else {
             foreach($this->sids as $id=>$sid)
             {
                  if(isset($except[$id])) continue;
                  if(isset($this->nsp->connected[$id]))
                  {
                      $socket = $this->nsp->connected[$id];
                      $volatile = isset($flags['volatile']) ? $flags['volatile'] : null;
                      $socket->packet($encodedPackets, true, $volatile);
                  }
              }
         }
    }
    
    public function clients($rooms, $fn) {
        $sids = array();
        foreach ($rooms as $room) {
            $sids = array_merge($sids, $this->rooms[$room]);
        }
        $fn();
    }

}