types

type DataExtractor interface {
	// ExtractBlockHeight extracts the latest block height from a response.
	// This is used to determine sync status - endpoints behind in block height
	// are potentially stale or syncing.
	//
	// Parameters:
	//   - request: Original request bytes (to identify method)
	//   - response: Response bytes to parse
	//
	// Returns:
	//   - Block height as int64
	//   - Error if extraction fails or response doesn't contain block height
	ExtractBlockHeight(request []byte, response []byte) (int64, error)

	// ExtractChainID extracts the chain identifier from a response.
	// This is used to validate endpoints are on the correct chain.
	//
	// Parameters:
	//   - request: Original request bytes (to identify method)
	//   - response: Response bytes to parse
	//
	// Returns:
	//   - Chain ID as string (hex for EVM, chain-name for Cosmos)
	//   - Error if extraction fails or response doesn't contain chain ID
	ExtractChainID(request []byte, response []byte) (string, error)

	// IsSyncing determines if the endpoint is currently syncing.
	// Syncing endpoints may return stale data and should be deprioritized.
	//
	// Parameters:
	//   - request: Original request bytes (to identify method)
	//   - response: Response bytes to parse
	//
	// Returns:
	//   - true if endpoint is syncing
	//   - false if endpoint is synced
	//   - Error if sync status cannot be determined
	IsSyncing(request []byte, response []byte) (bool, error)

	// IsArchival determines if the endpoint supports archival queries.
	// Archival endpoints can serve historical data queries.
	//
	// Parameters:
	//   - request: Original request bytes (to identify method)
	//   - response: Response bytes to parse
	//
	// Returns:
	//   - true if endpoint is archival (query succeeded)
	//   - false if endpoint is not archival (query failed)
	//   - Error if archival status cannot be determined
	IsArchival(request []byte, response []byte) (bool, error)

	// IsValidResponse checks if the response is valid for the protocol.
	// This performs basic validation without extracting specific data.
	//
	// Parameters:
	//   - request: Original request bytes (to identify method)
	//   - response: Response bytes to parse
	//
	// Returns:
	//   - true if response is valid (correct format, no errors)
	//   - false if response is invalid (malformed, contains error)
	//   - Error if validation fails unexpectedly
	IsValidResponse(request []byte, response []byte) (bool, error)
}

type ExtractedData struct {
	// BlockHeight is the latest block number (0 if not extracted).
	BlockHeight int64

	// InvalidBlockHeight is set when block height extraction was attempted
	// but the supplier returned an unparseable result (e.g. "result":[] or "result":{}).
	// When true, the endpoint should be marked with block height 0 so the
	// block height filter catches it, rather than treating it as "unknown".
	InvalidBlockHeight bool

	// ChainID is the chain identifier (empty if not extracted).
	ChainID string

	// IsSyncing indicates if the endpoint is syncing.
	IsSyncing bool

	// IsArchival indicates if the endpoint supports archival queries.
	// Only meaningful when ArchivalCheckPerformed is true.
	IsArchival bool

	// ArchivalCheckPerformed indicates whether an archival check was actually performed.
	// When true, IsArchival contains a definitive result (true or false).
	// When false, IsArchival should be ignored (request wasn't an archival query).
	ArchivalCheckPerformed bool

	// IsValidResponse indicates if the response was valid.
	IsValidResponse bool

	// ResponseTime is how long the request took.
	ResponseTime time.Duration

	// EndpointAddr identifies the endpoint that responded.
	EndpointAddr protocol.EndpointAddr

	// HTTPStatusCode is the HTTP status code from the response.
	HTTPStatusCode int

	// RawResponse is the original response bytes (for re-parsing if needed).
	RawResponse []byte

	// ExtractionErrors holds any errors that occurred during extraction.
	// Map from field name (e.g., "block_height") to error message.
	ExtractionErrors map[string]string
}

type ExtractionConfig struct {
	// ExtractBlockHeight enables block height extraction.
	ExtractBlockHeight bool

	// ExtractChainID enables chain ID extraction.
	ExtractChainID bool

	// CheckSyncStatus enables sync status checking.
	CheckSyncStatus bool

	// CheckArchival enables archival status checking.
	CheckArchival bool

	// ValidateResponse enables response validation.
	ValidateResponse bool
}

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

type NoOpDataExtractor struct{}