wip usage tasks

app/cli.php

@@ -15,6 +15,7 @@ include 'tasks/migrate.php';
 include 'tasks/sdks.php';
 include 'tasks/ssl.php';
 include 'tasks/vars.php';
+include 'tasks/usage.php';
 
 $cli
     ->task('version')

app/tasks/usage.php

@@ -0,0 +1,74 @@
+<?php
+
+global $cli;
+
+require_once __DIR__ . '/../init.php';
+
+use Utopia\App;
+use Utopia\CLI\Console;
+
+$cli
+    ->task('usage')
+    ->desc('Schedules syncing data from influxdb to Appwrite console db')
+    ->action(function () use ($register, $dbForConsole) {
+        Console::title('Usage Sync V1');
+        Console::success(APP_NAME . ' usage sync process v1 has started');
+
+        $interval = (int) App::getEnv('_APP_USAGE_SYNC_INTERVAL', '10'); //10 seconds
+
+        // Console::loop(function () use ($interval, $register, $dbForConsole) {
+        $time = date('d-m-Y H:i:s', time());
+        Console::info("[{$time}] Syncing usage data from influxdb to Appwrite Console DB every {$interval} seconds");
+
+        $client = $register->get('influxdb');
+
+        $client = $register->get('influxdb');
+
+        $requests = [];
+        $network = [];
+        $functions = [];
+
+        if ($client) {
+            // $start30 = DateTime::createFromFormat('U', \strtotime('-30 minutes'))->format(DateTime::RFC3339);
+            $start = DateTime::createFromFormat('U', \strtotime('-30 days'))->format(DateTime::RFC3339);
+            $end = DateTime::createFromFormat('U', \strtotime('now'))->format(DateTime::RFC3339);
+            $database = $client->selectDB('telegraf');
+
+            // Requests
+            $result = $database->query('SELECT sum(value) AS "value" FROM "appwrite_usage_requests_all" WHERE time > \'' . $start . '\' AND time < \'' . $end . '\' AND "metric_type"=\'counter\' GROUP BY time(' . '1d' . ') FILL(null)');
+            $points = $result->getPoints();
+
+            foreach ($points as $point) {
+                $requests[] = [
+                    'value' => (!empty($point['value'])) ? $point['value'] : 0,
+                    'date' => \strtotime($point['time']),
+                ];
+            }
+
+            // Network
+            $result = $database->query('SELECT sum(value) AS "value" FROM "appwrite_usage_network_all" WHERE time > \'' . $start . '\' AND time < \'' . $end . '\' AND "metric_type"=\'counter\' GROUP BY time(' . '1d' . ') FILL(null)');
+            $points = $result->getPoints();
+
+            foreach ($points as $point) {
+                $network[] = [
+                    'value' => (!empty($point['value'])) ? $point['value'] : 0,
+                    'date' => \strtotime($point['time']),
+                ];
+            }
+
+            // Functions
+            $result = $database->query('SELECT sum(value) AS "value" FROM "appwrite_usage_executions_all" WHERE time > \'' . $start . '\' AND time < \'' . $end . '\' AND "metric_type"=\'counter\' GROUP BY time(' . '1d' . ') FILL(null)');
+            $points = $result->getPoints();
+
+            foreach ($points as $point) {
+                $functions[] = [
+                    'value' => (!empty($point['value'])) ? $point['value'] : 0,
+                    'date' => \strtotime($point['time']),
+                ];
+            }
+
+            var_dump($requests, $network, $functions);
+        }
+
+        // }, $interval);
+    });

bin/usage

@@ -0,0 +1,3 @@
+#!/bin/sh
+
+php /usr/src/code/app/cli.php usage $@