flowcore

type CallResult struct {
	Data  []byte
	Error string
}

type CallUnaryFunctionActivityInput struct {
	ModuleName string `protobuf:"bytes,1,opt,name=module_name,json=moduleName" json:"module_name,omitempty"`
	FuncName   string `protobuf:"bytes,2,opt,name=func_name,json=funcName" json:"func_name,omitempty"`
	Input      []byte `protobuf:"bytes,3,opt,name=input" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type CallUnaryFunctionActivityOutput struct {

	// Types that are valid to be assigned to Response:
	//
	//	*CallUnaryFunctionActivityOutput_Output
	//	*CallUnaryFunctionActivityOutput_Error
	Response isCallUnaryFunctionActivityOutput_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

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

type CallUnaryFunctionActivityOutput_Output struct {
	Output []byte `protobuf:"bytes,1,opt,name=output,oneof"`
}

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

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              *autoflow.ModuleDescriptor
	PredeclaredFiles  *protoregistry.Files
	CallUnaryFunction func(context.Context, *CallUnaryFunctionActivityInput) (*CallUnaryFunctionActivityOutput, error)
	// contains filtered or unexported fields
}

type ModuleManager interface {
	// LoadModuleDescriptor loads a module descriptor.
	// Returns (nil, nil) if not found.
	LoadModuleDescriptor(ctx context.Context, moduleName string) (*autoflow.ModuleDescriptor, error)
	CallUnaryFunction(ctx context.Context, moduleName, funcName, idempotencyKey string, input []byte) (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 Workflow struct {
	Key         string
	Name        string
	IdentityKey string
	State       WorkflowState
	CreatedAt   time.Time
	UpdatedAt   time.Time
	Output      *RunWorkflowOutput
	Error       string
}

type WorkflowState = autocore.WorkflowState