<?php

namespace Webkul\UVDesk\ApiBundle\API;

use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\EventDispatcher\GenericEvent;
use Symfony\Component\Serializer\Serializer;
use Symfony\Component\Serializer\Encoder\XmlEncoder;
use Symfony\Component\Serializer\Encoder\JsonEncoder;
use Symfony\Component\Serializer\Normalizer\ObjectNormalizer;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Webkul\UVDesk\CoreFrameworkBundle\Entity\Ticket;
use Webkul\UVDesk\CoreFrameworkBundle\Entity\TicketStatus;
use Webkul\UVDesk\CoreFrameworkBundle\Entity\User;
use Webkul\UVDesk\CoreFrameworkBundle\Entity\Attachment;

use Webkul\UVDesk\CoreFrameworkBundle\Workflow\Events as CoreWorkflowEvents;

class Threads extends AbstractController
{
    /** Ticket Reply
     * @param Request $request
     */
    public function saveThread(Request $request, $ticketid, ContainerInterface $container)
    {
        $data = $request->request->all()? : json_decode($request->getContent(),true);
        $entityManager = $this->getDoctrine()->getManager();

        if (!isset($data['threadType']) || !isset($data['message'])) {
            $json['error'] = 'missing fields';
            $json['description'] = 'required: threadType: reply|forward|note , message';
            return new JsonResponse($json, Response::HTTP_BAD_REQUEST);
        }

        $ticket = $this->getDoctrine()->getRepository(Ticket::class)->findOneById($ticketid);

        // Check for empty ticket
        if (empty($ticket)) {
            $json['error'] = "Error! No such ticket with ticket id exist";
            return new JsonResponse($json, Response::HTTP_NOT_FOUND);
        } else if ('POST' != $request->getMethod()) {
            $json['error'] = "Error! invalid request method";
            return new JsonResponse($json, Response::HTTP_BAD_REQUEST);
        }

        // Check if message content is empty
        $parsedMessage = trim(strip_tags($data['message'], '<img>'));
        $parsedMessage = str_replace('&nbsp;', '', $parsedMessage);
        $parsedMessage = str_replace(' ', '', $parsedMessage);

        if (null == $parsedMessage) {
            $json['error'] = "Warning ! Reply content cannot be left blank.";
            return new JsonResponse($json, Response::HTTP_BAD_REQUEST);
        }

        if (array_key_exists('actAsType', $data) && isset($data['actAsEmail'])) {
            $actAsType = strtolower($data['actAsType']);
            $actAsEmail = $data['actAsEmail'];
            if ($actAsType == 'customer') {
                $user = $this->getDoctrine()->getRepository(User::class)->findOneByEmail($data['actAsEmail']);
            } else if($actAsType == 'agent' ) {
                $user = $this->getDoctrine()->getRepository(User::class)->findOneByEmail($data['actAsEmail']);
            } else {
                $json['error'] = 'Error! invalid actAs details.';
                $json['description'] = 'possible values actAsType: customer,agent. Also provide actAsEmail parameter with actAsType agent.';
                return new JsonResponse($json, Response::HTTP_BAD_REQUEST);
            }                                      
            if (!$user) {
                $json['error'] = 'Error! invalid actAs details.';
                return new JsonResponse($json, Response::HTTP_BAD_REQUEST);
            }
        } 

        if ($actAsType == 'agent') {
            $data['user'] = isset($user) && $user ? $user : $container->get('user.service')->getCurrentUser();
        } else {
            $data['user'] = $user;
        }

        $attachments = $request->files->get('attachments');
        if (!empty($attachments)) {
            $attachments = is_array($attachments) ? $attachments : [$attachments];
        }

        $threadDetails = [
            'user' => $data['user'],
            'createdBy' => $actAsType,
            'source' => 'api',
            'threadType' => strtolower($data['threadType']),
            'message' => str_replace(['&lt;script&gt;', '&lt;/script&gt;'], '', $data['message']),
            'attachments' => $attachments
        ];

        if (!empty($data['status'])){
            $ticketStatus =  $this->getDoctrine()->getRepository(TicketStatus::class)->findOneByCode($data['status']);
            $ticket->setStatus($ticketStatus);
        }
        if (isset($data['to'])) {
            $threadDetails['to'] = $data['to'];
        }

        if (isset($data['cc'])) {
            $threadDetails['cc'] = $data['cc'];
        }

        if (isset($data['cccol'])) {
            $threadDetails['cccol'] = $data['cccol'];
        }

        if (isset($data['bcc'])) {
            $threadDetails['bcc'] = $data['bcc'];
        }

        // Create Thread
        $thread = $container->get('ticket.service')->createThread($ticket, $threadDetails);

        // Check for thread types
        switch ($thread->getThreadType()) {
            case 'note':
                $event = new CoreWorkflowEvents\Ticket\Note();
                $event
                    ->setTicket($ticket)
                    ->setThread($thread)
                ;

                $container->get('event_dispatcher')->dispatch($event, 'uvdesk.automation.workflow.execute');

                $json['success'] = "success', Note added to ticket successfully.";
                return new JsonResponse($json, Response::HTTP_OK);
                break;
            case 'reply':
                $event = new CoreWorkflowEvents\Ticket\AgentReply();
                $event
                    ->setTicket($ticket)
                    ->setThread($thread)
                ;

                $container->get('event_dispatcher')->dispatch($event, 'uvdesk.automation.workflow.execute');

                $json['success'] = "success', Reply added to ticket successfully..";
                return new JsonResponse($json, Response::HTTP_OK);
                break;
            case 'forward':
                // Prepare headers
                $headers = ['References' => $ticket->getReferenceIds()];

                if (null != $ticket->currentThread->getMessageId()) {
                    $headers['In-Reply-To'] = $ticket->currentThread->getMessageId();
                }

                // Prepare attachments
                $attachments = $entityManager->getRepository(Attachment::class)->findByThread($thread);

                $projectDir = $container->get('kernel')->getProjectDir();
                $attachments = array_map(function($attachment) use ($projectDir) {
                return str_replace('//', '/', $projectDir . "/public" . $attachment->getPath());
                }, $attachments);

                // Forward thread to users
                try {
                    $messageId = $container->get('email.service')->sendMail($params['subject'] ?? ("Forward: " . $ticket->getSubject()), $thread->getMessage(), $thread->getReplyTo(), $headers, $ticket->getMailboxEmail(), $attachments ?? [], $thread->getCc() ?: [], $thread->getBcc() ?: []);
    
                    if (!empty($messageId)) {
                        $thread->setMessageId($messageId);
    
                        $entityManager->persist($createdThread);
                        $entityManager->flush();
                    }
                } catch (\Exception $e) {
                    // Do nothing ...
                    // @TODO: Log exception
                }

                $json['success'] = "success', Reply added to the ticket and forwarded successfully.";
                return new JsonResponse($json, Response::HTTP_OK);
                break;
            default:
                break;
        }
    }
}