Merge branch 'master' into adjust-cqrs-example

.github/workflows/tests.yml

@@ -11,6 +11,10 @@ on:
         required: false
         type: boolean
         default: false
+      runs-on:
+        required: false
+        type: string
+        default: 'ubuntu-latest'
     secrets:
       codecov_token:
         required: false
@@ -34,7 +38,7 @@ jobs:
         uses: golangci/golangci-lint-action@v3
   tests:
     needs: [build]
-    runs-on: ubuntu-latest
+    runs-on: ${{ inputs.runs-on }}
     steps:
       - uses: actions/checkout@v4
       - uses: actions/setup-go@v4
@@ -50,7 +54,7 @@ jobs:
       - run: make test_stress
         if: ${{ inputs.stress-tests }}
   codecov:
-    runs-on: ubuntu-latest
+    runs-on: ${{ inputs.runs-on }}
     if: ${{ inputs.codecov }}
     steps:
       - uses: actions/checkout@v4

codecov.yml

@@ -4,9 +4,10 @@ ignore:
 comment: no # do not comment PR with the result
 
 coverage:
-  project:
+  precision: 0
+  status:
+    patch: false # do not run coverage on patch nor changes
+    project:
       default:
         target: auto
         threshold: 5%
-  status:
-    patch: false # do not run coverage on patch nor changes

components/cqrs/command_processor_test.go

@@ -178,8 +178,10 @@ func TestCommandProcessor_multiple_same_command_handlers(t *testing.T) {
 }
 
 type mockSubscriber struct {
-	MessagesToSend []*message.Message
-	out            chan *message.Message
+	MessagesToSend              []*message.Message
+	WaitForAckBeforeSendingNext bool
+
+	out chan *message.Message
 }
 
 func (m *mockSubscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error) {
@@ -188,6 +190,10 @@ func (m *mockSubscriber) Subscribe(ctx context.Context, topic string) (<-chan *m
 	go func() {
 		for _, msg := range m.MessagesToSend {
 			m.out <- msg
+
+			if m.WaitForAckBeforeSendingNext {
+				<-msg.Acked()
+			}
 		}
 	}()
 

components/cqrs/event_processor_group_test.go

@@ -298,6 +298,7 @@ func TestEventProcessor_handler_group(t *testing.T) {
 			msg1,
 			msg2,
 		},
+		WaitForAckBeforeSendingNext: true,
 	}
 
 	var handlersCalls []int