demosifter

"emails":{
  "gmailEmails":{
    "filter":{
      "conditions":[{
        "date": "between now and 1 week before now"
      }]
    },
    "wants": [
      "archive",
      "headers",

demosifter

"nodes":[{
  "#": "First Node",
  "input": {
    "bucket": "gmailEmails"
  },
  "implementation": {
    "javascript": "server/node1.js"
  },
  "outputs": {
    "output1": {}

demosifter

module.exports = function (got) {
  // got.in contains the key/value pairs that match the given query
  const inData = got.in;   
  
  console.log('counter: node1.js: running...', inData.data);

  const json = inData.data.map(d => JSON.parse(d.value));

  json.forEach(function(value, i){
    console.log('datum#', i, 'value:', value)

demosifter

let textUtils = require('@redsift/text-utilities');
  // ...
  let counts = others.map(value => {
    let text = value.textBody || value.strippedHtmlBody || '';
    let count = textUtils.splitWords(textUtils.trimEmailThreads(text)).length;
    return count;
  });
  
  console.log(counts);

demosifter

"outputs":{
  "exports":{
    "count" : {
      "key$schema":"string"
    }
  }
}

demosifter

"nodes":[{
  "#": "First Node",
  "input": {
    "bucket": "gmailEmails"
  },
  "implementation": {
    "javascript": "server/node1.js"
  },
  "outputs": {
    "count": {}

demosifter

let textUtils = require('@redsift/text-utilities');

module.exports = function (got) {
  // got.in contains the key/value pairs that match the given query
  const inData = got.in;
  
  console.log('counter: node1.js: running...', inData.data);

  const json = inData.data.map(d => JSON.parse(d.value));

demosifter

curl -sSL https://static-sdk.redsift.io/install | bash

demosifter

redsift create counter

demosifter

const others = json.filter(j => j.user !== j['from'].email);