Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 1f07951b88 | |||
| b0a45f4000 |
@@ -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);
|
||||||
|
|||||||
@@ -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);
|
||||||
|
|||||||
Reference in New Issue
Block a user