appmanager

type AppManager[T transaction.Tx] struct {
	// contains filtered or unexported fields
}

type Builder[T transaction.Tx] struct {
	STF StateTransitionFunction[T] // The state transition function for processing transactions.
	DB  store.Store                // The database for storing application data.

	// Gas limits for validating, querying, and simulating transactions.
	ValidateTxGasLimit uint64
	QueryGasLimit      uint64
	SimulationGasLimit uint64

	// InitGenesis is a function that initializes the application state from a genesis file.
	// It takes a context, a source reader for the genesis file, and a transaction handler function.
	InitGenesis InitGenesis
	// ExportGenesis is a function that exports the application state to a genesis file.
	// It takes a context and a version number for the genesis file.
	ExportGenesis ExportGenesis
}

type Config struct {
	ValidateTxGasLimit uint64 `mapstructure:"validate-tx-gas-limit"` // TODO: check how this works on app mempool
	QueryGasLimit      uint64 `mapstructure:"query-gas-limit"`
	SimulationGasLimit uint64 `mapstructure:"simulation-gas-limit"`
}

type ExportGenesis func(ctx context.Context, version uint64) ([]byte, error)

type InitGenesis func(ctx context.Context, src io.Reader, txHandler func(json.RawMessage) error) error

type StateTransitionFunction[T transaction.Tx] interface {
	// DeliverBlock executes a block of transactions.
	DeliverBlock(
		ctx context.Context,
		block *appmanager.BlockRequest[T],
		state store.ReaderMap,
	) (blockResult *appmanager.BlockResponse, newState store.WriterMap, err error)

	// ValidateTx validates a transaction.
	ValidateTx(
		ctx context.Context,
		state store.ReaderMap,
		gasLimit uint64,
		tx T,
	) appmanager.TxResult

	// Simulate executes a transaction in simulation mode.
	Simulate(
		ctx context.Context,
		state store.ReaderMap,
		gasLimit uint64,
		tx T,
	) (appmanager.TxResult, store.WriterMap)

	// Query executes a query on the application.
	Query(
		ctx context.Context,
		state store.ReaderMap,
		gasLimit uint64,
		req transaction.Msg,
	) (transaction.Msg, error)

	// TODO: remove
	RunWithCtx(
		ctx context.Context,
		state store.ReaderMap,
		closure func(ctx context.Context) error,
	) (store.WriterMap, error)
}