Skip to content

Commit fa06d07

Browse files
committed
Hack: start the transmitter from application to send mock events
1 parent 3589cb6 commit fa06d07

2 files changed

Lines changed: 30 additions & 13 deletions

File tree

core/services/chainlink/application.go

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,7 @@ import (
6868
"github.com/smartcontractkit/chainlink/v2/core/services/llo/retirement"
6969
"github.com/smartcontractkit/chainlink/v2/core/services/ocr"
7070
"github.com/smartcontractkit/chainlink/v2/core/services/ocr2"
71+
securemint "github.com/smartcontractkit/chainlink/v2/core/services/ocr3/securemint"
7172
"github.com/smartcontractkit/chainlink/v2/core/services/ocrbootstrap"
7273
"github.com/smartcontractkit/chainlink/v2/core/services/ocrcommon"
7374
p2ptypes "github.com/smartcontractkit/chainlink/v2/core/services/p2p/types"
@@ -1020,6 +1021,25 @@ func newCREServices(
10201021
globalLogger.Debug("External registry not configured, skipping registry syncer and starting with an empty registry")
10211022
opts.CapabilitiesRegistry.SetLocalRegistry(&capabilities.TestMetadataRegistry{})
10221023
}
1024+
1025+
globalLogger.Infow("HACK: initializing Secure Mint transmitter for sending mock secure mint trigger events")
1026+
transmitterConfig := securemint.TransmitterConfig{
1027+
Logger: globalLogger,
1028+
CapabilitiesRegistry: opts.CapabilitiesRegistry,
1029+
DonID: 1,
1030+
TriggerCapabilityName: "securemint-trigger",
1031+
TriggerCapabilityVersion: "1.0.0",
1032+
TriggerTickerMinResolutionMs: 1000,
1033+
TriggerSendChannelBufferSize: 1000,
1034+
}
1035+
transmitter, err := transmitterConfig.NewTransmitter("securemint-transmitter")
1036+
if err != nil {
1037+
globalLogger.Errorw("could not create Secure Mint transmitter, skipping", "error", err)
1038+
} else {
1039+
srvcs = append(srvcs, transmitter)
1040+
globalLogger.Infow("HACK: successfully created Secure Mint transmitter")
1041+
}
1042+
10231043
return &CREServices{
10241044
workflowRateLimiter: workflowRateLimiter,
10251045
workflowLimits: workflowLimits,
Lines changed: 10 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,6 @@
11
package securemint
22

33
import (
4-
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/flags"
5-
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/types"
6-
74
capabilitiespb "github.com/smartcontractkit/chainlink-common/pkg/capabilities/pb"
85

96
kcr "github.com/smartcontractkit/chainlink-evm/gethwrappers/keystone/generated/capabilities_registry_1_1_0"
@@ -13,16 +10,16 @@ import (
1310
var SecureMintCapabilityFactoryFn = func(donFlags []string) []keystone_changeset.DONCapabilityWithConfig {
1411
var capabilities []keystone_changeset.DONCapabilityWithConfig
1512

16-
if flags.HasFlag(donFlags, types.SecureMintCapability) {
17-
capabilities = append(capabilities, keystone_changeset.DONCapabilityWithConfig{
18-
Capability: kcr.CapabilitiesRegistryCapability{
19-
LabelledName: "secure-mint-trigger", // TODO: use correct trigger name
20-
Version: "1.0.0",
21-
CapabilityType: 0, // TRIGGER
22-
},
23-
Config: &capabilitiespb.CapabilityConfig{},
24-
})
25-
}
13+
// if flags.HasFlag(donFlags, types.SecureMintCapability) {
14+
capabilities = append(capabilities, keystone_changeset.DONCapabilityWithConfig{
15+
Capability: kcr.CapabilitiesRegistryCapability{
16+
LabelledName: "secure-mint-trigger", // TODO: use correct trigger name
17+
Version: "1.0.0",
18+
CapabilityType: 0, // TRIGGER
19+
},
20+
Config: &capabilitiespb.CapabilityConfig{},
21+
})
22+
// }
2623

2724
return capabilities
2825
}

0 commit comments

Comments
 (0)