Greenkeeper/fbp spec 0.6.2

.eslintrc.json

@@ -0,0 +1,3 @@
+{
+  "extends": "airbnb-base"
+}

.gitignore

@@ -1,6 +1,4 @@
 /node_modules/
-spec/*.js
-spec/browser/*.js
 npm-debug.log
 .DS_Store
 .noflo.json

.travis.yml

@@ -1,7 +1,5 @@
 language: node_js
 sudo: false
 node_js:
-- '0.12'
-- '4.2'
-- '6.2'
+- 'lts/*'
 script: npm test

README.md

@@ -1,2 +1,15 @@
-# Canadianness
-## Example program using noflo
+# Canadianness [![Build Status](https://travis-ci.org/noflo/canadianness.svg?branch=master)](https://travis-ci.org/noflo/canadianness) [![Greenkeeper badge](https://badges.greenkeeper.io/noflo/canadianness.svg)](https://greenkeeper.io/)
+
+Basic example of programming with [NoFlo](https://noflojs.org).
+
+## Prerequisites
+
+You need to have [Node.js](http://nodejs.org) 6.10 or newer installed.
+
+## Install
+
+    npm install
+
+## Run tests
+
+    npm test

components/ArrayToStream.js

@@ -0,0 +1,47 @@
+const noflo = require('noflo');
+
+exports.getComponent = () => {
+  const c = new noflo.Component({
+    description: 'Convert input array to a NoFlo stream',
+    inPorts: {
+      in: {
+        datatype: 'array',
+        description: 'data we want to send',
+        required: true,
+      },
+    },
+    outPorts: {
+      out: {
+        datatype: 'string',
+        description: 'the data wrapped in brackets',
+        required: true,
+      },
+    },
+  });
+
+  c.process((input, output) => {
+    if (!input.hasData('in')) { return; }
+
+    let datas = input.getData('in');
+    if (!Array.isArray(datas)) {
+      datas = [datas];
+    }
+
+    output.send({
+      out: new noflo.IP('openBracket'),
+    });
+
+    datas.forEach((data) => {
+      output.send({
+        out: new noflo.IP('data', data),
+      });
+    });
+
+    output.send({
+      out: new noflo.IP('closeBracket'),
+    });
+    output.done();
+  });
+
+  return c;
+};

components/DetermineEmotion.js

@@ -0,0 +1,113 @@
+// ## Import libraries
+const noflo = require('noflo');
+
+// ## Useful functions
+//
+// Function to calculate most common value (the [mode](https://en.wikipedia.org/wiki/Mode_(statistics))
+function findMode(array) {
+  const frequency = {};
+  let maxFrequency = 0;
+  let result;
+  array.forEach((v) => {
+    frequency[v] = (frequency[v] || 0) + 1;
+    if (frequency[v] > maxFrequency) {
+      maxFrequency = frequency[v];
+      result = v;
+    }
+  });
+  return result;
+}
+
+// ## Component declaration
+//
+// Define the input and output ports, and describe their function
+exports.getComponent = () => {
+  const c = new noflo.Component({
+    description: 'Find all of the instances of `word` in `content` and send them out in a stream',
+    inPorts: {
+      content: {
+        datatype: 'string',
+        description: 'the content which we look for the word in',
+        required: true,
+      },
+    },
+    outPorts: {
+      emotion: {
+        datatype: 'string',
+        description: 'the emotion based the content in ehs',
+        required: true,
+      },
+      error: {
+        datatype: 'object',
+      },
+    },
+  });
+
+  // Since we want to work with a full stream, we disable bracket forwarding
+  c.forwardBrackets = {};
+
+  // ## Processing function
+  //
+  c.process((input, output) => {
+    // ### Receiving input
+    //
+    // We expect a [stream](noflojs.org/documentation/process-api/#full-stream)
+    // Will also accept a single (non-bracketed) input packet, returned as a stream of length 1
+    if (!input.hasStream('content')) { return; }
+
+    // The output will be a single packet (not a stream),
+    // hence we drop the `openBracket` and `closeBracket`
+    // and extract the data payload from the IP objects
+    const contents = input.getStream('content').filter(ip => ip.type === 'data').map(ip => ip.data);
+
+    // ### Component business logic
+    //
+    // First find which emotions are present, then calculate which one is most common.
+    // This could alternatively be split into two dedicate components.
+
+    // to hold the emotions found
+    const matches = [];
+
+    // the emotions we will use
+    const emotions = {
+      joy: ['eh!'],
+      neutral: ['eh'],
+      amusement: ['eh?', 'Eh?', 'Eh??'],
+      fear: ['eH??', 'eh??'],
+      surprise: ['eh !?', 'EH!?'],
+      anticipation: ['eh?!'],
+      excitment: ['EH!', 'eH!'],
+      sadness: ['...eh', '...eh...', '..eh', 'eh..', '..eh..'],
+      anger: ['EH!?', 'EH?'],
+    };
+
+    // go through our content and our emotions
+    // then add them to our `matches`
+    contents.forEach((content) => {
+      Object.keys(emotions).forEach((emotion) => {
+        const data = emotions[emotion];
+        if (data.indexOf(content) !== -1) {
+          matches.push(emotion);
+        }
+      });
+    });
+
+    // if we didn't get any emotions, it default to 'neutral'
+    let mode;
+    if (matches.length === 0) {
+      mode = 'neutral';
+    // if we did, we need to find the emotion that was the most common
+    } else {
+      mode = findMode(matches);
+    }
+
+    // ### Send output
+    //
+    // Also signals completion by using `sendDone()`
+    output.sendDone({
+      emotion: mode,
+    });
+  });
+
+  return c;
+};