vendor/uvdesk/mailbox-component/Controller/MailboxChannelXHR.php line 131

Open in your IDE?
  1. <?php
  3. namespace Webkul\UVDesk\MailboxBundle\Controller;
  5. use Symfony\Component\HttpFoundation\Request;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\HttpFoundation\JsonResponse;
  8. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  9. use Webkul\UVDesk\MailboxBundle\Utils\MailboxConfiguration;
  10. use Webkul\UVDesk\MailboxBundle\Services\MailboxService;
  11. use Symfony\Contracts\Translation\TranslatorInterface;
  12. use Symfony\Component\HttpKernel\KernelInterface;
  14. class MailboxChannelXHR extends AbstractController
  15. {
  16.     public function loadMailboxesXHR(Request $request, MailboxService $mailboxService)
  17.     {
  18.         $mailboxConfiguration = $mailboxService->parseMailboxConfigurations();
  20.         $defaultMailbox = $mailboxConfiguration->getDefaultMailbox();
  22.         $collection = array_map(function ($mailbox) use ($defaultMailbox) {
  23.             return [
  24.                 'id' => $mailbox->getId(),
  25.                 'name' => $mailbox->getName(),
  26.                 'isEnabled' => $mailbox->getIsEnabled(),
  27.                 'isDefault' => !empty($defaultMailbox) && $defaultMailbox->getId() == $mailbox->getId(),
  28.                 'isEmailDeliveryDisabled' => $mailbox->getIsEmailDeliveryDisabled() ? $mailbox->getIsEmailDeliveryDisabled() : false,
  29.             ];
  30.         }, array_values($mailboxConfiguration->getMailboxes()));
  32.         return new JsonResponse($collection ?? []);
  33.     }
  35.     public function removeMailboxConfiguration($id, Request $request, MailboxService $mailboxService, TranslatorInterface $translator)
  36.     {
  37.         $mailbox = null;
  38.         $mailboxConfiguration = $mailboxService->parseMailboxConfigurations();
  40.         foreach ($mailboxConfiguration->getMailboxes() as $configuredMailbox) {
  41.             if ($configuredMailbox->getId() == $id) {
  42.                 $mailbox = $configuredMailbox;
  44.                 break;
  45.             }
  46.         }
  48.         if (empty($mailbox)) {
  49.             return new JsonResponse([
  50.                 'alertClass' => 'danger',
  51.                 'alertMessage' => "No mailbox configuration was found for id '$id'.",
  52.             ], 404);
  53.         }
  55.         $updatedMailboxConfiguration = new MailboxConfiguration();
  57.         foreach ($mailboxConfiguration->getMailboxes() as $configuredMailbox) {
  58.             if ($configuredMailbox->getId() == $id) {
  59.                 continue;
  60.             }
  62.             $updatedMailboxConfiguration->addMailbox($configuredMailbox);
  63.         }
  65.         file_put_contents($mailboxService->getPathToConfigurationFile(), (string) $updatedMailboxConfiguration);
  67.         return new JsonResponse([
  68.             'alertClass' => 'success',
  69.             'alertMessage' => $translator->trans('Mailbox configuration removed successfully.'),
  70.         ]);
  71.     }
  73.     public function processMailXHR(Request $request, MailboxService $mailboxService)
  74.     {
  75.         if ("POST" != $request->getMethod()) {
  76.             return new JsonResponse([
  77.                 'success' => false, 
  78.                 'message' => 'Request not supported.'
  79.             ], 500);
  80.         } else if (null == $request->get('email')) {
  81.             return new JsonResponse([
  82.                 'success' => false, 
  83.                 'message' => 'Missing required email data in request content.'
  84.             ], 500);
  85.         }
  87.         try {
  88.             $processedThread = $mailboxService->processMail($request->get('email'));
  89.         } catch (\Exception $e) {
  90.             return new JsonResponse([
  91.                 'success' => false, 
  92.                 'message' => $e->getMessage()
  93.             ], 500);
  94.         }
  96.         $responseMessage = $processedThread['message'];
  98.         if (!empty($processedThread['content']['from'])) {
  99.             $responseMessage = "Received email from <info>" . $processedThread['content']['from']. "</info>. " . $responseMessage;
  100.         }
  102.         if (!empty($processedThread['content']['ticket']) && !empty($processedThread['content']['thread'])) {
  103.             $responseMessage .= " <comment>[tickets/" . $processedThread['content']['ticket'] . "/#" . $processedThread['content']['ticket'] . "]</comment>";
  104.         } else if (!empty($processedThread['content']['ticket'])) {
  105.             $responseMessage .= " <comment>[tickets/" . $processedThread['content']['ticket'] . "]</comment>";
  106.         }
  108.         return new JsonResponse([
  109.             'success' => true, 
  110.             'message' => $responseMessage, 
  111.         ]);
  112.     }
  114.     public function processOutlookMailXHR(Request $request, MailboxService $mailboxService)
  115.     {
  116.         $email = $request->get('email') ?? $request->toArray()['email'];
  117.         
  118.         if ("POST" != $request->getMethod()) {
  119.             return new JsonResponse([
  120.                 'success' => false, 
  121.                 'message' => 'Request not supported.'
  122.             ], 500);
  123.         } else if (null == $email) {
  124.             return new JsonResponse([
  125.                 'success' => false, 
  126.                 'message' => 'Missing required email data in request content.'
  127.             ], 500);
  128.         }
  129.         
  130.         try {
  131.             $processedThread = $mailboxService->processOutlookMail($email);
  132.         } catch (\Exception $e) {
  133.             return new JsonResponse([
  134.                 'success' => false, 
  135.                 'message' => $e->getMessage(), 
  136.                 'params' => $email
  137.             ], 500);
  138.         }
  140.         $responseMessage = $processedThread['message'];
  142.         if (!empty($processedThread['content']['from'])) {
  143.             $responseMessage = "Received email from <info>" . $processedThread['content']['from']. "</info>. " . $responseMessage;
  144.         }
  146.         if (!empty($processedThread['content']['ticket']) && !empty($processedThread['content']['thread'])) {
  147.             $responseMessage .= " <comment>[tickets/" . $processedThread['content']['ticket'] . "/#" . $processedThread['content']['ticket'] . "]</comment>";
  148.         } else if (!empty($processedThread['content']['ticket'])) {
  149.             $responseMessage .= " <comment>[tickets/" . $processedThread['content']['ticket'] . "]</comment>";
  150.         }
  152.         return new JsonResponse([
  153.             'success' => true, 
  154.             'message' => $responseMessage, 
  155.         ]);
  156.     }
  157. }