diff --git a/GAPP/apps/gapp-server/src/app/plugins/influxdb.ts b/GAPP/apps/gapp-server/src/app/plugins/influxdb.ts index e69de29..d0354ad 100644 --- a/GAPP/apps/gapp-server/src/app/plugins/influxdb.ts +++ b/GAPP/apps/gapp-server/src/app/plugins/influxdb.ts @@ -0,0 +1,12 @@ +import { FastifyInstance } from 'fastify'; +import fp from 'fastify-plugin'; +import { InfluxDB } from '@influxdata/influxdb-client'; + +export default fp(async (fastify: FastifyInstance, config) => { + const influxClient = new InfluxDB({ + token: '', + url: '' + }); + + fastify.decorate('influxClient', influxClient); +}); diff --git a/GAPP/apps/gapp-server/src/main.ts b/GAPP/apps/gapp-server/src/main.ts index 08bd676..3b5255b 100644 --- a/GAPP/apps/gapp-server/src/main.ts +++ b/GAPP/apps/gapp-server/src/main.ts @@ -1,7 +1,6 @@ import Fastify from 'fastify'; import { app } from './app/app'; import { getConfig } from './config'; -import { InfluxDB, Point } from '@influxdata/influxdb-client'; const config = getConfig(process.env); @@ -17,15 +16,3 @@ server.listen({ port: config.PORT, host: '0.0.0.0' }, (err) => { process.exit(1); } }); - - -const client = new InfluxDB({ url: config.INFLUXDB_HOST, token: config.INFLUXDB_TOKEN }); - -const writeApi = client.getWriteApi('FikFlights', 'Fik', 'ns'); - -const point = new Point('measurement'); - -point.tag('location', 'PRG') -point.intField('humidity', 185); - -writeApi.writePoint(point);