fix(mu): fetch wallet address of the process id for relay

servers/mu/src/domain/clients/relay.js

@@ -18,12 +18,19 @@ function httpSigName (address) {
   return `http-sig-${hexString}`;
 }
 
-export function topUpWith ({ fetch, logger, wallet, address }) {
+export function topUpWith ({ fetch, logger, wallet, address, fetchTransactionDetails }) {
   const privateKey = createPrivateKey({ key: wallet, format: 'jwk' })
   const s = createSigner(privateKey, 'rsa-pss-sha512', address)
   const params = ['alg', 'keyid'].sort()
 
-  return async ({ logId, relayUrl, amount, recipient }) => {
+  return async ({ logId, relayUrl, amount, recipientProcessId }) => {
+    let processInfo = await fetchTransactionDetails([recipientProcessId])
+    let recipient = processInfo?.data?.transactions?.edges?.length >= 1 ? processInfo.data.transactions.edges[0].node.owner.address : null
+
+    if(!recipient) {
+      return new Error("Invalid recipient for top up")
+    }
+
     let relayUrlObj = new URL(relayUrl)
     const urlString = `${relayUrl}?amount+integer=${amount}&recipient=${recipient}`
 

servers/mu/src/domain/clients/relay.test.js

@@ -32,14 +32,31 @@ describe('topUpWith function', function () {
   logger.tap = () => (args) => {
     return args
   }
-  let topUp = topUpWith({ fetch, logger, wallet, address })
+  const fetchTransactionDetails = async () => {
+    return {
+      data: {
+        transactions: {
+          edges: [
+            {
+              node: {
+                owner: {
+                  address: "asdf"
+                }
+              }
+            }
+          ]
+        }
+      }
+    }
+  }
+  let topUp = topUpWith({ fetch, logger, wallet, address, fetchTransactionDetails })
 
   it('should correctly sign and verify a request', async function () {
     const params = {
       logId: 'test-log',
       relayUrl: 'https://relay1.example/path/topup',
       amount: 100,
-      recipient: 'recipient-address'
+      recipient: 'recipient-process-id'
     }
 
     const result = await topUp(params)

servers/mu/src/domain/index.js

@@ -394,7 +394,8 @@ export const createResultApis = async (ctx) => {
     isWallet: gatewayClient.isWalletWith({ fetch, histogram, ARWEAVE_URL, logger: processMsgLogger, setById, getById }),
     writeDataItemArweave: uploaderClient.uploadDataItemWith({ UPLOADER_URL, logger: processMsgLogger, fetch, histogram }),
     RELAY_MAP,
-    topUp: RelayClient.topUpWith({ fetch, logger: processMsgLogger, wallet: MU_WALLET, address: walletAddress })
+    topUp: RelayClient.topUpWith({ fetch, logger: processMsgLogger, wallet: MU_WALLET, address: walletAddress }),
+    fetchTransactions: gatewayClient.fetchTransactionDetailsWith({ fetch, GRAPHQL_URL }),
   })
 
   const processSpawnLogger = logger.child('processSpawn')