src/AdminBundle/Services/WebhookService.php line 21

Open in your IDE?
  1. <?php
  3. namespace AdminBundle\Services;
  5. use AdminBundle\Entity\Booking;
  6. use Psr\Log\LoggerInterface;
  7. use Psr\Log\NullLogger;
  9. /**
  10. * Webhook Service - Trimite evenimente booking către Zendesk Bridge
  11. *
  12. * INSTALARE: Copy-paste acest fișier în src/AdminBundle/Services/
  13. */
  14. class WebhookService
  15. {
  16. private $webhookUrl;
  17. private $webhookSecret;
  18. private $logger;
  19. private $enabled;
  21. public function __construct(
  22. string $webhookUrl,
  23. string $webhookSecret,
  24. bool $enabled = true,
  25. LoggerInterface $logger = null
  26. ) {
  27. $this->webhookUrl = $webhookUrl;
  28. $this->webhookSecret = $webhookSecret;
  29. $this->enabled = $enabled;
  30. $this->logger = $logger ?: new NullLogger();
  31. }
  33. /**
  34. * Trimite webhook pentru un eveniment booking
  35. */
  36. public function send(Booking $booking, string $event): bool
  37. {
  38. if (!$this->enabled) {
  39. return true;
  40. }
  42. $payload = $this->buildPayload($booking, $event);
  43. $jsonPayload = json_encode($payload);
  44. $signature = $this->generateSignature($jsonPayload);
  46. try {
  47. $ch = curl_init($this->webhookUrl);
  48. curl_setopt_array($ch, [
  49. CURLOPT_POST => true,
  50. CURLOPT_POSTFIELDS => $jsonPayload,
  51. CURLOPT_HTTPHEADER => [
  52. 'Content-Type: application/json',
  53. 'X-Webhook-Signature: ' . $signature,
  54. ],
  55. CURLOPT_RETURNTRANSFER => true,
  56. CURLOPT_TIMEOUT => 10,
  57. CURLOPT_CONNECTTIMEOUT => 5,
  58. ]);
  60. $response = curl_exec($ch);
  61. $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  62. $error = curl_error($ch);
  63. curl_close($ch);
  65. if ($httpCode === 200) {
  66. $this->logger->info('Webhook sent', [
  67. 'booking' => $booking->getKey(),
  68. 'event' => $event,
  69. ]);
  70. return true;
  71. }
  73. $this->logger->error('Webhook failed', [
  74. 'booking' => $booking->getKey(),
  75. 'event' => $event,
  76. 'httpCode' => $httpCode,
  77. 'error' => $error,
  78. 'response' => $response,
  79. ]);
  80. return false;
  82. } catch (\Exception $e) {
  83. $this->logger->error('Webhook exception', [
  84. 'booking' => $booking->getKey(),
  85. 'event' => $event,
  86. 'exception' => $e->getMessage(),
  87. ]);
  88. return false;
  89. }
  90. }
  92. /**
  93. * Construiește payload-ul webhook cu toate datele necesare
  94. */
  95. private function buildPayload(Booking $booking, string $event): array
  96. {
  97. $payload = [
  98. 'key' => $booking->getKey(),
  99. 'event' => $event,
  100. 'data' => [
  101. 'booking' => [
  102. 'client_name' => trim($booking->getClientFirstName() . ' ' . $booking->getClientLastName()),
  103. 'client_email' => $booking->getClientEmail(),
  104. 'client_phone' => $booking->getClientPhone(),
  105. 'pickup_address' => $booking->getPickUpAddress(),
  106. 'pickup_datetime' => $booking->getPickUpDateTime()
  107. ? $booking->getPickUpDateTime()->format('c')
  108. : null,
  109. 'destination' => $booking->getDestinationAddress(),
  110. 'flight_number' => $booking->getFlightNumber(),
  111. 'notes' => $booking->getNotes(),
  112. 'price' => $booking->getOverridePrice(),
  113. 'payment_type' => $this->getPaymentTypeName($booking->getPaymentType()),
  114. ],
  115. ],
  116. ];
  118. // Adaugă date șofer dacă e alocat
  119. $driver = $booking->getDriver();
  120. if ($driver) {
  121. $payload['data']['driver'] = [
  122. 'id' => $driver->getId(),
  123. 'name' => $driver->getInternalName() ?: $driver->getFullName(),
  124. 'phone' => $driver->getPhone() ?: $driver->getMobilePhone(),
  125. ];
  127. $car = $driver->getCar();
  128. if ($car) {
  129. $payload['data']['driver']['vehicle'] = trim($car->getMaker() . ' ' . $car->getModel());
  130. $payload['data']['driver']['registration'] = $car->getPlateNumber();
  131. }
  132. }
  134. return $payload;
  135. }
  137. /**
  138. * Generează semnătura HMAC-SHA256
  139. */
  140. private function generateSignature(string $payload): string
  141. {
  142. $timestamp = time();
  143. $signedPayload = $timestamp . '.' . $payload;
  144. $signature = hash_hmac('sha256', $signedPayload, $this->webhookSecret);
  146. return "t={$timestamp},v1={$signature}";
  147. }
  149. /**
  150. * Convertește tipul de plată în nume
  151. */
  152. private function getPaymentTypeName(?int $type): string
  153. {
  154. $types = [
  155. 1 => 'Cash',
  156. 2 => 'Card',
  157. 3 => 'Account',
  158. 4 => 'Invoice',
  159. ];
  161. return $types[$type] ?? 'Unknown';
  162. }
  164. // =========================================
  165. // METODE HELPER - APELEAZĂ DIN EVENT LISTENER
  166. // =========================================
  168. public function onDispatched(Booking $booking): bool
  169. {
  170. return $this->send($booking, 'dispatched');
  171. }
  173. public function onAccepted(Booking $booking): bool
  174. {
  175. return $this->send($booking, 'accepted');
  176. }
  178. public function onEnroute(Booking $booking): bool
  179. {
  180. return $this->send($booking, 'enroute');
  181. }
  183. public function onArrived(Booking $booking): bool
  184. {
  185. return $this->send($booking, 'arrived');
  186. }
  188. public function onStarted(Booking $booking): bool
  189. {
  190. return $this->send($booking, 'started');
  191. }
  193. public function onCompleted(Booking $booking): bool
  194. {
  195. return $this->send($booking, 'completed');
  196. }
  198. public function onCancelled(Booking $booking): bool
  199. {
  200. return $this->send($booking, 'cancelled');
  201. }
  203. public function onNoShow(Booking $booking): bool
  204. {
  205. return $this->send($booking, 'no_show');
  206. }
  207. }