writetarget

type Config struct {
	PollPeriod        time.Duration
	AcceptanceTimeout time.Duration
}

type MonitorOpts struct {
	Lggr              logger.Logger
	Processors        map[string]beholder.ProtoProcessor
	EnabledProcessors []string
	Emitter           beholder.ProtoEmitter
}

type ReqConfig struct {
	Address   string
	Processor string
}

type TargetStrategy interface {
	// QueryTransmissionState defines how the report should be queried
	// via ChainReader, and how resulting errors should be classified.
	QueryTransmissionState(ctx context.Context, reportID uint16, request capabilities.CapabilityRequest) (*TransmissionState, error)
	// TransmitReport constructs the tx to transmit the report, and defines
	// any specific handling for sending the report via ChainWriter.
	TransmitReport(ctx context.Context, report []byte, reportContext []byte, signatures [][]byte, request capabilities.CapabilityRequest) (string, error)
	// Wrapper around the ChainWriter to get the transaction status
	GetTransactionStatus(ctx context.Context, transactionID string) (commontypes.TransactionStatus, error)
	// Wrapper around the ChainWriter to get the fee esimate
	GetEstimateFee(ctx context.Context, report []byte, reportContext []byte, signatures [][]byte, request capabilities.CapabilityRequest) (commontypes.EstimateFee, error)
	// GetTransactionFee retrieves the actual transaction fee in native currency from the transaction receipt.
	// This method should be implemented by chain-specific services and handle the conversion of gas units to native currency.
	GetTransactionFee(ctx context.Context, transactionID string) (decimal.Decimal, error)
}

type TransactionStatus uint8

type TransmissionState struct {
	Status      TransactionStatus
	Transmitter string
	Err         error
}

type WriteTargetOpts struct {
	ID string

	// toml: [<CHAIN>.WriteTargetCap]
	Config Config
	// ChainInfo contains the chain information (used as execution context)
	// TODO: simplify by passing via ChainService.GetChainStatus fn
	ChainInfo commontypes.ChainInfo

	Logger   logger.Logger
	Beholder *beholder.BeholderClient

	ChainService     chainService
	ConfigValidateFn func(request capabilities.CapabilityRequest) (string, error)

	NodeAddress      string
	ForwarderAddress string

	TargetStrategy       TargetStrategy
	WriteAcceptanceState commontypes.TransactionStatus
}