executors

type EmailExecutor ¶

type EmailExecutor struct{}

func NewEmailExecutor() *EmailExecutor

func (e *EmailExecutor) Execute(
	ctx context.Context,
	action domain.ToolAction,
	creds domain.EmailCredentials,
	params map[string]interface{},
) (string, error)

type HttpExecutor ¶

type HttpExecutor struct {
	// contains filtered or unexported fields
}

func NewHttpExecutor() *HttpExecutor

func (e *HttpExecutor) Execute(ctx context.Context, action domain.ToolAction,
	secrets map[string]interface{}, params map[string]interface{},
) (string, error)

type PostgresExecutor ¶ added in v1.0.15

type PostgresExecutor struct{}

PostgresExecutor implements the pg_list_tables/pg_describe_table/pg_query/pg_execute builtin tools. It holds no state of its own — the vault's tenant *sql.DB connection is resolved by internal/service/v1/mcp.ExecuteTool (via the shared vaultpg.ConnPool) and passed in per call, mirroring how VaultExecutor receives its couchdb/S3 clients per call.

func NewPostgresExecutor() *PostgresExecutor

func (e *PostgresExecutor) Execute(
	ctx context.Context,
	toolName string,
	db *sql.DB,
	params map[string]interface{},
) (domain.ToolExecResult, error)

type TractExecutor ¶

type TractExecutor struct{}

TractExecutor implements the tract-authoring builtin tools (list_tract_actions, create_tract, ...) that let an agent build and run tracts over MCP. It holds no state of its own — the tract service, the server-lifecycle context for run_tract's async StartRun call, and the caller's user_context are all supplied per call by internal/service/v1/mcp, which owns the service.TractService dependency (wired via McpService.SetTractService).

func NewTractExecutor() *TractExecutor

func (e *TractExecutor) Execute(
	ctx context.Context,
	baseCtx context.Context,
	ts TractService,
	toolName string,
	params map[string]interface{},
) (domain.ToolExecResult, error)

type TractService ¶

type TractService interface {
	CreateTract(
		ctx context.Context,
		name string,
		description string,
		def domain.TractDefinition,
	) (domain.Tract, []string, error)
	UpdateTract(
		ctx context.Context,
		id uuid.UUID,
		name string,
		description string,
		def domain.TractDefinition,
	) (domain.Tract, []string, error)
	GetTract(ctx context.Context, id uuid.UUID) (domain.Tract, error)
	ListTracts(ctx context.Context) ([]domain.Tract, error)
	CreateTrigger(
		ctx context.Context,
		name string,
		kind string,
		source string,
		config json.RawMessage,
		payloadSchema domain.ToolSchema,
	) (domain.Trigger, string, error)
	LinkTrigger(ctx context.Context, triggerUuid uuid.UUID, tractUuid uuid.UUID, filters []domain.TractCondition) error
	ListLinksByTract(ctx context.Context, tractUuid uuid.UUID) ([]repository.TractTriggerLink, error)
	StartRun(
		ctx context.Context,
		tract domain.Tract,
		payload json.RawMessage,
		startedBy string,
		triggerUuid uuid.UUID,
	) (domain.TractRun, error)
	ListRuns(ctx context.Context, tractUuid uuid.UUID, limit int32) ([]domain.TractRun, error)
	GetRun(ctx context.Context, id uuid.UUID) (domain.TractRun, []domain.TractRunStep, error)
	ListTractTools(ctx context.Context) ([]domain.McpToolRef, error)
	ListTriggerSources(ctx context.Context) ([]domain.TriggerPreset, error)
}

TractService is the narrow slice of service.TractService the tract-authoring builtin tools need. Defined here — not imported from internal/service — so this package never depends on the top-level service interfaces package; internal/service/v1/mcp passes its concrete service.TractService value in per call, which satisfies this interface structurally.

type VaultExecutor ¶

type VaultExecutor struct{}

func NewVaultExecutor() *VaultExecutor

func (e *VaultExecutor) Execute(
	ctx context.Context,
	toolName string,
	client *couchdb.LiveSyncClient,
	bucket storage.BinaryStore,
	params map[string]interface{},
) (domain.ToolExecResult, error)