-
Notifications
You must be signed in to change notification settings - Fork 38
Expand file tree
/
Copy pathhooks.ts
More file actions
60 lines (53 loc) · 1.31 KB
/
hooks.ts
File metadata and controls
60 lines (53 loc) · 1.31 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
export type OutboundRequestInfo = {
url: URL;
port: number;
method: string;
};
type HookName = "beforeOutboundRequest";
// Map hook names to argument types
interface HookTypes {
beforeOutboundRequest: {
args: [data: OutboundRequestInfo];
};
}
const hooks = new Map<
HookName,
Set<(...args: HookTypes[HookName]["args"]) => void | Promise<void>>
>();
export function addHook<N extends HookName>(
name: N,
fn: (...args: HookTypes[N]["args"]) => void | Promise<void>
) {
if (!hooks.has(name)) {
hooks.set(name, new Set([fn]));
} else {
hooks.get(name)!.add(fn);
}
}
export function removeHook<N extends HookName>(
name: N,
fn: (...args: HookTypes[N]["args"]) => void | Promise<void>
) {
hooks.get(name)?.delete(fn);
}
export function executeHooks<N extends HookName>(
name: N,
...args: [...HookTypes[N]["args"]]
): void {
const hookSet = hooks.get(name);
for (const fn of hookSet ?? []) {
try {
const result = (
fn as (...args: HookTypes[N]["args"]) => void | Promise<void>
)(...args);
// If it returns a promise, catch any errors but don't wait
if (result instanceof Promise) {
result.catch(() => {
// Silently ignore errors from user hooks
});
}
} catch {
// Silently ignore errors from user hooks
}
}
}