System Initiative

import { Debug } from "../debug.ts"; import { failureExecution, Func, ResultFailure, ResultSuccess, } from "../function.ts"; import { runCode } from "../execution.ts"; import { RequestCtx } from "../request.ts"; import { FunctionKind } from "../function.ts"; const debug = Debug("langJs:before"); export interface BeforeFunc extends Func { arg: unknown; } export type BeforeResultSuccess = ResultSuccess; export type BeforeResultFailure = ResultFailure; export type BeforeResult = BeforeResultSuccess | BeforeResultFailure; async function execute( { executionId }: RequestCtx, { arg, handler }: BeforeFunc, code: string, timeout: number, ): Promise<BeforeResult> { try { await runCode( code, handler, FunctionKind.Before, executionId, timeout, arg as Record<string, unknown>, ); } catch (err) { return failureExecution(err as Error, executionId); } return { protocol: "result", status: "success", executionId, }; } const wrapCode = (code: string, handler: string) => ` ${code} export { ${handler} }; `; export default { debug, execute, wrapCode, };