-
Notifications
You must be signed in to change notification settings - Fork 1.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[KS-193] Pass MercuryTriggerService to Mercury Transmitter #13118
Conversation
bolekk
commented
May 6, 2024
•
edited
Loading
edited
- Add EnableTriggerCapability flag to Relay config
- Create MercuryTriggerService lazily, on the first call to NewMercuryProvider()
- Make it available in the Transmitter (no-op for now)
29957ab
to
a137492
Compare
a137492
to
48613d5
Compare
48613d5
to
5c0805b
Compare
5c0805b
to
cd14cc2
Compare
cd14cc2
to
b247b40
Compare
b247b40
to
a385344
Compare
a385344
to
7c982a8
Compare
7c982a8
to
76617f1
Compare
@@ -179,6 +179,7 @@ type ApplicationOpts struct { | |||
LoopRegistry *plugins.LoopRegistry | |||
GRPCOpts loop.GRPCOpts | |||
MercuryPool wsrpc.Pool | |||
CapabilitiesRegistry *capabilities.Registry |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please use coretypes.CapabilitiesRegistry
here rather than the concrete type (chainlink-common/pkg/types/core
) as that will make loopification easy
@@ -33,7 +34,8 @@ type RelayerFactory struct { | |||
logger.Logger | |||
*plugins.LoopRegistry | |||
loop.GRPCOpts | |||
MercuryPool wsrpc.Pool | |||
MercuryPool wsrpc.Pool | |||
CapabilitiesRegistry *capabilities.Registry |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same here
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Some minor nits but otherwise LGTM
76617f1
to
d3a873d
Compare
1. Add EnableTriggerCapability flag to Relay config 2. Create MercuryTriggerService lazily, on the first call to NewMercuryProvider() 3. Make it available in the Transmitter (no-op for now)
d1964ff
to
36fb4d8
Compare
Quality Gate passedIssues Measures |
@@ -127,21 +127,38 @@ func (s *registrySyncer) Start(ctx context.Context) error { | |||
} | |||
if slices.Contains(triggerDONPeers, myId) { | |||
s.lggr.Info("member of a capability DON - starting remote publishers") | |||
|
|||
{ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Seems weird to have mocks explicitly instantiated in application code, can we not use dependency injection here?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This Syncer object is soon going to be replaced with a real one.
1. Add EnableTriggerCapability flag to Relay config 2. Create MercuryTriggerService lazily, on the first call to NewMercuryProvider() 3. Make it available in the Transmitter (no-op for now)
* Fix metric description on mercury_transmit_queue_load * Add changeset * Add changesets tag * Decouple gas tests (#12972) * Add first version of evm utils * Remove unused context util * Add WSServer tests * Add NewLegacyTransaction test * Update NewTestChainScopedConfig to apply correct defaults * Decouple gas package tests from core * Move testutils * Update paths * Fix import error * Add changeset * Add logs to identify when assumptions of log queuing behaviour are violated (#12846) * Add logs to identify when assumptions of log queuing behaviour are violated * Add tests * go import * Add changeset * Update enqueuing assumption * Update tests * Extract block tracking into a separate function * Clean up outdated enqueued blocks * Clean up imports * Ignore reord buffer in cleanup * Cleanup test name * tools/docker: bump postgres to v14 (#13156) * changed spammy error log to debug (#13153) * [KS-186] Add custom OCR3 Capability Provider (#13137) * [KS-193] Pass MercuryTriggerService to Mercury Transmitter (#13118) 1. Add EnableTriggerCapability flag to Relay config 2. Create MercuryTriggerService lazily, on the first call to NewMercuryProvider() 3. Make it available in the Transmitter (no-op for now) * update changeset to include db_update tag (#13170) * fix go-etheruem compatibility pipeline trigger (#13162) * Revert "Add logs to identify when assumptions of log queuing behaviour are violated" (#13173) * Revert "Add logs to identify when assumptions of log queuing behaviour are vi…" This reverts commit 6a342ae. * Add changeset * chore: update solana-build-contracts for node20 (#13175) * chore: update solana-build-contracts for node20 * chore: bump chainlink-solana version * Decouple utils tests from core (#12993) * Add first version of evm utils * Remove unused context util * Add WSServer tests * Add NewLegacyTransaction test * Update NewTestChainScopedConfig to apply correct defaults * Move testutils * Decouple utils tests from core * Add changeset --------- Co-authored-by: Dimitris Grigoriou <dimitris.grigoriou@smartcontract.com> Co-authored-by: ferglor <fergal.gribben@smartcontract.com> Co-authored-by: Jordan Krage <jmank88@gmail.com> Co-authored-by: Patrick <patrick.huie@smartcontract.com> Co-authored-by: Cedric <cedric.cordenier@smartcontract.com> Co-authored-by: Bolek <1416262+bolekk@users.noreply.github.com> Co-authored-by: Chunkai Yang <matYang@users.noreply.github.com> Co-authored-by: Bartek Tofel <bartek.tofel@smartcontract.com> Co-authored-by: Erik Burton <erikburt@users.noreply.github.com>