Authorize.php

<?php

abstract class Payment_Service_Command_Authorize implements Orderprocessing_Service_Interface_Command
{
    /**
     * @param Orderprocessing_Service_Interface_CommandParameter $parameter
     *
     * @see Orderprocessing_Service_Interface_Command::__invoke()
     */
    public function __invoke(Orderprocessing_Service_Interface_CommandParameter $parameter)
    {
        $start = microtime(true);
        $workPackage = $parameter->getWorkPackage();
        /* @var $context PaymentExt_Service_Context */
        $context = $parameter->getContext('PaymentExt_Service_Context');
        $processedItems = $parameter->getProcessedItems();
        $orderCollection = $workPackage->getOrderCollection();
        foreach ($processedItems->getAllOrdersWithoutFailedItems($orderCollection) as $order) {
            $paymentMethod = $context->getPaymentMethod($order);
            if ($paymentMethod->canAuthorize()) {
                $paymentResult = $paymentMethod->authorize($order);
            } else {
                $paymentResult = new PaymentExt_Service_Result_Successful();
            }
            $context->setPaymentResult($order, $paymentResult);
            if ($paymentResult instanceof Bob_Api_Result_Successful) {
                $processedItems->setOrderSuccessful($order);
            } else {
                $processedItems->setOrderFailed($order);
            }
        }
        $this->publishPaymentAttemptEventAsynchronously($orderCollection);
        HF()->statsd()->timing('fraud-detection.payment.timing', microtime(true) - $start);
    }

    /**
     * @param Transfer_Sales_OrderCollection $orderCollection
     */
    private function publishPaymentAttemptEventAsynchronously(\Transfer_Sales_OrderCollection $orderCollection)
    {
        HF()->log()->error('Starting asynchronous shit.');
        \Icicle\Coroutine\create(function () use ($orderCollection) {
            HF()->log()->error('Created (and started) the co routine');
            $fork = \Icicle\Concurrent\Forking\Fork::spawn(function () use ($orderCollection) {
                HF()->log()->error('Created a fork');
                $start = microtime();
                try {
                    $publisher = new PaymentExt_Service_Event_Publisher(
                        new Bi_Service_Adapter_RabbitMQProducer('OrdersExchange'),
                        $orderCollection
                    );
                    $publisher->publishInBulk();
                } catch (\Exception $e) {
                    HF()->log()->exception($e);
                }
                HF()->statsd()->timing('fraud-detection.payment-async.timing', microtime(true) - $start);
            });

            yield $fork->join();
        });
        HF()->log()->error('Run the loop.');

        \Icicle\Loop\run();
    }
}