<?php

namespace Liuggio\StatsdClient\Sender;

use Liuggio\StatsdClient\Exception\InvalidArgumentException;

Class SocketSender implements SenderInterface
{
    private $port;
    private $host;
    private $protocol;

    public function __construct($hostname = 'localhost', $port = 8126, $protocol = 'udp')
    {
        $this->host = $hostname;
        $this->port = $port;

        switch ($protocol) {
            case 'udp':
                $this->protocol = SOL_UDP;
                break;
            case 'tcp':
                $this->protocol = SOL_TCP;
                break;
            default:
                throw new InvalidArgumentException(sprintf('Use udp or tcp as protocol given %s', $protocol));
                break;
        }

    }

    /**
     * {@inheritDoc}
     */
    public function open()
    {
        $fp = socket_create(AF_INET, SOCK_DGRAM, $this->getProtocol());

        return $fp;
    }

    /**
     * {@inheritDoc}
     */
    public function write($handle, $message, $length = null)
    {
        return socket_sendto($handle, $message, strlen($message), 0, $this->getHost(), $this->getPort());
    }

    /**
     * {@inheritDoc}
     */
    public function close($handle)
    {
        socket_close($handle);
    }


    protected function setHost($host)
    {
        $this->host = $host;
    }

    protected function getHost()
    {
        return $this->host;
    }

    protected function setPort($port)
    {
        $this->port = $port;
    }

    protected function getPort()
    {
        return $this->port;
    }

    protected function setProtocol($protocol)
    {
        $this->protocol = $protocol;
    }

    protected function getProtocol()
    {
        return $this->protocol;
    }
}