feat(backend): add local payment

bruno/collections/Rafiki/Examples/Admin API - only locally/Peer-to-Peer Local Payment/Create Outgoing Payment.bru

@@ -0,0 +1,72 @@
+meta {
+  name: Create Outgoing Payment
+  type: graphql
+  seq: 3
+}
+
+post {
+  url: {{RafikiGraphqlHost}}/graphql
+  body: graphql
+  auth: none
+}
+
+body:graphql {
+  mutation CreateOutgoingPayment($input: CreateOutgoingPaymentInput!) {
+    createOutgoingPayment(input: $input) {
+      payment {
+        createdAt
+        error
+        metadata
+        id
+        walletAddressId
+        receiveAmount {
+          assetCode
+          assetScale
+          value
+        }
+        receiver
+        debitAmount {
+          assetCode
+          assetScale
+          value
+        }
+        sentAmount {
+          assetCode
+          assetScale
+          value
+        }
+        state
+        stateAttempts
+      }
+    }
+  }
+}
+
+body:graphql:vars {
+  {
+    "input": {
+      "walletAddressId": "{{gfranklinWalletAddressId}}",
+      "quoteId": "{{quoteId}}"
+    }
+  }
+}
+
+script:pre-request {
+  const scripts = require('./scripts');
+
+  scripts.addApiSignatureHeader();
+}
+
+script:post-response {
+  const body = res.getBody();
+
+  if (body?.data) {
+    bru.setEnvVar("outgoingPaymentId", body.data.createOutgoingPayment.payment.id);
+  }
+}
+
+tests {
+  test("Outgoing Payment id is string", function() {
+    expect(bru.getEnvVar("outgoingPaymentId")).to.be.a("string");
+  })
+}

bruno/collections/Rafiki/Examples/Admin API - only locally/Peer-to-Peer Local Payment/Create Quote.bru

@@ -0,0 +1,66 @@
+meta {
+  name: Create Quote
+  type: graphql
+  seq: 2
+}
+
+post {
+  url: {{RafikiGraphqlHost}}/graphql
+  body: graphql
+  auth: none
+}
+
+body:graphql {
+  mutation CreateQuote($input: CreateQuoteInput!) {
+    createQuote(input: $input) {
+      quote {
+        createdAt
+        expiresAt
+        id
+        walletAddressId
+        receiveAmount {
+          assetCode
+          assetScale
+          value
+        }
+        receiver
+        debitAmount {
+          assetCode
+          assetScale
+          value
+        }
+      }
+    }
+  }
+}
+
+body:graphql:vars {
+  {
+    "input": {
+      "walletAddressId": "{{gfranklinWalletAddressId}}",
+      "receiver": "{{receiverId}}"
+    }
+  }
+}
+
+script:pre-request {
+  const scripts = require('./scripts');
+
+  await scripts.loadWalletAddressIdsIntoVariables();
+
+  scripts.addApiSignatureHeader();
+}
+
+script:post-response {
+  const body = res.getBody();
+
+  if (body?.data) {
+    bru.setEnvVar("quoteId", body.data.createQuote.quote.id);
+  }
+}
+
+tests {
+  test("Quote id is string", function() {
+    expect(bru.getEnvVar("quoteId")).to.be.a("string");
+  })
+}

bruno/collections/Rafiki/Examples/Admin API - only locally/Peer-to-Peer Local Payment/Create Receiver -local Incoming Payment-.bru

@@ -0,0 +1,73 @@
+meta {
+  name: Create Receiver -local Incoming Payment-
+  type: graphql
+  seq: 1
+}
+
+post {
+  url: {{RafikiGraphqlHost}}/graphql
+  body: graphql
+  auth: none
+}
+
+body:graphql {
+  mutation CreateReceiver($input: CreateReceiverInput!) {
+    createReceiver(input: $input) {
+      receiver {
+        completed
+        createdAt
+        expiresAt
+        metadata
+        id
+        incomingAmount {
+          assetCode
+          assetScale
+          value
+        }
+        walletAddressUrl
+        receivedAmount {
+          assetCode
+          assetScale
+          value
+        }
+        updatedAt
+      }
+    }
+  }
+}
+
+body:graphql:vars {
+  {
+    "input": {
+      "metadata": {
+          "description": "For lunch!"
+      },
+      "incomingAmount": {
+        "assetCode": "USD",
+        "assetScale": 2,
+        "value": 500
+      },
+      "walletAddressUrl": "https://cloud-nine-wallet-backend/accounts/bhamchest"
+    }
+  }
+}
+
+script:pre-request {
+  const scripts = require('./scripts');
+
+  scripts.addApiSignatureHeader();
+}
+
+script:post-response {
+  const body = res.getBody();
+
+  if (body?.data) {
+    bru.setEnvVar("receiverId", body.data.createReceiver.receiver.id);
+  }
+}
+
+tests {
+  test("Receiver id is string", function() {
+    expect(bru.getEnvVar("receiverId")).to.be.a("string");
+  })
+}

bruno/collections/Rafiki/Examples/Admin API - only locally/Peer-to-Peer Local Payment/Get Outgoing Payment.bru

@@ -0,0 +1,57 @@
+meta {
+  name: Get Outgoing Payment
+  type: graphql
+  seq: 4
+}
+
+post {
+  url: {{RafikiGraphqlHost}}/graphql
+  body: graphql
+  auth: none
+}
+
+body:graphql {
+  query GetOutgoingPayment($id: String!) {
+  outgoingPayment(id: $id) {
+      createdAt
+      error
+      metadata
+      id
+      grantId
+      walletAddressId
+      quote {
+        id
+      }
+      receiveAmount {
+        assetCode
+        assetScale
+        value
+      }
+      receiver
+      debitAmount {
+        assetCode
+        assetScale
+        value
+      }
+      sentAmount {
+        assetCode
+        assetScale
+        value
+      }
+      state
+      stateAttempts
+    }
+  }
+}
+
+body:graphql:vars {
+  {
+      "id": "{{outgoingPaymentId}}"
+  }
+}
+
+script:pre-request {
+  const scripts = require('./scripts');
+
+  scripts.addApiSignatureHeader();
+}

localenv/cloud-nine-wallet/seed.yml

@@ -46,6 +46,12 @@ accounts:
     path: accounts/broke
     brunoEnvVar: brokeWalletAddress
     assetCode: USD
+  - name: "Luca Rossi"
+    id: 63dcc665-d946-4263-ac27-d0da1eb08a83
+    initialBalance: 50
+    path: accounts/lrossi
+    brunoEnvVar: lrossiWalletAddressId
+    assetCode: EUR
 rates:
   EUR:
     MXN: 18.78

packages/backend/migrations/20240916181643_require_estimated_exchange_rate.js

@@ -0,0 +1,30 @@
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+
+exports.up = function (knex) {
+  return knex('quotes')
+    .whereNull('estimatedExchangeRate')
+    .update({
+      estimatedExchangeRate: knex.raw('?? / ??', [
+        'lowEstimatedExchangeRateNumerator',
+        'lowEstimatedExchangeRateDenominator'
+      ])
+    })
+    .then(() => {
+      return knex.schema.table('quotes', (table) => {
+        table.decimal('estimatedExchangeRate', 20, 10).notNullable().alter()
+      })
+    })
+}
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.down = function (knex) {
+  return knex.schema.table('quotes', (table) => {
+    table.decimal('estimatedExchangeRate', 20, 10).nullable().alter()
+  })
+}

packages/backend/migrations/20240916181659_add_ilp_quote_details.js

@@ -0,0 +1,68 @@
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.up = function (knex) {
+  return (
+    knex.schema
+      // Create new table with columns from "quotes" to migrate
+      .createTable('ilpQuoteDetails', function (table) {
+        table.uuid('id').notNullable().primary()
+
+        // quoteId is purposefully not a FK referencing quote.id
+        // this allows us to create ilpQuoteDetail before quotes in service of
+        // fully decoupling payment method/quote services.
+        // https://github.com/interledger/rafiki/pull/2857#discussion_r1825891327
+        table.uuid('quoteId').notNullable().unique().index()
+
+        table.bigInteger('maxPacketAmount').notNullable()
+        table.decimal('minExchangeRateNumerator', 64, 0).notNullable()
+        table.decimal('minExchangeRateDenominator', 64, 0).notNullable()
+        table.decimal('lowEstimatedExchangeRateNumerator', 64, 0).notNullable()
+        table
+          .decimal('lowEstimatedExchangeRateDenominator', 64, 0)
+          .notNullable()
+        table.decimal('highEstimatedExchangeRateNumerator', 64, 0).notNullable()
+        table
+          .decimal('highEstimatedExchangeRateDenominator', 64, 0)
+          .notNullable()
+
+        table.timestamp('createdAt').defaultTo(knex.fn.now())
+        table.timestamp('updatedAt').defaultTo(knex.fn.now())
+      })
+      .then(() => {
+        return knex.raw(`
+          INSERT INTO "ilpQuoteDetails" (
+            id,
+            "quoteId",
+            "maxPacketAmount",
+            "minExchangeRateNumerator",
+            "minExchangeRateDenominator",
+            "lowEstimatedExchangeRateNumerator",
+            "lowEstimatedExchangeRateDenominator",
+            "highEstimatedExchangeRateNumerator",
+            "highEstimatedExchangeRateDenominator"
+          )
+          SELECT
+            gen_random_uuid(),
+            id AS "quoteId",
+            "maxPacketAmount",
+            "minExchangeRateNumerator",
+            "minExchangeRateDenominator",
+            "lowEstimatedExchangeRateNumerator",
+            "lowEstimatedExchangeRateDenominator",
+            "highEstimatedExchangeRateNumerator",
+            "highEstimatedExchangeRateDenominator"
+          FROM "quotes";
+        `)
+      })
+  )
+}
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.down = function (knex) {
+  return knex.schema.dropTableIfExists('ilpQuoteDetails')
+}