sdk

type CapabilityPromise interface {
	// contains filtered or unexported methods
}

type ConsensusAggregation[T any] interface {
	Descriptor() *pb.ConsensusDescriptor
	Default() *T
	Err() error
	WithDefault(t T) ConsensusAggregation[T]
}

type Environment[C any] struct {
	NodeEnvironment[C]
	SecretsProvider
}

type ExecutionHandler[C, R any] interface {
	CapabilityID() string
	Method() string
	TriggerCfg() *anypb.Any
	Callback() func(env *Environment[C], runtime R, payload *anypb.Any) (any, error)
}

type NodeEnvironment[C any] struct {
	Config    C
	LogWriter io.Writer
	Logger    *slog.Logger
}

type NodeRuntime interface {
	RuntimeBase
	IsNodeRuntime()
}

type NumericType interface {
	int | int8 | int16 | int32 | int64 | uint | uint8 | uint16 | uint32 | uint64 | float32 | float64 | *big.Int | decimal.Decimal
}

type Primitive interface {
	NumericType | string | bool
}

type Promise[T any] interface {
	Await() (T, error)
	CapabilityPromise
}

type Runner[C any] interface {
	Run(initFn func(env *Environment[C]) (Workflow[C], error))
}

type Runtime interface {
	RuntimeBase

	// RunInNodeMode is meant to be used by the helper method RunInNodeMode
	RunInNodeMode(fn func(nodeRuntime NodeRuntime) *pb.SimpleConsensusInputs) Promise[values.Value]
}

type RuntimeBase interface {
	// CallCapability is meant to be called by generated code
	CallCapability(request *pb.CapabilityRequest) Promise[*pb.CapabilityResponse]
	Rand() (*rand.Rand, error)
}

type SecretsProvider interface {
	GetSecret(*sdkpb.SecretRequest) Promise[*sdkpb.Secret]
}

type Trigger[M proto.Message, T any] interface {
	Adapt(m M) (T, error)
	// contains filtered or unexported methods
}

type Workflow[C any] []ExecutionHandler[C, Runtime]