<?php // database/migrations/YYYY_MM_DD_hhiiss_create_posts_table.php

use Illuminate\Support\Facades\Schema;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Database\Migrations\Migration;

class CreatePostsTable extends Migration
{
    public function up()
    {
        Schema::create('posts', function (Blueprint $table) {
            $table->increments('id');
            $table->string('title');
            $table->text('content');
            $table->timestamps();
        });
    }

    public function down()
    {
        Schema::dropIfExists('posts');
    }
}

<?php // database/factory/ModelFactory.php

// ...

$factory->define(App\Post::class, function (Faker\Generator $faker) {
    return [
        'title' => $faker->sentence,
        'content' => $faker->paragraph,
    ];
});

<?php // routes/api.php

Route::post('posts', 'PostsController@handle');

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

namespace App\Http\Controllers;

use App\Services\PostService;           // 직접 만들어야 한다.
use App\Thrift\ThriftResponse;          // 직접 만들어야 한다.
use Appkr\Thrift\Post\PostServiceProcessor;
                                        // 5절에서 IDL 정의에 의해 Thrift 컴파일러가 생성해 준 파일이다. 
use Illuminate\Http\Request;

class PostsController extends Controller
{
    public function handle(Request $request)
    {
        $service = new PostService();   // 서비스 인스턴스를 생성한다.
        $processor = new PostServiceProcessor($service);
                                        // 서비스 인스턴스를 프로세서에 주입한다.
        
        return ThriftResponse::make($request, $processor, 'json');
                                        // HTTP 요청을 Process하고 JSON HTTP 응답을 반환한다.
    }
}

<?php // app/Thrift/ThriftResponse.php

namespace App\Thrift;

use Illuminate\Http\Request;
use Thrift\Protocol\TCompactProtocol;   // 바이너리보다 더 가볍다(apache/thrift 라이브러리가 제공).
use Thrift\Transport\TMemoryBuffer;     
use Thrift\Protocol\TJSONProtocol;      // 디버깅할 때 편하다(apache/thrift 라이브러리가 제공). 
use Thrift\Protocol\TBinaryProtocol;    // 대표적 프로토콜이다(apache/thrift 라이브러리가 제공).
use UnexpectedValueException;

class ThriftResponse
{
    public static function make(Request $request, $processor, $format)
    {
        $readTransport = new TMemoryBuffer($request->getContent(false));
        $writeTransport = new TMemoryBuffer();
                                        // (역)직렬화 전에 HTTP 요청/응답을 바이트 단위로 읽고
                                        // 쓰기 위한 임시 저장소다.  

        switch ($format) {              // 프로토콜 객체를 만든다.
            case 'json':
                $readProtocol = new TJSONProtocol($readTransport);
                $writeProtocol = new TJSONProtocol($writeTransport);
                break;
            case 'binary':
                $readProtocol = new TBinaryProtocol($readTransport);
                $writeProtocol = new TBinaryProtocol($writeTransport);
                break;
            case 'compact':
                $readProtocol = new TCompactProtocol($readTransport);
                $writeProtocol = new TCompactProtocol($writeTransport);
                break;
            default:
                throw new UnexpectedValueException;
        }

        $readTransport->open();
        $writeTransport->open();
        $processor->process($readProtocol, $writeProtocol);
                                        // 프로세서에서 역직렬화된 HTTP 요청 본문과
                                        // HTTP 응답을 쓸 수 있는 객체를 인자로 넘긴다.
        $readTransport->close();
        $writeTransport->close();

        $content = $writeTransport->getBuffer();
                                        // 프로세서가 버퍼에 쓴 HTTP 응답 본문을 읽어서 변수에 담는다.

        return response($content)
            ->header('Content-Type', 'application/x-thrift');
                                        // Content-Type 헤더를 application/thrift로 지정해야 한다. 
    }
}

<?php // app/Service/PostsService.php

namespace App\Services;

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

class PostService implements PostServiceIf
{
    public function all(QueryFilter $qf, $offset, $limit)
    {
        $posts = EloquentPost::offset($offset)->limit($limit)->get();
                                        // $offset을 건너뛰고 $limit개의 포스트를 조회하는 엘로퀀트 쿼리다. 
                                        // QueryFilter는 이번 포스트에서는 쓰지 않는다.
        return $posts->map(function ($post) {
            return new ThriftPost($post->toArray());
        })->all();                      // EloquentCollection을 순회하면서 ThriftPost 객체에 맵핑해 준다.
    }

    public function find($id)
    {
        $post = EloquentPost::find($id);

        return new ThriftPost($post->toArray());
    }

    public function store($title, $content)
    {
        $post = new EloquentPost;
        $post->title = $title;
        $post->content = $content;
        $post->save();

        return new ThriftPost($post->toArray());
    }
}

<?php // tests/ThriftClientTest.php

use App\Post;
use Appkr\Thrift\Post\PostServiceClient;
use Appkr\Thrift\Post\QueryFilter;
use Illuminate\Foundation\Testing\DatabaseMigrations;
use Thrift\Protocol\TJSONProtocol;
use Thrift\Transport\THttpClient;

class ThriftClientTest extends TestCase
{
    use DatabaseMigrations;

    protected $client;

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

        $transport = new THttpClient(
            'localhost',
            '8000',
            'api/posts'
        );                              // apache/thrfit 라이브러에서 제공하는 HTTP 클라이언트다.

        $protocol = new TJSONProtocol($transport);
                                        // 편의를 위해 JSONProtocol을 이용했다.

        $this->client = new PostServiceClient($protocol);
                                        // IDL 컴파일할 때 자동 생성된 클라이언트다.
        
        factory(Post::class, 20)->create();
                                        // 매번 테스트마다 Post를 20개씩 만든다.
                                        // DatabaseMigrations에 의해서 테스트가 끝나면 롤백된다.
    }

    public function testAll()
    {
        $queryFilter = new QueryFilter([
            'keyword' => 'Lorem',
            'sortBy' => 'created_at',
            'sortDirection' => 'desc'
        ]);                             // QueryFilter 객체를 만들었다.
                                        // 앞서 언급했듯이 연관 배열 형식으로 객체를 만들 수 있다.
                                        // 정의하지 않은 필드는 무시된다. 예) 'foo' => 'bar'는 무시됨.

        $response = $this->client->all($queryFilter, 0, 10);
                                        // 로컬 라이브러리의 API를 호출하듯이 원격 API를 호출한다.
                                        // 마치 Guzzle이나, aws-php-sdk를 쓰는 것과 비슷하다. 
        var_dump($response);
    }

    public function testFind()
    {
        $response = $this->client->find(10);
        var_dump($response);
    }

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