diff --git a/core/services/relay/evm/cap_encoder.go b/core/services/relay/evm/cap_encoder.go index 1c7814ab16a..b52cbb71c66 100644 --- a/core/services/relay/evm/cap_encoder.go +++ b/core/services/relay/evm/cap_encoder.go @@ -87,8 +87,8 @@ func decodeID(input map[string]any, key string) ([]byte, error) { return nil, err } - if len(b) < 32 { - return nil, fmt.Errorf("incorrect length for id %s, expected 32 bytes, got %d", id, len(b)) + if len(b) != idLen { + return nil, fmt.Errorf("incorrect length for id %s, expected %d bytes, got %d", id, idLen, len(b)) } return b, nil diff --git a/core/services/workflows/delegate.go b/core/services/workflows/delegate.go index bde7aa275c4..fce630ff482 100644 --- a/core/services/workflows/delegate.go +++ b/core/services/workflows/delegate.go @@ -143,19 +143,19 @@ func emitReports(logger logger.Logger, trigger *triggers.MercuryTriggerService, reports := []triggers.FeedReport{ { FeedID: mercury.FeedID("0x1111111111111111111100000000000000000000000000000000000000000000").Bytes(), - FullReport: []byte{}, + FullReport: []byte(fmt.Sprintf(`{ "feed": "ETH", "price": %d }`, prices[0])), BenchmarkPrice: prices[0], ObservationTimestamp: t, }, { FeedID: mercury.FeedID("0x2222222222222222222200000000000000000000000000000000000000000000").Bytes(), - FullReport: []byte{}, + FullReport: []byte(fmt.Sprintf(`{ "feed": "LINK", "price": %d }`, prices[1])), BenchmarkPrice: prices[1], ObservationTimestamp: t, }, { FeedID: mercury.FeedID("0x3333333333333333333300000000000000000000000000000000000000000000").Bytes(), - FullReport: []byte{}, + FullReport: []byte(fmt.Sprintf(`{ "feed": "BTC", "price": %d }`, prices[2])), BenchmarkPrice: prices[2], ObservationTimestamp: t, },