Update sql querys for create-contour worker

src/create-contour/add-to-table.js

@@ -28,7 +28,7 @@ export const addData = async (
         const timestamp = process.argv[2] ?? datasetTimestamp;
         const geom = process.argv[2] ?? contourLine.geometry;
         const temp = process.argv[2] ?? contourLine.properties.TEMP;
-        let insertRow = await client.query(`INSERT INTO ${region}_contourLines(timestamp, geom, temp) VALUES($1);`, [timestamp, geom, temp]);
+        let insertRow = await client.query(`INSERT INTO ${region}_contourLines(timestamp, geom, temperature) VALUES(${timestamp}, ${geom}, ${temp});`);
         logger.info(`Inserted ${insertRow.rowCount} row`);
     } catch (e) {
         logger.error(e);

src/create-contour/get-client.js

@@ -1,9 +1,6 @@
 // Connect to databse
-
 import pkg from 'pg';
-const { Client } = pkg
-import dotenv from 'dotenv'
-dotenv.config();
+const { Client } = pkg;
 
 const pgHost = process.env.POSTGRES_HOST;
 const pgPort = process.env.POSTGRES_PORT;

src/create-contour/index.js

@@ -46,19 +46,17 @@ const contourLinesWorker = async (workerJob, inputs) => {
     // TODO check if this can be moved to seperate file
     let client;
     try {
-        (async () => {
-            client = await getClient();
-            let createTableQuery = `
+        client = await getClient();
+        let createTableQuery = `
     CREATE TABLE IF NOT EXISTS ${region}_contourLines(
       id BIGSERIAL PRIMARY KEY NOT NULL ,
-      timestamp timestamp without timezone,
+      timestamp timestamp,
       geom geometry,
-      temp number,
+      temperature numeric
     );
   `;
-            await client.query(createTableQuery);
-            logger.info(`Created table.`);
-        })();
+        await client.query(createTableQuery);
+        logger.info(`Created table.`);
     } catch (e) {
         logger.error(e);
         throw 'SQL execution aborted: ' + e;

src/create-contour/package.json

@@ -11,7 +11,6 @@
   "dependencies": {
     "amqplib": "^0.8.0",
     "dayjs": "^1.11.10",
-    "dotenv": "^16.4.1",
     "fs": "^0.0.1-security",
     "node": "^21.6.1",
     "pg": "^8.11.3",