diff --git a/core/services/job/orm.go b/core/services/job/orm.go index 92ec9b2e83c..514ab2aac7c 100644 --- a/core/services/job/orm.go +++ b/core/services/job/orm.go @@ -324,6 +324,11 @@ func (o *orm) CreateJob(ctx context.Context, jb *Job) error { return errors.New("invalid transmitter address in dual transmission config") } + _, ok = dualTransmissionConfig["meta"].(map[string][]string) + if !ok || !common.IsHexAddress(dtTransmitterAddress) { + return errors.New("invalid dual transmission config") + } + if err = validateKeyStoreMatchForRelay(ctx, jb.OCR2OracleSpec.Relay, tx.keyStore, dtTransmitterAddress); err != nil { return errors.Wrap(err, "unknown dual transmission transmitterAddress") }