Function wrapPromiseExecutor

packages/core/execution/src/promise.ts:76–138

(pe: PromiseExecutor)

// ---------------------------------------------------------------------------

const wrapPromiseExecutor = (pe: PromiseExecutor): EffectExecutor => {
  const adapter = {
    integrations: {
      list: () => fromPromise(() => pe.integrations.list()),
      get: (slug: Parameters<PromiseExecutor["integrations"]["get"]>[0]) =>
        fromPromise(() => pe.integrations.get(slug)),
      update: (
        slug: Parameters<PromiseExecutor["integrations"]["update"]>[0],
        patch: Parameters<PromiseExecutor["integrations"]["update"]>[1],
      ) => fromPromise(() => pe.integrations.update(slug, patch)),
      remove: (slug: Parameters<PromiseExecutor["integrations"]["remove"]>[0]) =>
        fromPromise(() => pe.integrations.remove(slug)),
      detect: (url: Parameters<PromiseExecutor["integrations"]["detect"]>[0]) =>
        fromPromise(() => pe.integrations.detect(url)),
    },
    connections: {
      create: (input: Parameters<PromiseExecutor["connections"]["create"]>[0]) =>
        fromPromise(() => pe.connections.create(input)),
      list: (filter?: Parameters<PromiseExecutor["connections"]["list"]>[0]) =>
        fromPromise(() => pe.connections.list(filter)),
      get: (ref: Parameters<PromiseExecutor["connections"]["get"]>[0]) =>
        fromPromise(() => pe.connections.get(ref)),
      update: (
        ref: Parameters<PromiseExecutor["connections"]["update"]>[0],
        input: Parameters<PromiseExecutor["connections"]["update"]>[1],
      ) => fromPromise(() => pe.connections.update(ref, input)),
      remove: (ref: Parameters<PromiseExecutor["connections"]["remove"]>[0]) =>
        fromPromise(() => pe.connections.remove(ref)),
      refresh: (ref: Parameters<PromiseExecutor["connections"]["refresh"]>[0]) =>
        fromPromise(() => pe.connections.refresh(ref)),
    },
    tools: {
      list: (filter?: Parameters<PromiseExecutor["tools"]["list"]>[0]) =>
        fromPromise(() => pe.tools.list(filter)),
      schema: (address: Parameters<PromiseExecutor["tools"]["schema"]>[0]) =>
        fromPromise(() => pe.tools.schema(address)),
    },
    providers: {
      list: () => fromPromise(() => pe.providers.list()),
      items: (key: Parameters<PromiseExecutor["providers"]["items"]>[0]) =>
        fromPromise(() => pe.providers.items(key)),
    },
    policies: {
      list: () => fromPromise(() => pe.policies.list()),
      create: (input: Parameters<PromiseExecutor["policies"]["create"]>[0]) =>
        fromPromise(() => pe.policies.create(input)),
      update: (input: Parameters<PromiseExecutor["policies"]["update"]>[0]) =>
        fromPromise(() => pe.policies.update(input)),
      remove: (input: Parameters<PromiseExecutor["policies"]["remove"]>[0]) =>
        fromPromise(() => pe.policies.remove(input)),
      resolve: (address: Parameters<PromiseExecutor["policies"]["resolve"]>[0]) =>
        fromPromise(() => pe.policies.resolve(address)),
    },
    execute: (
      address: Parameters<PromiseExecutor["execute"]>[0],
      args: Parameters<PromiseExecutor["execute"]>[1],
      options?: Parameters<PromiseExecutor["execute"]>[2],
    ) => fromPromise(() => pe.execute(address, args, options)),