Add redis service to CI

2 files changed, 30 insertions, 5 deletions

diff --git a/backend/.github/workflows/go.yaml b/backend/.github/workflows/go.yaml
index d886005..fe1b3a1 100644
--- a/backend/.github/workflows/go.yaml
+++ b/backend/.github/workflows/go.yaml
@@ -13,8 +13,19 @@ jobs:
   build:
     runs-on: ubuntu-latest
 
+    services:
+      redis:
+        image: redis
+        ports:
+          - 6379:6379
+        options: >-
+          --health-cmd "redis-cli ping"
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
+
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v4
         with:
           submodules: recursive
           token: ${{ secrets.PAT_TOKEN }}
@@ -32,12 +43,14 @@ jobs:
         run: go build -v ./...
       - name: Test
         run: go test -v ./...
+        env:
+          REDIS_ADDR: "localhost:6379"
 
   lint:
     runs-on: ubuntu-latest
 
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v4
         with:
           submodules: recursive
           token: ${{ secrets.PAT_TOKEN }}
diff --git a/backend/internal/redis/taskqueue/queue_test.go b/backend/internal/redis/taskqueue/queue_test.go
index b54d22a..aa817c5 100644
--- a/backend/internal/redis/taskqueue/queue_test.go
+++ b/backend/internal/redis/taskqueue/queue_test.go
@@ -3,6 +3,7 @@ package taskqueue
 import (
 	"context"
 	"errors"
+	"os"
 	"testing"
 	"time"
 
@@ -11,12 +12,23 @@ import (
 	"github.com/stretchr/testify/require"
 )
 
+func getRedisClient() *redis.Client {
+	addr := os.Getenv("REDIS_ADDR")
+	if addr == "" {
+		addr = "localhost:6379"
+	}
+
+	return redis.NewClient(&redis.Options{
+		Addr: addr,
+	})
+}
+
 func TestTaskQueue(t *testing.T) {
 	if testing.Short() {
 		t.Skip()
 	}
 
-	client := redis.NewClient(new(redis.Options))
+	client := getRedisClient()
 	defer func(client *redis.Client) {
 		_ = client.Close()
 	}(client)
@@ -202,7 +214,7 @@ func TestTaskQueue_List(t *testing.T) {
 		t.Skip()
 	}
 
-	client := redis.NewClient(new(redis.Options))
+	client := getRedisClient()
 	defer func(client *redis.Client) {
 		_ = client.Close()
 	}(client)
@@ -371,7 +383,7 @@ func TestTaskQueue_Return(t *testing.T) {
 		t.Skip()
 	}
 
-	client := redis.NewClient(new(redis.Options))
+	client := getRedisClient()
 	defer func(client *redis.Client) {
 		_ = client.Close()
 	}(client)