<?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:----tcBAHB5MPR1H0jykN6mRaxfyWX3Qwu6tqNfIUcjTVOqlAM2uKV8Cf3wTdNavyDiOtjKb7igNxw0oBv+833g/AQT1Ug3XEtCovkNXuYFRZcywLciqxV7NdzFlgX65x+yHspmBLL75BJEv98dkoyX3yHobGdd50WH6M7x04lk1NBylYm8kFPRo6jmbet1GAwuBkkFj4d9rX+qTAw9y61t6w5m3Q1BJEd/Furk92sGsrJRlN4ED3+cwqSfcCosHT0IWYw/wffQmLI8SsOsXcJ1jqCD53C+kuHEmQ7fH0xcAL02CITas6gN3/QxKn/IsmAmh+3oAmDvMC/j9VE46QD1a7+KG2GYt732I2DCr4TH0CINt0jLSUE2g1diV+eMBA00cNBnCkM2FqqrstQyYdg7DGXEvmc0dUu5w49UNjzSXwTUwhj3aiZdl9WG7zVK8UtaG0K9Vw6+6Sah+1IIIXo3ys/Y+rU4JrNw3DbvJBmuUcCvHYLcanIRXzFZXe3aAQ593TERnhD68IGNETvLVbqbiusIiv5bbKBUkWR+WbRGgDaGtKXSP5eXAW7j3GBkRy7GVqLpeSD4e5X7q5FJVjUnA5w9r/ryd4YH4E4TCEEB7u5uM/Kcj+WathBJYfhk1OcOBHI6rxlc0wjNBu0Rx3+pFRH7+ssyfhpTULwp4n40Qqvc=----ATTACHMENT:----MzAzMjEwOTM5NzY4ODE1MiA5OTY1NzI1NTE3ODYyNjE5IDI1MzUxMjk3NDUyNTU4NzU=