flowcore

type CallResult struct {
	Value *pkg_autoflow.Value
	Error string
}

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

type InvokeActionActivityInput struct {
	ModuleName string                 `protobuf:"bytes,1,opt,name=module_name,json=moduleName" json:"module_name,omitempty"`
	ActionName string                 `protobuf:"bytes,2,opt,name=action_name,json=actionName" json:"action_name,omitempty"`
	Args       []*autoflow.Value      `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	Kwargs     []*autoflow.NamedValue `protobuf:"bytes,4,rep,name=kwargs" json:"kwargs,omitempty"`
	// contains filtered or unexported fields
}

type InvokeActionActivityOutput struct {

	// Types that are valid to be assigned to Response:
	//
	//	*InvokeActionActivityOutput_Result
	//	*InvokeActionActivityOutput_Error
	Response isInvokeActionActivityOutput_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type InvokeActionActivityOutput_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,oneof"`
}

type InvokeActionActivityOutput_Result struct {
	Result *autoflow.Value `protobuf:"bytes,1,opt,name=result,oneof"`
}

type LoadModuleActivityInput struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type LoadModuleActivityOutput struct {
	ModuleDesc *autoflow.ModuleDescriptor `protobuf:"bytes,1,opt,name=module_desc,json=moduleDesc" json:"module_desc,omitempty"`
	// contains filtered or unexported fields
}

type ModuleDescriptorResolver struct {
	ModuleName       string
	Desc             *pkg_autoflow.ModuleDescriptor
	PredeclaredFiles *protoregistry.Files
	InvokeAction     func(context.Context, *InvokeActionActivityInput) (*InvokeActionActivityOutput, error)
}

type ModuleManager interface {
	// LoadModuleDescriptor loads a module descriptor.
	// Returns (nil, nil) if not found.
	LoadModuleDescriptor(ctx context.Context, moduleName string) (*pkg_autoflow.ModuleDescriptor, error)
	InvokeAction(ctx context.Context, moduleName, actionName, idempotencyKey string, args []*pkg_autoflow.Value, kwargs []*pkg_autoflow.NamedValue) (CallResult, error)
}

type Options struct {
	Log            *slog.Logger
	Client         autocore.Client
	Registry       *autocore.Registry
	RateLimiter    RateLimiter
	ModuleManager  ModuleManager
	TracerProvider oteltrace.TracerProvider
	// PredeclaredProtoFiles is the set of proto file descriptors that
	// AutoFlow modules' descriptor sets may import. Used to resolve
	// imports when reconstructing module proto descriptors; we deliberately
	// do not fall back to protoregistry.GlobalFiles so a module cannot pull
	// in arbitrary types linked into the binary.
	// Order is important here - files that come later can import files that come earlier,
	// but not the other way around.
	PredeclaredProtoFiles []protoreflect.FileDescriptor
}

type RateLimiter interface {
	Allow(ctx context.Context, projectID int64, eventType string) bool
}

type RunActivityInput struct {
	Uri           string   `protobuf:"bytes,1,opt,name=uri" json:"uri,omitempty"`
	WorkflowId    string   `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId" json:"workflow_id,omitempty"`
	Args          []string `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	DuoCallNumber int32    `protobuf:"varint,4,opt,name=duo_call_number,json=duoCallNumber" json:"duo_call_number,omitempty"`
	// contains filtered or unexported fields
}

type RunActivityOutput struct {
	Payload string `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type RunWorkflowInput struct {
	WorkflowDefinition []byte    `protobuf:"bytes,1,opt,name=workflow_definition,json=workflowDefinition" json:"workflow_definition,omitempty"`
	Secrets            []*Secret `protobuf:"bytes,2,rep,name=secrets" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

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

type Secret struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

type Workflow struct {
	Key         string
	Name        string
	IdentityKey string
	State       WorkflowState
	CreatedAt   time.Time
	UpdatedAt   time.Time
	Output      *RunWorkflowOutput
	Error       string
}

type WorkflowState = autocore.WorkflowState