1
0
Fork 0
mirror of synced 2024-07-06 23:21:05 +12:00

fix usage task

This commit is contained in:
Damodar Lohani 2022-11-02 06:23:31 +00:00
parent c4daf33a72
commit 9cdce06d96

View file

@ -28,9 +28,8 @@ class Usage extends Task
->param('type', 'timeseries', new WhiteList(['timeseries', 'database'])) ->param('type', 'timeseries', new WhiteList(['timeseries', 'database']))
->inject('dbForConsole') ->inject('dbForConsole')
->inject('influxdb') ->inject('influxdb')
->inject('register')
->inject('logError') ->inject('logError')
->callback(fn ($type, $dbForConsole, $influxDB, $register, $logError) => $this->action($type, $dbForConsole, $influxDB, $register, $logError)); ->callback(fn ($type, $dbForConsole, $influxDB, $logError) => $this->action($type, $dbForConsole, $influxDB, $logError));
} }
@ -71,12 +70,12 @@ class Usage extends Task
}, $interval); }, $interval);
} }
public function action(string $type, UtopiaDatabase $dbForConsole, InfluxDatabase $influxDB, Registry $register, callable $logError) public function action(string $type, UtopiaDatabase $dbForConsole, InfluxDatabase $influxDB, callable $logError)
{ {
Console::title('Usage Aggregation V1'); Console::title('Usage Aggregation V1');
Console::success(APP_NAME . ' usage aggregation process v1 has started'); Console::success(APP_NAME . ' usage aggregation process v1 has started');
$errorLogger = fn(Throwable $error, string $action = 'syncUsageStats') => $logError($register, $error, "usage", $action); $errorLogger = fn(Throwable $error, string $action = 'syncUsageStats') => $logError($error, "usage", $action);
switch ($type) { switch ($type) {
case 'timeseries': case 'timeseries':