Light Node

README.md

@@ -209,7 +209,20 @@ Let's revisit the example mentioned earlier:
 This whole process resembles the unix pipeline system, and no security is breached along the way, thanks to Bitcoin.
 
 
+# Modes
 
+There are two modes:
+
+**1. Full Node:** Works with your OWN node, which means you need a Bitcoin node.
+**2. Light Node:** Works WITHOUT a Bitcoin node. Instead it uses a remote insight endpoint (Default: bchsvexplorer.com)
+
+By default Bitpipe runs as Light node.
+
+If you want to use your own Bitcoin node instead of a remote Insight API, you can add the following line to the `.env` file:
+
+```
+LOCAL=true
+```
 
 
 # Usage

demo/default/bitchat.js

@@ -0,0 +1,24 @@
+/*
+You can filter this transaction with the following bitquery:
+{
+  "v": 3,
+  "q": {
+    "find": {
+      "out.b0": { "op": 106 },
+      "out.b1": { "op": 0 }
+    }
+  }
+}
+*/
+var axios = require('axios')
+const host = "https://pipe.bitdb.network"
+var datapay = require('datapay')
+axios.post(host + "/bitpipe", {
+  data: [ "", "Hello from Bitpipe"]
+})
+.then(function(response) {
+  console.log("response = ", response)
+})
+.catch(function(e) {
+  console.log("Error = ", e)
+})

demo/default/bitchat2.js

@@ -0,0 +1,20 @@
+// post multiple consecutive messages
+var axios = require('axios')
+const host = "https://pipe.bitdb.network"
+var datapay = require('datapay')
+var seed = "#";
+var run = async function(space) {
+  return axios.post(host + "/bitpipe", {
+    data: [ "", space + seed ]
+  })
+};
+(async function() {
+  for(i=0; i < 30; i++) {
+    let space = "#".repeat(i)
+    let response = await run(space).catch(function(e) {
+      console.log("Error", e)
+    })
+    await new Promise(done => setTimeout(done, 2000));
+    console.log("response = ", response.data)
+  }
+})();

demo/default/payload.js

@@ -1,5 +1,5 @@
 var axios = require('axios')
-const host = "https://bitpipe.bitdb.network"
+const host = "https://pipe.bitdb.network"
 var datapay = require('datapay')
 axios.post(host + "/bitpipe", {
   data: [ "0x6d02", "hello from datapay" ]

index.js

@@ -30,6 +30,7 @@ const PRIVATE_KEYS = KEYS.filter(function(p) {
 var app = null
 var current_index = 0
 
+var rpc
 var start = function(o) {
   var lambda = null
   var port = 8081
@@ -52,14 +53,19 @@ var start = function(o) {
   app.use(express.urlencoded({extended: true}));
   app.use(express.json())
   app.use(express.static('public'))
-  const rpc = new RpcClient({
-    'protocol': 'http',
-    'user': KEY_MAPPING.rpc_user ? KEY_MAPPING.rpc_user : 'root',
-    'pass': KEY_MAPPING.rpc_pass ? KEY_MAPPING.rpc_pass : 'bitcoin',
-    'host': KEY_MAPPING.host ? KEY_MAPPING.host : ip.address(),
-    'port': '8332',
-    'limit': 15
-  })
+  if (KEY_MAPPING.LOCAL) {
+    // rpc
+    rpc = new RpcClient({
+      'protocol': 'http',
+      'user': KEY_MAPPING.rpc_user ? KEY_MAPPING.rpc_user : 'root',
+      'pass': KEY_MAPPING.rpc_pass ? KEY_MAPPING.rpc_pass : 'bitcoin',
+      'host': KEY_MAPPING.host ? KEY_MAPPING.host : ip.address(),
+      'port': '8332',
+      'limit': 15
+    })
+  } else {
+    // use remote insight
+  }
   app.get('/', function (req, res) {
     res.send('Hello Bitpipe!\n\nMake a POST request to:' + req.protocol + "://" + req.headers.host + req.originalUrl + "/bitpipe with a datapay payload.\n\nMore at https://github.com/unwriter/datapay")
   })
@@ -99,18 +105,28 @@ var run = function(err, payload, res) {
       payload.pay = { key : current_key }
     }
     console.log('payload = ', payload)
-    datapay.build(payload, function(err, signed_tx) {
-      console.log("signed tx = ", signed_tx)
-      rpc.sendRawTransaction(signed_tx, function(err, r) {
+    if (KEY_MAPPING.LOCAL) {
+      datapay.build(payload, function(err, signed_tx) {
+        console.log("signed tx = ", signed_tx)
+        rpc.sendRawTransaction(signed_tx, function(err, r) {
+          if (err) {
+            console.log("error: ", err)
+            res.json({success: false, message: err.toString()})
+          } else {
+            console.log("success: ", r)
+            res.json({success: true})
+          }
+        })
+      })
+    } else {
+      datapay.send(payload, function(err, res) {
         if (err) {
-          console.log("error: ", err)
-          res.json({success: false, message: err.toString()})
+          console.log("Error:", err)
         } else {
-          console.log("success: ", r)
-          res.json({success: true})
+          console.log("result = ", res)
         }
       })
-    })
+    }
   }
 }
 if (require.main === module) {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "bitpipe",
-  "version": "0.0.2",
+  "version": "0.0.3",
   "description": "",
   "main": "index.js",
   "scripts": {