<?php // tests/ThriftClientTest.php

use App\Post as EloquentPost;
use Appkr\Thrift\Post\Post as ThriftPost;
use Appkr\Thrift\Post\PostServiceClient;
use Appkr\Thrift\Post\QueryFilter;
use Illuminate\Foundation\Testing\DatabaseTransactions;
use Thrift\Protocol\TJSONProtocol;
use Thrift\Transport\THttpClient;

/**
 * @property \Appkr\Thrift\Post\PostServiceClient client
 */
class ThriftClientTest extends TestCase
{
    // 테스트 중에 생성된 데이터를 테스트가 끝나면 롤백해주는 라라벨의 내장 Trait다.  
    use DatabaseTransactions;

    public function setUp()
    {
        parent::setUp();

        $transport = new THttpClient(
            'localhost',
            '8000',
            'api/posts'
        );

        $protocol = new TJSONProtocol($transport);

        $this->client = new PostServiceClient($protocol);

        // 테스트를 위해 레코드 20개를 만든다.
        // testAll, testFind, testStore 등 테스트 메서드가 세 개이므로 총 세 번 호출된다.
        factory(EloquentPost::class, 20)->create();
    }

    public function testAll()
    {
        $queryFilter = new QueryFilter([
            'keyword' => 'Lorem',
            'sortBy' => 'id',
            'sortDirection' => 'desc'
        ]);

        $response = $this->client->all($queryFilter, 0, 10);

        print_r($response);

        if (count($response)) {
            // Lorem이란 텍스트를 가진 레코드가 없을 수도 있어, if 절에 넣었다.
            // 응답으로 받은 컬렉션의 요소가 ThriftPost 객체인지 검사한다(IDL에 그렇게 정의했음).
            $this->assertInstanceOf(ThriftPost::class, $response[0]);
        }
    }

    public function testFind()
    {
        $response = $this->client->find(1);

        print_r($response);

        $this->assertInstanceOf(ThriftPost::class, $response);
        $this->assertEquals($response->id, 1);
    }

    public function testStore()
    {
        $response = $this->client->store(
            'foo',
            'Lorem content'
        );

        print_r($response);

        $this->assertInstanceOf(ThriftPost::class, $response);
        $this->assertEquals($response->title, 'foo');
    }
}

<?php // app/Services/PostService.php

namespace App\Services;

use App\Post as EloquentPost;
use Appkr\Thrift\Post\Post as ThriftPost;
use Appkr\Thrift\Post\PostField;
use Appkr\Thrift\Post\PostServiceIf;
use Appkr\Thrift\Post\QueryFilter;

class PostService implements PostServiceIf
{
    public function all(QueryFilter $qf, $offset, $limit)
    {
        $builder = new EloquentPost;

        // $qf 변수는 QueryFilter 객체다.
        // $qf 변수는 라라벨에서 쓰던 Request 객체라고 생각하면 되는데,
        // Thrift에서는 클라이언트가 IDL에 정의한 객체(struct)를 넘기므로
        // 서버에서 $qf->keyword처럼 객체 액세스를 할 수 있다.
        if ($qf->keyword) {
            // 고급 DB를 사용한다면 Full text BOOLEAN MATCH를 사용할 수 있을 것이다.
            // 여기서는 간략히 QueryFilter를 사용하는 컨셉만 소개한다.
            $builder->where('title', 'like', "%{$qf->keyword}%");
        }

        $posts = $builder->orderBy($qf->sortBy, $qf->sortDirection)
                         ->offset($offset)
                         ->limit($limit)
                         ->get();

        return $posts->map(function ($post) {
            return new ThriftPost($post->toArray());
        })->all();
    }

    public function find($id)
    {
        // 1부와 동일 ...
    }

    public function store($title, $content)
    {
        // 1부와 동일 ...
    }
}

<?php // app/Http/Controllers/PostsController

namespace App\Http\Controllers;

use App\Services\PostService;
use App\Thrift\BarMiddleware;
use App\Thrift\FooMiddleware;
use App\Thrift\ThriftResponse;
use App\Thrift\ThriftServiceHandler;
use Appkr\Thrift\Post\PostServiceProcessor;
use Illuminate\Http\Request;

class PostsController extends Controller
{
    public function handle(Request $request, $format = 'json')
    {
        // 그림에서 본 것처럼 Thrift 요청은 바깥쪽에 있는 FooMiddleware를 먼저 거치게 된다.
        $middleware = new FooMiddleware(
            new BarMiddleware
        );

        $service = new PostService();
        // PostService를 앞서 만든 미들웨어로 싸서 ThriftServiceHandler를 만들었다. 
        $handler = new ThriftServiceHandler($service, $middleware);
        // 이제 Thrift 컴파일러가 만들어준 프로세서에 미들웨어로 여러겹 포장한 서비스를 넘겨서 처리를 위임한다.
        $processor = new PostServiceProcessor($handler);

        return ThriftResponse::make($request, $processor, $format);
    }
}

<?php // app/Thrift/ThriftServiceHandler.php

namespace App\Thrift;

/**
 * @property service
 * @property \App\Thrift\ThriftMiddleware|null middleware
 */
class ThriftServiceHandler
{
    public function __construct($service, ThriftMiddleware $middleware = null)
    {
        $this->service = $service;
        $this->middleware = $middleware;
    }
    
    // 가령 클라이언트가 all API를 호출했다면, PostServiceProcessor가 PostService::all()
    // 메서드를 호출할 때 클라이언트가 제시한 인자인 QueryParameter 객체와, offset 0, limit 10을
    // 넘겨준다. 그런데, 앞 절에서 PostServiceProcessor에 넘겨 준 것은 PostService가 아니라
    // 이 서비스를 미들웨어로 몇 꺼풀 싸 놓은 ThriftServiceHandler를 넘겼다.
    // ThriftServiceHandler에는 all 메서드가 없다. 일치하는 메서드가 없으므로 __call 메서드가 호출된다. 
    public function __call($method, $arguments)
    {
        // 생성자를 통해 초기화한 미들웨어가 있으면 이 로직을 수행한다.
        if ($this->middleware) {
            // 등록된 미들웨어의 handle 메서드를 호출한다. 1절의 테스트를 가정하면,
            // 이 때 PostService 객체, all, [QueryFilter 객체, 0, 10] 등을 인자로 넘기게 된다.
            return $this->middleware->handle($this->service, $method, $arguments);
        }

        // 등록된 미들웨어가 없으면 클라이언트가 전달한 인자로 PostService::all 메서드를 바로 호출한다. 
        return call_user_func_array([$this->service, $method], $arguments);
    }
}

<?php // app/Thrift/FooMiddleware.php

namespace App\Thrift;

use Appkr\Thrift\Errors\ErrorCode;
use Appkr\Thrift\Errors\SystemException;
use Appkr\Thrift\Errors\UserException;
use Log;

class FooMiddleware extends ThriftMiddleware
{
    // ThriftServiceHandler::__call에서 이 메서드를 호출했다. 
    public function handle($service, $method, $arguments)
    {
        try {
            // 컨셉만 보여 주기 위해서 로그에 메시지를 쓰는 것으로 대신한다.
            Log::info('handling thrift request', [func_get_args(), __METHOD__]);

            // 책임 연쇄 패턴에서 가장 중요한 부분이다. next 메서드는 다음 절에서 살펴본다.
            // 우리 예제에서 next는 BarMiddleware다.
            return $this->next($service, $method, $arguments);
        } catch (SystemException $e) {
            // 추가적인 예외 처리를 여기서 한다.
            // SystemException은 Thrift IDL에 정의한 struct므로 클라이언트와 연결된 프로토콜을 통해
            // 안전하게 전달된다. 클라이언트 측에서도 SystemException으로 역 직렬화되어 바로 사용할 수 있다.
            throw $e;
        } catch (UserException $e) {
            throw $e;
        } catch (\Exception $e) {
            // SystemException 및 UserException을 제외한 라라벨의 일반적인 예외를 핸들링한다.
            // 이 예제에서는 로그에 디버그 메시지를 쓴다. Thrift가 없는 라라벨 프로젝트라면
            // app/Exceptions/Handler.php의 전역 예외 처리기가 예외를 소비했을 것이다.
            // 라라벨의 Handler::report 메서드를 대신하는 역할을 한다.
            Log::debug(sprintf(
                "%s \n\n%s \n%s:%d \n\n%s",
                get_class($e),
                $e->getMessage(),
                $e->getFile(),
                $e->getLine(),
                $e->getTraceAsString()
            ));

            // Thrift 클라이언트가 이해할 수 있는 SystemException으로 변경하여 클라이언트에게 돌려준다.
            // 라라벨의 Handler::render 메서드를 대신하는 역할을 한다.
            throw new SystemException([
                'code' => ErrorCode::INTERNAL_SERVER_ERROR,
                'message' => $e->getMessage()
            ]);
        }
    }
}

<?php // app/Thrift/ThriftMiddleware.php

namespace App\Thrift;

abstract class ThriftMiddleware
{
    protected $successor = null;

    public function __construct(ThriftMiddleware $successor = null)
    {
        // 3.1.절에서 new FooMiddleware(new BarMiddleware)처럼
        // 미들웨어 생성자에 다른 미들웨어를 넣은 것을 기억할 것이다. 바로 이 부분이다.
        // $successor는 이번 미들웨어를 통과하고 나면, 그 다음에 통과해야 할 미들웨어다.
        // 이제 FooMiddleware의 $successor는 BarMiddleware다.
        $this->successor = $successor;
    }

    abstract public function handle($service, $method, $arguments);

    public function next($service, $method, $arguments)
    {
        if ($this->successor) {
            // 구체 미들웨어 클래스의 handle 메서드에서 항상 next 메서드를 호출했던 것을 기억할 것이다.
            // FooMiddleware는 BarMiddleware라는 $successor를 가지고 있으므로
            // BarMiddlware::handle 메서드가 호출될 것이다.
            return $this->successor->handle($service, $method, $arguments);
        }

        // 반면 BarMiddlware는 $succesor가 없으므로 아래 구문이 호출된다.
        // 이 예제에서는 PostService::all 메서드가 호출되는 것이다.
        return call_user_func_array([$service, $method], $arguments);
    }
}

<?php // tests/ThriftClientTest.php

class ThriftClientTest extends TestCase
{
    // ...
    
    public function testFind()
    {
        $response = $this->client->find(100);

        print_r($response);

        $this->assertInstanceOf(ThriftPost::class, $response);
        $this->assertEquals($response->id, 100);
    }
    
    // ...
}