remove calls

Leo4815162342 · Feb 27, 2024 · e5d0dce · e5d0dce
1 parent 9e7dd66
commit e5d0dce
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/src/stream-writer/index.ts b/src/stream-writer/index.ts
@@ -114,7 +114,7 @@ export class BatchStreamWriter {
     return bodyHeaders;
   }
 
-  public async writeBatch(batch: number[][], dateFormatter?: (timestamp: number) => string) {
+  public async writeBatch(batch: number[][]) {
     const batchWithinRange: (number | string)[][] = [];
 
     for (let j = 0; j < batch.length; j++) {
@@ -123,16 +123,12 @@ export class BatchStreamWriter {
         item.length > 0 && item[0] >= this.startDateTs && item[0] < this.endDateTs;
 
       if (isItemInRange) {
-        if (dateFormatter) {
-          //@ts-expect-error TODO: fix this
-          item[0] = dateFormatter(item[0]);
-        }
         batchWithinRange.push(item);
       }
     }
 
     for (let i = 0; i < batchWithinRange.length; i++) {
-      let item = batchWithinRange[i];
+      const item = batchWithinRange[i];
 
       const isFirstItem = i === 0;
       const isLastItem = i === batchWithinRange.length - 1;
@@ -156,10 +152,6 @@ export class BatchStreamWriter {
           body += ',' + (!this.isInline ? '\n' : '');
         }
 
-        if (dateFormatter && (this.format === Format.json || this.format === Format.array)) {
-          item[0] = `"${item[0]}"`;
-        }
-
         if (this.format === Format.json) {
           const jsonObjectBody = item.map((val, i) => `"${this.bodyHeaders[i]}":${val}`).join(',');
           body += `{${jsonObjectBody}}`;