Merge pull request #1298 from permaweb/feat/upload-wallet-messages-to-hb

feat(mu): write wallet messages to hb

Author: VinceJuliano

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

@@ -2,7 +2,7 @@ import { identity } from 'ramda'
 import { of, fromPromise, Rejected } from 'hyper-async'
 import { withTimerMetricsFetch } from '../lib/with-timer-metrics-fetch.js'
 
-function uploadDataItemWith ({ UPLOADER_URL, fetch, histogram, logger }) {
+function uploadDataItemWith ({ UPLOADER_URL, fetch, histogram, logger, HB_GRAPHQL_URL }) {
   const dataItemFetch = withTimerMetricsFetch({
     fetch,
     timer: histogram,
@@ -36,7 +36,24 @@ function uploadDataItemWith ({ UPLOADER_URL, fetch, histogram, logger }) {
               Accept: 'application/json'
             },
             body
+          }).then((res) => { return { body, res } })
+        )
+      )
+      .chain(
+        fromPromise(({ body, res }) =>
+          dataItemFetch(`${HB_GRAPHQL_URL}/~arweave@2.9-pre/tx?codec-device=ans104@1.0`, {
+            method: 'POST',
+            headers: {
+              'Content-Type': 'application/octet-stream',
+              Accept: 'application/json'
+            },
+            body
           })
+            .then(() => res)
+            .catch((err) => {
+              logger.tap({ log: 'Error while communicating with HB uploader:' })(err)
+              return res
+            })
         )
       )
       .bimap(logger.tap({ log: 'Error while communicating with uploader:' }), identity)

servers/mu/src/domain/index.js

@@ -312,7 +312,7 @@ export const createApis = async (ctx) => {
     isWallet: gatewayClient.isWalletWith({ fetch, histogram, getProcess, ARWEAVE_URL, SU_ROUTER_URL, HB_ROUTER_URL, ENABLE_HB_WALLET_CHECK, logger: sendDataItemLogger }),
     isHyperBeamProcess: gatewayClient.isHyperBeamProcessWith({ getProcess, logger: sendDataItemLogger, getIsHyperBeamProcess, setIsHyperBeamProcess }),
     logger: sendDataItemLogger,
-    writeDataItemArweave: uploaderClient.uploadDataItemWith({ UPLOADER_URL, logger: sendDataItemLogger, fetch, histogram }),
+    writeDataItemArweave: uploaderClient.uploadDataItemWith({ UPLOADER_URL, logger: sendDataItemLogger, fetch, histogram, HB_GRAPHQL_URL }),
     spawnPushEnabled: SPAWN_PUSH_ENABLED,
     db,
     traceDb,
@@ -536,7 +536,7 @@ export const createResultApis = async (ctx) => {
     fetchResult: cuClient.resultWith({ fetch: fetchWithCache, histogram, CU_URL, logger: processMsgLogger }),
     fetchHyperBeamResult: cuClient.fetchHyperBeamResultWith({ fetch, histogram, logger: processMsgLogger, fetchHBProcesses }),
     isWallet: gatewayClient.isWalletWith({ fetch, histogram, getProcess, ARWEAVE_URL, SU_ROUTER_URL, HB_ROUTER_URL, ENABLE_HB_WALLET_CHECK, logger: processMsgLogger, setById, getById }),
-    writeDataItemArweave: uploaderClient.uploadDataItemWith({ UPLOADER_URL, logger: processMsgLogger, fetch, histogram }),
+    writeDataItemArweave: uploaderClient.uploadDataItemWith({ UPLOADER_URL, logger: processMsgLogger, fetch, histogram, HB_GRAPHQL_URL }),
     isHyperBeamProcess: gatewayClient.isHyperBeamProcessWith({ getProcess, logger: processMsgLogger, getIsHyperBeamProcess, setIsHyperBeamProcess }),
     RELAY_MAP,
     topUp: RelayClient.topUpWith({