kenmirrors/firefly-iii
1
0
Fork 0
mirror of https://github.com/firefly-iii/firefly-iii.git synced 2025-10-12 15:35:15 +00:00
Code Issues Projects Releases Wiki Activity

Expand webhooks to support multiple delivery payloads, event triggers and responses.

Browse Source
This commit is contained in:
James Cole
2025-08-19 19:35:12 +02:00
parent 44a00ec8eb
commit 293be04d40
17 changed files with 586 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files

127
database/migrations/2025_08_19_180459_create_webhook_details_tables.php Normal file
View File

@@ -0,0 +1,127 @@
<?php
use Illuminate\Database\Migrations\Migration;
use Illuminate\Database\QueryException;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;
return new class extends Migration {
private const TABLE_ALREADY_EXISTS = 'If this table exists already (see the error message), this is not a problem. Other errors? Please open a discussion on GitHub.';
private const TABLE_ERROR = 'Could not create table "%s": %s';
/**
* Run the migrations.
*/
public function up(): void
{
if (!Schema::hasTable('webhook_triggers')) {
Schema::create('webhook_triggers', function (Blueprint $table) {
$table->id();
$table->timestamps();
$table->smallInteger('key')->unsigned();
$table->string('title', 100);
$table->unique(['key', 'title']);
});
}
if (!Schema::hasTable('webhook_responses')) {
Schema::create('webhook_responses', function (Blueprint $table) {
$table->id();
$table->timestamps();
$table->smallInteger('key')->unsigned();
$table->string('title', 100);
$table->unique(['key', 'title']);
});
}
if (!Schema::hasTable('webhook_deliveries')) {
Schema::create('webhook_deliveries', function (Blueprint $table) {
$table->id();
$table->timestamps();
$table->smallInteger('key')->unsigned();
$table->string('title', 100);
$table->unique(['key', 'title']);
});
}
// webhook_webhook_trigger
if (!Schema::hasTable('webhook_webhook_trigger')) {
try {
Schema::create(
'webhook_webhook_trigger',
static function (Blueprint $table): void {
$table->increments('id');
$table->integer('webhook_id', false, true);
$table->bigInteger('webhook_trigger_id', false, true);
$table->foreign('webhook_id')->references('id')->on('webhooks')->onDelete('cascade');
$table->foreign('webhook_trigger_id','link_to_trigger')->references('id')->on('webhook_triggers')->onDelete('cascade');
// unique combi:
$table->unique(['webhook_id', 'webhook_trigger_id']);
}
);
} catch (QueryException $e) {
app('log')->error(sprintf(self::TABLE_ERROR, 'webhook_webhook_trigger', $e->getMessage()));
app('log')->error(self::TABLE_ALREADY_EXISTS);
}
}
// webhook_webhook_response
if (!Schema::hasTable('webhook_webhook_response')) {
try {
Schema::create(
'webhook_webhook_response',
static function (Blueprint $table): void {
$table->increments('id');
$table->integer('webhook_id', false, true);
$table->bigInteger('webhook_response_id', false, true);
$table->foreign('webhook_id')->references('id')->on('webhooks')->onDelete('cascade');
$table->foreign('webhook_response_id','link_to_response')->references('id')->on('webhook_responses')->onDelete('cascade');
// unique combi:
$table->unique(['webhook_id', 'webhook_response_id']);
}
);
} catch (QueryException $e) {
app('log')->error(sprintf(self::TABLE_ERROR, 'webhook_webhook_response', $e->getMessage()));
app('log')->error(self::TABLE_ALREADY_EXISTS);
}
}
// webhook_webhook_delivery
if (!Schema::hasTable('webhook_webhook_delivery')) {
try {
Schema::create(
'webhook_webhook_delivery',
static function (Blueprint $table): void {
$table->increments('id');
$table->integer('webhook_id', false, true);
$table->bigInteger('webhook_delivery_id', false, true);
$table->foreign('webhook_id')->references('id')->on('webhooks')->onDelete('cascade');
$table->foreign('webhook_delivery_id','link_to_delivery')->references('id')->on('webhook_deliveries')->onDelete('cascade');
// unique combi:
$table->unique(['webhook_id', 'webhook_delivery_id']);
}
);
} catch (QueryException $e) {
app('log')->error(sprintf(self::TABLE_ERROR, 'webhook_webhook_delivery', $e->getMessage()));
app('log')->error(self::TABLE_ALREADY_EXISTS);
}
}
}
/**
* Reverse the migrations.
*/
public function down(): void
{
Schema::dropIfExists('webhook_webhook_delivery');
Schema::dropIfExists('webhook_webhook_trigger');
Schema::dropIfExists('webhook_webhook_response');
Schema::dropIfExists('webhook_triggers');
Schema::dropIfExists('webhook_responses');
Schema::dropIfExists('webhook_deliveries');
}
};