larapaper/app/Http/Controllers/Api/PluginWebhookController.php

<?php

namespace App\Http\Controllers\Api;

use App\Http\Controllers\Controller;
use App\Models\Plugin;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Validator;
use Illuminate\Validation\Rule;

class PluginWebhookController extends Controller
{
    public function __invoke(Request $request, Plugin $plugin): JsonResponse
    {
        if ($plugin->data_strategy !== 'webhook') {
            return response()->json(['error' => 'Plugin does not use webhook strategy'], 400);
        }

        if ($request->isMethod('get')) {
            return response()->json([
                'merge_variables' => $plugin->data_payload ?? [],
            ]);
        }

        if (! $request->has('merge_variables')) {
            return response()->json(['error' => 'Request must contain merge_variables key'], 400);
        }

        $validator = Validator::make(
            $request->all(),
            [
                'merge_strategy' => ['nullable', 'string', Rule::in(Plugin::webhookMergeStrategies())],
                'stream_limit' => ['nullable', 'integer', 'min:1'],
            ],
            [
                'merge_strategy.in' => 'merge_strategy must be one of: deep_merge, stream',
                'stream_limit.integer' => 'stream_limit must be a positive integer',
                'stream_limit.min' => 'stream_limit must be a positive integer',
            ]
        );

        if ($validator->fails()) {
            return response()->json(['error' => $validator->errors()->first()], 400);
        }

        $mergeVariables = Plugin::mergeWebhookPayload(
            currentPayload: $plugin->data_payload,
            incomingPayload: $request->input('merge_variables'),
            mergeStrategy: $request->string('merge_strategy')->toString() ?: null,
            streamLimit: $request->has('stream_limit') ? (int) $request->input('stream_limit') : null,
        );

        if (! Plugin::dataPayloadWithinWireLimit($mergeVariables)) {
            return response()->json(Plugin::oversizedDataPayloadErrorPayload(), 413);
        }

        $plugin->update([
            'data_payload' => $mergeVariables,
            'data_payload_updated_at' => now(),
        ]);

        return response()->json(['message' => 'Data updated successfully']);
    }
}