ingest

tcmts.hub.ingest · #3ipuifsn · term · runs on the server

uses process

Read Jetstream every minute, from where it was left, until caught up; then work out again the facts of releases mirrored before they were all kept (#6vw3vpta), and read again the profiles due (renewProfiles).

import { readJetstream, renewFacts, renewProfiles } from "#codebase/tcmts/hub";
import { every } from "#codebase/tcmts/server";

export const ingest = every(process.env.TCM_HUB_EVERY || "1m", async () => {
  await readJetstream();
  await renewFacts();
  await renewProfiles();
})

uses