Use docker compose for integration tests, add comprehensive test suite (#105)

- Add docker-compose.yml with Centrifugo v6 config (delta, recovery, smallhistory namespaces)
- Update CI to use docker compose instead of inline docker run
- Add integration tests: recovery, delta compression, presence, history, token auth, RPC, multiple subscriptions
- Expose SubscriptionState on abstract Subscription class (was only on SubscriptionImpl)
- Add http dev dependency for server API calls in tests
- Add "Run tests locally" section to README

Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>

Author: FZambia

.github/workflows/ci.yaml

@@ -25,7 +25,7 @@ jobs:
           - sdk: beta
             protobuf: "5.0.0"
           - sdk: beta
-            protobuf: "6.0.0"            
+            protobuf: "6.0.0"
     steps:
       - uses: actions/checkout@v4
 
@@ -39,11 +39,11 @@ jobs:
       - name: Override protobuf version
         run: dart pub add protobuf:${{ matrix.protobuf }}
 
-      - name: Install coveralls
-        run: sudo gem install coveralls-lcov 
-
       - name: Start Centrifugo
-        run: docker run -d -p 8000:8000 -e CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_DELTA_PUBLISH=true -e CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_ALLOWED_DELTA_TYPES="fossil" -e CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_HISTORY_SIZE="100" -e CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_HISTORY_TTL="300s" -e CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_FORCE_RECOVERY="true" centrifugo/centrifugo:v6 centrifugo --client.insecure
+        run: docker compose up -d --wait
+
+      - name: Run analyzer
+        run: dart analyze lib/
 
       - name: Run tests
-        run: bash tool/test.sh
+        run: dart run test --reporter expanded

README.md

@@ -24,6 +24,20 @@ When a mobile application goes to the background there are OS-specific limitatio
 
 See also [PlugFox/spinify](https://github.com/PlugFox/spinify) for an alternative Dart (Flutter) real-time client SDK implementation.
 
+## Run tests locally
+
+Start test Centrifugo server:
+
+```
+docker compose up
+```
+
+Then run tests:
+
+```
+dart run test --reporter expanded
+```
+
 ## Instructions for maintainers/contributors
 
 ### How to update protobuf definitions

docker-compose.yml

@@ -0,0 +1,42 @@
+services:
+  centrifugo:
+    image: centrifugo/centrifugo:v6
+    command:
+      - centrifugo
+    ports:
+      - "8000:8000"
+    environment:
+      - CENTRIFUGO_CLIENT_INSECURE=true
+      - CENTRIFUGO_CLIENT_CONCURRENCY=8
+      - CENTRIFUGO_CLIENT_TOKEN_HMAC_SECRET_KEY=secret
+      - CENTRIFUGO_LOG_LEVEL=trace
+      - CENTRIFUGO_HTTP_API_KEY=test-api-key
+      # Default channel (without namespace).
+      - CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_PRESENCE=true
+      - CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_ALLOWED_DELTA_TYPES=fossil
+      - CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_DELTA_PUBLISH=true
+      - CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_HISTORY_SIZE=100
+      - CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_HISTORY_TTL=300s
+      - CENTRIFUGO_CHANNEL_WITHOUT_NAMESPACE_FORCE_RECOVERY=true
+      # Define namespace names (space-separated).
+      - CENTRIFUGO_CHANNEL_NAMESPACES=delta recovery smallhistory
+      # delta: stream subscription with fossil delta compression + recovery.
+      - CENTRIFUGO_CHANNEL_NAMESPACES_DELTA_ALLOWED_DELTA_TYPES=fossil
+      - CENTRIFUGO_CHANNEL_NAMESPACES_DELTA_DELTA_PUBLISH=true
+      - CENTRIFUGO_CHANNEL_NAMESPACES_DELTA_FORCE_RECOVERY=true
+      - CENTRIFUGO_CHANNEL_NAMESPACES_DELTA_HISTORY_SIZE=100
+      - CENTRIFUGO_CHANNEL_NAMESPACES_DELTA_HISTORY_TTL=300s
+      - CENTRIFUGO_CHANNEL_NAMESPACES_DELTA_ALLOW_SUBSCRIBE_FOR_CLIENT=true
+      - CENTRIFUGO_CHANNEL_NAMESPACES_DELTA_ALLOW_PUBLISH_FOR_SUBSCRIBER=true
+      # recovery: stream subscription with recovery.
+      - CENTRIFUGO_CHANNEL_NAMESPACES_RECOVERY_FORCE_RECOVERY=true
+      - CENTRIFUGO_CHANNEL_NAMESPACES_RECOVERY_HISTORY_SIZE=100
+      - CENTRIFUGO_CHANNEL_NAMESPACES_RECOVERY_HISTORY_TTL=300s
+      - CENTRIFUGO_CHANNEL_NAMESPACES_RECOVERY_ALLOW_SUBSCRIBE_FOR_CLIENT=true
+      - CENTRIFUGO_CHANNEL_NAMESPACES_RECOVERY_ALLOW_PUBLISH_FOR_SUBSCRIBER=true
+      # smallhistory: stream with tiny history for unrecoverable position testing.
+      - CENTRIFUGO_CHANNEL_NAMESPACES_SMALLHISTORY_FORCE_RECOVERY=true
+      - CENTRIFUGO_CHANNEL_NAMESPACES_SMALLHISTORY_HISTORY_SIZE=2
+      - CENTRIFUGO_CHANNEL_NAMESPACES_SMALLHISTORY_HISTORY_TTL=300s
+      - CENTRIFUGO_CHANNEL_NAMESPACES_SMALLHISTORY_ALLOW_SUBSCRIBE_FOR_CLIENT=true
+      - CENTRIFUGO_CHANNEL_NAMESPACES_SMALLHISTORY_ALLOW_PUBLISH_FOR_SUBSCRIBER=true

lib/src/subscription.dart

@@ -17,6 +17,8 @@ enum SubscriptionState { unsubscribed, subscribing, subscribed }
 abstract class Subscription {
   String get channel;
 
+  SubscriptionState get state;
+
   Stream<SubscribingEvent> get subscribing;
   Stream<SubscribedEvent> get subscribed;
   Stream<UnsubscribedEvent> get unsubscribed;
@@ -68,6 +70,7 @@ class SubscriptionImpl implements Subscription {
     }
   }
 
+  @override
   var state = SubscriptionState.unsubscribed;
 
   @override

pubspec.yaml

@@ -18,5 +18,6 @@ dependencies:
 
 dev_dependencies:
   build_runner: ^2.0.3
+  http: ^1.1.0
   mockito: ^5.0.7
   test: ^1.17.4