refactor(syncer): alias to ORM with new spec DS

smartcontractkit · Nov 21, 2024 · 4dd15dd · 4dd15dd
1 parent 694dfe9
commit 4dd15dd
Show file tree

Hide file tree

Showing 3 changed files with 66 additions and 3 deletions.
diff --git a/core/services/workflows/syncer/handler.go b/core/services/workflows/syncer/handler.go
@@ -101,7 +101,7 @@ type eventHandler struct {
 // newEventHandler returns a new eventHandler instance.
 func newEventHandler(
 	lggr logger.Logger,
-	orm WorkflowSecretsDS,
+	orm ORM,
 	gateway FetcherFunc,
 	workflowStore store.Store,
 	capRegistry core.CapabilitiesRegistry,

diff --git a/core/services/workflows/syncer/mocks/orm.go b/core/services/workflows/syncer/mocks/orm.go
diff --git a/core/services/workflows/syncer/orm.go b/core/services/workflows/syncer/orm.go
@@ -36,14 +36,19 @@ type WorkflowSpecsDS interface {
 	CreateWorkflowSpec(ctx context.Context, spec *job.WorkflowSpec) (int64, error)
 }
 
-type WorkflowRegistryDS = WorkflowSecretsDS
+type ORM interface {
+	WorkflowSecretsDS
+	WorkflowSpecsDS
+}
+
+type WorkflowRegistryDS = ORM
 
 type orm struct {
 	ds   sqlutil.DataSource
 	lggr logger.Logger
 }
 
-var _ WorkflowSecretsDS = (*orm)(nil)
+var _ WorkflowRegistryDS = (*orm)(nil)
 
 func NewWorkflowRegistryDS(ds sqlutil.DataSource, lggr logger.Logger) *orm {
 	return &orm{