From daedd80948a4700465a33c93281e673d0bb1c1a7 Mon Sep 17 00:00:00 2001
From: Teppo Kurki <teppo.kurki@iki.fi>
Date: Tue, 7 Nov 2023 08:12:51 +0200
Subject: [PATCH] fix: resurrect the command line query utility

---
 src/HistoryAPI.ts | 18 +++++++++++++-----
 src/query.ts      | 12 +++++++-----
 2 files changed, 20 insertions(+), 10 deletions(-)

diff --git a/src/HistoryAPI.ts b/src/HistoryAPI.ts
index 30ce5f4..18a23e1 100644
--- a/src/HistoryAPI.ts
+++ b/src/HistoryAPI.ts
@@ -76,6 +76,8 @@ interface SimpleResponse {
   status: (s: number) => void
   /* eslint-disable-next-line  @typescript-eslint/no-explicit-any */
   json: (j: any) => void
+  header: (n: string, v: string) => void
+  send: (c: string) => void
 }
 
 interface SimpleRequest {
@@ -97,7 +99,7 @@ function getPositions(
   format: string,
   timeResolutionMillis: number,
   debug: (s: string) => void,
-  res: Response,
+  res: SimpleResponse,
 ) {
   const query = `
   select
@@ -141,7 +143,7 @@ export function getValues(
   format: string,
   debug: (s: string) => void,
   req: SimpleRequest,
-  res: Response,
+  res: SimpleResponse,
 ) {
   const start = Date.now()
   const timeResolutionMillis =
@@ -356,7 +358,7 @@ function splitPathExpression(pathExpression: string): PathSpec {
 }
 
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
-function outputPositionsGpx(rows: any[], context: string, res: Response) {
+function outputPositionsGpx(rows: any[], context: string, res: SimpleResponse) {
   let responseBody = `<?xml version="1.0" encoding="UTF-8" ?>
   <gpx xmlns="http://www.topografix.com/GPX/1/1" version="1.1" creator="signalk-to-influxdb2">
   <metadata><author>${context}</author></metadata>
@@ -386,7 +388,13 @@ function outputPositionsGpx(rows: any[], context: string, res: Response) {
 }
 
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
-function outputPositionsJson(rows: any[], context: string, from: ZonedDateTime, to: ZonedDateTime, res: Response) {
+function outputPositionsJson(
+  rows: any[],
+  context: string,
+  from: ZonedDateTime,
+  to: ZonedDateTime,
+  res: SimpleResponse,
+) {
   const resultData = rows.map((row) => {
     return [row.time.toISOString(), [row.lon, row.lat]]
   })
@@ -401,7 +409,7 @@ function outputPositionsJson(rows: any[], context: string, from: ZonedDateTime,
   })
 }
 
-function outputError(res: Response, status: number, detail: string) {
+function outputError(res: SimpleResponse, status: number, detail: string) {
   res.status(status)
   res.json({
     status: status.toString(),
diff --git a/src/query.ts b/src/query.ts
index 6e4fed3..5e22172 100644
--- a/src/query.ts
+++ b/src/query.ts
@@ -35,8 +35,10 @@ const req = {
     resolution: '60s',
   },
 }
-// const resp = {
-//   status: (n: number) => undefined,
-//   json: (s: any) => console.log(JSON.stringify(s, null, 2)),
-// }
-//getValues(skinflux, context, start, end, format, toConsole, req, resp)
+const resp = {
+  status: (n: number) => undefined,
+  json: (s: any) => console.log(JSON.stringify(s, null, 2)),
+  header: (n: string, v: string) => console.log(`${n}:${v}`),
+  send: (c: string) => console.log(c),
+}
+getValues(skinflux, context, start, end, format, toConsole, req, resp)