From ffee4c7051982f3677d6717d24e7b357a89802eb Mon Sep 17 00:00:00 2001
From: Adam Soltys <asoltys@gmail.com>
Date: Wed, 29 Jul 2020 10:04:57 -0700
Subject: warn about missing and unconfirmed transactions

---
 lib/read.js | 25 +++++++++++++++++++++++++
 1 file changed, 25 insertions(+)
 create mode 100644 lib/read.js

(limited to 'lib')

diff --git a/lib/read.js b/lib/read.js
new file mode 100644
index 00000000..dfd70e75
--- /dev/null
+++ b/lib/read.js
@@ -0,0 +1,25 @@
+module.exports = (stream, func) => {
+  var remaining = "";
+
+  stream.on("data", function (data) {
+    remaining += data;
+    var index = remaining.indexOf("\n");
+    var last = 0;
+    while (index > -1) {
+      var line = remaining.substring(last, index);
+      last = index + 1;
+      func(line);
+      index = remaining.indexOf("\n", last);
+    }
+
+    remaining = remaining.substring(last);
+  });
+
+  stream.on("error", () => {});
+
+  stream.on("end", function () {
+    if (remaining.length > 0) {
+      func(remaining);
+    }
+  });
+};
-- 
cgit v1.2.3