vendor/gos/web-socket-bundle/src/DataCollector/WebsocketDataCollector.php line 7

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Gos\Bundle\WebSocketBundle\DataCollector;
  5. use Symfony\Component\Stopwatch\StopwatchEvent;
  7. trigger_deprecation('gos/web-socket-bundle', '3.1', 'The "%s" class is deprecated and will be removed in 4.0.', WebsocketDataCollector::class);
  9. /**
  10. * @deprecated to be removed in 4.0
  11. */
  12. final class WebsocketDataCollector extends WebsocketCompatibilityDataCollector
  13. {
  14. private array $rawData = [];
  16. public function lateCollect(): void
  17. {
  18. $pusherCount = [];
  19. $totalPush = 0;
  20. $pusherDuration = [];
  21. $durationTotal = 0.0;
  23. foreach ($this->rawData as $pusherName => $durations) {
  24. if (!isset($pusherCount[$pusherName])) {
  25. $pusherCount[$pusherName] = 0;
  26. }
  28. $pusherDurationTotal = array_sum($durations);
  29. $pusherCount[$pusherName] += $count = \count($durations);
  30. $totalPush += $count;
  31. $pusherDuration[$pusherName] = $pusherDurationTotal;
  32. $durationTotal += $pusherDurationTotal;
  33. }
  35. $this->data = [
  36. 'pusher_counts' => $pusherCount,
  37. 'push_total' => $totalPush,
  38. 'durations' => $pusherDuration,
  39. 'duration_total' => $durationTotal,
  40. ];
  41. }
  43. /**
  44. * @return int[]
  45. */
  46. public function getPusherCounts(): array
  47. {
  48. return $this->data['pusher_counts'];
  49. }
  51. public function getTotalDuration(): float
  52. {
  53. return $this->data['duration_total'];
  54. }
  56. /**
  57. * @return float[]
  58. */
  59. public function getDurations(): array
  60. {
  61. return $this->data['durations'];
  62. }
  64. public function getPushTotal(): int
  65. {
  66. return $this->data['push_total'];
  67. }
  69. public function collectData(StopwatchEvent $event, string $pusherName): void
  70. {
  71. if (!isset($this->rawData[$pusherName])) {
  72. $this->rawData[$pusherName] = [];
  73. }
  75. $this->rawData[$pusherName][] = $event->getDuration();
  76. }
  78. public function reset(): void
  79. {
  80. $this->rawData = [];
  82. $this->data = [
  83. 'pusher_counts' => [],
  84. 'push_total' => 0,
  85. 'durations' => [],
  86. 'duration_total' => 0,
  87. ];
  88. }
  90. public function getName(): string
  91. {
  92. return 'websocket';
  93. }
  94. }