<?php // core/Infrastructure/Queries/CvsProduct.php

namespace Search\Infrastructure\Queries;

use Bootake\SearchService\Thrift\Search\Product as ThriftProduct;
use Bootake\SearchService\Thrift\Search\SearchFilter;
use Bootake\SearchService\Thrift\Search\Section;
use Bootake\SearchService\Thrift\Search\SectionType;
use Illuminate\Support\Collection;
use Search\Application\OutMappers\ProductMapper;
use Search\Domain\Product;

class CvsProduct extends BaseQuery implements Queryable
{
    public function model()
    {
        // 엘로퀀트 모델 인스턴스다. 모델에 선언한 몇 가지 속성에 접근하기 위해서 필요하다.
        // BaseQuery라는 추상 부모 클래스에서 abstract function으로 이 메서드의 구현을 강제하고 있다.
        return new Product;
    }

    public function query(SearchFilter $sf, int $regionId, $offset = 0, $limit = 50)
    {
        // Elastic Search로 부터 받은 검색 결과를 $rawResults에 담았다.
        $this->rawResults = $this->client->search(
            $this->buildParam($sf, $regionId)
        );

        // 검색 결과는 여러 상점에서 제폼을 검색하므로 동일 제품이 검색 결과에 나타난다.
        // Elastic Search는 이미 Aggregation(GROUP BY)된 결과를 반환하는 것이 아니라,
        // 특정 필드 값에 따라 Aggregation했을 때의 ID값을 결과에 포함하여 반환한다.
        // 해서 실제 필요한 개수보다 더 많은 레코드를 요청하고, 필요한 레코드만 골라낸 후 페이징을 해야 한다.
        // 부모 클래스의 fetch() 메서드가 이 역할을 담당한다.
        $filtered = $this->fetch($this->model->distinctAttribute(), $offset, $limit);

        return $this->buildSection($filtered, $sf, $regionId);
    }

    protected function buildParam(SearchFilter $sf, $regionId)
    {
        // Elastic Search에 전달할 검색 파라미터다.
        return [
            // ...
        ];
    }

    protected function buildSection(Collection $payload, SearchFilter $sf, int $regionId)
    {
        // HTTP 응답으로 반환할 필드만 골라서 맵핑한다.
        // 이 과정에서 런타임에 계산해야 할 값들을 추가하거나, 데이터를 가공하거나 캐스팅하기도 한다.
        $mapped = (new ProductMapper)->mapCollection($payload, $sf, $regionId);
        
        // 정렬한다. 이 포스트의 대상이 되는 문제의 메서드가 여기서 호출된다.
        // 정렬한 결과를 미리 정의한 ThriftProduct Type에 맞도록 맵핑했다. 
        $sorted = $this->sortByStoreStatusAndCanBuyNow($mapped)
                       ->map(function (array $product) {
                           return new ThriftProduct($product);
                       })
                       ->values()->all();

        // $sorted 배열은 [ThriftProduct, ThriftProduct, ...] 형식인데,
        // 얘를 다시 Thrift 인터페이스에서 정의한 Section Type으로 랩핑한다.
        // getTotal()등의 메서드는 부모 클래스에 있다.
        return new Section([
            'type' => SectionType::PRODUCT,
            'matchedCount' => $this->getTotal(),
            'perPage' => $this->perPage(),
            'currentPage' => $this->resolveCurrentPage(),
            'stores' => [],
            'products' => $sorted,
        ]);
    }

    protected function sortByStoreStatusAndCanBuyNow(Collection $unsorted)
    {
        return $unsorted->sortBy(function($product) {
            // 'canBuyNow' 속성은 불리언이라 정렬을 위해 정수 값으로 바꾸어, $canBuyNow 변수에 할당했다.
            // 'canBuyNow'는 지금 장바구니에 담긴 상품과 같은 상점의 제품이란 의미다.
            $canBuyNow = $product['canBuyNow'] ? 1 : 2;

            // 제품이 속한 상점의 상태(영업 중 -> 배송 준비 중 -> 영업 준비 중)와
            // $canBuyNow를 복합해서 정렬해야 하므로 두 개 값을 결합했다.
            // 즉, 지금 상점이 영업 중이고 장바구니에 담긴 상품과 같은 상품이라 바로 구매 가능한 상품이 우선 노출된다.
            return sprintf('%d%d', $product['storeStatus'], $canBuyNow);
        });
    }
}

<?php // tests/TestCase.php

namespace Test;

class TestCase extends \Laravel\Lumen\Testing\TestCase
{
    public function createApplication()
    {
        return require __DIR__.'/../bootstrap/app.php';
    }

    protected static function getTestableMethod($class, $name) {
        // $class의 Reflection 인스턴스를 만든다.
        $reflection = new \ReflectionClass($class);
        
        // $name 메서드를 접근 가능하도록 한다.
        $method = $reflection->getMethod($name);
        $method->setAccessible(true);

        // Reflection된 클래스가 아니라, 메서드를 반환한다.
        return $method;
    }
}

<?php // tests/Unit/QueryTest.php

namespace Test\Unit;

use Bootake\SearchService\Thrift\Search\StoreStatus;
use Elasticsearch\ClientBuilder;
use Search\Infrastructure\Queries\CvsProduct;

class QueryTest extends \Test\TestCase
{
    /** @test */
    function cvs_products_collection_should_be_sorted_by_its_parent_store_status()
    {
        $productCollection = collect([
            ['storeStatus' => StoreStatus::CLOSED, 'canBuyNow' => true],
            ['storeStatus' => StoreStatus::CLOSED, 'canBuyNow' => false],
            ['storeStatus' => StoreStatus::PREPARING, 'canBuyNow' => true],
            ['storeStatus' => StoreStatus::PREPARING, 'canBuyNow' => false],
            ['storeStatus' => StoreStatus::OPENED, 'canBuyNow' => true],
            ['storeStatus' => StoreStatus::OPENED, 'canBuyNow' => false],
        ]);

        // 1절에서 설명한 테스트 타켓 클래스의 인스턴스를 만든다.
        $cvsProductQuery = new CvsProduct(
            ClientBuilder::fromConfig([/*...*/])
        );

        // 테스트 헬퍼를 이용해서 다른 클래스에서 접근할 수 있는 메서드를 가져온다. 
        $method = static::getTestableMethod(
            CvsProduct::class,
            'sortByStoreStatusAndCanBuyNow'
        );

        // 메서드를 호출하고 반환값을 저장한다.
        $response = $method->invokeArgs($cvsProductQuery, [$productCollection]);

        $this->assertEquals(
            ['storeStatus' => StoreStatus::OPENED, 'canBuyNow' => true],
            $response->first()
        );

        $this->assertEquals(
            ['storeStatus' => StoreStatus::CLOSED, 'canBuyNow' => false],
            $response->last()
        );
    }
}