sync

type CollectorDiff struct {
	Code map[string]*starknetTypes.Contract
	// contains filtered or unexported fields
}

type L1Client interface {
	ChainID(ctx context.Context) (*big.Int, error)
	BlockNumber(ctx context.Context) (uint64, error)
	FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]ethtypes.Log, error)
	SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- ethtypes.Log) (ethereum.Subscription, error)
	TransactionByHash(ctx context.Context, hash common.Hash) (tx *ethtypes.Transaction, isPending bool, err error)
}

type StateDiffCollector interface {
	// Run starts the collection of StateDiff.
	Run()
	// GetChannel returns the channel that will be used to collect the StateDiff.
	GetChannel() chan *CollectorDiff
	// Close closes the collection of StateDiff.
	Close()
	// LatestBlock returns the last block of StarkNet
	LatestBlock() *feeder.StarknetBlock
	// PendingBlock returns the pending block of StarkNet
	PendingBlock() *feeder.StarknetBlock
}

type Synchronizer struct {

	// Running is true when the service is active and running
	Running bool
	// contains filtered or unexported fields
}