ingest

tcmts.registry.ingest · #frxh66pt · 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 (#kchtao5f), read again the profiles due (renewProfiles), and ask listed codebases' servers again whether their main branches moved (#xvxcnfxp).

import { readJetstream, renewCodebases, 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();
  await renewCodebases();
})

uses