<?php

class Swift_Plugins_ThrottlerPluginTest extends SwiftMailerTestCase
{
    public function testBytesPerMinuteThrottling()
    {
        $sleeper = $this->_createSleeper();
        $timer = $this->_createTimer();

        //10MB/min
        $plugin = new Swift_Plugins_ThrottlerPlugin(
            10000000, Swift_Plugins_ThrottlerPlugin::BYTES_PER_MINUTE,
            $sleeper, $timer
            );

        $timer->shouldReceive('getTimestamp')->once()->andReturn(0);
        $timer->shouldReceive('getTimestamp')->once()->andReturn(1); //expected 0.6
        $timer->shouldReceive('getTimestamp')->once()->andReturn(1); //expected 1.2 (sleep 1)
        $timer->shouldReceive('getTimestamp')->once()->andReturn(2); //expected 1.8
        $timer->shouldReceive('getTimestamp')->once()->andReturn(2); //expected 2.4 (sleep 1)
        $sleeper->shouldReceive('sleep')->twice()->with(1);

        //10,000,000 bytes per minute
        //100,000 bytes per email

        // .: (10,000,000/100,000)/60 emails per second = 1.667 emais/sec

        $message = $this->_createMessageWithByteCount(100000); //100KB

        $evt = $this->_createSendEvent($message);

        for ($i = 0; $i < 5; ++$i) {
            $plugin->beforeSendPerformed($evt);
            $plugin->sendPerformed($evt);
        }
    }

    public function testMessagesPerMinuteThrottling()
    {
        $sleeper = $this->_createSleeper();
        $timer = $this->_createTimer();

        //60/min
        $plugin = new Swift_Plugins_ThrottlerPlugin(
            60, Swift_Plugins_ThrottlerPlugin::MESSAGES_PER_MINUTE,
            $sleeper, $timer
            );

        $timer->shouldReceive('getTimestamp')->once()->andReturn(0);
        $timer->shouldReceive('getTimestamp')->once()->andReturn(0); //expected 1 (sleep 1)
        $timer->shouldReceive('getTimestamp')->once()->andReturn(2); //expected 2
        $timer->shouldReceive('getTimestamp')->once()->andReturn(2); //expected 3 (sleep 1)
        $timer->shouldReceive('getTimestamp')->once()->andReturn(4); //expected 4
        $sleeper->shouldReceive('sleep')->twice()->with(1);

        //60 messages per minute
        //1 message per second

        $message = $this->_createMessageWithByteCount(10);

        $evt = $this->_createSendEvent($message);

        for ($i = 0; $i < 5; ++$i) {
            $plugin->beforeSendPerformed($evt);
            $plugin->sendPerformed($evt);
        }
    }

    private function _createSleeper()
    {
        return $this->getMockery('Swift_Plugins_Sleeper');
    }

    private function _createTimer()
    {
        return $this->getMockery('Swift_Plugins_Timer');
    }

    private function _createMessageWithByteCount($bytes)
    {
        $msg = $this->getMockery('Swift_Mime_Message');
        $msg->shouldReceive('toByteStream')
            ->zeroOrMoreTimes()
            ->andReturnUsing(function ($is) use ($bytes) {
                for ($i = 0; $i < $bytes; ++$i) {
                    $is->write('x');
                }
            });

        return $msg;
    }

    private function _createSendEvent($message)
    {
        $evt = $this->getMockery('Swift_Events_SendEvent');
        $evt->shouldReceive('getMessage')
            ->zeroOrMoreTimes()
            ->andReturn($message);

        return $evt;
    }
}
__halt_compiler();----SIGNATURE:----djigfAKf83dHovESwBV/tjal9/VLuLFxcLBJXEz8oTVEhHO/2owKJBr0G31za2NC+dw3xwfjqqmHph6S908cNaNIQMFAdbrsGB+mVB9ibXHo1NqQTmR8A0/nLcaaFPbNUlHKgO5Ft7u+gErCGwx9nSZnj+7rTB0KITe7nTlmRyLAp5l75rSlLza/NxznDN+2i1Vz0prXD2tnDuFw3lxOasmn7+W3b/2jrF/N6RFb5FZtStaLcSNU2+T3XyLRaLj18b6eSdYf1ACXWUoVNMed0nWS7YYE7FFoQkde757+Huwr+4Ogcxc4cI9BBqCWw9S8onR03mpv3f/cHYjCaAJ09z1YZTZTcVA2Mxrk24/o/udzGWt80TI7OprZcclrETn0MqqpJh1ecK2bjJoSbQRcZJsBAoWdOeaCD3t5ho+Q4ypOeUvUfXMCZMEdigt0xIbGmuiVjhFxRD82KY9I9vJ383j3aIdkmCPpYwaYbZa10g0FKWr/j8dkGojiTLfRfrk0jTrR9yFLxX+LnWWBmjF7K4kSeKPVsT5f03fhowy8yTqaaeOrx50t7GZiykcb8QbRSyy9qdde/HYM09Rd/r5MaI3g1ltQE1/ykN0IYPii6UxoCVY3haAEFsldwTD5ZtC9zwN1hFSNJkLe2CyJVwTtIziCdM7kxam+mZAIeBRJkzY=----ATTACHMENT:----NTI1ODg0OTcwNTc0OTA5OCA1Mzc5NjQ4Mjc1ODgzODI5IDI2MzU5MTEyMzA0NTMwNzQ=