Vox\Webservice\Transaction

Complexity

Total Complexity

7

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	rollback()	0	11	3
A	addUpdated()	0	3	1
A	addCreated()	0	3	1
A	__construct()	0	9	1
A	addDeleted()	0	3	1

<?php

namespace Vox\Webservice;

use Metadata\MetadataFactoryInterface;
use SplObjectStorage;

/**
 * 
 * @author Jhonatan Teixeira <jhonatan.teixeira@gmail.com>
 */
class Transaction implements TransactionInterface
{
    use MetadataTrait;

The trait Vox\Webservice\MetadataTrait requires the property $id which is not provided by Vox\Webservice\Transaction.

    
    /**
     * @var SplObjectStorage
     */
    private $storage;
    
    /**
     * @var TransferManagerInterface
     */
    private $transferManager;
    
    /**
     * @var WebserviceClientInterface
     */
    private $webServiceClient;
    
    private $states = [
        'created' => 'delete',
        'updated' => 'put',
        'deleted' => 'post',
    ];
    
    public function __construct(
        TransferManagerInterface $transferManager, 
        WebserviceClientInterface $webServiceClient,
        MetadataFactoryInterface $metadataFactory
    ) {
        $this->storage          = new SplObjectStorage();
        $this->transferManager  = $transferManager;
        $this->webServiceClient = $webServiceClient;
        $this->metadataFactory  = $metadataFactory;
    }

    public function addCreated($object)
    {
        $this->storage[$object] = $this->states['created'];
    }
    
    public function addUpdated($object)
    {
        $this->storage[$object] = $this->states['updated'];
    }
    
    public function addDeleted($object)
    {
        $this->storage[$object] = $this->states['deleted'];
    }
    
    public function rollback()
    {
        foreach ($this->storage as $object) {
            $state = $this->storage->getInfo();
            $args  = [$object];
            
            if ($state == 'delete') {
                $args= [get_class($object), $this->getIdValue($object)];
            }
            
            call_user_func([$this->webServiceClient, $state], ...$args);
        }
    }
}