@@ -194,9 +194,9 @@ func (m *OCRv2TestState) DeployCluster() {
194194
195195 // Setting up Mock adapter
196196 m .Clients .KillgraveClient = env .MockAdapter
197- m .Common .RPCDetails .MockServerEndpoint = m .Clients .Killgravenodeclient .InternalEndpoint
197+ m .Common .RPCDetails .MockServerEndpoint = m .Clients .KillgraveClient .InternalEndpoint
198198 m .Common .RPCDetails .MockServerURL = "mockserver-bridge"
199- err = m .Clients .Killgravenodeclient .SetAdapterBasedIntValuePath ("/mockserver-bridge" , []string {http .MethodGet , http .MethodPost }, 10 )
199+ err = m .Clients .KillgraveClient .SetAdapterBasedIntValuePath ("/mockserver-bridge" , []string {http .MethodGet , http .MethodPost }, 10 )
200200 require .NoError (m .TestConfig .T , err , "Failed to set mock adapter value" )
201201 }
202202
@@ -205,12 +205,12 @@ func (m *OCRv2TestState) DeployCluster() {
205205 if * m .Common .TestConfig .Common .InsideK8s {
206206 m .ChainlinkNodesK8s , m .TestConfig .err = nodeclient .ConnectChainlinkNodes (m .Common .Env )
207207 require .NoError (m .TestConfig .T , m .TestConfig .err )
208- m .Clients .Chainlinknodeclient .ChainlinkNodes = m .GetChainlinkNodes ()
209- m .Clients .Chainlinknodeclient .NKeys , m .TestConfig .err = m .Common .CreateNodeKeysBundle (m .Clients .Chainlinknodeclient .ChainlinkNodes )
208+ m .Clients .ChainlinkClient .ChainlinkNodes = m .GetChainlinkNodes ()
209+ m .Clients .ChainlinkClient .NKeys , m .TestConfig .err = m .Common .CreateNodeKeysBundle (m .Clients .ChainlinkClient .ChainlinkNodes )
210210 require .NoError (m .TestConfig .T , m .TestConfig .err )
211211 } else {
212- m .Clients .Chainlinknodeclient .ChainlinkNodes = m .Clients .DockerEnv .CLClusterTestEnv .ClCluster .NodeAPIs ()
213- m .Clients .Chainlinknodeclient .NKeys , m .TestConfig .err = m .Common .CreateNodeKeysBundle (m .Clients .DockerEnv .CLClusterTestEnv .ClCluster .NodeAPIs ())
212+ m .Clients .ChainlinkClient .ChainlinkNodes = m .Clients .DockerEnv .CLClusterTestEnv .ClCluster .NodeAPIs ()
213+ m .Clients .ChainlinkClient .NKeys , m .TestConfig .err = m .Common .CreateNodeKeysBundle (m .Clients .DockerEnv .CLClusterTestEnv .ClCluster .NodeAPIs ())
214214 require .NoError (m .TestConfig .T , m .TestConfig .err )
215215 }
216216
@@ -224,7 +224,7 @@ func (m *OCRv2TestState) DeployCluster() {
224224 if * m .Common .TestConfig .Common .Network == "localnet" {
225225 // fetch predeployed account 0 to use as funder
226226 m .Clients .DevnetClient = starknetdevnet .NewDevNet (m .Common .RPCDetails .RPCL2External )
227- accounts , err := m .Clients .Devnetnodeclient .Accounts ()
227+ accounts , err := m .Clients .DevnetClient .Accounts ()
228228 require .NoError (m .TestConfig .T , err )
229229 account := accounts [0 ]
230230 m .Account .Account = account .Address
@@ -248,10 +248,10 @@ func (m *OCRv2TestState) LoadOCR2Config() (*ops.OCR2Config, error) {
248248 var peerIDs []string
249249 var txKeys []string
250250 var cfgKeys []string
251- for i , key := range m .Clients .Chainlinknodeclient .NKeys {
251+ for i , key := range m .Clients .ChainlinkClient .NKeys {
252252 offChaiNKeys = append (offChaiNKeys , key .OCR2Key .Data .Attributes .OffChainPublicKey )
253253 peerIDs = append (peerIDs , key .PeerID )
254- txKeys = append (txKeys , m .Clients .Chainlinknodeclient .AccountAddresses [i ])
254+ txKeys = append (txKeys , m .Clients .ChainlinkClient .AccountAddresses [i ])
255255 onChaiNKeys = append (onChaiNKeys , key .OCR2Key .Data .Attributes .OnChainPublicKey )
256256 cfgKeys = append (cfgKeys , key .OCR2Key .Data .Attributes .ConfigPublicKey )
257257 }
@@ -267,13 +267,13 @@ func (m *OCRv2TestState) LoadOCR2Config() (*ops.OCR2Config, error) {
267267}
268268
269269func (m * OCRv2TestState ) SetUpNodes () {
270- err := m .Common .CreateJobsForContract (m .GetChainlinkClient (), m .Contracts .ObservationSource , m .Contracts .JuelsPerFeeCoinSource , m .Contracts .OCRAddr , m .Clients .Chainlinknodeclient .AccountAddresses )
270+ err := m .Common .CreateJobsForContract (m .GetChainlinkClient (), m .Contracts .ObservationSource , m .Contracts .JuelsPerFeeCoinSource , m .Contracts .OCRAddr , m .Clients .ChainlinkClient .AccountAddresses )
271271 require .NoError (m .TestConfig .T , err , "Creating jobs should not fail" )
272272}
273273
274274// GetNodeKeys Returns the node key bundles
275275func (m * OCRv2TestState ) GetNodeKeys () []nodeclient.NodeKeysBundle {
276- return m .Clients .Chainlinknodeclient .NKeys
276+ return m .Clients .ChainlinkClient .NKeys
277277}
278278
279279func (m * OCRv2TestState ) GetChainlinkNodes () []* nodeclient.ChainlinkClient {
@@ -290,7 +290,7 @@ func (m *OCRv2TestState) GetChainlinkClient() *ChainlinkClient {
290290}
291291
292292func (m * OCRv2TestState ) SetBridgeTypeAttrs (attr * nodeclient.BridgeTypeAttributes ) {
293- m .Clients .Chainlinknodeclient .bTypeAttr = attr
293+ m .Clients .ChainlinkClient .bTypeAttr = attr
294294}
295295
296296func (m * OCRv2TestState ) GetDefaultObservationSource () string {
@@ -327,13 +327,13 @@ func (m *OCRv2TestState) ValidateRounds(rounds int, isSoak bool) error {
327327 if err != nil {
328328 return err
329329 }
330- resLINK , errLINK := m .Clients .Starknetnodeclient .CallContract (ctx , starknet.CallOps {
330+ resLINK , errLINK := m .Clients .StarknetClient .CallContract (ctx , starknet.CallOps {
331331 ContractAddress : linkContractAddress ,
332332 Selector : starknetutils .GetSelectorFromNameFelt ("balance_of" ),
333333 Calldata : []* felt.Felt {contractAddress },
334334 })
335335 require .NoError (m .TestConfig .T , errLINK , "Reader balance from LINK contract should not fail" , "err" , errLINK )
336- resAgg , errAgg := m .Clients .Starknetnodeclient .CallContract (ctx , starknet.CallOps {
336+ resAgg , errAgg := m .Clients .StarknetClient .CallContract (ctx , starknet.CallOps {
337337 ContractAddress : contractAddress ,
338338 Selector : starknetutils .GetSelectorFromNameFelt ("link_available_for_payment" ),
339339 })
@@ -350,7 +350,7 @@ func (m *OCRv2TestState) ValidateRounds(rounds int, isSoak bool) error {
350350
351351 for start := time .Now (); time .Since (start ) < m .Common .TestEnvDetails .TestDuration ; {
352352 m .TestConfig .L .Info ().Msg (fmt .Sprintf ("Elapsed time: %s, Round wait: %s " , time .Since (start ), m .Common .TestEnvDetails .TestDuration ))
353- res , err2 := m .Clients .OCR2nodeclient .LatestTransmissionDetails (ctx , contractAddress )
353+ res , err2 := m .Clients .OCR2Client .LatestTransmissionDetails (ctx , contractAddress )
354354 require .NoError (m .TestConfig .T , err2 , "Failed to get latest transmission details" )
355355 // end condition: enough rounds have occurred
356356 if ! isSoak && increasing >= rounds && positive {
@@ -427,7 +427,7 @@ func (m *OCRv2TestState) ValidateRounds(rounds int, isSoak bool) error {
427427 if err != nil {
428428 return err
429429 }
430- roundDataRaw , err := m .Clients .Starknetnodeclient .CallContract (ctx , starknet.CallOps {
430+ roundDataRaw , err := m .Clients .StarknetClient .CallContract (ctx , starknet.CallOps {
431431 ContractAddress : proxyAddress ,
432432 Selector : starknetutils .GetSelectorFromNameFelt ("latest_round_data" ),
433433 })
0 commit comments