registry

type ContractEvent struct {
	Type        string
	ChainID     []byte
	Endpoint    string
	PublicKey   []byte
	BlockNumber uint64
	TxHash      []byte
}

type Event struct {
	Type      EventType
	ChainID   []byte
	Endpoint  string
	PublicKey []byte
	Timestamp time.Time
}

type EventType string

type L1Block struct {
	Number    uint64
	Hash      []byte
	Timestamp time.Time
}

type L1Client interface {
	GetLatestBlockNumber(ctx context.Context) (uint64, error)
	GetBlockByNumber(ctx context.Context, blockNumber uint64) (*L1Block, error)
	GetContractEvents(ctx context.Context, contractAddr string, fromBlock, toBlock uint64) ([]ContractEvent, error)
	SubscribeToContractEvents(ctx context.Context, contractAddr string) (<-chan ContractEvent, error)
}

type RollupInfo struct {
	ChainID      []byte
	Endpoint     string
	PublicKey    []byte
	StartingSlot uint64
	IsActive     bool
	UpdatedAt    time.Time
}

type Service interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	GetActiveRollups(ctx context.Context) ([][]byte, error)
	GetRollupEndpoint(ctx context.Context, chainID []byte) (string, error)
	GetRollupPublicKey(ctx context.Context, chainID []byte) ([]byte, error)
	IsRollupActive(ctx context.Context, chainID []byte) (bool, error)
	WatchRegistry(ctx context.Context) (<-chan Event, error)
	GetRollupInfo(chainID []byte) (*RollupInfo, error)
	GetAllRollups() map[string]*RollupInfo
	SetPollingInterval(interval time.Duration)
}