balanceofsatoshis/balances/table_rows_from_csv.js

const asyncAuto = require('async/auto');
const {returnResult} = require('asyncjs-util');

const columnDivider = ',';
const newLine = '\n';
const quoteMark = '"';

/** Get rows for table output from CSV

  {
    [csv]: <CSV String>
  }

  @returns via cbk or Promise
  {
    rows: [[<Column String>]]
  }
*/
module.exports = ({csv}, cbk) => {
  return new Promise((resolve, reject) => {
    return asyncAuto({
      // Get the parse function
      parse: async () => (await import('csv-parse')).parse,

      // Parse CSV
      entries: ['parse', ({parse}, cbk) => {
        if (!csv) {
          return cbk(null, []);
        }

        return parse(csv, (err, entries) => {
          if (!!err) {
            return cbk([400, 'FailedToParseCsv', {err}]);
          }

          return cbk(null, entries);
        });
      }],

      // Arrange rows
      rows: ['entries', ({entries}, cbk) => {
        if (!entries.length) {
          return cbk(null, {rows: [[]]});
        }

        const [header] = entries;

        const datedRecords = entries.slice([header].length).sort((a, b) => {
          if (a[2] > b[2]) {
            return 1;
          }

          if (b[2] > a[2]) {
            return -1;
          }

          return 0;
        });

        const rows = [].concat([header]).concat(datedRecords);

        return cbk(null, {rows});
      }],
    },
    returnResult({reject, resolve, of: 'rows'}, cbk));
  });
};