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

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

demosifter

module.exports = function (got) {
  const json = got.in.data.map(d => JSON.parse(d.value));

  const query = got.query;
  const threadId = query[0];
  let newestCount = json
    .sort((a, b) => new Date(b.date).getTime() - new Date(a.date).getTime())
    .shift().count;

  return [{

demosifter

loadThreadListView (listInfo) {
  console.log('counter: loadThreadListView: ', listInfo);
  if (listInfo) {
    return {
      template: '001_list_common_txt',
      value: {
        color: '#ffffff',
        backgroundColor: '#e11010',
        subtitle: listInfo + ' words'
      }

demosifter

module.exports = function (got) {
  const total = got.in.data.reduce((p, d) => p + parseInt(d.value), 0);

  return {
    key: 'word_count',
    value: total
  }
}

demosifter

return {
  key: `${value.threadId}/${value.id}`, // instead of 'value.id
  value: {
    count: count,
    date: value.date
  }
}

demosifter

<div class="column">
  <p>I'm a Sift!</p>
  <p id='number'>0</p>
</div>

demosifter

//...
constructor() {
  // You have to call the super() method to initialize the base class.
  super();
  this.controller.subscribe('counts', this.onCounts.bind(this));
}

// for more info: https://docs.redsift.com/docs/client-code-siftview
presentView(value) {
  console.log('counter: presentView: ', value);

demosifter

constructor() {
  // You have to call the super() method to initialize the base class.
  super();
  this._suHandler = this.onStorageUpdate.bind(this);
}

loadView(state) {
  console.log('counter: loadView', state);
  
  this.storage.subscribe(['count'], this._suHandler);

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)