AmericanExpressTest\HyperledgerFabricClient\Channel\ChannelTest

Complexity

Total Complexity

18

Size/Duplication

Total Lines	203
Duplicated Lines	12.32 %

Importance

Changes	1
Bugs	0	Features	0

17 Methods

Rating	Name	Duplication	Size	Complexity
A	testChannelThrowsExceptionOnEmptyChaincodeName()	0	3	1
A	testCanAddOnePeer()	0	6	1
A	testCanAddManyPeers()	10	10	1
A	testCanSpecifyInitialPeers()	0	10	1
A	createChaincodeHeaderExtension()	0	7	1
A	doChaincodeProposal()	0	10	2
A	testChannelCanProcessChaincodeProposalAndOverrideDefaultPeers()	0	13	1
A	testCanSetManyPeers()	13	13	1
A	testPeersIsEmptyCollectionByDefault()	0	3	1
A	testChannelWillWrapExceptionOnProcessChaincodeProposal()	0	7	1
A	testFailToCreateChannelWithInvalidPeers()	0	3	1
A	testThrowsRuntimeExceptionOnMissingPeers()	0	6	1
A	createChaincodeProposalPayload()	0	4	1
A	setUp()	0	12	1
A	testChannelCanProcessChaincodeProposal()	0	9	1
A	testChannelCanProcessChaincodeProposalWithDefaultPeers()	0	11	1
A	testChannelCanCreateChaincode()	0	6	1

<?php

/**
 * Copyright 2017 American Express Travel Related Services Company, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
 * or implied. See the License for the specific language governing
 * permissions and limitations under the License.
 */

declare(strict_types=1);

namespace AmericanExpressTest\HyperledgerFabricClient\Channel;

use AmericanExpress\HyperledgerFabricClient\Chaincode\Chaincode;
use AmericanExpress\HyperledgerFabricClient\Channel\Channel;
use AmericanExpress\HyperledgerFabricClient\Exception\InvalidArgumentException;
use AmericanExpress\HyperledgerFabricClient\Exception\RuntimeException;
use AmericanExpress\HyperledgerFabricClient\Peer\PeerInterface;
use AmericanExpress\HyperledgerFabricClient\Proposal\ResponseCollection;
use AmericanExpress\HyperledgerFabricClient\Proposal\ProposalProcessorInterface;
use AmericanExpress\HyperledgerFabricClient\ProtoFactory\ChaincodeHeaderExtensionFactory;
use AmericanExpress\HyperledgerFabricClient\ProtoFactory\ChaincodeProposalPayloadFactory;
use AmericanExpress\HyperledgerFabricClient\Transaction\TransactionOptions;
use AmericanExpress\HyperledgerFabricClient\Identity\SerializedIdentityAwareHeaderGeneratorInterface;
use AmericanExpressTest\HyperledgerFabricClient\TestAsset\MockProposalProcessor;
use Hyperledger\Fabric\Protos\Peer\ChaincodeID;
use PHPUnit\Framework\TestCase;

/**
 * @covers \AmericanExpress\HyperledgerFabricClient\Channel\Channel
 */
class ChannelTest extends TestCase
{
    /**
     * @var PeerInterface|\PHPUnit_Framework_MockObject_MockObject
     */
    private $peer;

    /**
     * @var ProposalProcessorInterface|\PHPUnit_Framework_MockObject_MockObject
     */
    private $client;

    /**
     * @var SerializedIdentityAwareHeaderGeneratorInterface|\PHPUnit_Framework_MockObject_MockObject
     */
    private $headerGenerator;

    /**
     * @var Channel
     */
    private $sut;

    protected function setUp()
    {
        $this->client = $this->getMockBuilder(ProposalProcessorInterface::class)
            ->getMock();

        $this->headerGenerator = $this->getMockBuilder(SerializedIdentityAwareHeaderGeneratorInterface::class)
            ->getMock();

        $this->peer = $this->getMockBuilder(PeerInterface::class)
            ->getMock();

        $this->sut = new Channel('foo', $this->client, $this->headerGenerator);
    }

    public function testPeersIsEmptyCollectionByDefault()
    {
        self::assertCount(0, $this->sut->getPeers());
    }

    public function testCanSpecifyInitialPeers()
    {
        $this->sut = new Channel(
            'foo',
            $this->client,
            $this->headerGenerator,
            [$this->peer]
        );
        self::assertCount(1, $this->sut->getPeers());
        self::assertContains($this->peer, $this->sut->getPeers());
    }

    public function testCanAddOnePeer()
    {
        $this->sut->addPeers($this->peer);

        self::assertCount(1, $this->sut->getPeers());
        self::assertContains($this->peer, $this->sut->getPeers());
    }

    public function testCanAddManyPeers()

This method seems to be duplicated in your project.

    {
        $peer = $this->getMockBuilder(PeerInterface::class)
            ->getMock();

        $this->sut->addPeers($this->peer, $peer);

        self::assertCount(2, $this->sut->getPeers());
        self::assertContains($this->peer, $this->sut->getPeers());
        self::assertContains($peer, $this->sut->getPeers());
    }

    public function testCanSetManyPeers()

This method seems to be duplicated in your project.

    {
        $peer = $this->getMockBuilder(PeerInterface::class)
            ->getMock();

        $this->sut->setPeers([
            $this->peer,
            $peer,
        ]);

        self::assertCount(2, $this->sut->getPeers());
        self::assertContains($this->peer, $this->sut->getPeers());
        self::assertContains($peer, $this->sut->getPeers());
    }

    public function testChannelCanCreateChaincode()
    {
        $chainCode = $this->sut->getChaincode('FizBuz');

        self::assertInstanceOf(Chaincode::class, $chainCode);
        self::assertSame($chainCode->getName(), 'FizBuz');
    }

    /**
     * @expectedException InvalidArgumentException
     */
    public function testChannelThrowsExceptionOnEmptyChaincodeName()
    {
        $this->sut->getChaincode('');
    }

    public function testChannelCanProcessChaincodeProposal()
    {
        $this->client->method('processProposal')

The method method() does not exist on AmericanExpress\HyperledgerFabricClient\Proposal\ProposalProcessorInterface.

            ->willReturn($proposalResponse = new ResponseCollection());

        $result = $this->doChaincodeProposal(new TransactionOptions([
            'peers' => [$this->peer],
        ]));
        self::assertSame($proposalResponse, $result);
    }

    /**
     * @expectedException RuntimeException
     */
    public function testChannelWillWrapExceptionOnProcessChaincodeProposal()
    {
        $this->client->method('processProposal')
            ->willThrowException(new InvalidArgumentException());

        $this->doChaincodeProposal(new TransactionOptions([
            'peers' => [$this->peer],
        ]));
    }

    public function testChannelCanProcessChaincodeProposalWithDefaultPeers()
    {
        $this->sut = new Channel(
            'foo',
            $processor = new MockProposalProcessor(),
            $this->headerGenerator,
            [$this->peer]
        );

        $this->doChaincodeProposal(null, $this->sut);
        self::assertContains($this->peer, $processor->getTransactionOptions()->getPeers());
    }

    public function testChannelCanProcessChaincodeProposalAndOverrideDefaultPeers()
    {
        $this->sut = new Channel(
            'foo',
            $processor = new MockProposalProcessor(),
            $this->headerGenerator
        );

        $transactionOptions = new TransactionOptions();
        $transactionOptions->addPeers($this->peer);

        $this->doChaincodeProposal($transactionOptions);
        self::assertContains($this->peer, $processor->getTransactionOptions()->getPeers());
    }

    /**
     * @expectedException RuntimeException
     */
    public function testThrowsRuntimeExceptionOnMissingPeers()
    {
        $this->client->method('processProposal')
            ->willReturn($proposalResponse = new ResponseCollection());

        $this->doChaincodeProposal();
    }

    public function createChaincodeHeaderExtension()
    {
        return ChaincodeHeaderExtensionFactory::fromChaincodeId(
            (new ChaincodeID())
                ->setPath('FizBuz')
                ->setName('FooBar')
                ->setVersion('v12.34')
        );
    }

    public function createChaincodeProposalPayload()
    {
        return ChaincodeProposalPayloadFactory::fromChaincodeInvocationSpecArgs([
            'foo' => 'bar',
        ]);
    }

    public function doChaincodeProposal(TransactionOptions $options = null, Channel $channel = null)
    {
        if ($channel === null) {
            $channel = $this->sut;
        }

        return $channel->processChaincodeProposal(
            $this->createChaincodeProposalPayload(),
            $this->createChaincodeHeaderExtension(),
            $options
        );
    }

    /**
     * @expectedException \AmericanExpress\HyperledgerFabricClient\Exception\InvalidArgumentException
     */
    public function testFailToCreateChannelWithInvalidPeers()
    {
        new Channel('foo', $this->client, $this->headerGenerator, [new \stdClass()]);
    }
}