Merge pull request #1250 from permaweb/jfrain99/improve-mu-hb-compat

fix(mu): fix casing, pushparams for hb compat in mu

Author: jfrain99

scheduler-utils/src/client/gateway.js

@@ -33,10 +33,10 @@ export const parseHyperBeamResponse = (process) => {
 
   const signedCommitment = commitments[processId]
   const committed = signedCommitment.committed
-  const originalTags = Object.values(signedCommitment['original-tags'])
+  const originalTags = Object.values(signedCommitment['original-tags'] ?? {})
   const data = process.data
   const tags = []
-  if (!originalTags) {
+  if (!originalTags || originalTags.length === 0) {
     delete process.data
     const tags = Object.keys(process).map(key => ({ name: key, value: process[key] }))
     return { id: processId, tags, data }
@@ -70,9 +70,7 @@ export function loadProcessWith ({ fetch, HB_GRAPHQL_URL, GRAPHQL_URL, GRAPHQL_M
         query ($ids: [ID!]!) {
         transactions(
           ids: $ids
-          tags: [
-            { name: "Type", values: ["Process"] }
-        ]) {
+        ) {
           pageInfo {
             hasNextPage
           }

servers/mu/package.json

@@ -20,7 +20,7 @@
   },
   "dependencies": {
     "@permaweb/ao-scheduler-utils": "^0.0.28",
-    "@permaweb/aoconnect": "^0.0.88",
+    "@permaweb/aoconnect": "^0.0.90",
     "arbundles": "0.11.0",
     "arweave": "^1.14.4",
     "async-mutex": "^0.5.0",

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

@@ -67,13 +67,13 @@ function writeDataItemWith ({ fetch, histogram, logger, wallet }) {
 
             // Helper function to convert tags array to object (like assoc in mainnet.js)
             const tagsToObj = tags.reduce((acc, tag) => {
-              acc[tag.name] = tag.value
+              acc[tag.name.toLowerCase()] = tag.value
               return acc
             }, {})
 
             // Create push request parameters following mainnet.js pattern
             let pushParams = {}
-            if (tagsToObj.Type === 'Process') {
+            if (tagsToObj.type === 'Process') {
               pushParams = {
                 path: '/push',
                 method: 'POST',
@@ -91,19 +91,18 @@ function writeDataItemWith ({ fetch, histogram, logger, wallet }) {
               }
             } else {
               pushParams = {
-                type: 'Message',
-                path: `/${processId}[email protected]/push`,
+                Type: 'Message',
+                path: `/${processId}/push`,
                 method: 'POST',
                 ...tagsToObj,
                 'data-protocol': 'ao',
-                'scheduler-device': '[email protected]',
-                'push-device': '[email protected]',
-                variant: 'ao.N.1',
                 target: processId,
-                signingFormat: 'ANS-104',
-                'accept-bundle': 'true',
-                'accept-codec': '[email protected]',
-                data: dataStr
+                'signing-format': 'ANS-104',
+                accept: 'application/json',
+                'accept-bundle': 'true'
+              }
+              if (dataStr) {
+                pushParams.data = dataStr
               }
             }
 

servers/mu/src/domain/lib/write-message-tx.js

@@ -78,8 +78,8 @@ export function writeMessageTxWith (env) {
             schedulerType: ctx.schedulerType,
             processId: ctx.tx.processId,
             id: ctx.dataItem?.id || '',
-            tags: ctx.dataItem?.tags || [],
-            dataStr: ctx.dataItem?.data || ''
+            tags: ctx.dataItem?.tags || ctx?.cachedMsg?.msg?.Tags || [],
+            dataStr: ctx.dataItem?.data || ctx?.cachedMsg?.msg?.Data || ''
           })
             .map(assoc('schedulerTx', __, ctx))
             .map(ctxSchema.parse)

servers/mu/src/domain/lib/write-process-tx.js

@@ -42,8 +42,8 @@ export function writeProcessTxWith (env) {
               schedulerType: ctx.schedulerType,
               processId: ctx.tx.id,
               id: ctx.dataItem?.id || '',
-              tags: ctx.dataItem?.tags || [],
-              dataStr: ctx.dataItem?.data || ''
+              tags: ctx.dataItem?.tags || ctx?.cachedMsg?.msg?.Tags || [],
+              dataStr: ctx.dataItem?.data || ctx?.cachedMsg?.msg?.Data || ''
             })
           })
       })