feat: sunshine implemenetation

README.md

@@ -12,25 +12,17 @@
 [![Commitizen friendly](https://img.shields.io/badge/commitizen-friendly-brightgreen.svg)](http://commitizen.github.io/cz-cli/)
 
 
-kronos-interceptor
+kronos-interceptor-decode-json
 =====
-introspects / modifies requests as they pass between endpoints
-
-```javascript
-
-interceptor1.connected = interceptor2
-
-promise = interceptor1.receive(request);
-```
-
+decodes json streams into objects
 
 install
 =======
 
 With [npm](http://npmjs.org) do:
 
 ```shell
-npm install kronos-interceptor
+npm install kronos-interceptor-decode-json
 ```
 
 license

decode-json.js

@@ -0,0 +1,38 @@
+/* jslint node: true, esnext: true */
+
+'use strict';
+
+const pcs = require('parse-concat-stream'),
+	Interceptor = require('kronos-interceptor').Interceptor;
+
+/**
+ *
+ */
+class DecodeJSONInterceptor extends Interceptor {
+	static get name() {
+		return 'decode-json';
+	}
+
+	get type() {
+		return DecodeJSONInterceptor.name;
+	}
+
+	receive(request, args) {
+		return new Promise((fullfilled, rejected) =>
+			request.payload.pipe(pcs((err, data) => {
+				if (err) {
+					rejected(err);
+				} else {
+					fullfilled({
+						data: data
+					});
+				}
+			})));
+	}
+}
+
+exports.decode = DecodeJSONInterceptor;
+
+exports.registerWithManager = manager => Promise.all([
+	manager.registerInterceptor(DecodeJSONInterceptor),
+]);

package.json

@@ -2,6 +2,7 @@
   "name": "kronos-interceptor-decode-json",
   "version": "0.0.0-semantic-release",
   "description": "decodes json streams into objects",
+  "main": "decode-json.js",
   "keywords": [
     "kronos-interceptor"
   ],
@@ -29,13 +30,16 @@
     "mocha": "2.4.5",
     "semantic-release": "6.2.1"
   },
-  "contributors": [{
-    "name": "Torsten Link",
-    "email": "torstenlink@gmx.de"
-  }, {
-    "name": "Markus Felten",
-    "email": "markus.felten@gmx.de"
-  }],
+  "contributors": [
+    {
+      "name": "Torsten Link",
+      "email": "torstenlink@gmx.de"
+    },
+    {
+      "name": "Markus Felten",
+      "email": "markus.felten@gmx.de"
+    }
+  ],
   "license": "BSD-2-Clause",
   "engines": {
     "node": ">=6"
@@ -44,5 +48,9 @@
     "commitizen": {
       "path": "./node_modules/cz-conventional-changelog"
     }
+  },
+  "dependencies": {
+    "kronos-interceptor": "^2.2.1",
+    "parse-concat-stream": "^0.2.0"
   }
 }

tests/decode_test.js

@@ -0,0 +1,67 @@
+/* global describe, it, xit */
+/* jslint node: true, esnext: true */
+
+'use strict';
+
+const chai = require('chai'),
+  assert = chai.assert,
+  expect = chai.expect,
+  should = chai.should(),
+  fs = require('fs'),
+  path = require('path'),
+  kti = require('kronos-test-interceptor'),
+  JSONDecodeInterceptor = require('../decode-json').decode;
+
+const mochaInterceptorTest = kti.mochaInterceptorTest,
+  testResponseHandler = kti.testResponseHandler;
+
+const logger = {
+  debug(a) {
+    console.log(a);
+  }
+};
+
+/* simple owner with name */
+function dummyEndpoint(name) {
+  return {
+    get name() {
+      return name;
+    },
+    get path() {
+      return '/get:id';
+    },
+    toString() {
+      return this.name;
+    },
+    "step": logger
+  };
+}
+
+describe('interceptors', () => {
+  const ep = dummyEndpoint('ep');
+
+  mochaInterceptorTest(JSONDecodeInterceptor, ep, {}, 'decode-json', (itc, withConfig) => {
+    if (!withConfig) return;
+
+    describe('json', () => {
+      it('toJSON', () => {
+        assert.deepEqual(itc.toJSON(), {
+          type: 'decode-json'
+        });
+      });
+    });
+
+    itc.connected = dummyEndpoint('ep');
+    itc.connected.receive = testResponseHandler;
+
+    it('passing request', () => itc.receive({
+      payload: fs.createReadStream(path.join(__dirname, 'fixtures/simple.json'))
+    }).then((response) => {
+      assert.deepEqual(response, {
+        data: {
+          a: 1
+        }
+      });
+    }));
+  });
+});

tests/fixtures/simple.json

@@ -0,0 +1,3 @@
+{
+  "a": 1
+}