chain

type Adapter interface {
	ParseBlock(data json.RawMessage) (*Block, error)
	GetRecentBlocks(ctx context.Context, limit int) ([]json.RawMessage, error)
	GetBlockByID(ctx context.Context, id string) (json.RawMessage, error)
	GetBlockByHeight(ctx context.Context, height uint64) (json.RawMessage, error)
	InitSchema(ctx context.Context, store storage.Store) error
	GetStats(ctx context.Context, store storage.Store) (map[string]interface{}, error)
}

type Block struct {
	ID        string                 `json:"id"`
	ParentID  string                 `json:"parentId"` // Single parent (linear)
	Height    uint64                 `json:"height"`
	Timestamp time.Time              `json:"timestamp"`
	Status    Status                 `json:"status"`
	TxCount   int                    `json:"txCount,omitempty"`
	TxIDs     []string               `json:"txIds,omitempty"`
	Data      json.RawMessage        `json:"data,omitempty"`
	Metadata  map[string]interface{} `json:"metadata,omitempty"`
}

type ChainType string

type Config struct {
	ChainType    ChainType
	ChainName    string
	RPCEndpoint  string
	RPCMethod    string // pvm
	HTTPPort     int
	PollInterval time.Duration
	DataDir      string // For default storage
}

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

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

type Stats struct {
	TotalBlocks    int64     `json:"total_blocks"`
	LatestHeight   uint64    `json:"latest_height"`
	PendingBlocks  int64     `json:"pending_blocks"`
	AcceptedBlocks int64     `json:"accepted_blocks"`
	ChainType      ChainType `json:"chain_type"`
	LastUpdated    time.Time `json:"last_updated"`
}

type Status string

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