erpsaas/app/Http/Controllers/PlaidWebhookController.php

<?php

namespace App\Http\Controllers;

use App\Jobs\ProcessTransactionUpdate;
use App\Models\Company;
use Illuminate\Http\Request;

class PlaidWebhookController extends Controller
{
    public function handleWebhook(Request $request)
    {
        $payload = $request->all();

        if ($payload['webhook_type'] === 'TRANSACTIONS') {
            $this->handleTransactionsWebhook($payload);
        }

        return response()->json(['message' => 'Plaid Transaction Webhook Received']);
    }

    private function handleTransactionsWebhook(array $payload): void
    {
        if ($payload['webhook_code'] === 'DEFAULT_UPDATE') {
            $this->handleDefaultUpdate($payload);
        }
    }

    private function handleDefaultUpdate(array $payload): void
    {
        $newTransactions = $payload['new_transactions'];
        $itemId = $payload['item_id'];

        $company = Company::whereHas('connectedBankAccounts', static function ($query) use ($itemId) {
            $query->where('item_id', $itemId);
        })->first();

        if ($company && $newTransactions > 0) {
            ProcessTransactionUpdate::dispatch($company, $itemId)
                ->onQueue('transactions');
        }
    }
}