MyMetricProvider.php 9.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290
  1. <?php
  2. namespace ThurData\Servers\KerioEmail\App\Libs\Metrics;
  3. use WHMCS\UsageBilling\Contracts\Metrics\MetricInterface;
  4. use WHMCS\UsageBilling\Contracts\Metrics\ProviderInterface;
  5. use WHMCS\UsageBilling\Metrics\Metric;
  6. use WHMCS\UsageBilling\Metrics\Usage;
  7. use WHMCS\UsageBilling\Metrics\Units\GigaBytes;
  8. use ThurData\Servers\KerioEmail\Api\KerioWhmcs;
  9. class MyMetricProvider implements ProviderInterface
  10. {
  11. private $moduleParams = [];
  12. public function __construct($moduleParams)
  13. {
  14. $this->moduleParams = $moduleParams;
  15. }
  16. public function metrics()
  17. {
  18. return [
  19. new Metric(
  20. 'mailboxes',
  21. 'Email Accounts',
  22. MetricInterface::TYPE_SNAPSHOT
  23. ),
  24. new Metric(
  25. 'aliases',
  26. 'Email Aliases',
  27. MetricInterface::TYPE_SNAPSHOT
  28. ),
  29. new Metric(
  30. 'distributionLists',
  31. 'Distribution Lists',
  32. MetricInterface::TYPE_SNAPSHOT
  33. ),
  34. new Metric(
  35. 'domainAliases',
  36. 'Domain Aliases',
  37. MetricInterface::TYPE_SNAPSHOT
  38. ),
  39. new Metric(
  40. 'storage',
  41. 'Storage',
  42. MetricInterface::TYPE_SNAPSHOT,
  43. new GigaBytes()
  44. )
  45. ];
  46. }
  47. public function usage()
  48. {
  49. $api = new KerioWhmcs('whmcsKerioEmail', 'Thurdata', '1.0');
  50. try {
  51. $api->login($this->moduleParams['serverhostname'], $this->moduleParams['serverusername'], $this->moduleParams['serverpassword']);
  52. $domains = $api->getDomains(['id','name','aliasList']);
  53. } catch (KerioApiException $error) {
  54. logModuleCall(
  55. 'kerioEmail',
  56. __FUNCTION__,
  57. $error,
  58. 'Debug Error',
  59. $error->getMessage()
  60. );
  61. return ['error' => $error->getMessage()];
  62. }
  63. $usage = [];
  64. foreach ($domains as $domain)
  65. {
  66. $domainName = $domain['name'];
  67. $domainID = $domain['id'];
  68. $countOfDomainAliases = count($domain['aliasList']);
  69. try
  70. {
  71. $fields = array(
  72. 'loginName',
  73. 'fullName',
  74. 'consumedSize'
  75. );
  76. $mailboxes = $api->getUsers($fields,$domainID);
  77. $countOfMailboxes = count($mailboxes);
  78. $totalUsage = 0;
  79. if ($countOfMailboxes > 0) {
  80. foreach ($mailboxes as $mailboxe) {
  81. switch($mailboxe['consumedSize']['units']) {
  82. case 'Bytes' :
  83. $usage = $mailboxe['consumedSize']['value']/1024/1024;
  84. break;
  85. case 'KiloBytes' :
  86. $usage = $mailboxe['consumedSize']['value']/1024;
  87. break;
  88. case 'MegaBytes' :
  89. $usage = $mailboxe['consumedSize']['value'];
  90. break;
  91. case 'GigaBytes' :
  92. $usage = $mailboxe['consumedSize']['value']*1024;
  93. break;
  94. }
  95. $totalUsage += $usage;
  96. }
  97. }
  98. $storage = $totalUsage == 0 ? 0 : round($totalUsage);
  99. } catch (KerioApiException $error) {
  100. logModuleCall(
  101. 'kerioEmail',
  102. __FUNCTION__,
  103. $error,
  104. 'Debug Error',
  105. $error->getMessage()
  106. );
  107. return ['error' => $error->getMessage()];
  108. }
  109. try
  110. {
  111. $fields = array(
  112. "id",
  113. "name");
  114. $mailingLists = $api->getMailingLists($fields,$domainID);
  115. $countOfDistributionList = count($mailingLists);
  116. } catch (KerioApiException $error) {
  117. logModuleCall(
  118. 'kerioEmail',
  119. __FUNCTION__,
  120. $error,
  121. 'Debug Error',
  122. $error->getMessage()
  123. );
  124. return ['error' => $error->getMessage()];
  125. }
  126. try
  127. {
  128. $fields = array(
  129. "id",
  130. "name");
  131. $aliases = $api->getAliases($fields,$domainID);
  132. $countOfEmailAliases = count($aliases);
  133. } catch (KerioApiException $error) {
  134. logModuleCall(
  135. 'kerioEmail',
  136. __FUNCTION__,
  137. $error,
  138. 'Debug Error',
  139. $error->getMessage()
  140. );
  141. return ['error' => $error->getMessage()];
  142. }
  143. $domainData = [
  144. 'mailboxes' => $countOfMailboxes,
  145. 'distributionLists' => $countOfDistributionList,
  146. 'aliases' => $countOfEmailAliases,
  147. 'domainAliases' => $countOfDomainAliases,
  148. 'storage' => $storage,
  149. ];
  150. $usage[$domainName] = $this->wrapUserData($domainData);
  151. }
  152. $api->logout();
  153. return $usage;
  154. }
  155. public function tenantUsage($tenant)
  156. {
  157. $api = new KerioWhmcs('whmcsKerioEmail', 'Thurdata', '1.0');
  158. try {
  159. $api->login($this->moduleParams['serverhostname'], $this->moduleParams['serverusername'], $this->moduleParams['serverpassword']);
  160. $domainID = $api->getDomainId($tenant);
  161. } catch (KerioApiException $error) {
  162. logModuleCall(
  163. 'kerioEmail',
  164. __FUNCTION__,
  165. $error,
  166. 'Debug Error',
  167. $error->getMessage()
  168. );
  169. return ['error' => $error->getMessage()];
  170. }
  171. $usage = [];
  172. $countOfDomainAliases = count($domain['aliasList']);
  173. try
  174. {
  175. $fields = array(
  176. 'loginName',
  177. 'fullName',
  178. 'consumedSize'
  179. );
  180. $mailboxes = $api->getUsers($fields,$domainID);
  181. $countOfMailboxes = count($mailboxes);
  182. $totalUsage = 0;
  183. if ($countOfMailboxes > 0) {
  184. foreach ($mailboxes as $mailboxe) {
  185. switch($mailboxe['consumedSize']['units']) {
  186. case 'Bytes' :
  187. $usage = $mailboxe['consumedSize']['value']/1024/1024;
  188. break;
  189. case 'KiloBytes' :
  190. $usage = $mailboxe['consumedSize']['value']/1024;
  191. break;
  192. case 'MegaBytes' :
  193. $usage = $mailboxe['consumedSize']['value'];
  194. break;
  195. case 'GigaBytes' :
  196. $usage = $mailboxe['consumedSize']['value']*1024;
  197. break;
  198. }
  199. $totalUsage += $usage;
  200. }
  201. }
  202. $storage = $totalUsage == 0 ? 0 : round($totalUsage);
  203. } catch (KerioApiException $error) {
  204. logModuleCall(
  205. 'kerioEmail',
  206. __FUNCTION__,
  207. $error,
  208. 'Debug Error',
  209. $error->getMessage()
  210. );
  211. return ['error' => $error->getMessage()];
  212. }
  213. try
  214. {
  215. $fields = array(
  216. "id",
  217. "name");
  218. $mailingLists = $api->getMailingLists($fields,$domainID);
  219. $countOfDistributionList = count($mailingLists);
  220. } catch (KerioApiException $error) {
  221. logModuleCall(
  222. 'kerioEmail',
  223. __FUNCTION__,
  224. $error,
  225. 'Debug Error',
  226. $error->getMessage()
  227. );
  228. return ['error' => $error->getMessage()];
  229. }
  230. try
  231. {
  232. $fields = array(
  233. "id",
  234. "name");
  235. $aliases = $api->getAliases($fields,$domainID);
  236. $countOfEmailAliases = count($aliases);
  237. } catch (KerioApiException $error) {
  238. logModuleCall(
  239. 'kerioEmail',
  240. __FUNCTION__,
  241. $error,
  242. 'Debug Error',
  243. $error->getMessage()
  244. );
  245. return ['error' => $error->getMessage()];
  246. }
  247. $domainData = [
  248. 'mailboxes' => $countOfMailboxes,
  249. 'distributionLists' => $countOfDistributionList,
  250. 'aliases' => $countOfEmailAliases,
  251. 'domainAliases' => $countOfDomainAliases,
  252. 'storage' => $storage,
  253. ];
  254. $usage = $this->wrapUserData($domainData);
  255. $api->logout();
  256. return $usage;
  257. }
  258. private function wrapUserData($data)
  259. {
  260. $wrapped = [];
  261. foreach ($this->metrics() as $metric) {
  262. $key = $metric->systemName();
  263. if ($data[$key]) {
  264. $value = $data[$key];
  265. $metric = $metric->withUsage(
  266. new Usage($value)
  267. );
  268. }
  269. $wrapped[] = $metric;
  270. }
  271. return $wrapped;
  272. }
  273. }