feat(backend): additional webhook events for outgoing payments (#3651)

* feat(backend): add additional webhook events for outgoing payments

* feat(backend): update webhook recipients logic

* chore(backend): extract funded and cancelled events into a new type

* chore(backend): move IncomingPaymentInitiationReason to separate file

* chore(backend): simplify webhook recipients logic

Author: sanducb

localenv/mock-account-servicing-entity/generated/graphql.ts

@@ -0,0 +1,37 @@
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.up = async function (knex) {
+  const hasColumn = await knex.schema.hasColumn(
+    'outgoingPaymentCardDetails',
+    'requestId'
+  )
+  if (!hasColumn) {
+    await knex.schema.alterTable(
+      'outgoingPaymentCardDetails',
+      function (table) {
+        table.string('requestId').notNullable()
+      }
+    )
+  }
+}
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.down = async function (knex) {
+  const hasColumn = await knex.schema.hasColumn(
+    'outgoingPaymentCardDetails',
+    'requestId'
+  )
+  if (hasColumn) {
+    await knex.schema.alterTable(
+      'outgoingPaymentCardDetails',
+      function (table) {
+        table.dropColumn('requestId')
+      }
+    )
+  }
+}

packages/backend/migrations/20250917082624_add_request_id_to_outgoing_payment_card_details.js

@@ -0,0 +1,35 @@
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.up = function (knex) {
+  return knex.schema
+    .alterTable('outgoingPayments', function (table) {
+      table.enum('initiatedBy', ['CARD', 'OPEN_PAYMENTS', 'ADMIN'])
+    })
+    .then(() => {
+      return Promise.all([
+        knex.raw(
+          `UPDATE "outgoingPayments" SET "initiatedBy" = 'OPEN_PAYMENTS' WHERE "grantId" IS NOT NULL`
+        ),
+        knex.raw(
+          `UPDATE "outgoingPayments" SET "initiatedBy" = 'ADMIN' WHERE "grantId" IS NULL`
+        )
+      ])
+    })
+    .then(() => {
+      return knex.raw(
+        `ALTER TABLE "outgoingPayments" ALTER COLUMN "initiatedBy" SET NOT NULL`
+      )
+    })
+}
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.down = function (knex) {
+  return knex.schema.alterTable('outgoingPayments', function (table) {
+    table.dropColumn('initiatedBy')
+  })
+}

packages/backend/migrations/20250917082746_add_initiated_by_to_outgoing_payment.js

@@ -51,7 +51,10 @@ export class Asset extends BaseModel implements LiquidityAccount {
             balance
           },
           tenantId: this.tenantId,
-          webhooks: finalizeWebhookRecipients([this.tenantId], config)
+          webhooks: finalizeWebhookRecipients(
+            { tenantIds: [this.tenantId] },
+            config
+          )
         })
       }
     }

packages/backend/src/asset/model.ts

@@ -205,7 +205,8 @@ export const Config = {
   ),
   cardServiceUrl: optional(envString, 'CARD_SERVICE_URL'),
   posServiceUrl: optional(envString, 'POS_SERVICE_URL'),
-  posWebhookServiceUrl: optional(envString, 'POS_WEBHOOK_SERVICE_URL')
+  posWebhookServiceUrl: optional(envString, 'POS_WEBHOOK_SERVICE_URL'),
+  cardWebhookUrl: optional(envString, 'CARD_WEBHOOK_SERVICE_URL')
 }
 
 // eslint-disable-next-line @typescript-eslint/no-explicit-any