feat: reading from influx

GAPP/apps/gapp-server/src/app.ts

@@ -25,7 +25,7 @@ export const app = async (fastify: FastifyInstance, opts: AppOptions) => {
         token: opts.influxDbToken,
         org: opts.influxDbOrg,
     });
-    await fastify.register(sondehubPlugin, { dev: false });
+    await fastify.register(sondehubPlugin, { dev: true });
     await fastify.register(carsServicePlugin);
     await fastify.register(telemetryServicePlugin);
 

GAPP/apps/gapp-server/src/services/cars.service.ts

@@ -2,6 +2,7 @@ import { InfluxDB, Point, QueryApi, WriteApi } from '@influxdata/influxdb-client
 import { InfluxDbServiceBase } from '../utils/influxdb-service-base';
 import { Organization } from '@influxdata/influxdb-client-apis';
 import { CarStatus } from '../schemas';
+import { arrayAsString } from '../utils/array-as-atring';
 
 export class CarsService extends InfluxDbServiceBase {
     private writeAPi: WriteApi;
@@ -36,6 +37,7 @@ export class CarsService extends InfluxDbServiceBase {
         console.log(callsigns);
         const query = `from(bucket: "cars")
             |> range(start: -24h)
+            |> filter(fn: (r) => contains(value: r.callsign, set: ${arrayAsString(callsigns)}))
             |> last()
             |> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value")
             |> keep(columns: ["_time", "altitude", "longitude", "latitude", "callsign"])`;

GAPP/apps/gapp-server/src/utils/array-as-atring.ts

@@ -0,0 +1,3 @@
+export const arrayAsString = (array: (string | number)[]): string => {
+    return `["${array.join('","')}"]`;
+};

GAPP/libs/sondehub/src/lib/uploader.ts

@@ -12,7 +12,7 @@ interface BasePacket {
 }
 
 export interface TelemetryPacket extends Partial<BasePacket> {
-    dev?: boolean;
+    dev?: string;
     time_received?: string;
     payload_callsign: string;
     datetime: string;
@@ -238,6 +238,8 @@ export class Uploader {
             enhancedPacket.time_received = new Date().toISOString();
         }
 
+        enhancedPacket.dev = packet.dev ?? this.uploaderConfig.dev ? 'true' : 'false';
+
         return enhancedPacket;
     }