feat: lc messages and use slot/current for feed

Author: twilson63

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@permaweb/aos",
-  "version": "2.0.7",
+  "version": "2.0.8",
   "private": true,
   "repository": "https://github.com/permaweb/aos.git",
   "license": "MIT",
@@ -22,7 +22,7 @@
     "test-all": "yarn workspaces --parallel run test"
   },
   "dependencies": {
-    "@permaweb/aoconnect": "^0.0.89",
+    "@permaweb/aoconnect": "^0.0.90",
     "arweave": "^1.15.1",
     "chalk": "^5.3.0",
     "figlet": "^1.7.0",

src/services/mainnet.js

@@ -60,15 +60,13 @@ export function sendMessageMainnet({ processId, wallet, tags, data }, spinner) {
   const { request } = setupMainnet(wallet)
   const submitRequest = fromPromise(request)
   const params = {
-    Type: 'Message',
+    type: 'Message',
     path: `/${processId}[email protected]/push/[email protected]`,
     method: 'POST',
-    ...tags.filter(t => t.name !== 'device').reduce((a, t) => assoc(t.name, t.value, a), {}),
+    ...tags.reduce((a, t) => assoc(t.name, t.value, a), {}),
     'data-protocol': 'ao',
     variant: 'ao.N.1',
     target: processId,
-    "accept-bundle": "true",
-    // "accept-codec": "[email protected]",
     "signing-format": "ANS-104"
   }
   // set data if needed
@@ -144,17 +142,16 @@ export function spawnProcessMainnet({ wallet, src, tags, data, isHyper }) {
   const params = {
     path: '/push',
     method: 'POST',
-    Type: 'Process',
+    type: 'Process',
     device: '[email protected]',
     'scheduler-device': '[email protected]',
     'push-device': '[email protected]',
     'execution-device': '[email protected]',
     'data-protocol': 'ao',
     variant: 'ao.N.1',
+    // ...tags.reduce((a, t) => assoc(t.name.toLowerCase(), t.value, a), {}),
     ...tags.reduce((a, t) => assoc(t.name, t.value, a), {}),
     'aos-version': pkg.version,
-    'accept-bundle': 'true',
-    'codec-device': '[email protected]',
     'signing-format': 'ANS-104'
   }
   if (data) {
@@ -219,22 +216,20 @@ export async function liveMainnet(id, watch) {
       try {
         isJobRunning = true;
         // Get the current slot
-        const currentSlotPath = `/${id}[email protected]/slot/current/body/[email protected]`        // LIVE PARAMS
+        const currentSlotPath = `/${id}[email protected]/slot/current`        // LIVE PARAMS
         const currentSlotParams = {
           path: currentSlotPath,
           method: 'POST',
           device: '[email protected]',
           'data-protocol': 'ao',
           variant: 'ao.N.1',
           'aos-version': pkg.version,
-          signingFormat: 'ANS-104',
-          "accept-bundle": "true",
-          "accept-codec": "[email protected]"
+          'signing-format': 'ANS-104'
         }
         const currentSlot = await request(currentSlotParams)
           .then(res => res.body)
-          .then(JSON.parse)
-          .then(res => res.body)
+          // .then(JSON.parse)
+          // .then(res => res.body)
 
         if (isNaN(cursor)) {
           cursor = currentSlot + 1
@@ -252,9 +247,7 @@ export async function liveMainnet(id, watch) {
             'push-device': '[email protected]',
             variant: 'ao.N.1',
             'aos-version': pkg.version,
-            signingFormat: 'ANS-104',
-            "accept-bundle": "true",
-            "accept-codec": "[email protected]"
+            'signing-format': 'ANS-104',
           }
           const results = await request(params)
             .then(res => res.body)
@@ -451,13 +444,11 @@ export async function handleNodeTopup(jwk, insufficientBalance) {
       'data-protocol': 'ao',
       variant: 'ao.N.1',
       target: PAYMENT.subledger,
-      'accept-bundle': 'true',
-      'accept-codec': '[email protected]',
-      'signingFormat': 'ANS-104',
+      'signing-format': 'ANS-104',
       action: 'Transfer',
-      Recipient: walletAddress,
-      Route: ledgerAddress,
-      Quantity: sendQuantity
+      recipient: walletAddress,
+      route: ledgerAddress,
+      quantity: sendQuantity
     }
 
     const transferRes = await aoMainnet.request(transferParams);

yarn.lock

@@ -835,10 +835,10 @@
     ramda "^0.30.0"
     zod "^3.23.5"
 
-"@permaweb/aoconnect@^0.0.89":
-  version "0.0.89"
-  resolved "https://registry.yarnpkg.com/@permaweb/aoconnect/-/aoconnect-0.0.89.tgz#10f984e39675b60196f57887dc7afdea22594af9"
-  integrity sha512-Wphud6V+KfQLn+siiWij/ms1TpRJ7CWA/rt01Jk+QKbQP5kW3IcncwmfNTFygoCdAQPterD6s5SHr/hNLlFCUQ==
+"@permaweb/aoconnect@^0.0.90":
+  version "0.0.90"
+  resolved "https://registry.yarnpkg.com/@permaweb/aoconnect/-/aoconnect-0.0.90.tgz#41dfec3f7ace9449a2af60feab04fb4c08d6c354"
+  integrity sha512-VKEkwKV5Lv6q2pai38gz/ngcRML4iApWsJc5B8X8ow9fJIXnd9UK8y0HMbrKUF/VB5Eb8r8lJhDr76yiL6QWAA==
   dependencies:
     "@dha-team/arbundles" "1.0.3"
     "@permaweb/ao-scheduler-utils" "~0.0.25"