chore: Update the types

This commit is contained in:
BluJ
2023-04-11 11:54:57 -06:00
parent 9810c222dd
commit be2019fda1
13 changed files with 188 additions and 101 deletions

View File

@@ -1,4 +0,0 @@
export declare const ReadyProof: unique symbol;
export type ReadyReceipt = {
[ReadyProof]: never;
};

View File

@@ -3,5 +3,4 @@ export * as trigger from "./trigger";
export { TriggerInput } from "./trigger/TriggerInput";
export { HealthReceipt } from "./HealthReceipt";
export { readyCheck } from "./readyCheck";
export { ReadyProof } from "./ReadyProof";
export { ReadyProof } from "../mainFn/ReadyProof";

View File

@@ -1,55 +0,0 @@
import { InterfaceReceipt } from "../mainFn/interfaceReceipt";
import { Daemon, Effects } from "../types";
import { CheckResult } from "./checkFns/CheckResult";
import { ReadyReceipt } from "./ReadyProof";
import { HealthReceipt } from "./HealthReceipt";
import { Trigger } from "./trigger";
import { TriggerInput } from "./trigger/TriggerInput";
import { defaultTrigger } from "./trigger/defaultTrigger";
function readReciptOf<A extends { daemon: Daemon }>(a: A) {
return a as A & ReadyReceipt;
}
export function readyCheck(o: {
effects: Effects;
started(onTerm: () => void): null;
interfaceReceipt: InterfaceReceipt;
healthReceipts: Iterable<HealthReceipt>;
daemonReceipt: Daemon;
name: string;
trigger?: Trigger;
fn(): Promise<CheckResult> | CheckResult;
onFirstSuccess?: () => () => Promise<unknown> | unknown;
}) {
new Promise(async () => {
const trigger = (o.trigger ?? defaultTrigger)();
let currentValue: TriggerInput = {
lastResult: null,
hadSuccess: false,
};
for (
let res = await trigger.next(currentValue);
!res.done;
res = await trigger.next(currentValue)
) {
try {
const { status, message } = await o.fn();
if (!currentValue.hadSuccess) {
await o.started(o?.onFirstSuccess ?? (() => o.daemonReceipt.term()));
}
await o.effects.setHealth({
name: o.name,
status,
message,
});
currentValue.hadSuccess = true;
currentValue.lastResult = "success";
} catch (_) {
currentValue.lastResult = "failure";
}
}
});
return readReciptOf({
daemon: o.daemonReceipt,
});
}