From 8300fa0d0acaf16743005c33551771693fd06976 Mon Sep 17 00:00:00 2001
From: Ben West <bewest@gmail.com>
Date: Sun, 13 Jul 2014 20:46:54 -0700
Subject: [PATCH] some very simple helper scripts to work with the api

---
 bin/create_svg.sh | 23 ++++++++++++++
 bin/tsvtojson.sh  | 15 ++++++++++
 lib/api.js        | 76 ++++++++++++++++++++++++++++++++++++++++++++++-
 package.json      |  3 +-
 4 files changed, 115 insertions(+), 2 deletions(-)
 create mode 100755 bin/create_svg.sh
 create mode 100755 bin/tsvtojson.sh

diff --git a/bin/create_svg.sh b/bin/create_svg.sh
new file mode 100755
index 00000000..3fbb8fe8
--- /dev/null
+++ b/bin/create_svg.sh
@@ -0,0 +1,23 @@
+#!/bin/bash
+
+SVG=$1
+DIRECTION=$2
+AT=$3
+OPTS=""
+if [ -n "$AT" ]; then
+  OPTS="--date ${AT}"
+fi
+ISO=$(date -Iseconds $OPTS)
+UNIX=$(date +%s $OPTS)
+
+(
+cat <<EOF
+{ "svg": $SVG,
+  "device": "test",
+  "direction": "$DIRECTION",
+  "dateString": "$ISO",
+  "date": "$UNIX"
+}
+EOF
+) | tr -d '\n'
+echo
diff --git a/bin/tsvtojson.sh b/bin/tsvtojson.sh
new file mode 100755
index 00000000..68ff9762
--- /dev/null
+++ b/bin/tsvtojson.sh
@@ -0,0 +1,15 @@
+#!/bin/bash
+
+INPUT=$1
+
+(
+echo '['
+first=""
+cat $1 | while read dateString date svg direction device ; do
+  test -n "$first" && printf "," || printf -v first "nope"
+  ./bin/create_svg.sh $svg $direction $dateString
+  echo
+done 
+
+echo ']'
+) | tr -d '\n' | json
diff --git a/lib/api.js b/lib/api.js
index c78e7399..57352955 100644
--- a/lib/api.js
+++ b/lib/api.js
@@ -1,6 +1,7 @@
 'use strict';
 
 var consts = require('./constants');
+var es = require('event-stream');
 
 function api (env, entries, settings) {
 
@@ -12,6 +13,7 @@ function api (env, entries, settings) {
     var sendJSONStatus = require('./middleware/send-json-status')( );
     api.set('title', 'Nightscout API v1');
     api.use(sendJSONStatus);
+    api.use(bodyParser.raw());
     api.use(bodyParser.json());
     api.use(require('express-extension-to-accept')([
       'json', 'svg', 'csv', 'txt', 'png', 'html', 'tsv'
@@ -48,7 +50,6 @@ function api (env, entries, settings) {
             res.json(status);
           }
         });
-        return res.json({status: 'ok'});
     });
 
     api.get('/entries', function(req, res) {
@@ -77,6 +78,79 @@ function api (env, entries, settings) {
         return;
     });
 
+    api.post('/entries/preview', function (req, res) {
+        var badge = '';
+        var status = {
+          params: req.params,
+          body: req.body,
+          query: req.query
+        };
+        console.log(status);
+        var incoming = [ ];
+        if ('svg' in req.body) {
+          incoming.push(req.body);
+        }
+        if (req.body.length) {
+          incoming = incoming.concat(req.body);
+        }
+
+        function inputs ( ) {
+          var rec_sep = ',';
+          var input;
+          if (req.is('text/*')) {
+            if (req.is('text/tsv')) {
+              rec_sep = '\t';
+            }
+            input = es.pipeline(req,
+              es.split('\n'),
+              es.map(function (str, next) {
+                var p = str.split(rec_sep);
+                if (p.length < 4) { return next(null); }
+                var rec = {
+                  dateString: p[0]
+                , date: parseInt(p[1])
+                , svg: p[2]
+                , direction: p[3]
+                , device: p[4]
+                };
+                console.log(p);
+                next(null, rec);
+              })
+            );
+            return input;
+          }
+          return es.readArray(incoming);
+        }
+
+        es.pipeline(inputs( ),
+          es.writeArray(function (err, result) {
+            // incoming = incoming.concat(result);
+            // var records =  incoming.concat(result);
+            console.log(result);
+            return res.format({
+              /*
+              html: function ( ) {
+                res.send("<h1>STATUS OK</h1>");
+              },
+              png: function ( ) {
+                res.redirect(302, badge + '.png');
+              },
+              svg: function ( ) {
+                res.redirect(302, badge + '.svg');
+              },
+              text: function ( ) {
+                res.send("STATUS OK");
+              },
+              */
+              json: function ( ) {
+                res.json(result);
+              }
+            });
+          }) // ;
+        );
+        return;
+    });
+
     api.get('/entries/:id', function(req, res) {
         console.log('body', req.body);
         console.log('params', req.params);
diff --git a/package.json b/package.json
index eb1fd9d9..0d6c7283 100644
--- a/package.json
+++ b/package.json
@@ -37,6 +37,7 @@
     "express": "^4.5.1",
     "mongodb": "^1.4.7",
     "socket.io": "^0.9.17",
-    "express-extension-to-accept": "0.0.2"
+    "express-extension-to-accept": "0.0.2",
+    "event-stream": "~3.1.5"
   }
 }