Spaces:
Configuration error
Configuration error
File size: 3,212 Bytes
3a65265 |
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 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 |
import path from "node:path";
import { pathToFileURL } from "node:url";
import type { MoltbotPluginApi } from "../plugins/types.js";
import type { HookEntry } from "./types.js";
import { shouldIncludeHook } from "./config.js";
import { loadHookEntriesFromDir } from "./workspace.js";
import type { InternalHookHandler } from "./internal-hooks.js";
export type PluginHookLoadResult = {
hooks: HookEntry[];
loaded: number;
skipped: number;
errors: string[];
};
function resolveHookDir(api: MoltbotPluginApi, dir: string): string {
if (path.isAbsolute(dir)) return dir;
return path.resolve(path.dirname(api.source), dir);
}
function normalizePluginHookEntry(api: MoltbotPluginApi, entry: HookEntry): HookEntry {
return {
...entry,
hook: {
...entry.hook,
source: "moltbot-plugin",
pluginId: api.id,
},
metadata: {
...entry.metadata,
hookKey: entry.metadata?.hookKey ?? `${api.id}:${entry.hook.name}`,
events: entry.metadata?.events ?? [],
},
};
}
async function loadHookHandler(
entry: HookEntry,
api: MoltbotPluginApi,
): Promise<InternalHookHandler | null> {
try {
const url = pathToFileURL(entry.hook.handlerPath).href;
const cacheBustedUrl = `${url}?t=${Date.now()}`;
const mod = (await import(cacheBustedUrl)) as Record<string, unknown>;
const exportName = entry.metadata?.export ?? "default";
const handler = mod[exportName];
if (typeof handler === "function") {
return handler as InternalHookHandler;
}
api.logger.warn?.(`[hooks] ${entry.hook.name} handler is not a function`);
return null;
} catch (err) {
api.logger.warn?.(`[hooks] Failed to load ${entry.hook.name}: ${String(err)}`);
return null;
}
}
export async function registerPluginHooksFromDir(
api: MoltbotPluginApi,
dir: string,
): Promise<PluginHookLoadResult> {
const resolvedDir = resolveHookDir(api, dir);
const hooks = loadHookEntriesFromDir({
dir: resolvedDir,
source: "moltbot-plugin",
pluginId: api.id,
});
const result: PluginHookLoadResult = {
hooks,
loaded: 0,
skipped: 0,
errors: [],
};
for (const entry of hooks) {
const normalizedEntry = normalizePluginHookEntry(api, entry);
const events = normalizedEntry.metadata?.events ?? [];
if (events.length === 0) {
api.logger.warn?.(`[hooks] ${entry.hook.name} has no events; skipping`);
api.registerHook(events, async () => undefined, {
entry: normalizedEntry,
register: false,
});
result.skipped += 1;
continue;
}
const handler = await loadHookHandler(entry, api);
if (!handler) {
result.errors.push(`[hooks] Failed to load ${entry.hook.name}`);
api.registerHook(events, async () => undefined, {
entry: normalizedEntry,
register: false,
});
result.skipped += 1;
continue;
}
const eligible = shouldIncludeHook({ entry: normalizedEntry, config: api.config });
api.registerHook(events, handler, {
entry: normalizedEntry,
register: eligible,
});
if (eligible) {
result.loaded += 1;
} else {
result.skipped += 1;
}
}
return result;
}
|