58 lines
1.3 KiB
TypeScript
58 lines
1.3 KiB
TypeScript
|
import { ActiveQuery, addHandler } from "@lumeweb/libkernel/module";
|
||
|
|
|
||
|
|
const types: Set<string> = new Set<string>();
|
||
|
|
const networks: Map<string, Set<string>> = new Map<string, Set<string>>();
|
||
|
|
|
||
|
|
addHandler("registerType", handleRegisterType);
|
||
|
|
addHandler("getTypes", handleGetTypes);
|
||
|
|
addHandler("getNetworkTypes", handleGetNetworkType);
|
||
|
|
addHandler("registerNetwork", handleRegisterNetwork);
|
||
|
|
|
||
|
|
function handleRegisterType(aq: ActiveQuery) {
|
||
|
|
types.add(aq.callerInput);
|
||
|
|
|
||
|
|
aq.respond();
|
||
|
|
}
|
||
|
|
|
||
|
|
function handleGetTypes(aq: ActiveQuery) {
|
||
|
|
aq.respond([...types.values()]);
|
||
|
|
}
|
||
|
|
|
||
|
|
function handleRegisterNetwork(aq: ActiveQuery) {
|
||
|
|
if (!("types" in aq.callerInput)) {
|
||
|
|
aq.reject("types missing");
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!Array.isArray(aq.callerInput.types)) {
|
||
|
|
aq.reject("types must be an array");
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
let network = networks.get(aq.domain);
|
||
|
|
|
||
|
|
if (network) {
|
||
|
|
aq.callerInput.type.forEach((item) => network?.add(item));
|
||
|
|
} else {
|
||
|
|
networks.set(aq.domain, new Set([aq.callerInput.types]));
|
||
|
|
}
|
||
|
|
|
||
|
|
aq.respond();
|
||
|
|
}
|
||
|
|
|
||
|
|
function handleGetNetworkType(aq: ActiveQuery) {
|
||
|
|
if (!("module" in aq.callerInput)) {
|
||
|
|
aq.reject("module missing");
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!networks.has(aq.callerInput.module)) {
|
||
|
|
aq.reject("module is not registered");
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
aq.respond([
|
||
|
|
...(networks.get(aq.callerInput.module) as Set<string>).values(),
|
||
|
|
]);
|
||
|
|
}
|