server

type Config struct {
	Logger *slog.Logger
	// Metadata is the store backing the MidnightState query RPCs
	// (GetAssetCreates, GetAssetSpends, GetRegistrations,
	// GetDeregistrations, GetUtxoEvents). Nil leaves those RPCs
	// unimplemented. Any metadata.MetadataStore implementation satisfies
	// this narrower interface structurally.
	Metadata eventStore
	// BlockNumberByHash resolves a Cardano block hash to its block number.
	// It receives the RPC's context and must stop when it is done, so a
	// canceled or timed-out request does not hold its admission slot.
	// It backs GetUtxoEvents' end_block_hash boundary so that boundary is
	// honored even when the target block has no Midnight events of its
	// own (found=false for an unknown hash, not an error). Nil causes
	// GetUtxoEvents to fail requests that set end_block_hash.
	BlockNumberByHash func(ctx context.Context, hash []byte) (blockNumber uint64, found bool, err error)
	// Host and Port are the gRPC listen address. Defaults to 127.0.0.1:50051.
	Host string
	Port uint
	// TLSCertFilePath and TLSKeyFilePath enable TLS when both are set. When
	// both are empty the server listens without TLS. Setting only one is an
	// error.
	TLSCertFilePath string
	TLSKeyFilePath  string
	// ReflectionEnabled exposes gRPC service discovery. It defaults off.
	ReflectionEnabled bool
	// ShutdownTimeout bounds GracefulStop before escalating to a hard Stop.
	// Defaults to 30s.
	ShutdownTimeout time.Duration
	// Database backs the governance/parameters/block/epoch/stability RPCs.
	// Wrap a *database.Database with NewDatabase. Required for those RPCs to
	// work; RPCs that only need Database are unaffected by a nil SlotTimer.
	Database MidnightDatabase
	// SlotTimer resolves block timestamps and, for the as-of-timestamp
	// variants of the stability RPCs, converts a wall-clock time back to a
	// slot. Required by GetBlockByHash, GetLatestBlock, GetStableBlock, and
	// GetLatestStableBlock.
	SlotTimer SlotTimer
	// PromRegistry registers the server's request-count and latency
	// instruments. Nil is safe -- they just never expose themselves to a
	// registry.
	PromRegistry prometheus.Registerer
}

type MidnightDatabase interface {
	GetLatestMidnightGovernanceDatum(
		ctx context.Context,
		datumType string,
		blockNumber uint64,
	) (*models.MidnightGovernanceDatum, error)
	GetMidnightAriadneParamsAtOrBeforeEpoch(
		ctx context.Context,
		epoch uint64,
	) (*models.MidnightAriadneParams, error)
	GetMidnightEpochCandidatesByEpoch(
		ctx context.Context,
		epoch uint64,
	) (*models.MidnightEpochCandidates, error)
	// GetMidnightCommitteeCandidateRegistrationsByTxHashes returns the
	// on-chain provenance (block/slot/tx-index/tx-inputs) for candidate
	// UTxOs whose creating tx hash is in txHashes, for GetEpochCandidates to
	// join against the (tx_hash, output_index, datum) membership decoded
	// from a MidnightEpochCandidates snapshot.
	GetMidnightCommitteeCandidateRegistrationsByTxHashes(
		ctx context.Context,
		txHashes [][]byte,
	) ([]models.MidnightCommitteeCandidateRegistration, error)
	GetPoolStakeSnapshotsByEpoch(
		ctx context.Context,
		epoch uint64,
		snapshotType string,
	) ([]*models.PoolStakeSnapshot, error)
	GetEpoch(ctx context.Context, epochId uint64) (*models.Epoch, error)
	GetEpochBySlot(ctx context.Context, slot uint64) (*models.Epoch, error)
	BlockByHash(ctx context.Context, hash []byte) (models.Block, error)
	// BlockByNumber returns the block at the given 0-based consensus block
	// number, translating to the blob store's internal 1-based index.
	BlockByNumber(ctx context.Context, number uint64) (models.Block, error)
	BlocksRecent(ctx context.Context, count int) ([]models.Block, error)
	BlockBeforeSlot(ctx context.Context, slot uint64) (models.Block, error)
}

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

type SlotTimer interface {
	SlotToTime(slot uint64) (time.Time, error)
	TimeToSlot(t time.Time) (uint64, error)
}