S3ClientStub::throw500ExceptionWhenExecutingCommand() - Code Metrics - Inspection of "Added test for rawlist connection checker." - thephpleague/flysystem-aws-s3-v3 - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 2.x ( 741cb0...393be3 )

by Frank

created 2020-10-13 12:47 UTC

throw500ExceptionWhenExecutingCommand() A

↳ Parent: S3ClientStub

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	7
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	1

<?php

declare(strict_types=1);

namespace League\Flysystem\AwsS3V3;

use Aws\Command;
use Aws\CommandInterface;
use Aws\S3\Exception\S3Exception;
use Aws\S3\S3ClientInterface;
use Aws\S3\S3ClientTrait;
use GuzzleHttp\Psr7\Response;

/**
 * @codeCoverageIgnore
 */
class S3ClientStub implements S3ClientInterface
{
    use S3ClientTrait;

    /**
     * @var S3ClientInterface
     */
    private $actualClient;

    /**
     * @var S3Exception[]
     */
    private $stagedExceptions = [];

    public function __construct(S3ClientInterface $client)
    {
        return $this->actualClient = $client;

    }

    public function failOnNextCopy(): void
    {
        $this->throwExceptionWhenExecutingCommand('CopyObject');
    }

    public function throwExceptionWhenExecutingCommand(string $commandName, S3Exception $exception = null): void
    {
        $this->stagedExceptions[$commandName] = $exception ?: new S3Exception($commandName, new Command($commandName));
    }

    public function throw500ExceptionWhenExecutingCommand(string $commandName): void
    {
        $response = new Response(500);
        $exception = new S3Exception($commandName, new Command($commandName), compact('response'));

        $this->throwExceptionWhenExecutingCommand($commandName, $exception);
    }

    public function execute(CommandInterface $command)
    {
        return $this->executeAsync($command)->wait();
    }

    public function getCommand($name, array $args = [])
    {
        return $this->actualClient->getCommand($name, $args);
    }

    public function getHandlerList()
    {
        return $this->actualClient->getHandlerList();
    }

    public function getIterator($name, array $args = [])
    {
        return $this->actualClient->getIterator($name, $args);
    }

    public function __call($name, array $arguments)
    {
        return $this->actualClient->__call($name, $arguments);
    }

    public function executeAsync(CommandInterface $command)
    {
        if (array_key_exists($name = $command->getName(), $this->stagedExceptions)) {
            $exception = $this->stagedExceptions[$name];
            unset($this->stagedExceptions[$name]);
            throw $exception;
        }

        return $this->actualClient->executeAsync($command);
    }

    public function getCredentials()
    {
        return $this->actualClient->getCredentials();
    }

    public function getRegion()
    {
        return $this->actualClient->getRegion();
    }

    public function getEndpoint()
    {
        return $this->actualClient->getEndpoint();
    }

    public function getApi()
    {
        return $this->actualClient->getApi();
    }

    public function getConfig($option = null)
    {
        return $this->actualClient->getConfig($option);
    }

    public function getPaginator($name, array $args = [])
    {
        return $this->actualClient->getPaginator($name, $args);
    }

    public function waitUntil($name, array $args = [])
    {
        $this->actualClient->waitUntil($name, $args);
    }

    public function getWaiter($name, array $args = [])
    {
        return $this->actualClient->getWaiter($name, $args);
    }

    public function createPresignedRequest(CommandInterface $command, $expires, array $options = [])
    {
        return $this->actualClient->createPresignedRequest($command, $expires, $options);
    }

    public function getObjectUrl($bucket, $key)
    {
        return $this->actualClient->getObjectUrl($bucket, $key);
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace League\Flysystem\AwsS3V3;
6
7			use Aws\Command;
8			use Aws\CommandInterface;
9			use Aws\S3\Exception\S3Exception;
10			use Aws\S3\S3ClientInterface;
11			use Aws\S3\S3ClientTrait;
12			use GuzzleHttp\Psr7\Response;
13
14			/**
15			* @codeCoverageIgnore
16			*/
17			class S3ClientStub implements S3ClientInterface
18			{
19			use S3ClientTrait;
20
21			/**
22			* @var S3ClientInterface
23			*/
24			private $actualClient;
25
26			/**
27			* @var S3Exception[]
28			*/
29			private $stagedExceptions = [];
30
31			public function __construct(S3ClientInterface $client)
32			{
33			return $this->actualClient = $client;
			0 ignored issues – show Bug introduced 2020-10-13 12:48 UTC by Report Bug Copy Issue Report Constructors do not have meaningful return values, anything that is returned from here is discarded. Are you sure this is correct? Loading history...
34			}
35
36			public function failOnNextCopy(): void
37			{
38			$this->throwExceptionWhenExecutingCommand('CopyObject');
39			}
40
41			public function throwExceptionWhenExecutingCommand(string $commandName, S3Exception $exception = null): void
42			{
43			$this->stagedExceptions[$commandName] = $exception ?: new S3Exception($commandName, new Command($commandName));
44			}
45
46			public function throw500ExceptionWhenExecutingCommand(string $commandName): void
47			{
48			$response = new Response(500);
49			$exception = new S3Exception($commandName, new Command($commandName), compact('response'));
50
51			$this->throwExceptionWhenExecutingCommand($commandName, $exception);
52			}
53
54			public function execute(CommandInterface $command)
55			{
56			return $this->executeAsync($command)->wait();
57			}
58
59			public function getCommand($name, array $args = [])
60			{
61			return $this->actualClient->getCommand($name, $args);
62			}
63
64			public function getHandlerList()
65			{
66			return $this->actualClient->getHandlerList();
67			}
68
69			public function getIterator($name, array $args = [])
70			{
71			return $this->actualClient->getIterator($name, $args);
72			}
73
74			public function __call($name, array $arguments)
75			{
76			return $this->actualClient->__call($name, $arguments);
77			}
78
79			public function executeAsync(CommandInterface $command)
80			{
81			if (array_key_exists($name = $command->getName(), $this->stagedExceptions)) {
82			$exception = $this->stagedExceptions[$name];
83			unset($this->stagedExceptions[$name]);
84			throw $exception;
85			}
86
87			return $this->actualClient->executeAsync($command);
88			}
89
90			public function getCredentials()
91			{
92			return $this->actualClient->getCredentials();
93			}
94
95			public function getRegion()
96			{
97			return $this->actualClient->getRegion();
98			}
99
100			public function getEndpoint()
101			{
102			return $this->actualClient->getEndpoint();
103			}
104
105			public function getApi()
106			{
107			return $this->actualClient->getApi();
108			}
109
110			public function getConfig($option = null)
111			{
112			return $this->actualClient->getConfig($option);
113			}
114
115			public function getPaginator($name, array $args = [])
116			{
117			return $this->actualClient->getPaginator($name, $args);
118			}
119
120			public function waitUntil($name, array $args = [])
121			{
122			$this->actualClient->waitUntil($name, $args);
123			}
124
125			public function getWaiter($name, array $args = [])
126			{
127			return $this->actualClient->getWaiter($name, $args);
128			}
129
130			public function createPresignedRequest(CommandInterface $command, $expires, array $options = [])
131			{
132			return $this->actualClient->createPresignedRequest($command, $expires, $options);
133			}
134
135			public function getObjectUrl($bucket, $key)
136			{
137			return $this->actualClient->getObjectUrl($bucket, $key);
138			}
139			}
140

thephpleague / flysystem-aws-s3-v3

Push — 2.x ( 741cb0...393be3 )

throw500ExceptionWhenExecutingCommand() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like