UploadCommandHandler::sourceToStream() - Code Metrics - sugeng-sulistiyawan/yii2-aws-s3 - Measure and Improve Code Quality continuously with Scrutinizer

UploadCommandHandler::sourceToStream() A
last analyzed 2023-05-06 05:03 UTC

↳ Parent: UploadCommandHandler

Complexity

Conditions	2
Paths	2

Size

Total Lines	7
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

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

<?php

namespace diecoding\aws\s3\handlers;

use diecoding\aws\s3\commands\UploadCommand;
use diecoding\aws\s3\base\handlers\Handler;
use GuzzleHttp\Psr7\Utils;
use Psr\Http\Message\StreamInterface;

/**
 * Class UploadCommandHandler
 *
 * @package diecoding\aws\s3\handlers
 */
final class UploadCommandHandler extends Handler
{
    /**
     * @param \diecoding\aws\s3\commands\UploadCommand $command
     *
     * @return \Aws\ResultInterface|\GuzzleHttp\Promise\PromiseInterface
     */
    public function handle(UploadCommand $command)
    {
        $source = $this->sourceToStream($command->getSource());
        $options = array_filter($command->getOptions());

        $promise = $this->s3Client->uploadAsync(
            $command->getBucket(),
            $command->getFilename(),
            $source,
            $command->getAcl(),
            $options
        );

        return $command->isAsync() ? $promise : $promise->wait();
    }

    /**
     * Create a new stream based on the input type.
     *
     * @param resource|string|StreamInterface $source path to a local file, resource or stream
     *
     * @return StreamInterface
     */
    protected function sourceToStream($source): StreamInterface
    {
        if (is_string($source)) {
            $source = Utils::tryFopen($source, 'r+');
        }

        return Utils::streamFor($source);
    }
}


1			<?php
2
3			namespace diecoding\aws\s3\handlers;
4
5			use diecoding\aws\s3\commands\UploadCommand;
6			use diecoding\aws\s3\base\handlers\Handler;
7			use GuzzleHttp\Psr7\Utils;
8			use Psr\Http\Message\StreamInterface;
9
10			/**
11			* Class UploadCommandHandler
12			*
13			* @package diecoding\aws\s3\handlers
14			*/
15			final class UploadCommandHandler extends Handler
16			{
17			/**
18			* @param \diecoding\aws\s3\commands\UploadCommand $command
19			*
20			* @return \Aws\ResultInterface\|\GuzzleHttp\Promise\PromiseInterface
21			*/
22			public function handle(UploadCommand $command)
23			{
24			$source = $this->sourceToStream($command->getSource());
25			$options = array_filter($command->getOptions());
26
27			$promise = $this->s3Client->uploadAsync(
28			$command->getBucket(),
29			$command->getFilename(),
30			$source,
31			$command->getAcl(),
32			$options
33			);
34
35			return $command->isAsync() ? $promise : $promise->wait();
36			}
37
38			/**
39			* Create a new stream based on the input type.
40			*
41			* @param resource\|string\|StreamInterface $source path to a local file, resource or stream
42			*
43			* @return StreamInterface
44			*/
45			protected function sourceToStream($source): StreamInterface
46			{
47			if (is_string($source)) {
48			$source = Utils::tryFopen($source, 'r+');
49			}
50
51			return Utils::streamFor($source);
52			}
53			}
54

sugeng-sulistiyawan / yii2-aws-s3

UploadCommandHandler::sourceToStream() A last analyzed 2023-05-06 05:03 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

UploadCommandHandler::sourceToStream() A
last analyzed 2023-05-06 05:03 UTC