zrcadlo https://github.com/atscan/atscan
20 řádky
488 B
JavaScript
20 řádky
488 B
JavaScript
import { MetricsTime, Worker } from "npm:bullmq";
|
|
import { ATScan } from "./lib/atscan.js";
|
|
import { saveRepo } from "./lib/repo.js";
|
|
|
|
const ats = new ATScan({ enableNats: true });
|
|
ats.debug = true;
|
|
await ats.init();
|
|
|
|
async function processJob(job) {
|
|
await saveRepo(ats, job.data, job);
|
|
return Promise.resolve();
|
|
}
|
|
|
|
const worker = new Worker("repo-snapshot", processJob, {
|
|
connection: ats.redisConnectionOptions(),
|
|
metrics: {
|
|
maxDataPoints: MetricsTime.ONE_WEEK * 2,
|
|
},
|
|
});
|