fix lint issues

smartcontractkit · Nov 19, 2024 · e3223e0 · e3223e0
1 parent ddd703e
commit e3223e0
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/core/services/chainlink/application.go b/core/services/chainlink/application.go
@@ -23,6 +23,7 @@ import (
 	"github.com/smartcontractkit/chainlink-common/pkg/loop"
 	commonservices "github.com/smartcontractkit/chainlink-common/pkg/services"
 	"github.com/smartcontractkit/chainlink-common/pkg/sqlutil"
+	commontypes "github.com/smartcontractkit/chainlink-common/pkg/types"
 	"github.com/smartcontractkit/chainlink-common/pkg/utils"
 	"github.com/smartcontractkit/chainlink-common/pkg/utils/jsonserializable"
 	"github.com/smartcontractkit/chainlink-common/pkg/utils/mailbox"
@@ -215,7 +216,7 @@ func NewApplication(opts ApplicationOpts) (Application, error) {
 
 	// TODO: wire this up to config so we only instantiate it
 	// if a workflow registry address is provided.
-	workflowRegistrySyncer := syncer.NewWorkflowRegistry(nil, nil, nil, nil, "")
+	workflowRegistrySyncer := syncer.NewWorkflowRegistry[commontypes.ContractReader](nil, nil, nil, nil, "")
 	srvcs = append(srvcs, workflowRegistrySyncer)
 
 	var externalPeerWrapper p2ptypes.PeerWrapper

diff --git a/core/services/workflows/syncer/orm_test.go b/core/services/workflows/syncer/orm_test.go
@@ -25,7 +25,7 @@ func TestWorkflowArtifactsORM_GetAndUpdate(t *testing.T) {
 	giveHash := hex.EncodeToString(giveBytes)
 	giveContent := "some contents"
 
-	gotID, err := orm.Update(ctx, giveURL, giveContent)
+	gotID, err := orm.Create(ctx, giveURL, giveHash, giveContent)
 	require.NoError(t, err)
 
 	url, err := orm.GetSecretsURLByID(ctx, gotID)
@@ -40,7 +40,7 @@ func TestWorkflowArtifactsORM_GetAndUpdate(t *testing.T) {
 	require.NoError(t, err)
 	assert.Equal(t, "some contents", contents)
 
-	_, err = orm.Update(ctx, giveURL, "new contents")
+	_, err = orm.Update(ctx, giveHash, "new contents")
 	require.NoError(t, err)
 
 	contents, err = orm.GetContents(ctx, giveURL)

diff --git a/core/services/workflows/syncer/workflow_registry.go b/core/services/workflows/syncer/workflow_registry.go
@@ -150,10 +150,10 @@ func WithReader(reader types.ContractReader) func(*workflowRegistry) {
 
 // NewWorkflowRegistry returns a new workflowRegistry.
 // Only queries for WorkflowRegistryForceUpdateSecretsRequestedV1 events.
-func NewWorkflowRegistry(
+func NewWorkflowRegistry[T ContractReader](
 	lggr logger.Logger,
 	orm WorkflowRegistryDS,
-	reader types.ContractReader,
+	reader T,
 	gateway FetcherFunc,
 	addr string,
 	opts ...func(*workflowRegistry),