restore

Leo4815162342 · Feb 27, 2024 · 537a797 · 537a797
1 parent e5d0dce
commit 537a797
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 10 deletions.
diff --git a/src/cli/cli.ts b/src/cli/cli.ts
@@ -14,16 +14,12 @@ import { processData } from '../processor';
 import { formatBytes } from '../utils/formatBytes';
 import chalk from 'chalk';
 import debug from 'debug';
-// import dayjs from 'dayjs';
-// import utc from 'dayjs/plugin/utc';
 
 import { version } from '../../package.json';
 import { BatchStreamWriter } from '../stream-writer';
 import { BufferObject } from '../buffer-fetcher/types';
 import { formatTimeDuration } from '../utils/formatTimeDuration';
 
-// dayjs.extend(utc);
-
 const DEBUG_NAMESPACE = 'dukascopy-node:cli';
 
 export async function run(argv: NodeJS.Process['argv']) {
@@ -192,10 +188,7 @@ export async function run(argv: NodeJS.Process['argv']) {
               ignoreFlats
             });
 
-            await batchStreamWriter.writeBatch(
-              processedBatch
-              // dateFormat ? timeStamp => dayjs(timeStamp).utc().format(dateFormat) : undefined
-            );
+            await batchStreamWriter.writeBatch(processedBatch);
           }
 
           if (isLastBatch) {

diff --git a/src/stream-writer/index.ts b/src/stream-writer/index.ts
@@ -101,7 +101,7 @@ export class BatchStreamWriter {
   private initHeaders() {
     const bodyHeaders =
       this.timeframe === Timeframe.tick
-        ? ['timestamp', 'askPrice', 'bidPrice', 'askVolume', 'bidVolume'] // TODO: add custom header names as cli options
+        ? ['timestamp', 'askPrice', 'bidPrice', 'askVolume', 'bidVolume']
         : ['timestamp', 'open', 'high', 'low', 'close', 'volume'];
 
     if (!this.volumes) {
@@ -115,7 +115,7 @@ export class BatchStreamWriter {
   }
 
   public async writeBatch(batch: number[][]) {
-    const batchWithinRange: (number | string)[][] = [];
+    const batchWithinRange: number[][] = [];
 
     for (let j = 0; j < batch.length; j++) {
       const item = batch[j];