MCPcopy Create free account
hub / github.com/UsefulSoftwareCo/executor / execute

Function execute

packages/core/sdk/src/executor.ts:4266–4497  ·  view source on GitHub ↗
(
      address: ToolAddress,
      args: unknown,
      options?: InvokeOptions,
    )

Source from the content-addressed store, hash-verified

4264 });
4265
4266 const execute = (
4267 address: ToolAddress,
4268 args: unknown,
4269 options?: InvokeOptions,
4270 ): Effect.Effect<unknown, ExecuteError> => {
4271 const handler = pickHandler(options);
4272 return Effect.gen(function* () {
4273 // oxlint-disable executor/no-instanceof-error, executor/no-unknown-error-message, executor/no-manual-tag-check -- boundary: normalize arbitrary unknown plugin failures into a human-readable message for ToolInvocationError/telemetry
4274 const formatInvocationCauseMessage = (cause: unknown): string => {
4275 if (cause instanceof Error && cause.message.length > 0) return cause.message;
4276 // Non-Error / empty-message causes: `String(plainObject)` renders
4277 // "[object Object]", which is what telemetry then shows as the only
4278 // label for the failure. Prefer the tag, else stringify structurally.
4279 if (typeof cause === "object" && cause !== null) {
4280 const tag = (cause as { readonly _tag?: unknown })._tag;
4281 if (typeof tag === "string") return tag;
4282 return Inspectable.toStringUnknown(cause, 0);
4283 }
4284 return String(cause);
4285 };
4286 // oxlint-enable executor/no-instanceof-error, executor/no-unknown-error-message, executor/no-manual-tag-check
4287 const wrapInvocationError = <A, E>(
4288 effect: Effect.Effect<A, E>,
4289 ): Effect.Effect<A, ToolInvocationError> =>
4290 effect.pipe(
4291 Effect.mapError(
4292 (cause) =>
4293 new ToolInvocationError({
4294 address,
4295 message: formatInvocationCauseMessage(cause),
4296 cause,
4297 }),
4298 ),
4299 );
4300
4301 // Static path — O(1) map lookup for plugin-contributed static tools
4302 // (core-tools, plugin executor namespaces). Addressed by their fqid,
4303 // not the 5-segment dynamic form.
4304 const staticEntry = staticTools.get(String(address));
4305 if (staticEntry) {
4306 const policyRules = yield* listActivePolicyRuleSet();
4307 const policy = yield* resolvePolicyFromRuleSet(
4308 String(address),
4309 policyRules,
4310 staticEntry.tool.annotations?.requiresApproval,
4311 );
4312 if (policy.action === "block") {
4313 return yield* new ToolBlockedError({
4314 address,
4315 pattern: policy.pattern ?? "*",
4316 });
4317 }
4318 yield* enforceApproval(staticEntry.tool.annotations, address, args, policy, handler);
4319 return yield* wrapInvocationError(
4320 staticEntry.tool.handler({
4321 ctx: staticEntry.ctx,
4322 args,
4323 elicit: buildElicit(address, args, handler),

Callers 3

createExecutorFunction · 0.70
runUserCodeFunction · 0.50

Calls 15

pickHandlerFunction · 0.85
listActivePolicyRuleSetFunction · 0.85
resolvePolicyFromRuleSetFunction · 0.85
enforceApprovalFunction · 0.85
wrapInvocationErrorFunction · 0.85
buildElicitFunction · 0.85
parseToolAddressFunction · 0.85
byOwnerFunction · 0.85
toolSuggestionsFunction · 0.85

Tested by

no test coverage detected