chainstore

type CachedValue[T any] struct {
	// contains filtered or unexported fields
}

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

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

type ChainStore interface {

	// GetBlock retrieves a block by hash or number
	GetBlock(ctx context.Context, blockHashOrNumber any) (rpctypes.PolyBlock, error)

	// GetTransaction retrieves a transaction by hash
	GetTransaction(ctx context.Context, txHash common.Hash) (rpctypes.PolyTransaction, error)

	// GetReceipt retrieves a transaction receipt by transaction hash
	GetReceipt(ctx context.Context, txHash common.Hash) (rpctypes.PolyReceipt, error)

	// GetLatestBlock retrieves the most recent block
	GetLatestBlock(ctx context.Context) (rpctypes.PolyBlock, error)

	// GetBlockByNumber retrieves a block by its number
	GetBlockByNumber(ctx context.Context, number *big.Int) (rpctypes.PolyBlock, error)

	// GetBlockByHash retrieves a block by its hash
	GetBlockByHash(ctx context.Context, hash common.Hash) (rpctypes.PolyBlock, error)

	// Static info (fetch once, cache indefinitely)
	GetChainID(ctx context.Context) (*big.Int, error)
	GetClientVersion(ctx context.Context) (string, error)

	// Semi-static info (cache for minutes)
	GetSyncStatus(ctx context.Context) (any, error)
	GetSafeBlock(ctx context.Context) (*big.Int, error)
	GetFinalizedBlock(ctx context.Context) (*big.Int, error)

	// Block-aligned info (cache per block)
	GetBaseFee(ctx context.Context) (*big.Int, error)
	GetBaseFeeForBlock(ctx context.Context, blockNumber *big.Int) (*big.Int, error)

	// Frequent info (cache for seconds)
	GetGasPrice(ctx context.Context) (*big.Int, error)
	GetFeeHistory(ctx context.Context, blockCount int, newestBlock string, rewardPercentiles []float64) (*FeeHistoryResult, error)

	// Very frequent info (minimal cache)
	GetPendingTransactionCount(ctx context.Context) (*big.Int, error)
	GetQueuedTransactionCount(ctx context.Context) (*big.Int, error)
	GetTxPoolStatus(ctx context.Context) (map[string]any, error)
	GetNetPeerCount(ctx context.Context) (*big.Int, error)

	// === CAPABILITY & MANAGEMENT ===
	IsMethodSupported(method string) bool
	RefreshCapabilities(ctx context.Context) error
	GetSupportedMethods() []string

	// === CONNECTION INFO ===
	GetRPCURL() string
	MeasureConnectionLatency(ctx context.Context) (time.Duration, error)

	// === SIGNATURE LOOKUP ===
	// GetSignature retrieves function/event signatures from 4byte.directory
	GetSignature(ctx context.Context, hexSignature string) ([]Signature, error)

	// Close closes the store and releases any resources
	Close() error
}

type ChainStoreConfig struct {
	// Cache TTLs for different data types
	StaticTTL       time.Duration // Never expire (0)
	SemiStaticTTL   time.Duration // 5 minutes
	FrequentTTL     time.Duration // 30 seconds
	VeryFrequentTTL time.Duration // 5 seconds

	// Capability detection
	CapabilityTTL time.Duration // 1 hour

	// Feature toggles
	EnableTxPoolMonitoring   bool
	EnableFinalityTracking   bool
	EnableFeeHistoryTracking bool

	// Signature lookup configuration
	EnableSignatureLookup      bool          // Enable 4byte.directory lookups
	SignatureLookupTTL         time.Duration // Cache TTL for signatures (1 hour)
	SignatureLookupTimeout     time.Duration // HTTP timeout for API calls (5 seconds)
	SignatureLookupAPIURL      string        // 4byte.directory function signatures API endpoint
	EventSignatureLookupAPIURL string        // 4byte.directory event signatures API endpoint
}

type FeeHistoryResult struct {
	OldestBlock   *big.Int     `json:"oldestBlock"`
	BaseFeePerGas []*big.Int   `json:"baseFeePerGas"`
	GasUsedRatio  []float64    `json:"gasUsedRatio"`
	Reward        [][]*big.Int `json:"reward,omitempty"`
}

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

type Signature struct {
	ID             int       `json:"id"`
	CreatedAt      time.Time `json:"created_at"`
	TextSignature  string    `json:"text_signature"`
	HexSignature   string    `json:"hex_signature"`
	BytesSignature string    `json:"bytes_signature"`
}

type SignatureResponse struct {
	Count    int         `json:"count"`
	Next     *string     `json:"next"`
	Previous *string     `json:"previous"`
	Results  []Signature `json:"results"`
}