Add tests for IsDisabled() methods.

dogmatiq · Oct 15, 2024 · 09710f3 · 09710f3
1 parent 59b39f9
commit 09710f3
Show file tree

Hide file tree

Showing 5 changed files with 123 additions and 5 deletions.
diff --git a/config/aggregate_test.go b/config/aggregate_test.go
@@ -102,7 +102,7 @@ func TestAggregate_Identity(t *testing.T) {
 	})
 }
 
-func TestAggregate_Routes(t *testing.T) {
+func TestAggregate_RouteSet(t *testing.T) {
 	t.Run("it returns the normalized routes", func(t *testing.T) {
 		h := &AggregateMessageHandlerStub{
 			ConfigureFunc: func(c dogma.AggregateConfigurer) {
@@ -190,6 +190,36 @@ func TestAggregate_Routes(t *testing.T) {
 	})
 }
 
+func TestAggregate_IsDisabled(t *testing.T) {
+	disable := false
+
+	h := &AggregateMessageHandlerStub{
+		ConfigureFunc: func(c dogma.AggregateConfigurer) {
+			c.Identity("name", "19cb98d5-dd17-4daf-ae00-1b413b7b899a")
+			c.Routes(
+				dogma.HandlesCommand[CommandStub[TypeA]](),
+				dogma.RecordsEvent[EventStub[TypeA]](),
+			)
+			if disable {
+				c.Disable()
+			}
+		},
+	}
+
+	cfg := runtimeconfig.FromAggregate(h)
+
+	if cfg.IsDisabled() {
+		t.Fatal("did not expect handler to be disabled")
+	}
+
+	disable = true
+	cfg = runtimeconfig.FromAggregate(h)
+
+	if !cfg.IsDisabled() {
+		t.Fatal("expected handler to be disabled")
+	}
+}
+
 func TestAggregate_Interface(t *testing.T) {
 	h := &AggregateMessageHandlerStub{
 		ConfigureFunc: func(c dogma.AggregateConfigurer) {

diff --git a/config/application_test.go b/config/application_test.go
@@ -82,7 +82,7 @@ func TestApplication_Identity(t *testing.T) {
 	})
 }
 
-func TestApplication_Routes(t *testing.T) {
+func TestApplication_RouteSet(t *testing.T) {
 	t.Run("it returns the normalized routes", func(t *testing.T) {
 		app := &ApplicationStub{
 			ConfigureFunc: func(c dogma.ApplicationConfigurer) {

diff --git a/config/integration_test.go b/config/integration_test.go
@@ -98,7 +98,7 @@ func TestIntegration_Identity(t *testing.T) {
 	})
 }
 
-func TestIntegration_Routes(t *testing.T) {
+func TestIntegration_RouteSet(t *testing.T) {
 	t.Run("it returns the normalized routes", func(t *testing.T) {
 		h := &IntegrationMessageHandlerStub{
 			ConfigureFunc: func(c dogma.IntegrationConfigurer) {
@@ -186,6 +186,35 @@ func TestIntegration_Routes(t *testing.T) {
 	})
 }
 
+func TestIntegration_IsDisabled(t *testing.T) {
+	disable := false
+
+	h := &IntegrationMessageHandlerStub{
+		ConfigureFunc: func(c dogma.IntegrationConfigurer) {
+			c.Identity("name", "19cb98d5-dd17-4daf-ae00-1b413b7b899a")
+			c.Routes(
+				dogma.HandlesCommand[CommandStub[TypeA]](),
+			)
+			if disable {
+				c.Disable()
+			}
+		},
+	}
+
+	cfg := runtimeconfig.FromIntegration(h)
+
+	if cfg.IsDisabled() {
+		t.Fatal("did not expect handler to be disabled")
+	}
+
+	disable = true
+	cfg = runtimeconfig.FromIntegration(h)
+
+	if !cfg.IsDisabled() {
+		t.Fatal("expected handler to be disabled")
+	}
+}
+
 func TestIntegration_Interface(t *testing.T) {
 	h := &IntegrationMessageHandlerStub{
 		ConfigureFunc: func(c dogma.IntegrationConfigurer) {

diff --git a/config/process_test.go b/config/process_test.go
@@ -102,7 +102,7 @@ func TestProcess_Identity(t *testing.T) {
 	})
 }
 
-func TestProcess_Routes(t *testing.T) {
+func TestProcess_RouteSet(t *testing.T) {
 	t.Run("it returns the normalized routes", func(t *testing.T) {
 		h := &ProcessMessageHandlerStub{
 			ConfigureFunc: func(c dogma.ProcessConfigurer) {
@@ -182,6 +182,36 @@ func TestProcess_Routes(t *testing.T) {
 	})
 }
 
+func TestProcess_IsDisabled(t *testing.T) {
+	disable := false
+
+	h := &ProcessMessageHandlerStub{
+		ConfigureFunc: func(c dogma.ProcessConfigurer) {
+			c.Identity("name", "19cb98d5-dd17-4daf-ae00-1b413b7b899a")
+			c.Routes(
+				dogma.HandlesEvent[EventStub[TypeA]](),
+				dogma.ExecutesCommand[CommandStub[TypeA]](),
+			)
+			if disable {
+				c.Disable()
+			}
+		},
+	}
+
+	cfg := runtimeconfig.FromProcess(h)
+
+	if cfg.IsDisabled() {
+		t.Fatal("did not expect handler to be disabled")
+	}
+
+	disable = true
+	cfg = runtimeconfig.FromProcess(h)
+
+	if !cfg.IsDisabled() {
+		t.Fatal("expected handler to be disabled")
+	}
+}
+
 func TestProcess_Interface(t *testing.T) {
 	h := &ProcessMessageHandlerStub{
 		ConfigureFunc: func(c dogma.ProcessConfigurer) {

diff --git a/config/projection_test.go b/config/projection_test.go
@@ -98,7 +98,7 @@ func TestProjection_Identity(t *testing.T) {
 	})
 }
 
-func TestProjection_Routes(t *testing.T) {
+func TestProjection_RouteSet(t *testing.T) {
 	t.Run("it returns the normalized routes", func(t *testing.T) {
 		h := &ProjectionMessageHandlerStub{
 			ConfigureFunc: func(c dogma.ProjectionConfigurer) {
@@ -194,6 +194,35 @@ func TestProjection_Routes(t *testing.T) {
 	})
 }
 
+func TestProjection_IsDisabled(t *testing.T) {
+	disable := false
+
+	h := &ProjectionMessageHandlerStub{
+		ConfigureFunc: func(c dogma.ProjectionConfigurer) {
+			c.Identity("name", "19cb98d5-dd17-4daf-ae00-1b413b7b899a")
+			c.Routes(
+				dogma.HandlesEvent[EventStub[TypeA]](),
+			)
+			if disable {
+				c.Disable()
+			}
+		},
+	}
+
+	cfg := runtimeconfig.FromProjection(h)
+
+	if cfg.IsDisabled() {
+		t.Fatal("did not expect handler to be disabled")
+	}
+
+	disable = true
+	cfg = runtimeconfig.FromProjection(h)
+
+	if !cfg.IsDisabled() {
+		t.Fatal("expected handler to be disabled")
+	}
+}
+
 func TestProjection_Interface(t *testing.T) {
 	h := &ProjectionMessageHandlerStub{
 		ConfigureFunc: func(c dogma.ProjectionConfigurer) {