3 Commits
0.0.3 ... 0.0.5

Author SHA1 Message Date
1f07951b88 Remove excessive logging per line 2026-02-18 19:17:45 +00:00
b0a45f4000 Add WARN log warning that version checking is not enabled. 2026-02-17 18:56:09 +00:00
b42e37c569 Fix import path in three places.
Switch Dockerfile to use absolute paths
2026-02-17 18:53:41 +00:00
5 changed files with 6 additions and 5 deletions

View File

@@ -20,7 +20,7 @@ WORKDIR /app
COPY package*.json ./ COPY package*.json ./
RUN npm ci --omit=dev RUN npm ci --omit=dev
COPY --from=builder /app/dist ./dist COPY --from=builder /app/dist /app/dist
USER node USER node

View File

@@ -1,6 +1,6 @@
import { readFileSync, existsSync } from "node:fs" import { readFileSync, existsSync } from "node:fs"
import { join } from "node:path" import { join } from "node:path"
import { log } from "./logger"; import { log } from "./logger.js";
interface Config { interface Config {
Mq: Mq, Mq: Mq,

View File

@@ -26,6 +26,7 @@ async function main() {
} }
// Check if package already processed HERE... // Check if package already processed HERE...
log('WARN', 'Version check disabled, downloading data from source');
// exit(0) if done, else continue // exit(0) if done, else continue
const inputStream: Readable = await getRequestStream(packageInfo.assets[0].browser_download_url); const inputStream: Readable = await getRequestStream(packageInfo.assets[0].browser_download_url);

View File

@@ -1,9 +1,9 @@
import { connect, JSONCodec } from "nats"; import { connect, JSONCodec } from "nats";
import type { ConnectionOptions, NatsConnection, Payload } from "nats"; import type { ConnectionOptions, NatsConnection, Payload } from "nats";
import { log } from "./logger"; import { log } from "./logger.js";
import { hostname } from "node:os"; import { hostname } from "node:os";
import type { MQFileUpdate } from "@owlboard/backend-data-contracts/dist/data-ingress_mq-file-update"; import type { MQFileUpdate } from "@owlboard/backend-data-contracts/dist/data-ingress_mq-file-update";
import type { Mq } from "./config"; import type { Mq } from "./config.js";
const jc = JSONCodec(); const jc = JSONCodec();

View File

@@ -36,7 +36,7 @@ export async function* processPisStream(cfg: GeneralConfig, inputStream: Readabl
if (!line.trim()) continue; if (!line.trim()) continue;
const record = JSON.parse(line) as InputRecord; const record = JSON.parse(line) as InputRecord;
log('DEBUG', `JSON Line Parsed: ${JSON.stringify(record)}`) // log('DEBUG', `JSON Line Parsed: ${JSON.stringify(record)}`)
const crsHash = XXH.h64(record.stops.join('|'), SEED); const crsHash = XXH.h64(record.stops.join('|'), SEED);
const tiplocStops = await mapStopsToTiploc(record.stops); const tiplocStops = await mapStopsToTiploc(record.stops);