From b8a0aa47bfc578c581747540b4cbff8229eb10f1 Mon Sep 17 00:00:00 2001
From: Benjamin Nussbaum <bnussbau@users.noreply.github.com>
Date: Mon, 31 Mar 2025 21:45:28 +0200
Subject: [PATCH] feat: update plugin data via webhook

---
 .../views/livewire/plugins/receipt.blade.php  | 74 +++++++++++--------
 routes/api.php                                | 21 ++++++
 tests/Feature/PluginWebhookTest.php           | 69 +++++++++++++++++
 3 files changed, 135 insertions(+), 29 deletions(-)
 create mode 100644 tests/Feature/PluginWebhookTest.php

diff --git a/resources/views/livewire/plugins/receipt.blade.php b/resources/views/livewire/plugins/receipt.blade.php
index 4b98611..f3acbda 100644
--- a/resources/views/livewire/plugins/receipt.blade.php
+++ b/resources/views/livewire/plugins/receipt.blade.php
@@ -313,41 +313,57 @@ HTML;
                     </div>
 
                     <div class="mb-4">
-                        <flux:radio.group wire:model="data_strategy" label="Data Strategy" variant="segmented">
+                        <flux:radio.group wire:model.live="data_strategy" label="Data Strategy" variant="segmented">
                             <flux:radio value="polling" label="Polling"/>
-                            <flux:radio value="webhook" label="Webhook" disabled/>
+                            <flux:radio value="webhook" label="Webhook"/>
                         </flux:radio.group>
                     </div>
 
-                    <div class="mb-4">
-                        <flux:input label="Polling URL" wire:model="polling_url" id="polling_url"
-                                    placeholder="https://example.com/api"
-                                    class="block mt-1 w-full" type="text" name="polling_url" autofocus>
-                            <x-slot name="iconTrailing">
-                                <flux:button size="sm" variant="subtle" icon="cloud-arrow-down" wire:click="updateData"
-                                             tooltip="Fetch data now" class="-mr-1"/>
-                            </x-slot>
-                        </flux:input>
-                    </div>
+                    @if($data_strategy === 'polling')
+                        <div class="mb-4">
+                            <flux:input label="Polling URL" wire:model="polling_url" id="polling_url"
+                                        placeholder="https://example.com/api"
+                                        class="block mt-1 w-full" type="text" name="polling_url" autofocus>
+                                <x-slot name="iconTrailing">
+                                    <flux:button size="sm" variant="subtle" icon="cloud-arrow-down" wire:click="updateData"
+                                                 tooltip="Fetch data now" class="-mr-1"/>
+                                </x-slot>
+                            </flux:input>
+                        </div>
 
-                    <div class="mb-4">
-                        <flux:radio.group wire:model="polling_verb" label="Polling Verb" variant="segmented">
-                            <flux:radio value="get" label="GET"/>
-                            <flux:radio value="post" label="POST"/>
-                        </flux:radio.group>
-                    </div>
+                        <div class="mb-4">
+                            <flux:radio.group wire:model="polling_verb" label="Polling Verb" variant="segmented">
+                                <flux:radio value="get" label="GET"/>
+                                <flux:radio value="post" label="POST"/>
+                            </flux:radio.group>
+                        </div>
 
-                    <div class="mb-4">
-                        <flux:textarea
-                            label="Polling Headers (one per line, format: Header: Value)"
-                            wire:model="polling_header"
-                            id="polling_header"
-                            class="block mt-1 w-full font-mono"
-                            name="polling_header"
-                            rows="3"
-                            placeholder="Authorization: Bearer ey.*******&#10;Content-Type: application/json"
-                        />
-                    </div>
+                        <div class="mb-4">
+                            <flux:textarea
+                                label="Polling Headers (one per line, format: Header: Value)"
+                                wire:model="polling_header"
+                                id="polling_header"
+                                class="block mt-1 w-full font-mono"
+                                name="polling_header"
+                                rows="3"
+                                placeholder="Authorization: Bearer ey.*******&#10;Content-Type: application/json"
+                            />
+                        </div>
+                    @else
+                        <div class="mb-4">
+                            <flux:input
+                                label="Webhook URL"
+                                :value="route('api.custom_plugins.webhook', ['plugin_uuid' => $plugin->uuid])"
+                                class="block mt-1 w-full font-mono"
+                                readonly
+                                copyable
+                            >
+                            </flux:input>
+                        </div>
+                        <div>
+                            <p>Send JSON payload with key <code>merge_variables</code> to the webhook URL. The payload will be merged with the plugin data.</p>
+                        </div>
+                            @endif
 
                     <div class="flex">
                         <flux:spacer/>
diff --git a/routes/api.php b/routes/api.php
index f8942d0..94562c9 100644
--- a/routes/api.php
+++ b/routes/api.php
@@ -194,3 +194,24 @@ Route::post('/display/update', function (Request $request) {
 })
     ->name('display.update')
     ->middleware('auth:sanctum', 'ability:update-screen');
+
+Route::post('custom_plugins/{plugin_uuid}', function (string $plugin_uuid) {
+    $plugin = \App\Models\Plugin::where('uuid', $plugin_uuid)->firstOrFail();
+
+    // Check if plugin uses webhook strategy
+    if ($plugin->data_strategy !== 'webhook') {
+        return response()->json(['error' => 'Plugin does not use webhook strategy'], 400);
+    }
+
+    $request = request();
+    if (! $request->has('merge_variables')) {
+        return response()->json(['error' => 'Request must contain merge_variables key'], 400);
+    }
+
+    $plugin->update([
+        'data_payload' => $request->input('merge_variables'),
+        'data_payload_updated_at' => now(),
+    ]);
+
+    return response()->json(['message' => 'Data updated successfully']);
+})->name('api.custom_plugins.webhook');
diff --git a/tests/Feature/PluginWebhookTest.php b/tests/Feature/PluginWebhookTest.php
new file mode 100644
index 0000000..70fa53a
--- /dev/null
+++ b/tests/Feature/PluginWebhookTest.php
@@ -0,0 +1,69 @@
+<?php
+
+use App\Models\Plugin;
+use Illuminate\Support\Str;
+
+test('webhook updates plugin data for webhook strategy', function () {
+    // Create a plugin with webhook strategy
+    $plugin = Plugin::factory()->create([
+        'data_strategy' => 'webhook',
+        'data_payload' => ['old' => 'data'],
+    ]);
+
+    // Make request to update plugin data
+    $response = $this->postJson("/api/custom_plugins/{$plugin->uuid}", [
+        'merge_variables' => ['new' => 'data'],
+    ]);
+
+    // Assert response
+    $response->assertOk()
+        ->assertJson(['message' => 'Data updated successfully']);
+
+    // Assert plugin was updated
+    $this->assertDatabaseHas('plugins', [
+        'id' => $plugin->id,
+        'data_payload' => json_encode(['new' => 'data']),
+    ]);
+});
+
+test('webhook returns 400 for non-webhook strategy plugins', function () {
+    // Create a plugin with non-webhook strategy
+    $plugin = Plugin::factory()->create([
+        'data_strategy' => 'polling',
+        'data_payload' => ['old' => 'data'],
+    ]);
+
+    // Make request to update plugin data
+    $response = $this->postJson("/api/custom_plugins/{$plugin->uuid}", [
+        'merge_variables' => ['new' => 'data'],
+    ]);
+
+    // Assert response
+    $response->assertStatus(400)
+        ->assertJson(['error' => 'Plugin does not use webhook strategy']);
+});
+
+test('webhook returns 400 when merge_variables is missing', function () {
+    // Create a plugin with webhook strategy
+    $plugin = Plugin::factory()->create([
+        'data_strategy' => 'webhook',
+        'data_payload' => ['old' => 'data'],
+    ]);
+
+    // Make request without merge_variables
+    $response = $this->postJson("/api/custom_plugins/{$plugin->uuid}", []);
+
+    // Assert response
+    $response->assertStatus(400)
+        ->assertJson(['error' => 'Request must contain merge_variables key']);
+});
+
+test('webhook returns 404 for non-existent plugin', function () {
+    // Make request with non-existent plugin UUID
+    $response = $this->postJson('/api/custom_plugins/'.Str::uuid(), [
+        'merge_variables' => ['new' => 'data'],
+    ]);
+
+    // Assert response
+    $response->assertNotFound();
+});