From c13277ebef2ef40bd3002b4f93c46cd78e3bd08c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Bart=C5=82omiej=20Pluta?=
 <noreply.git@mx.bartlomiejpluta.com>
Date: Thu, 14 Nov 2024 14:17:37 +0100
Subject: [PATCH] Fix token parsing for InfluxDB

---
 src/consumers/influxdb/index.ts | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/consumers/influxdb/index.ts b/src/consumers/influxdb/index.ts
index 556006a..51f521a 100644
--- a/src/consumers/influxdb/index.ts
+++ b/src/consumers/influxdb/index.ts
@@ -1,3 +1,4 @@
+import { readFileSync } from "fs";
 import { InfluxDB, Point } from "@influxdata/influxdb-client";
 import { Consumer } from "../abstract";
 import { InfluxDBConfig } from "./types";
@@ -17,7 +18,7 @@ export class InfluxDBConsumer extends Consumer<InfluxDBConfig> {
   protected async publish({ databaseURL, apiToken, organization, bucket }: InfluxDBConfig, date: Dayjs, measurement: Measurement) {
     const db = new InfluxDB({ 
       url: databaseURL,
-      token: apiToken,
+      token: readFileSync(apiToken, 'utf8'),
     });
 
     const api = db.getWriteApi(organization, bucket);
@@ -47,7 +48,7 @@ export class InfluxDBConsumer extends Consumer<InfluxDBConfig> {
       .timestamp(date.clone().set('hour', 23).set('minute', 59).set('second', 59).toDate())
       .floatField('value', measurement.reading.C);
 
-    hourlyEnergy.forEach(api.writePoint);
+    hourlyEnergy.forEach(p => api.writePoint(p));
     api.writePoint(dailyEnergy);
     api.writePoint(monthlyEnergy);
     api.writePoint(annualyEnergy);