Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 1f07951b88 | |||
| b0a45f4000 | |||
| b42e37c569 |
@@ -20,7 +20,7 @@ WORKDIR /app
|
||||
COPY package*.json ./
|
||||
RUN npm ci --omit=dev
|
||||
|
||||
COPY --from=builder /app/dist ./dist
|
||||
COPY --from=builder /app/dist /app/dist
|
||||
|
||||
USER node
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
import { readFileSync, existsSync } from "node:fs"
|
||||
import { join } from "node:path"
|
||||
import { log } from "./logger";
|
||||
import { log } from "./logger.js";
|
||||
|
||||
interface Config {
|
||||
Mq: Mq,
|
||||
|
||||
@@ -26,6 +26,7 @@ async function main() {
|
||||
}
|
||||
|
||||
// Check if package already processed HERE...
|
||||
log('WARN', 'Version check disabled, downloading data from source');
|
||||
// exit(0) if done, else continue
|
||||
|
||||
const inputStream: Readable = await getRequestStream(packageInfo.assets[0].browser_download_url);
|
||||
|
||||
@@ -1,9 +1,9 @@
|
||||
import { connect, JSONCodec } from "nats";
|
||||
import type { ConnectionOptions, NatsConnection, Payload } from "nats";
|
||||
import { log } from "./logger";
|
||||
import { log } from "./logger.js";
|
||||
import { hostname } from "node:os";
|
||||
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();
|
||||
|
||||
|
||||
@@ -36,7 +36,7 @@ export async function* processPisStream(cfg: GeneralConfig, inputStream: Readabl
|
||||
if (!line.trim()) continue;
|
||||
|
||||
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 tiplocStops = await mapStopsToTiploc(record.stops);
|
||||
|
||||
Reference in New Issue
Block a user