build

Author: patrickhuie19

devenv/http/handler.go

@@ -77,7 +77,11 @@ func (h *handler) Start(ctx context.Context) error {
 	}
 
 	h.logger.Info("initialising capabilities service")
-	if err := h.svc.Service.Initialise(ctx, "", nil, h.kvstore, h.capabilityRegistry, nil, nil, nil, nil, nil, nil); err != nil {
+	if err := h.svc.Service.Initialise(ctx, core.StandardCapabilitiesDependencies{
+		Config:             "",
+		Store:              h.kvstore,
+		CapabilityRegistry: h.capabilityRegistry,
+	}); err != nil {
 		h.logger.Errorf("Failed to initialise service: %v", err)
 		return err
 	}

http_action/action/action_test.go

@@ -273,7 +273,10 @@ func TestInitialise_NilConfig(t *testing.T) {
 		srv := NewService(lggr, limits.Factory{})
 		gc := gcmocks.NewGatewayConnector(t)
 
-		err := srv.Initialise(context.Background(), "", nil, nil, nil, nil, nil, nil, gc, nil)
+		err := srv.Initialise(context.Background(), core.StandardCapabilitiesDependencies{
+			Config:           "",
+			GatewayConnector: gc,
+		})
 		require.Error(t, err)
 		assert.Contains(t, err.Error(), "unexpected end of JSON input")
 	})
@@ -283,7 +286,10 @@ func TestInitialise_NilConfig(t *testing.T) {
 		srv := NewService(lggr, limits.Factory{})
 		gc := gcmocks.NewGatewayConnector(t)
 
-		err := srv.Initialise(context.Background(), "invalid json", nil, nil, nil, nil, nil, nil, gc, nil)
+		err := srv.Initialise(context.Background(), core.StandardCapabilitiesDependencies{
+			Config:           "invalid json",
+			GatewayConnector: gc,
+		})
 		require.Error(t, err)
 		assert.Contains(t, err.Error(), "invalid character")
 	})
@@ -293,7 +299,10 @@ func TestInitialise_NilConfig(t *testing.T) {
 		srv := NewService(lggr, limits.Factory{})
 		gc := gcmocks.NewGatewayConnector(t)
 
-		err := srv.Initialise(context.Background(), "{}", nil, nil, nil, nil, nil, nil, gc, nil)
+		err := srv.Initialise(context.Background(), core.StandardCapabilitiesDependencies{
+			Config:           "{}",
+			GatewayConnector: gc,
+		})
 		require.Error(t, err)
 		assert.Contains(t, err.Error(), "invalid proxy mode")
 	})
@@ -303,7 +312,10 @@ func TestInitialise_NilConfig(t *testing.T) {
 		srv := NewService(lggr, limits.Factory{})
 		gc := gcmocks.NewGatewayConnector(t)
 
-		err := srv.Initialise(context.Background(), "null", nil, nil, nil, nil, nil, nil, gc, nil)
+		err := srv.Initialise(context.Background(), core.StandardCapabilitiesDependencies{
+			Config:           "null",
+			GatewayConnector: gc,
+		})
 		require.Error(t, err)
 		assert.Contains(t, err.Error(), "invalid proxy mode")
 	})

http_trigger/trigger/trigger_test.go

@@ -14,6 +14,7 @@ import (
 	"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/triggers/http"
 	"github.com/smartcontractkit/chainlink-common/pkg/logger"
 	"github.com/smartcontractkit/chainlink-common/pkg/settings/limits"
+	"github.com/smartcontractkit/chainlink-common/pkg/types/core"
 	gcmocks "github.com/smartcontractkit/chainlink-common/pkg/types/core/mocks"
 	gateway_common "github.com/smartcontractkit/chainlink-common/pkg/types/gateway"
 )
@@ -58,7 +59,10 @@ func TestService_RegisterTrigger(t *testing.T) {
 			svc := NewService(logger.Test(t), limits.Factory{Logger: logger.Test(t)})
 			cfgStr := fmt.Sprintf(`{"sendChannelBufferSize": %d}`, tc.sendChannelBufSize)
 			gc := mockedGatewayConnector(t)
-			err := svc.Initialise(t.Context(), cfgStr, nil, nil, nil, nil, nil, nil, gc, nil)
+			err := svc.Initialise(t.Context(), core.StandardCapabilitiesDependencies{
+				Config:           cfgStr,
+				GatewayConnector: gc,
+			})
 			require.NoError(t, err)
 			svc.connectorHandler = mockHandler
 			ctx := context.Background()
@@ -104,7 +108,10 @@ func TestService_UnregisterTrigger(t *testing.T) {
 			svc := NewService(logger.Test(t), limits.Factory{Logger: logger.Test(t)})
 			cfg := "{}"
 			gc := mockedGatewayConnector(t)
-			err := svc.Initialise(t.Context(), cfg, nil, nil, nil, nil, nil, nil, gc, nil)
+			err := svc.Initialise(t.Context(), core.StandardCapabilitiesDependencies{
+				Config:           cfg,
+				GatewayConnector: gc,
+			})
 			require.NoError(t, err)
 			svc.connectorHandler = mockHandler
 
@@ -125,7 +132,10 @@ func TestService_Start_HealthReport_Ready_Close(t *testing.T) {
 	svc := NewService(logger.Test(t), limits.Factory{Logger: logger.Test(t)})
 	cfg := "{}"
 	gc := mockedGatewayConnector(t)
-	err := svc.Initialise(t.Context(), cfg, nil, nil, nil, nil, nil, nil, gc, nil)
+	err := svc.Initialise(t.Context(), core.StandardCapabilitiesDependencies{
+		Config:           cfg,
+		GatewayConnector: gc,
+	})
 	require.NoError(t, err)
 	svc.connectorHandler = mockHandler
 

libs/testutils/capabilities_registry.go

@@ -149,3 +149,7 @@ func (r *capabilitiesRegistry) Contains(capabilityIDs []string) error {
 func (r *capabilitiesRegistry) NodeByPeerID(ctx context.Context, peerID types.PeerID) (capabilities.Node, error) {
 	return capabilities.Node{}, errors.New("unimplemented")
 }
+
+func (r *capabilitiesRegistry) DONsForCapability(ctx context.Context, capabilityID string) ([]capabilities.DONWithNodes, error) {
+	return []capabilities.DONWithNodes{}, nil
+}