MessageApp\Message\Sender\TransactionalMessageSender

Complexity

Total Complexity

10

Size/Duplication

Total Lines	94
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	send()	0	4	1
A	beginTransaction()	0	9	2
A	commit()	0	17	4
A	rollback()	0	9	2

<?php

namespace MessageApp\Message\Sender;

use MessageApp\Message;
use RemiSan\TransactionManager\Exception\BeginException;
use RemiSan\TransactionManager\Exception\CommitException;
use RemiSan\TransactionManager\Exception\NoRunningTransactionException;
use RemiSan\TransactionManager\Exception\RollbackException;
use RemiSan\TransactionManager\Transactional;

class TransactionalMessageSender implements MessageSender, Transactional
{
    /**
     * @var MessageSender
     */
    private $messageSender;

    /**
     * @var Message[]
     */
    private $messages;

    /**
     * @var boolean
     */
    private $transactionRunning;

    /**
     * @param MessageSender $messageSender
     */
    public function __construct(MessageSender $messageSender)
    {
        $this->messageSender = $messageSender;
        $this->messages = [];
        $this->transactionRunning = false;
    }

    /**
     * Send a message
     *
     * @param  Message $message
     * @param  object $context
     * @return void
     */
    public function send(Message $message, $context)
    {
        $this->messages[] = [ $message, $context ];
    }

    /**
     * Open transaction.
     *
     * @throws BeginException
     */
    public function beginTransaction()
    {
        if ($this->transactionRunning) {
            throw new BeginException('Transaction already running');
        }

        $this->messages = [];
        $this->transactionRunning = true;
    }

    /**
     * Commit transaction.
     *
     * @throws CommitException
     * @throws NoRunningTransactionException
     */
    public function commit()
    {
        if (!$this->transactionRunning) {
            throw new NoRunningTransactionException();
        }

        try {
            foreach ($this->messages as $message) {
                $this->messageSender->send($message[0], $message[1]);
            }
        } catch (\Exception $e) {
            throw new CommitException('Error during commit', 0, $e);
        }

        $this->messages = [];
        $this->transactionRunning = false;
    }

    /**
     * Rollback transaction.
     *
     * @throws RollbackException
     * @throws NoRunningTransactionException
     */
    public function rollback()
    {
        if (!$this->transactionRunning) {
            throw new NoRunningTransactionException();
        }

        $this->messages = [];
        $this->transactionRunning = false;
    }
}