Function buildBridge

packages/plugins/apps/src/plugin/bindings.ts:136–176

(input: {
  readonly declared: Readonly<Record<string, IntegrationDecl>>;
  readonly bindings: Readonly<Record<string, string | readonly string[]>>;
  readonly resolver: ClientResolver;
  readonly invokeOptions?: InvokeOptions;
})

  });

export const buildBridge = (input: {
  readonly declared: Readonly<Record<string, IntegrationDecl>>;
  readonly bindings: Readonly<Record<string, string | readonly string[]>>;
  readonly resolver: ClientResolver;
  readonly invokeOptions?: InvokeOptions;
}): AppToolBridge => ({
  call: (toolPath, args) => {
    const [root, ...path] = toolPath.split(".");
    const [field, rawIndex] = (root ?? "").split("#");
    const decl = input.declared[field ?? ""];
    const binding = input.bindings[field ?? ""];
    const connection =
      rawIndex === undefined
        ? typeof binding === "string"
          ? binding
          : undefined
        : Array.isArray(binding)
          ? binding[Number(rawIndex)]
          : undefined;
    if (!field || !decl || !connection || path.length === 0) {
      return Effect.runPromise(
        Effect.fail(
          new BindingError({
            role: field ?? "",
            integration: decl?.slug ?? "",
            message: `undeclared integration call: ${toolPath}`,
          }),
        ),
      );
    }
    return Effect.runPromise(
      input.resolver.call({
        integration: decl.slug,
        connection,
        path,
        args,
        invokeOptions: input.invokeOptions,
      }),
    );
  },
});