Respond to PR comments.

Author: jhorbulyk

component.json

@@ -42,7 +42,7 @@
       "main": "./lib/actions/write.js",
       "title": "Write CSV attachment",
       "fields": {
-        "reader": {
+        "writer": {
           "viewClass": "CSVReadView"
         }
       },

lib/actions/write.js

@@ -15,16 +15,16 @@ let rowCount = 0;
 exports.init = function init(cfg) {
     return co(function* gen() {
 
-        const delimiter = cfg.reader.delimiter || ',';
+        const delimiter = cfg.writer.delimiter || ',';
         console.log('Using delimiter: \'%s\'', delimiter);
         const options = {
             header: true,
             delimiter
         };
 
-        if (cfg.reader.columns) {
+        if (cfg.writer.columns) {
 
-            const columns = Object.keys(_.keyBy(cfg.reader.columns, 'property'));
+            const columns = Object.keys(_.keyBy(cfg.writer.columns, 'property'));
 
             console.log('Configured column names:', columns);
             options.columns = columns;
@@ -44,11 +44,6 @@ exports.init = function init(cfg) {
 exports.process = function ProcessAction(msg, cfg) {
     // eslint-disable-next-line consistent-this
     const self = this;
-    const startRow = cfg.reader.startRow || 0;
-
-    if (startRow !== 0 && rowCount === 0) {
-        console.log('Skipping the first %s rows', startRow + 1);
-    }
 
     if (timeout) {
         clearTimeout(timeout);
@@ -57,7 +52,7 @@ exports.process = function ProcessAction(msg, cfg) {
     timeout = setTimeout(() => {
         console.log('Closing the stream due to inactivity');
         co(function* gen() {
-            const finalRowCount = rowCount - startRow;
+            const finalRowCount = rowCount;
             console.log('The resulting CSV file contains %s rows', finalRowCount);
             stringifier.end();
 
@@ -79,48 +74,12 @@ exports.process = function ProcessAction(msg, cfg) {
         });
     }, 10000);
 
-    if (startRow <= rowCount) {
-        let row = msg.body;
-        if (cfg.reader.columns) {
-            const columns = Object.keys(_.keyBy(cfg.reader.columns, 'property'));
-            row = _.pick(msg.body, columns);
-        }
-        stringifier.write(row);
+    let row = msg.body;
+    if (cfg.writer.columns) {
+        const columns = Object.keys(_.keyBy(cfg.writer.columns, 'property'));
+        row = _.pick(msg.body, columns);
     }
+    stringifier.write(row);
     rowCount++;
     this.emit('end');
 };
-
-/**
-
-
-co(function* proc() {
-    yield init();
-
-    for (let i = 0; i <= 100; i++) {
-
-        processAction({
-            body: {
-                run: i,
-                timestamp: Date.now()
-            }
-        });
-    }
-
-    setTimeout(()=> {
-
-        console.log('Next round');
-
-
-        for (let i = 100; i <= 200; i++) {
-
-            processAction({
-                body: {
-                    run: i,
-                    timestamp: Date.now()
-                }
-            });
-        }
-    }, 10000);
-});
- **/