Add Redis integration tests and update CI workflow to include Redis service

Author: sdogruyol

.github/workflows/ci.yml

@@ -7,6 +7,16 @@ on:
 jobs:
   test:
     runs-on: ubuntu-latest
+    services:
+      redis:
+        image: redis:7-alpine
+        ports:
+          - 6379:6379
+        options: >-
+          --health-cmd "redis-cli ping"
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
 
     strategy:
       matrix:
@@ -35,6 +45,8 @@ jobs:
         run: shards install
 
       - name: Run tests
+        env:
+          REDIS_URL: redis://localhost:6379/0
         run: crystal spec
 
       - name: Check code formatting

README.md

@@ -335,6 +335,12 @@ crystal spec
 crystal tool format --check
 ```
 
+To run the real Redis integration spec locally, start Redis and set `REDIS_URL`:
+
+```bash
+REDIS_URL=redis://localhost:6379/0 crystal spec
+```
+
 ## Contributing
 
 1. Fork it (<https://github.com/kemalcr/kemal-cache/fork>)

spec/redis_integration_spec.cr

@@ -0,0 +1,40 @@
+require "./spec_helper"
+
+describe Kemal::Cache::RedisStore do
+  it "works against a real Redis instance" do
+    redis_url = real_redis_url
+    pending!("REDIS_URL is not set") unless redis_url
+
+    namespace = unique_redis_namespace("kemal-cache-integration")
+    other_namespace = unique_redis_namespace("kemal-cache-integration-other")
+    store = Kemal::Cache::RedisStore.new(redis_url, namespace)
+    client = Redis::Client.new(URI.parse(redis_url))
+
+    begin
+      store.clear
+      client.del("#{other_namespace}:keep")
+
+      store.set("greeting", "hello", 50.milliseconds)
+      store.get("greeting").should eq("hello")
+
+      store.delete("greeting")
+      store.get("greeting").should be_nil
+
+      store.set("one", "1", 50.milliseconds)
+      store.set("two", "2", 50.milliseconds)
+      client.set("#{other_namespace}:keep", "3", ex: 50.milliseconds)
+      store.clear
+
+      store.get("one").should be_nil
+      store.get("two").should be_nil
+      client.get("#{other_namespace}:keep").should eq("3")
+
+      store.set("short", "ttl", 5.milliseconds)
+      sleep 10.milliseconds
+      store.get("short").should be_nil
+    ensure
+      store.clear
+      client.del("#{other_namespace}:keep")
+    end
+  end
+end

spec/spec_helper.cr

@@ -115,3 +115,11 @@ def mount_cache(config : Kemal::Cache::Config = Kemal::Cache::Config.new, &)
   yield
   Kemal.config.setup
 end
+
+def real_redis_url : String?
+  ENV["REDIS_URL"]?
+end
+
+def unique_redis_namespace(prefix : String = "kemal-cache-spec") : String
+  "#{prefix}-#{Random.rand(1_000_000)}-#{Time.utc.to_unix_ms}"
+end