Sending a message via minode

Dockerfile

@@ -1,7 +1,13 @@
-FROM node:16.14.2
+FROM node:18-bullseye
+
+RUN apt-get update
+RUN apt-get install -yq python3-pip
 
 WORKDIR /app
 
+RUN pip install pyzmq \
+    git+https://git.bitmessage.org/Bitmessage/MiNode.git@queue#egg=minode
+
 COPY package.json package.json
 COPY package-lock.json package-lock.json
 
@@ -9,4 +15,4 @@ RUN npm install
 
 COPY . .
 
-CMD [ "node", "index.js" ]
+CMD ["node", "index.js"]

index.js

@@ -1,68 +1,42 @@
-var messages = require('bitmessage').messages;
-var objects = require('bitmessage').objects;
-var Address = require('bitmessage').Address;
-var TcpTransport = require('bitmessage-transports').TcpTransport;
-var eccrypto = require("eccrypto");
+
+const objects = require('bitmessage').objects,
+      Address = require('bitmessage').Address;
+
+const { spawn } = require('child_process');
+const zmq = require('zeromq');
 
 (async () => {
-  const from = Address.fromPassphrase('loremipsum1');
-  console.log('[from]', from.encode());
-  console.log('[from sign priv key]', from.signPrivateKey.toString('hex'));
-  console.log('[from version]', from.version);
-  console.log('[from stream]', from.stream);
-  console.log('[from behaviour]', from.behavior);
-  const toAddr = Address.fromPassphrase('gru');
-  console.log('[toAddr]', toAddr.encode());
-  console.log('[toAddr enc pub key]', toAddr.encPublicKey.toString('hex'));
-  console.log('[toAddr version]', toAddr.version);
-  console.log('[toAddr stream]', toAddr.stream);
-  console.log('[toAddr ripe]', toAddr.ripe);
-  const encodedMsg = await objects.msg.encodePayloadAsync({
+  const sock = zmq.socket('pub');
+
+  sock.bindSync('tcp://127.0.0.1:5566');
+  console.log('Publisher bound to port 5566');
+
+  spawn(
+    'minode', ['--request-queue', 'tcp://127.0.0.1:5566'],
+    {timeout: 300000, killSignal: 'SIGQUIT'}
+  ).stderr.on('data', (data) => {
+    console.log(`${data}`);
+  });
+
+  const sender = Address.fromRandom(),
+	recipient = Address.fromPassphrase('test');
+  console.log('sender:', sender.encode());
+  console.log('recipient:', recipient.encode());
+
+  var msg = await objects.msg.encodePayloadAsync({
     ttl: 1800,
-    from: from,
-    to: toAddr,
-    message: 'hey there!',
-    subject: 'Lorem Ipsum',
+    from: sender,
+    to: recipient,
+    message: 'The quick brown fox jumps over the lazy dog.',
+    subject: 'hello',
     encoding: 2,
-    friend: true,
-    skipPow: true,
+    friend: true
   });
-  const strippedMsg = encodedMsg.slice(8);
-  console.log('[check messages]', strippedMsg);
-  console.log('[check messages]', strippedMsg.toString('hex'));
-  var d = await objects.msg.decodePayloadAsync(encodedMsg, {
-    skipPow: true,
-    identities: toAddr,
-  });
-  console.log('[decoded]', d.message);
-  // const encPublicKey = '04a60f6cd97ecd16768215ef059ccfbb1840b736bcdb0763872ddfeef4c417d2ec8439383ce68de9a2b30ad44e9f0e56a13fc2895a6e41f7cf3757e46181d32dd0';
-  // const encPrivateKey = '2cb5ae4e8cf8c71d1221f5c6c46810b448207cacedd86cc52219c3f107048c10';
-  // const dec = await objects.msg.decPayloadTest(encPrivateKey, e);
-  // console.log('[dec]', dec);
-  // var encObj = encrypted.decode(buf);
-  // resolve(eccrypto.decrypt(privateKey, encObj));
+  console.log('msg:', msg.toString('hex'));
+
+  console.log('Sending the msg');
+  sock.send(Buffer.concat([
+    Buffer.from('msg', 'ascii'), Buffer.from('00', 'hex'), msg
+  ]));
 
 })();
-// var tcp = new TcpTransport({
-//   dnsSeeds: [['bootstrap8444.bitmessage.org', 8444]],
-// });
-
-// tcp.bootstrap().then(function (nodes) {
-//   var remoteHost = nodes[0][0];
-//   var remotePort = nodes[0][1];
-//   console.log('Connecting to', nodes[0]);
-//   tcp.connect(remotePort, remoteHost);
-// });
-
-// tcp.on('established', function (version) {
-//   console.log('Connection established to', version.userAgent);
-
-//   tcp.on('message', function (command, payload) {
-//     console.log('Got new', command, 'message');
-//     var decoded;
-//     if (command === 'addr') {
-//       decoded = messages.addr.decodePayload(payload);
-//       console.log('Got', decoded.addrs.length, 'node addresses');
-//     }
-//   });
-// });

package.json

@@ -11,7 +11,9 @@
   "license": "ISC",
   "dependencies": {
     "bignum": "^0.13.1",
-    "bitmessage": "^0.6.6",
-    "bitmessage-transports": "^0.1.4"
+    "bitmessage": "git+https://git.bitmessage.org/Bitmessage/bitmessage-js.git#mac",
+    "nan": "2.15.0",
+    "secp256k1": "3.7.1",
+    "zeromq": "5.3.1"
   }
 }