core

type Acceptor interface {
	// Accept processes an accepted item
	Accept(ctx context.Context, containerID ids.ID, container []byte) error
}

type AppError struct {
	Code    int32
	Message string
}

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

type Block interface {
	ID() ids.ID
	ParentID() ids.ID
	Height() uint64
	Timestamp() int64
	Bytes() []byte
	Verify(context.Context) error
	Accept(context.Context) error
	Reject(context.Context) error
}

type BootstrapTracker interface {
	// OnBootstrapStarted is called when bootstrapping starts
	OnBootstrapStarted() error
	// OnBootstrapCompleted is called when bootstrapping completes
	OnBootstrapCompleted() error
	// IsBootstrapped returns whether the node has finished bootstrapping
	IsBootstrapped() bool
}

type ConsensusContext interface {
	// Context returns the underlying Go context
	Context() context.Context

	// NodeID returns the node ID
	NodeID() ids.NodeID

	// ChainID returns the chain ID
	ChainID() ids.ID

	// Deadline returns the deadline for operations
	Deadline() time.Time
}

type Decidable interface {
	// ID returns the ID of this decidable
	ID() ids.ID

	// Accept marks this as accepted
	Accept(context.Context) error

	// Reject marks this as rejected
	Reject(context.Context) error

	// Status returns the current status
	Status() Status
}

type Error = warp.Error

type Fx struct {
	ID ids.ID
	Fx interface{}
}

type Handler = warp.Handler

type HealthCheckable interface {
	// HealthCheck returns health information
	HealthCheck(context.Context) (interface{}, error)
}

type HealthStatus int

type ID interface{ ~[32]byte }

type Message struct {
	Type    MessageType
	NodeID  ids.NodeID
	Content []byte
}

type MessageType uint32

type Protocol[I comparable] interface {
	// Initialize initializes the protocol
	Initialize(ctx context.Context) error

	// Step runs one poll/round of the protocol
	Step(ctx context.Context) error

	// Status returns the status of an item (e.g., {unknown, preferred, decided})
	Status(id I) (string, error)
}

type SendConfig = warp.SendConfig

type Sender = warp.Sender

type State interface {
	// GetBlock gets a block
	GetBlock(ids.ID) (Block, error)

	// PutBlock puts a block
	PutBlock(Block) error

	// GetLastAccepted gets last accepted
	GetLastAccepted() (ids.ID, error)

	// SetLastAccepted sets last accepted
	SetLastAccepted(ids.ID) error
}

type Status int

type TestDecidable struct {
	TestID     ids.ID
	TestStatus Status
	AcceptFunc func(context.Context) error
	RejectFunc func(context.Context) error
}

type Tx interface {
	ID() ids.ID
	Bytes() []byte
	Verify(context.Context) error
	Accept(context.Context) error
}

type UTXO interface {
	ID() ids.ID
	TxID() ids.ID
	OutputIndex() uint32
	Amount() uint64
}

type VM interface {
	// Initialize initializes the VM
	Initialize(
		ctx context.Context,
		chainCtx *consensuscontext.Context,
		dbManager manager.Manager,
		genesisBytes []byte,
		upgradeBytes []byte,
		configBytes []byte,
		toEngine chan<- Message,
		fxs []*Fx,
		warpSender interface{},
	) error

	// SetState sets the state of the VM
	SetState(ctx context.Context, state VMState) error

	// Shutdown shuts down the VM
	Shutdown(ctx context.Context) error

	// Version returns the version of the VM
	Version(ctx context.Context) (string, error)

	// HealthCheck returns nil if the VM is healthy
	HealthCheck(ctx context.Context) (interface{}, error)

	// CreateHandlers returns the HTTP handlers for the VM
	CreateHandlers(ctx context.Context) (map[string]http.Handler, error)

	// CreateStaticHandlers returns the static HTTP handlers for the VM
	CreateStaticHandlers(ctx context.Context) (map[string]http.Handler, error)

	// NewHTTPHandler returns a new HTTP handler for the VM
	NewHTTPHandler(ctx context.Context) (http.Handler, error)
}

type VMState uint8