functions

type ArtifactStore interface {
	Put(ctx context.Context, key string, data []byte, hash string) error
	Get(ctx context.Context, key string) ([]byte, string, error)
	Delete(ctx context.Context, key string) error
}

type BatchOp struct {
	Op         string                 `json:"op"` // create, update, delete, connect, disconnect, inc
	Model      string                 `json:"model"`
	ID         string                 `json:"id,omitempty"`
	Payload    map[string]interface{} `json:"payload,omitempty"`
	Connect    map[string]interface{} `json:"connect,omitempty"`
	Disconnect map[string]interface{} `json:"disconnect,omitempty"`
	Field      string                 `json:"field,omitempty"` // for inc
	By         float64                `json:"by,omitempty"`    // for inc
}

type BatchRequest struct {
	IdempotencyKey string    `json:"idempotency_key"`
	Operations     []BatchOp `json:"operations"`
}

type BatchResult struct {
	OK     bool                   `json:"ok"`
	IDs    []string               `json:"ids,omitempty"`
	Error  string                 `json:"error,omitempty"`
	Replay bool                   `json:"replay,omitempty"`
	Result map[string]interface{} `json:"result,omitempty"`
}

type DataGatewayCall struct {
	InvocationID string                 `json:"invocation_id"`
	ProjectID    string                 `json:"project_id"`
	TenantID     string                 `json:"tenant_id,omitempty"`
	Op           string                 `json:"op"`
	Payload      map[string]interface{} `json:"payload,omitempty"`
}

type DataGatewayResponse struct {
	OK    bool                   `json:"ok"`
	Data  map[string]interface{} `json:"data,omitempty"`
	Error string                 `json:"error,omitempty"`
}

type DataOpHandler func(ctx context.Context, call *DataGatewayCall) (*DataGatewayResponse, error)

type DefaultLimitsProvider struct{}

type DenoRuntimeProvider struct {
	DenoPath string
	WorkDir  string
	Gateway  FunctionDataGateway
	Registry *InvocationRegistry
}

type EngineDataGateway struct {

	// CheckCapability returns nil if the call is allowed.
	CheckCapability func(ctx context.Context, call *DataGatewayCall) error
	HostCallCount   map[string]int // invocationID → count
	MaxHostCalls    int
	// contains filtered or unexported fields
}

type EventDispatcher interface {
	Publish(ctx context.Context, msg *EventMessage) error
	Subscribe(ctx context.Context, handler func(ctx context.Context, msg *EventMessage) error) (func() error, error)
}

type EventMessage struct {
	ID             string                 `json:"id"`
	ProjectID      string                 `json:"project_id"`
	Function       string                 `json:"function"`
	Trigger        string                 `json:"trigger"` // webhook, email, payment, lifecycle
	IdempotencyKey string                 `json:"idempotency_key"`
	Payload        map[string]interface{} `json:"payload"`
	Attempt        int                    `json:"attempt"`
	MaxDeliver     int                    `json:"max_deliver"`
}

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

type FunctionDataGateway interface {
	Handle(ctx context.Context, call *DataGatewayCall) (*DataGatewayResponse, error)
}

type FunctionInvoker interface {
	Invoke(ctx context.Context, env *InvocationEnvelope) (*InvocationResult, error)
}

type FunctionLimits struct {
	MemoryBytes      int64
	Timeout          time.Duration
	MaxRequestBytes  int64
	MaxResponseBytes int64
	MaxLogBytes      int64
	MaxHostCalls     int
	MaxConcurrency   int
}

type FunctionLimitsProvider interface {
	LimitsFor(ctx context.Context, projectID string, fn *models.ApitoFunction) (FunctionLimits, error)
}

type FunctionTransport interface {
	Request(ctx context.Context, subject string, payload []byte, timeout time.Duration) ([]byte, error)
	RespondHandler(ctx context.Context, subject string, queueGroup string, handler func(payload []byte) ([]byte, error)) (func() error, error)
	Close() error
}

type GatewayBridge struct {
	URL          string
	Token        string
	InvocationID string
	// contains filtered or unexported fields
}

type GatewayDeps interface {
	// GetProjectDriver returns the project DB for the invocation's trusted DB context.
	GetProjectDriver(ctx context.Context, inv *InvocationContext) (interfaces.ProjectDBInterface, error)
	// ResolveModel maps a guest model name to a schema model.
	ResolveModel(inv *InvocationContext, modelArg string) (*models.ModelType, error)
	// NewParam clones the invocation param for a driver call.
	NewParam(inv *InvocationContext) *models.CommonSystemParams
}

type HookLimitsProvider struct {
	Hook func(ctx context.Context, projectID string, fn *models.ApitoFunction) (memoryBytes int64, timeoutMs int64, maxConcurrency int, err error)
}

type InvocationContext struct {
	Envelope     *InvocationEnvelope
	DBCtx        context.Context
	Param        *models.CommonSystemParams
	Project      *models.Project
	Capabilities []string
	Gateway      FunctionDataGateway
}

type InvocationEnvelope struct {
	Version      string                 `json:"version"`
	InvocationID string                 `json:"invocation_id"`
	ProjectID    string                 `json:"project_id"`
	TenantID     string                 `json:"tenant_id,omitempty"`
	Function     string                 `json:"function"`
	RevisionID   string                 `json:"revision_id,omitempty"`
	Runtime      string                 `json:"runtime"`
	UserID       string                 `json:"user_id,omitempty"`
	Role         string                 `json:"role,omitempty"`
	Principal    Principal              `json:"principal"`
	Capabilities []string               `json:"capabilities,omitempty"`
	Request      map[string]interface{} `json:"request"`
	DeadlineMs   int64                  `json:"deadline_ms"`
	Idempotency  string                 `json:"idempotency_key,omitempty"`
	ArtifactKey  string                 `json:"artifact_key,omitempty"`
	ArtifactHash string                 `json:"artifact_hash,omitempty"`
	Source       string                 `json:"source,omitempty"`
	Handler      string                 `json:"handler,omitempty"`
}

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

type InvocationResult struct {
	Version      string                 `json:"version"`
	OK           bool                   `json:"ok"`
	Response     map[string]interface{} `json:"response,omitempty"`
	Error        string                 `json:"error,omitempty"`
	ErrorClass   string                 `json:"error_class,omitempty"` // timeout, oom, permission, egress, abort, …
	Logs         []LogEntry             `json:"logs,omitempty"`
	DurationMs   int64                  `json:"duration_ms,omitempty"`
	HostCalls    int                    `json:"host_calls,omitempty"`
	ResultDigest string                 `json:"result_digest,omitempty"`
}

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

type LogEntry struct {
	Level   string `json:"level"`
	Message string `json:"message"`
	At      string `json:"at,omitempty"`
}

type ManagerOption func(*RuntimeManager)

type MemoryBatchExecutor struct {
	Apply func(ctx context.Context, projectID, tenantScope string, op BatchOp) (string, error)
	// contains filtered or unexported fields
}

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

type NATSConn interface {
	RequestWithContext(ctx context.Context, subject string, data []byte) ([]byte, error)
	QueueSubscribe(subject, queue string, handler func(subject string, data []byte) ([]byte, error)) (func() error, error)
	Close()
}

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

type Principal struct {
	Mode   string `json:"mode"` // caller | service
	UserID string `json:"user_id,omitempty"`
	Role   string `json:"role,omitempty"`
}

type ProjectBatchExecutor interface {
	ExecuteBatch(ctx context.Context, projectID, tenantScope string, req *BatchRequest) (*BatchResult, error)
}

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

type RuntimeProvider interface {
	Name() string
	Execute(ctx context.Context, env *InvocationEnvelope, limits FunctionLimits) (*InvocationResult, error)
}

type StubRuntimeProvider struct {
	RuntimeName string
}

type TenantScopeError struct {
	Code    string
	Message string
}

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