llo

type ChannelDefinitionCacheFactory interface {
	NewCache(cfg lloconfig.PluginConfig) (llotypes.ChannelDefinitionCache, error)
}

type ChannelDefinitionCacheORM interface {
	// TODO: What about delete/cleanup?
	// https://smartcontract-it.atlassian.net/browse/MERC-3653
	LoadChannelDefinitions(ctx context.Context, addr common.Address) (dfns llotypes.ChannelDefinitions, blockNum int64, err error)
	StoreChannelDefinitions(ctx context.Context, addr common.Address, dfns llotypes.ChannelDefinitions, blockNum int64) (err error)
}

type Closer interface {
	Close() error
}

type DelegateConfig struct {
	Logger   logger.Logger
	Queryer  pg.Queryer
	Runner   streams.Runner
	Registry Registry
	JobName  null.String

	// LLO
	ChannelDefinitionCache llotypes.ChannelDefinitionCache

	// OCR3
	BinaryNetworkEndpointFactory ocr2types.BinaryNetworkEndpointFactory
	V2Bootstrappers              []ocrcommontypes.BootstrapperLocator
	ContractConfigTracker        ocr2types.ContractConfigTracker
	ContractTransmitter          ocr3types.ContractTransmitter[llotypes.ReportInfo]
	Database                     ocr3types.Database
	OCRLogger                    ocrcommontypes.Logger
	MonitoringEndpoint           ocrcommontypes.MonitoringEndpoint
	OffchainConfigDigester       ocr2types.OffchainConfigDigester
	OffchainKeyring              ocr2types.OffchainKeyring
	OnchainKeyring               ocr3types.OnchainKeyring[llotypes.ReportInfo]
	LocalConfig                  ocr2types.LocalConfig
}

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

type Key interface {
	Sign3(digest ocrtypes.ConfigDigest, seqNr uint64, r ocrtypes.Report) (signature []byte, err error)
	Verify3(publicKey ocrtypes.OnchainPublicKey, cd ocrtypes.ConfigDigest, seqNr uint64, r ocrtypes.Report, signature []byte) bool
	PublicKey() ocrtypes.OnchainPublicKey
	MaxSignatureLength() int
}

type LLOOnchainKeyring ocr3types.OnchainKeyring[llotypes.ReportInfo]

type ORM interface {
	ChannelDefinitionCacheORM
}

type OffchainConfigDigester struct {
	ChainID         *big.Int
	ContractAddress common.Address
}

type Registry interface {
	Get(streamID streams.StreamID) (strm streams.Stream, exists bool)
}

type Transmitter interface {
	llotypes.Transmitter
	services.Service
}