Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-23 08:58:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

hamster additions

Browse source
This commit is contained in:
shimon 2024-01-17 21:53:12 +02:00
parent be3e3baca0
commit 40e17ad625
1 changed files with 34 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
src/Appwrite/Platform/Workers/Hamster.php
View file

@ -277,7 +277,7 @@ class Hamster extends Action
$limit = $periodValue['limit'];
$period = $periodValue['period'];
$requestDocs = $dbForProject->find('stats_v2', [
$requestDocs = $dbForProject->find('stats', [
Query::equal('period', [$period]),
Query::equal('metric', [$metric]),
Query::limit($limit),
@ -302,8 +302,8 @@ class Hamster extends Action
/**
* Workaround to combine network.inbound+network.outbound as network.
*/
$statsPerProject["usage_bandwidth_infinity"] = $statsPerProject["usage_inbound_infinity"] + $statsPerProject["usage_outbound_infinity"];
$statsPerProject["usage_bandwidth_24h"] = $statsPerProject["usage_inbound_24h"] + $statsPerProject["usage_outbound_24h"];
$statsPerProject["usage_network_infinity"] = $statsPerProject["usage_inbound_infinity"] + $statsPerProject["usage_outbound_infinity"];
$statsPerProject["usage_network_24h"] = $statsPerProject["usage_inbound_24h"] + $statsPerProject["usage_outbound_24h"];
unset($statsPerProject["usage_outbound_24h"]);
unset($statsPerProject["usage_inbound_24h"]);
unset($statsPerProject["usage_outbound_infinity"]);
@ -368,6 +368,19 @@ class Hamster extends Action
throw new \Exception('Membership not found. Skipping organization : ' . $organization->getId());
}
$billingPlan = $membership->getAttribute('billingPlan', null);
$billingPlanDowngrade = $membership->getAttribute('billingPlanDowngrade', null);
if (!empty($billingPlan) && empty($billingPlanDowngrade)) {
$statsPerOrganization['billing-plan'] = $billingPlan;
}
if (in_array($billingPlan, ['tier-1', 'tier-2'])) {
$billingStartDate = $membership->getAttribute('billingStartDate', null);
$statsPerOrganization['billing-start-plan-date'] = $billingStartDate;
}
$userId = $membership->getAttribute('userId', null);
if ($userId) {
$user = $dbForConsole->getDocument('users', $userId);
@ -410,6 +423,24 @@ class Hamster extends Action
try {
$statsPerUser = [];
$membership = $dbForConsole->findOne('teams', [
Query::equal('userInternalId', [$user->getInternalId()])
]);
if (!empty($membership) || !$membership->isEmpty()) {
$billingPlan = $membership->getAttribute('billingPlan', null);
$billingPlanDowngrade = $membership->getAttribute('billingPlanDowngrade', null);
if (!empty($billingPlan) && empty($billingPlanDowngrade)) {
$statsPerUser['billing-plan'] = $billingPlan;
}
if (in_array($billingPlan, ['tier-1', 'tier-2'])) {
$billingStartDate = $membership->getAttribute('billingStartDate', null);
$statsPerUser['billing-start-plan-date'] = $billingStartDate;
}
}
$statsPerUser['time'] = $user->getAttribute('$time');
/** Organization name */