namespace App\Models;

use Illuminate\Database\Eloquent\Model;

final class Integration extends Model
{
    protected $fillable = [
        'user_id',
        ...
        'sheet_file_id',
        ...
    ];

    public function user()
    {
        return $this->belongsTo(User::class);
    }
}

namespace App\Domain\Google;

use Closure;
use Illuminate\Support\Facades\Http;

class PushNotifications
{
    public string $channelId;

    public string $fileId;

    public string $token;

    public function __construct(string $channelId, string $fileId, string $token)
    {
        $this->channelId = $channelId;
        $this->fileId = $fileId;
        $this->token = $token;
    }

    public function subscribe(): array
    {
        return $this->request(function ($client) {
            return $client->post("https://www.googleapis.com/drive/v3/files/{$this->fileId}/watch", [
                'id'      => $this->channelId,
                'type'    => 'web_hook',
                'address' => route('webhook'), // todo
                'expire'  => 86400, // time in seconds = 1 day
            ]);
        });
    }

    public function unsubscribe(): array
    {
        return $this->request(function ($client) {
            $client->post("https://www.googleapis.com/drive/v3/channels/stop", [
                'id'          => $this->channelId,
                'resource_id' => $this->fileId,
            ]);
        });
    }

    private function request(Closure $closure)
    {
        $client = Http::withHeaders([
            'Authorization' => "Bearer {$this->token}",
        ]);

        $response = $closure($client);

        if ($response->clientError()) {
            throw new \Exception($response->json()['error']['message']);
        }

        return $response->json();
    }
}