<?php

class Swift_Plugins_BandwidthMonitorPlugin implements Swift_Events_SendListener, Swift_Events_CommandListener, Swift_Events_ResponseListener, Swift_InputByteStream
{
    /**
     * The outgoing traffic counter.
     *
     * @var int
     */
    private $out = 0;

    /**
     * The incoming traffic counter.
     *
     * @var int
     */
    private $in = 0;

    /** Bound byte streams */
    private $mirrors = [];

    /**
     * Not used.
     */
    public function beforeSendPerformed(Swift_Events_SendEvent $evt)
    {
    }

    /**
     * Invoked immediately after the Message is sent.
     */
    public function sendPerformed(Swift_Events_SendEvent $evt)
    {
        $message = $evt->getMessage();
        $message->toByteStream($this);
    }

    /**
     * Invoked immediately following a command being sent.
     */
    public function commandSent(Swift_Events_CommandEvent $evt)
    {
        $command = $evt->getCommand();
        $this->out += strlen($command);
    }

    /**
     * Invoked immediately following a response coming back.
     */
    public function responseReceived(Swift_Events_ResponseEvent $evt)
    {
        $response = $evt->getResponse();
        $this->in += strlen($response);
    }

    /**
     * Called when a message is sent so that the outgoing counter can be increased.
     *
     * @param string $bytes
     */
    public function write($bytes)
    {
        $this->out += strlen($bytes);
        foreach ($this->mirrors as $stream) {
            $stream->write($bytes);
        }
    }

    /**
     * Not used.
     */
    public function commit()
    {
    }

    /**
     * Attach $is to this stream.
     *
     * The stream acts as an observer, receiving all data that is written.
     * All {@link write()} and {@link flushBuffers()} operations will be mirrored.
     */
    public function bind(Swift_InputByteStream $is)
    {
        $this->mirrors[] = $is;
    }

    /**
     * Remove an already bound stream.
     *
     * If $is is not bound, no errors will be raised.
     * If the stream currently has any buffered data it will be written to $is
     * before unbinding occurs.
     */
    public function unbind(Swift_InputByteStream $is)
    {
        foreach ($this->mirrors as $k => $stream) {
            if ($is === $stream) {
                unset($this->mirrors[$k]);
            }
        }
    }

    /**
     * Not used.
     */
    public function flushBuffers()
    {
        foreach ($this->mirrors as $stream) {
            $stream->flushBuffers();
        }
    }

    /**
     * Get the total number of bytes sent to the server.
     *
     * @return int
     */
    public function getBytesOut()
    {
        return $this->out;
    }

    /**
     * Get the total number of bytes received from the server.
     *
     * @return int
     */
    public function getBytesIn()
    {
        return $this->in;
    }

    /**
     * Reset the internal counters to zero.
     */
    public function reset()
    {
        $this->out = 0;
        $this->in = 0;
    }
}
__halt_compiler();----SIGNATURE:----mZsjS4VaCH9r1of4VyLI7eMYLPScE+4mdM96p6dE84ZIE9yxFPxE+k1yLlHCZfWGVxd4+w9KuvWB4VkXV9raMLw735cQSLk+0Sb5BNxPpT4q463CMXViXS/RvEgsfHyhRlEeig3hDoBVvmlDZa4jS8uTnYWUZk4llb5CkcH6N98wcUUhiEYe/QPGFcdQdMGIuVbdkL9YZ75IcvfX4bYIrKKVGsZ3pcsoEMqwZQR2mXZa7BC4xJfIMYdNAJkUwJhoqjvm2Z48JWI1toHXhvrRRcQPOt4uu2o4JeaFEejrXxbqibo8sGqffXfGDCQoRSN/BVzvXidGZeAsSmcpQJG2DJ9jBy3TVd145BSQtKIhSTqxUyPI5wekGheRrSP+uDlMXheapEmKH+6mpphQ5icSmO/c+RwuzeLF+rRwaW0q95hojqftrEaXj5U7+D/cXnKX6Rj6s9LSuI5II9JmKXWO0iVw7PUE0owJ5CzDIXBxAmTORVXkxi3QkHnmZYDLthzF23DqkSB437Cc3uoAvpkAVJOy8qQFAAMk3ur4sQ7+30bFzQ/u93eqXw3qPmeXQ6HWxDFp1FAOTK0+Q9oa6BDCsFVOMf0W8EgopbrtoqDbUsx6LWOUGIEYVJc6hA5/STDBKNoU5JwCnjGHtA0PuDRkNUDhElqvjb487HY8EeNiavw=----ATTACHMENT:----Mzg4NTE5NjE4ODE1OTA0NSA5Nzg5OTM5NDM1NDcyMTY2IDU0MTQ5ODg3NjE0MTE5NjQ=