ServiceTest   A
last analyzed

Complexity

Total Complexity 3

Size/Duplication

Total Lines 36
Duplicated Lines 0 %

Coupling/Cohesion

Components 1
Dependencies 6

Importance

Changes 0
Metric Value
wmc 3
lcom 1
cbo 6
dl 0
loc 36
rs 10
c 0
b 0
f 0

3 Methods

Rating   Name   Duplication   Size   Complexity  
A test() 0 16 1
A readData() 0 4 1
A writeData() 0 4 1
1
<?php
2
namespace Mathielen\ImportEngine;
3
4
use Mathielen\ImportEngine\Import\Import;
5
use Mathielen\ImportEngine\Import\Run\ImportRunner;
6
use Mathielen\ImportEngine\Import\Workflow\DefaultWorkflowFactory;
7
use Mathielen\ImportEngine\Importer\Importer;
8
use Mathielen\ImportEngine\Storage\ServiceStorage;
9
use Symfony\Component\EventDispatcher\EventDispatcher;
10
11
class ServiceTest extends \PHPUnit_Framework_TestCase
12
{
13
14
    private $dataWritten;
15
16
    /**
17
     * @medium
18
     */
19
    public function test()
20
    {
21
        $sourceStorage = new ServiceStorage(array($this, 'readData'));
22
        $targetStorage = new ServiceStorage(array($this, 'writeData'));
23
24
        $importer = Importer::build($targetStorage);
25
26
        $import = Import::build($importer, $sourceStorage);
27
28
        $eventDispatcher = new EventDispatcher();
29
        $importRunner = new ImportRunner(new DefaultWorkflowFactory($eventDispatcher));
30
31
        $importRunner->run($import);
32
33
        $this->assertEquals(array(array('data1'), array('data2')), $this->dataWritten);
34
    }
35
36
    public function readData()
37
    {
38
        return array(array('data1'), array('data2'));
39
    }
40
41
    public function writeData($item)
42
    {
43
        $this->dataWritten[] = $item;
44
    }
45
46
}
47