Removed RedisCounter and added a native counter

composer.json

@@ -26,8 +26,7 @@
     "nikic/fast-route": "^1",
     "rdlowrey/auryn": "^1",
     "amphp/aerys": "^0.4.4",
-    "amphp/artax": "^2",
-    "amphp/redis": "^0.2.5"
+    "amphp/artax": "^2"
   },
   "require-dev": {
     "phpunit/phpunit": "^5",

server.php

@@ -5,7 +5,7 @@
 use Auryn\Injector;
 use ekinhbayar\GitAmp\Github\Credentials;
 use ekinhbayar\GitAmp\Storage\Counter;
-use ekinhbayar\GitAmp\Storage\RedisCounter;
+use ekinhbayar\GitAmp\Storage\NativeCounter;
 use ekinhbayar\GitAmp\Websocket\Handler;
 use Monolog\Logger;
 use Monolog\Handler\StreamHandler;
@@ -14,13 +14,11 @@
 use function Aerys\router;
 use function Aerys\websocket;
 
-//require_once __DIR__ . '/vendor/autoload.php';
-
 $configuration = require_once __DIR__ . '/config.php';
 
 $injector = new Injector;
 
-$injector->alias(Counter::class, RedisCounter::class);
+$injector->alias(Counter::class, NativeCounter::class);
 
 $injector->alias(Credentials::class, get_class($configuration['github']));
 

src/Storage/Counter.php

@@ -4,9 +4,13 @@
 
 use Amp\Promise;
 
-interface Counter {
-    public function increment(string $key): Promise;
-    public function decrement(string $key): Promise;
-    public function get(string $key): Promise;
-    public function set(string $key, int $val): Promise;
+interface Counter
+{
+    public function increment();
+
+    public function decrement();
+
+    public function get(): int;
+
+    public function set(int $val);
 }

src/Storage/NativeCounter.php

@@ -0,0 +1,28 @@
+<?php declare(strict_types = 1);
+
+namespace ekinhbayar\GitAmp\Storage;
+
+class NativeCounter implements Counter
+{
+    private $counter = 0;
+
+    public function increment()
+    {
+        $this->counter++;
+    }
+
+    public function decrement()
+    {
+        $this->counter--;
+    }
+
+    public function get(): int
+    {
+        return $this->counter;
+    }
+
+    public function set(int $val)
+    {
+        $this->counter = $val;
+    }
+}

src/Websocket/Handler.php

@@ -32,7 +32,7 @@ public function onStart(Endpoint $endpoint)
     {
         $this->endpoint = $endpoint;
 
-        $this->counter->set('connected_users', 0);
+        $this->counter->set(0);
 
         repeat(function() {
             $this->emit(yield $this->gitamp->listen());
@@ -55,9 +55,9 @@ public function onOpen(int $clientId, $handshakeData)
     {
         $this->emit(yield $this->gitamp->listen());
 
-        yield $this->counter->increment('connected_users');
+        $this->counter->increment();
 
-        $this->sendConnectedUsersCount(yield $this->counter->get('connected_users'));
+        $this->sendConnectedUsersCount($this->counter->get());
     }
 
     private function emit(Results $events)
@@ -81,9 +81,9 @@ public function onData(int $clientId, Websocket\Message $msg)
 
     public function onClose(int $clientId, int $code, string $reason)
     {
-        yield $this->counter->decrement('connected_users');
+        $this->counter->decrement();
 
-        $this->sendConnectedUsersCount(yield $this->counter->get('connected_users'));
+        $this->sendConnectedUsersCount($this->counter->get());
     }
 
     public function onStop()

tests/Storage/NativeCounterTest.php

@@ -0,0 +1,61 @@
+<?php declare(strict_types = 1);
+
+namespace ekinhbayar\GitAmpTests\Storage;
+
+use ekinhbayar\GitAmp\Storage\NativeCounter;
+use PHPUnit\Framework\TestCase;
+
+class NativeCounterTest extends TestCase
+{
+    public function testGet()
+    {
+        $nativeCounter = new NativeCounter();
+
+        $this->assertSame(0, $nativeCounter->get());
+    }
+
+    public function testSet()
+    {
+        $nativeCounter = new NativeCounter();
+
+        $nativeCounter->set(5);
+
+        $this->assertSame(5, $nativeCounter->get());
+    }
+
+    public function testIncrement()
+    {
+        $nativeCounter = new NativeCounter();
+
+        $nativeCounter->increment();
+
+        $this->assertSame(1, $nativeCounter->get());
+
+        $nativeCounter->increment();
+
+        $this->assertSame(2, $nativeCounter->get());
+
+        $nativeCounter->increment();
+
+        $this->assertSame(3, $nativeCounter->get());
+    }
+
+    public function testDecrement()
+    {
+        $nativeCounter = new NativeCounter();
+
+        $nativeCounter->set(5);
+
+        $nativeCounter->decrement();
+
+        $this->assertSame(4, $nativeCounter->get());
+
+        $nativeCounter->decrement();
+
+        $this->assertSame(3, $nativeCounter->get());
+
+        $nativeCounter->decrement();
+
+        $this->assertSame(2, $nativeCounter->get());
+    }
+}