koel/tests/Integration/Services/S3ServiceTest.php

<?php

namespace Tests\Integration\Services;

use App\Models\Song;
use App\Services\S3Service;
use Aws\CommandInterface;
use Aws\S3\S3ClientInterface;
use GuzzleHttp\Psr7\Request;
use Illuminate\Cache\Repository as Cache;
use Mockery;
use Mockery\MockInterface;
use Tests\TestCase;

class S3ServiceTest extends TestCase
{
    /**
     * @var S3ClientInterface|MockInterface
     */
    private $s3Client;

    /**
     * @var Cache|MockInterface
     */
    private $cache;

    /**
     * @var S3Service
     */
    private $s3Service;

    public function setUp()
    {
        parent::setUp();
        $this->s3Client = Mockery::mock(S3ClientInterface::class);
        $this->cache = Mockery::mock(Cache::class);
        $this->s3Service = new S3Service($this->s3Client, $this->cache);
    }

    public function testGetSongPublicUrl(): void
    {
        $song = factory(Song::class)->create(['path' => 's3://foo/bar']);

        $cmd = Mockery::mock(CommandInterface::class);
        $this->s3Client->shouldReceive('getCommand')
            ->with('GetObject', [
                'Bucket' => 'foo',
                'Key' => 'bar',
            ])
            ->andReturn($cmd);

        $request = Mockery::mock(Request::class, ['getUri' => 'https://aws.com/foo.mp3']);

        $this->s3Client->shouldReceive('createPresignedRequest')
            ->with($cmd, '+1 hour')
            ->andReturn($request);

        $this->cache->shouldReceive('remember')
            ->once()
            ->andReturn('https://aws.com/foo.mp3');

        self::assertSame('https://aws.com/foo.mp3', $this->s3Service->getSongPublicUrl($song));
    }
}