added mixpanel analytics

stefanak-michal · stefanak-michal · commit a146ab686f9b · 2024-07-13T12:22:00.000+02:00
diff --git a/README.md b/README.md
@@ -255,6 +255,12 @@ environments for security reasons._
 
 Server state is not reported by server but it is evaluated by received response. You can access current state through property `$protocol->serverState`. This property is updated with every call `getResponse(s)`.
 
+## :bar_chart: Analytics
+
+Bolt does collect anonymous analytics data. These data are stored offline (as files in temp directory) and submitted once a day. You can opt out with environment variable `BOLT_ANALYTICS_OPTOUT`.
+
+Analytics data are public and available at [Mixpanel](https://eu.mixpanel.com/p/7ttVKqvjdqJtGCjLCFgdeC).
+
 ## :pushpin: More solutions
 
 If you need simple class to cover basic functionality you can
diff --git a/composer.json b/composer.json
@@ -10,6 +10,7 @@
     "require": {
         "php": "^8.1",
         "ext-mbstring": "*",
+        "ext-curl": "*",
         "psr/simple-cache": "^3.0"
     },
     "require-dev": {
diff --git a/src/Bolt.php b/src/Bolt.php
@@ -26,9 +26,56 @@ final class Bolt
 
     public function __construct(private IConnection $connection)
     {
+        if (!file_exists(getcwd() . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR)) {
+            mkdir(getcwd() . DIRECTORY_SEPARATOR . 'temp');
+        }
+        if (!getenv('BOLT_ANALYTICS_OPTOUT')) {
+            $this->track();
+        }
         $this->setProtocolVersions(5.4, 5, 4.4);
     }
 
+    private function track(): void
+    {
+        foreach (glob(getcwd() . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . 'queries.*.cnt') as $file) {
+            $time = intval(explode('.', basename($file))[1]);
+            if ($time < strtotime('today')) {
+                $count = file_get_contents($file);
+                unlink($file);
+
+                $curl = curl_init();
+                curl_setopt_array($curl, [
+                    CURLOPT_URL => 'https://api-eu.mixpanel.com/import?strict=0&project_id=3355308',
+                    CURLOPT_RETURNTRANSFER => true,
+                    CURLOPT_ENCODING => '',
+                    CURLOPT_MAXREDIRS => 10,
+                    CURLOPT_TIMEOUT => $this->connection->getTimeout(),
+                    CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
+                    CURLOPT_CUSTOMREQUEST => 'POST',
+                    CURLOPT_SSL_VERIFYPEER => false,
+                    CURLOPT_POSTFIELDS => json_encode([
+                        [
+                            'properties' => [
+                                '$insert_id' => $file,
+                                'distinct_id' => sha1(implode('', [php_uname(), disk_total_space('.'), filectime('/'), phpversion()])),
+                                'amount' => $count,
+                                'time' => $time
+                            ],
+                            'event' => 'queries'
+                        ]
+                    ]),
+                    CURLOPT_HTTPHEADER => [
+                        'Content-Type: application/json',
+                        'accept: application/json',
+                        'authorization: Basic MDJhYjRiOWE2YTM4MThmNWFlZDEzYjNiMmE5M2MxNzQ6',
+                    ],
+                ]);
+                curl_exec($curl);
+                curl_close($curl);
+            }
+        }
+    }
+
     /**
      * Connect via Connection, execute handshake on it, create and return protocol version class
      * @throws BoltException
diff --git a/src/helpers/FileCache.php b/src/helpers/FileCache.php
@@ -13,17 +13,22 @@
  */
 class FileCache implements CacheInterface
 {
+    private string $tempDir;
+
     public function __construct()
     {
-        if (!file_exists(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR))
-            mkdir(__DIR__ . DIRECTORY_SEPARATOR . 'temp');
+        $this->tempDir = getcwd() . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR;
+
+        if (!file_exists($this->tempDir)) {
+            mkdir(rtrim($this->tempDir, DIRECTORY_SEPARATOR));
+        }
 
         // clean old
-        foreach (scandir(__DIR__ . DIRECTORY_SEPARATOR . 'temp') as $file) {
+        foreach (scandir($this->tempDir . 'temp') as $file) {
             if ($file == '.' || $file == '..')
                 continue;
-            if (filemtime(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $file) < strtotime('-1 hour'))
-                unlink(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $file);
+            if (filemtime($this->tempDir . $file) < strtotime('-1 hour'))
+                unlink($this->tempDir . $file);
         }
     }
 
@@ -37,7 +42,7 @@ public function __construct()
      */
     public function get(string $key, mixed $default = null): mixed
     {
-        return $this->has($key) ? file_get_contents(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $key) : $default;
+        return $this->has($key) ? file_get_contents($this->tempDir . $key) : $default;
     }
 
     /**
@@ -53,7 +58,7 @@ public function get(string $key, mixed $default = null): mixed
      */
     public function set(string $key, mixed $value, \DateInterval|int|null $ttl = null): bool
     {
-        return is_int(file_put_contents(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $key, $value));
+        return is_int(file_put_contents($this->tempDir . $key, $value));
     }
 
     /**
@@ -65,18 +70,18 @@ public function set(string $key, mixed $value, \DateInterval|int|null $ttl = nul
      */
     public function delete(string $key): bool
     {
-        return $this->has($key) && unlink(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $key);
+        return $this->has($key) && unlink($this->tempDir . $key);
     }
 
     /**
      * @inheritDoc
      */
     public function clear(): bool
     {
-        foreach (scandir(__DIR__ . DIRECTORY_SEPARATOR . 'temp') as $file) {
+        foreach (scandir(rtrim($this->tempDir, DIRECTORY_SEPARATOR)) as $file) {
             if ($file == '.' || $file == '..')
                 continue;
-            unlink(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $file);
+            unlink($this->tempDir . $file);
         }
         return true;
     }
@@ -143,6 +148,6 @@ public function deleteMultiple(iterable $keys): bool
      */
     public function has(string $key): bool
     {
-        return file_exists(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $key);
+        return file_exists($this->tempDir . $key);
     }
 }
diff --git a/src/protocol/AProtocol.php b/src/protocol/AProtocol.php
@@ -63,8 +63,19 @@ public function __construct(
      */
     protected function write(iterable $generator): void
     {
-        foreach ($generator as $buffer)
+        if (!getenv('BOLT_ANALYTICS_OPTOUT')) {
+            $this->track();
+        }
+        foreach ($generator as $buffer) {
             $this->connection->write($buffer);
+        }
+    }
+
+    private function track(): void
+    {
+        $file = getcwd() . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . 'queries.' . strtotime('today') . '.cnt';
+        $count = file_exists($file) ? intval(file_get_contents($file)) : 0;
+        file_put_contents($file, $count + 1);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -13,17 +13,22 @@`
`13`	`13`	`*/`
`14`	`14`	`class FileCache implements CacheInterface`
`15`	`15`	`{`
	`16`	`+ private string $tempDir;`
	`17`	`+`
`16`	`18`	`public function __construct()`
`17`	`19`	`{`
`18`		`- if (!file_exists(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR))`
`19`		`- mkdir(__DIR__ . DIRECTORY_SEPARATOR . 'temp');`
	`20`	`+ $this->tempDir = getcwd() . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR;`
	`21`	`+`
	`22`	`+ if (!file_exists($this->tempDir)) {`
	`23`	`+ mkdir(rtrim($this->tempDir, DIRECTORY_SEPARATOR));`
	`24`	`+ }`
`20`	`25`
`21`	`26`	`// clean old`
`22`		`- foreach (scandir(__DIR__ . DIRECTORY_SEPARATOR . 'temp') as $file) {`
	`27`	`+ foreach (scandir($this->tempDir . 'temp') as $file) {`
`23`	`28`	`if ($file == '.' \|\| $file == '..')`
`24`	`29`	`continue;`
`25`		`- if (filemtime(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $file) < strtotime('-1 hour'))`
`26`		`- unlink(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $file);`
	`30`	`+ if (filemtime($this->tempDir . $file) < strtotime('-1 hour'))`
	`31`	`+ unlink($this->tempDir . $file);`
`27`	`32`	`}`
`28`	`33`	`}`
`29`	`34`
`@@ -37,7 +42,7 @@ public function __construct()`
`37`	`42`	`*/`
`38`	`43`	`public function get(string $key, mixed $default = null): mixed`
`39`	`44`	`{`
`40`		`- return $this->has($key) ? file_get_contents(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $key) : $default;`
	`45`	`+ return $this->has($key) ? file_get_contents($this->tempDir . $key) : $default;`
`41`	`46`	`}`
`42`	`47`
`43`	`48`	`/**`
`@@ -53,7 +58,7 @@ public function get(string $key, mixed $default = null): mixed`
`53`	`58`	`*/`
`54`	`59`	`public function set(string $key, mixed $value, \DateInterval\|int\|null $ttl = null): bool`
`55`	`60`	`{`
`56`		`- return is_int(file_put_contents(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $key, $value));`
	`61`	`+ return is_int(file_put_contents($this->tempDir . $key, $value));`
`57`	`62`	`}`
`58`	`63`
`59`	`64`	`/**`
`@@ -65,18 +70,18 @@ public function set(string $key, mixed $value, \DateInterval\|int\|null $ttl = nul`
`65`	`70`	`*/`
`66`	`71`	`public function delete(string $key): bool`
`67`	`72`	`{`
`68`		`- return $this->has($key) && unlink(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $key);`
	`73`	`+ return $this->has($key) && unlink($this->tempDir . $key);`
`69`	`74`	`}`
`70`	`75`
`71`	`76`	`/**`
`72`	`77`	`* @inheritDoc`
`73`	`78`	`*/`
`74`	`79`	`public function clear(): bool`
`75`	`80`	`{`
`76`		`- foreach (scandir(__DIR__ . DIRECTORY_SEPARATOR . 'temp') as $file) {`
	`81`	`+ foreach (scandir(rtrim($this->tempDir, DIRECTORY_SEPARATOR)) as $file) {`
`77`	`82`	`if ($file == '.' \|\| $file == '..')`
`78`	`83`	`continue;`
`79`		`- unlink(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $file);`
	`84`	`+ unlink($this->tempDir . $file);`
`80`	`85`	`}`
`81`	`86`	`return true;`
`82`	`87`	`}`
`@@ -143,6 +148,6 @@ public function deleteMultiple(iterable $keys): bool`
`143`	`148`	`*/`
`144`	`149`	`public function has(string $key): bool`
`145`	`150`	`{`
`146`		`- return file_exists(__DIR__ . DIRECTORY_SEPARATOR . 'temp' . DIRECTORY_SEPARATOR . $key);`
	`151`	`+ return file_exists($this->tempDir . $key);`
`147`	`152`	`}`
`148`	`153`	`}`