feat: rename paymentPointer keys in webhook event json column

interledger · Sep 28, 2023 · 5294676 · 5294676
1 parent d8ea382
commit 5294676
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/packages/backend/migrations/20230918113102_rename_payment_pointer_tables.js b/packages/backend/migrations/20230918113102_rename_payment_pointer_tables.js
@@ -24,7 +24,13 @@ exports.up = function (knex) {
       table.renameColumn('paymentPointerId', 'walletAddressId')
       table.foreign('walletAddressId').references('walletAddresses.id')
       table.index(['walletAddressId', 'createdAt', 'id'])
-    })
+    }),
+    knex('webhookEvents').update({
+      // renames paymentPointer keys (if any) to walletAddress in data json column
+      data: knex.raw(
+        "data - 'paymentPointer' || json_build_object('walletAddress', data->'paymentPointer')"
+      )
+    }).whereRaw("data \\? 'paymentPonter'")
   ])
 }
 
@@ -54,6 +60,11 @@ exports.down = function (knex) {
       table.renameColumn('walletAddressId', 'paymentPointerId')
       table.foreign('paymentPointerId').references('paymentPointers.id')
       table.index(['paymentPointerId', 'createdAt', 'id'])
-    })
+    }),
+    knex('webhookEvents').update({
+      data: knex.raw(
+        "data - 'walletAddress' || json_build_object('paymentPointer', data->'walletAddress')"
+      )
+    }).whereRaw("data \\? 'walletAddress'")
   ])
 }