Trying to fix CI (#49)

* Trying to fix CI

* Fix races

* test for races

Author: mishankov

.github/workflows/ci.yml

@@ -49,7 +49,7 @@ jobs:
     runs-on: ${{ matrix.os }}-latest
     strategy:
       matrix:
-        os: [ubuntu]
+        os: [ubuntu, windows, macos]
     steps:
       - uses: actions/checkout@v6
 
@@ -59,12 +59,14 @@ jobs:
           go-version: stable
 
       - name: Test
-        run: |
-          go test -v -coverprofile="coverage.tmp.txt" ./...
-          cat coverage.tmp.txt | grep -v "demo-app" | grep -v "platforma/docs" > coverage.txt
+        run: go test -v -race -coverprofile="coverage.tmp.txt" ./...
+
+      - name: Filter coverage
+        if: matrix.os == 'ubuntu'
+        run: cat coverage.tmp.txt | grep -v "demo-app" | grep -v "platforma/docs" > coverage.txt
 
       - name: Upload coverage reports to Codecov
-        # upload coverage reports only once
+        if: matrix.os == 'ubuntu'
         uses: shogo82148/actions-goveralls@25f5320d970fb565100cf1993ada29be1bb196a1
         with:
           path-to-profile: coverage.txt

Taskfile.dist.yml

@@ -11,7 +11,7 @@ tasks:
 
   test:
     cmds:
-      - go test -coverprofile=coverage.tmp.out ./...
+      - go test -race -coverprofile=coverage.tmp.out ./...
       - cat coverage.tmp.out | grep -v "demo-app" | grep -v "platforma/docs" > coverage.out
       - go tool cover -html=coverage.out -o coverage.html
 

database/database_test.go

@@ -1,3 +1,5 @@
+//go:build linux
+
 package database_test
 
 import (

queue/processor_test.go

@@ -3,6 +3,7 @@ package queue_test
 import (
 	"context"
 	"errors"
+	"sync/atomic"
 	"testing"
 	"time"
 
@@ -15,14 +16,14 @@ func TestProcessor(t *testing.T) {
 	t.Run("simple queue", func(t *testing.T) {
 		t.Parallel()
 		ctx := context.Background()
-		res := 0
+		var res atomic.Int32
 
 		q := &mockQueue[job]{
 			jobChan: make(chan job, 10),
 		}
 
 		p := queue.New(queue.HandlerFunc[job](func(_ context.Context, job job) {
-			res += job.data
+			res.Add(int32(job.data))
 		}), q, 4, time.Microsecond)
 
 		go p.Run(context.TODO())
@@ -31,10 +32,10 @@ func TestProcessor(t *testing.T) {
 		p.Enqueue(ctx, job{data: 1})
 		p.Enqueue(ctx, job{data: 1})
 
-		time.Sleep(1 * time.Millisecond)
+		time.Sleep(100 * time.Millisecond)
 
-		if res != 3 {
-			t.Errorf("expected res to be 1, got %d", res)
+		if res.Load() != 3 {
+			t.Errorf("expected res to be 3, got %d", res.Load())
 		}
 	})
 

scheduler/scheduler_test.go

@@ -1,9 +1,9 @@
 package scheduler_test
 
 import (
-	"bytes"
 	"context"
 	"errors"
+	"sync/atomic"
 	"testing"
 	"time"
 
@@ -14,45 +14,45 @@ import (
 func TestSuccessRun(t *testing.T) {
 	t.Parallel()
 
-	buf := bytes.Buffer{}
+	var counter atomic.Int32
 	s := scheduler.New(1*time.Second, application.RunnerFunc(func(ctx context.Context) error {
-		buf.WriteString("1")
+		counter.Add(1)
 		return nil
 	}))
 
 	go s.Run(context.TODO())
 
 	time.Sleep(3500 * time.Millisecond)
 
-	if buf.String() != "111" {
-		t.Errorf("wrong buffer content. expected %v, got %v", "111", buf.String())
+	if counter.Load() != 3 {
+		t.Errorf("wrong counter value. expected %v, got %v", 3, counter.Load())
 	}
 }
 
 func TestErrorRun(t *testing.T) {
 	t.Parallel()
 
-	buf := bytes.Buffer{}
+	var counter atomic.Int32
 	s := scheduler.New(1*time.Second, application.RunnerFunc(func(ctx context.Context) error {
-		buf.WriteString("1")
+		counter.Add(1)
 		return errors.New("some error")
 	}))
 
 	go s.Run(context.TODO())
 
 	time.Sleep(3500 * time.Millisecond)
 
-	if buf.String() != "111" {
-		t.Errorf("wrong buffer content. expected %v, got %v", "111", buf.String())
+	if counter.Load() != 3 {
+		t.Errorf("wrong counter value. expected %v, got %v", 3, counter.Load())
 	}
 }
 
 func TestContextDecline(t *testing.T) {
 	t.Parallel()
 
-	buf := bytes.Buffer{}
+	var counter atomic.Int32
 	s := scheduler.New(1*time.Second, application.RunnerFunc(func(ctx context.Context) error {
-		buf.WriteString("1")
+		counter.Add(1)
 		return nil
 	}))
 
@@ -65,8 +65,8 @@ func TestContextDecline(t *testing.T) {
 
 	err := s.Run(ctx)
 
-	if buf.String() != "111" {
-		t.Errorf("wrong buffer content. expected %v, got %v", "111", buf.String())
+	if counter.Load() != 3 {
+		t.Errorf("wrong counter value. expected %v, got %v", 3, counter.Load())
 	}
 
 	if err == nil {