{

use Emitter;

public function __construct(

AdapterInterface $adapter,

Sender $sender,

SidProviderInterface $sidProvider,

private Encoder $encoder,

int $fd,

private string $nsp,

?callable $addCallback = null

) {

$this->adapter = $adapter;

$this->sender = $sender;

$this->addCallback = $addCallback;

$this->fd = $fd;

$this->sidProvider = $sidProvider;

}

public function getFd(): int

{

return $this->fd;

}

public function getSid(): string

{

return $this->sidProvider->getSid($this->fd);

}

public function join(string ...$rooms)

{

$this->adapter->add($this->getSid(), ...$rooms);

}

public function leave(string ...$rooms)

{

$this->adapter->del($this->getSid(), ...$rooms);

}

public function leaveAll()

{

$this->adapter->del($this->getSid());

}

public function disconnect()

{

$closePacket = Packet::create([

'type' => Packet::CLOSE,

'nsp' => $this->nsp,

]);

// notice client is about to disconnect

$this->sender->push($this->fd, Engine::MESSAGE . $this->encoder->encode($closePacket));

$this->sender->disconnect($this->fd);

}

public function getNamespace(): string

{

return $this->nsp;

}

/**

public function getRequest(): ServerRequestInterface

{

// If the connection is closed (onClose called)，

// WebSocketContext would have been released.

// $serverRequest is null in this case.

$serverRequest = Context::get(ServerRequestInterface::class);

if (! $serverRequest instanceof ServerRequestInterface) {

throw new ConnectionClosedException('the request has been freed');

}

return $serverRequest;

}