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

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.     private $mailboxService;
  17.     private $translator;
  18.     private $kernel;
  20.     public function __construct(KernelInterface $kernel, MailboxService $mailboxService, TranslatorInterface $translator)
  21.     {
  22.         $this->mailboxService = $mailboxService;
  23.         $this->translator = $translator;
  24.         $this->kernel = $kernel;
  25.     }
  27.     public function processRawContentMail(Request $request)
  28.     {
  29.         $rawEmail = file_get_contents($this->kernel->getProjectDir(). "/rawEmailContent.txt");
  31.         if ($rawEmail != false &&  !empty($rawEmail)) {
  32.            $this->mailboxService->processMail($rawEmail);
  33.         }else{
  34.             dump("Empty Text file not allow");
  35.         } 
  36.         exit(0);
  37.     }
  39.     public function processMailXHR(Request $request)
  40.     {
  41.         if ("POST" != $request->getMethod()) {
  42.             return new JsonResponse([
  43.                 'success' => false, 
  44.                 'message' => 'Request not supported.'
  45.             ], 500);
  46.         } else if (null == $request->get('email')) {
  47.             return new JsonResponse([
  48.                 'success' => false, 
  49.                 'message' => 'Missing required email data in request content.'
  50.             ], 500);
  51.         }
  53.         try {
  54.             $processedThread = $this->mailboxService->processMail($request->get('email'));
  55.         } catch (\Exception $e) {
  56.             return new JsonResponse([
  57.                 'success' => false, 
  58.                 'message' => $e->getMessage()
  59.             ], 500);
  60.         }
  62.         $responseMessage = $processedThread['message'];
  64.         if (!empty($processedThread['content']['from'])) {
  65.             $responseMessage = "Received email from <info>" . $processedThread['content']['from']. "</info>. " . $responseMessage;
  66.         }
  68.         if (!empty($processedThread['content']['ticket']) && !empty($processedThread['content']['thread'])) {
  69.             $responseMessage .= " <comment>[tickets/" . $processedThread['content']['ticket'] . "/#" . $processedThread['content']['thread'] . "]</comment>";
  70.         } else if (!empty($processedThread['content']['ticket'])) {
  71.             $responseMessage .= " <comment>[tickets/" . $processedThread['content']['ticket'] . "]</comment>";
  72.         }
  74.         return new JsonResponse([
  75.             'success' => true, 
  76.             'message' => $responseMessage, 
  77.         ]);
  78.     }
  79.     
  80.     public function loadMailboxesXHR(Request $request)
  81.     {
  82.         $collection = array_map(function ($mailbox) {
  83.             return [
  84.                 'id' => $mailbox->getId(),
  85.                 'name' => $mailbox->getName(),
  86.                 'isEnabled' => $mailbox->getIsEnabled(),
  87.                 'isDeleted' => $mailbox->getIsDeleted() ? $mailbox->getIsDeleted() : false,
  88.             ];
  89.         }, $this->mailboxService->parseMailboxConfigurations()->getMailboxes());
  91.         return new JsonResponse($collection ?? []);
  92.     }
  94.     public function removeMailboxConfiguration($id, Request $request)
  95.     {
  96.         $mailboxService = $this->mailboxService;
  97.         $existingMailboxConfiguration = $mailboxService->parseMailboxConfigurations();
  99.         foreach ($existingMailboxConfiguration->getMailboxes() as $configuration) {
  100.             if ($configuration->getId() == $id) {
  101.                 $mailbox = $configuration;
  103.                 break;
  104.             }
  105.         }
  107.         if (empty($mailbox)) {
  108.             return new JsonResponse([
  109.                 'alertClass' => 'danger',
  110.                 'alertMessage' => "No mailbox found with id '$id'.",
  111.             ], 404);
  112.         }
  114.         $mailboxConfiguration = new MailboxConfiguration();
  116.         foreach ($existingMailboxConfiguration->getMailboxes() as $configuration) {
  117.             if ($configuration->getId() == $id) {
  118.                 continue;
  119.             }
  121.             $mailboxConfiguration->addMailbox($configuration);
  122.         }
  124.         file_put_contents($mailboxService->getPathToConfigurationFile(), (string) $mailboxConfiguration);
  126.         return new JsonResponse([
  127.             'alertClass' => 'success',
  128.             'alertMessage' => $this->translator->trans('Mailbox configuration removed successfully.'),
  129.         ]);
  130.     }
  131. }