Job(Queue)

1. 세팅

@ .env

QUEUE_CONNECTION=database

 

2. Job 생성

php artisan make:job CollectCommentsJob

@ CollectCommentsJob

<?php

namespace App\Jobs;

use App\Enums\StateType;
use App\Target;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Http;

class CollectCommentsJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $target;
    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(Target $target)
    {
        $this->target = $target;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        try {
            $response = Http::get(config("services.google.domain")."/videos", [
                "id" => $this->getYoutubeVideoId($this->target->url),
                "part" => "statistics, snippet",
                "key" => config("services.google.key")
            ]);

            $video = $response->json()["items"][0][1];

            $this->target->update([
                "idx" => $video["id"],
                "title" => $video["snippet"]["title"],
                "body" => $video["snippet"]["description"],
                "thumbnail" => $video["snippet"]["thumbnails"]["default"]["url"],
                "state" => StateType::SUCCESS
            ]);
        }catch(\Exception $exception){
            $this->target->update([
                "state" => StateType::FAIL
            ]);
        }
    }

    public function getYoutubeVideoId($url)
    {
        if (strpos($url, "watch") !== false)
            return str_replace("https://www.youtube.com/watch?v=", "", $url);

        return str_replace("https://youtu.be/", "", $url);
    }
}

 

3. Job 호출하기

<?php

namespace App\Http\Controllers\Api;

use App\Http\Controllers\Controller;
use App\Http\Resources\TargetResource;
use App\Jobs\CollectCommentsJob;
use App\Target;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Http;

class TargetController extends ApiController
{
    public function store(Request $request)
    {
        $request->validate([
            "platform" => "required|string|max:500",
            "url" => "required|string|max:5000",
        ]);

        $target = auth()->user()->targets()->create($request->all());

        dispatch(new CollectCommentsJob($target));

        return $this->respondCreated(TargetResource::make($target));
    }
}