Demo for query storing
Change-Id: I947bcac841992c3f6cfd01ab337c265b0d01cb70
diff --git a/node_modules/console-stream/index.js b/node_modules/console-stream/index.js
new file mode 100644
index 0000000..5e64ad6
--- /dev/null
+++ b/node_modules/console-stream/index.js
@@ -0,0 +1,45 @@
+var Stream = require("stream")
+var console = require("console")
+
+var NEW_LINE = "\n"
+
+module.exports = ConsoleStream
+
+function ConsoleStream() {
+ var stream = new Stream()
+ stream.writable = true
+ var buffered = ""
+
+ stream.write = write
+ stream.destroy = destroy
+ stream.end = end
+
+ return stream
+
+ function write(buffer) {
+ var s = buffered + String(buffer)
+ var lines = s.split(NEW_LINE)
+ for (var i = 0; i < lines.length - 1; i++) {
+ console.log(lines[i])
+ }
+
+ buffered = lines[i]
+ }
+
+ function destroy() {
+ stream.writable = false
+ stream.emit("close")
+ }
+
+ function end(buffer) {
+ if (arguments.length === 1) {
+ stream.write(buffer)
+ }
+
+ if (buffered) {
+ console.log(buffered)
+ }
+
+ stream.destroy()
+ }
+}