Server.php

<?php
/*
    This file is part of Erebot, a modular IRC bot written in PHP.

    Copyright © 2010 François Poirotte

    Erebot is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    Erebot is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with Erebot.  If not, see <http://www.gnu.org/licenses/>.
*/

namespace Erebot\Identd;

class Server implements \Erebot\Interfaces\ReceivingConnection
{
    protected $bot;

    protected $socket;

    protected $workerCls;

    public function __construct(
        \Erebot\Interfaces\Core $bot,
        $connector = '0.0.0.0:113',
        $workerCls = '\\Erebot\\Identd\\Worker'
    ) {
        $this->bot          = $bot;
        $this->workerCls    = $workerCls;
        $this->socket       = stream_socket_server('tcp://' . $connector, $errno, $errstr);
        if (!$this->socket) {
            throw new \Exception(
                "Could not create identd server (".$errstr.")"
            );
        }
    }

    public function __destruct()
    {
        $this->disconnect();
    }

    public function connect()
    {
        $this->bot->addConnection($this);
    }

    public function disconnect($quitMessage = null)
    {
        $this->bot->removeConnection($this);
        if ($this->socket !== null) {
            stream_socket_shutdown($this->socket, STREAM_SHUT_RDWR);
        }
        $this->socket = null;
    }

    public function isConnected()
    {
        return true;
    }

    public function getSocket()
    {
        return $this->socket;
    }

    public function emptyReadQueue()
    {
        return true;
    }

    public function read()
    {
        $socket = stream_socket_accept($this->socket);
        if (!$socket) {
            return false;
        }
        $worker = new $this->workerCls($this->bot, $socket);
        return $worker;
    }

    public function process()
    {
    }

    public function getBot()
    {
        return $this->bot;
    }

    public function getConfig($chan)
    {
        return null;
    }

    public function getIO()
    {
        return null;
    }
}