PEAR2/Net/RouterOS/Query.php

Go to the documentation of this file.

<?php

namespace PEAR2\Net\RouterOS;

class Query
{

    const ACTION_EXIST = '';
    
    const ACTION_NOT_EXIST = '-';
    
    const ACTION_EQUALS = '=';
    
    const ACTION_LESS_THAN = '<';
    
    const ACTION_GREATHER_THAN = '>';

    protected $words = array();

    private function __construct()
    {
        
    }

    protected static function sanitizeAction($action)
    {
        $action = (string) $action;
        switch ($action) {
        case Query::ACTION_EXIST:
        case Query::ACTION_NOT_EXIST:
        case Query::ACTION_EQUALS:
        case Query::ACTION_LESS_THAN:
        case Query::ACTION_GREATHER_THAN:
            return $action;
        default:
            throw new UnexpectedValueException(
                'Unknown action specified', 208, null, $action
            );
        }
    }

    public static function where(
        $name, $value = null, $action = self::ACTION_EXIST
    ) {
        $query = new self;
        return $query->addWhere($name, $value, $action);
    }

    public function not()
    {
        $this->words[] = array('#!', null);
        return $this;
    }

    public function orWhere($name, $value = null, $action = self::ACTION_EXIST)
    {
        $this->addWhere($name, $value, $action)->words[] = array('#|', null);
        return $this;
    }

    public function andWhere($name, $value = null, $action = self::ACTION_EXIST)
    {
        $this->addWhere($name, $value, $action)->words[] = array('#&', null);
        return $this;
    }

    public function send(Communicator $com)
    {
        if (!$com->getTransmitter()->isAcceptingData()) {
            throw new SocketException(
                'Transmitter is invalid. Sending aborted.', 209
            );
        }
        $bytes = 0;
        foreach ($this->words as $queryWord) {
            list($predicate, $value) = $queryWord;
            $prefix = '?' . $predicate;
            if (null === $value) {
                $bytes += $com->sendWord($prefix);
            } else {
                $prefix .= '=';
                if (is_string($value)) {
                    $bytes += $com->sendWord($prefix . $value);
                } else {
                    $bytes += $com->sendWordFromStream($prefix, $value);
                }
            }
        }
        return $bytes;
    }

    protected function addWhere($name, $value, $action)
    {
        $this->words[] = array(
            self::sanitizeAction($action)
            . Message::sanitizeArgumentName($name),
            (null === $value ? null : Message::sanitizeArgumentValue($value))
        );
        return $this;
    }

}