plugins

type APICallConfig struct {
	URL string `json:"url"`
}

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

type Dispatcher func(ctx context.Context, url string, taskID string, payload map[string]any) error

type ExternalReviewConfig struct {
	ExternalURL string `json:"external_url"`
}

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

type PaymentConfig struct {
	PaymentServiceURL string `json:"payment_service_url"`
}

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

type PluginContext struct {
	Context         context.Context
	Record          *store.TaskRecord
	Inputs          map[string]any
	OutputNamespace string
}

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

type SOAPCallConfig struct {
	ServiceID  string `json:"service_id"`
	Operation  string `json:"operation"`
	Path       string `json:"path,omitempty"`        // relative to the service URL; "" posts to the service URL itself
	SOAPAction string `json:"soap_action,omitempty"` // SOAP 1.1 action; quoted automatically, "" sends SOAPAction: ""
}

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

type SOAPInterpreter interface {
	// BuildEnvelope returns the SOAP envelope XML for the operation, derived
	// from the task's mapped inputs. An error means the request cannot even be
	// built (e.g. an incomplete document); the plugin then skips the call and
	// hands the error straight to Interpret, so user-facing prose stays in the
	// domain.
	BuildEnvelope(operation string, inputs map[string]any) (string, error)

	// Interpret turns the call outcome into a record state ("" leaves the
	// state unchanged) and the fields to record into the output namespace.
	// callErr is the build or transport error (nil on success); resp is the
	// raw response, nil when the call never happened. A non-2xx status arrives
	// here as a response, not an error — SOAP faults carry meaningful bodies.
	Interpret(operation string, callErr error, resp *remote.RawResponse) (state string, out map[string]any)
}

type TaskPlugin interface {
	// Execute runs the custom logic of the plugin, updating the task record status and metadata.
	// The config argument contains the custom plugin configuration parameters unmarshaled from JSON.
	Execute(ctx PluginContext, config json.RawMessage) error
}

type UserInputConfig struct {
	StatusOverride string `json:"status_override,omitempty"`
}

type UserInputPlugin struct{}