ingest

tcmts.registry.ingest · #ekhh5pxr · 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 (renewFacts), and read again the profiles due (renewProfiles).

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

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

uses