<?php namespace services\model;
/**
 * Copyright 2017 OpenStack Foundation
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * http://www.apache.org/licenses/LICENSE-2.0
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 **/
use Illuminate\Http\UploadedFile;
use libs\utils\ITransactionService;
use models\exceptions\EntityNotFoundException;
use models\exceptions\ValidationException;
use models\main\File;
use models\main\IEmailCreationRequestRepository;
use models\main\IFolderRepository;
use models\main\IMemberRepository;
use models\main\MemberPromoCodeEmailCreationRequest;
use models\main\SpeakerCreationEmailCreationRequest;
use models\summit\ISpeakerRegistrationRequestRepository;
use models\summit\ISpeakerRepository;
use models\summit\ISpeakerSummitRegistrationPromoCodeRepository;
use models\summit\PresentationSpeaker;
use models\summit\PresentationSpeakerSummitAssistanceConfirmationRequest;
use models\summit\SpeakerRegistrationRequest;
use models\summit\SpeakerSummitRegistrationPromoCode;
use models\summit\Summit;
use App\Http\Utils\FileUploader;
/**
 * Class SpeakerService
 * @package services\model
 */
final class SpeakerService implements ISpeakerService
{
    /**
     * @var ISpeakerRepository
     */
    private $speaker_repository;

    /**
     * @var IMemberRepository
     */
    private $member_repository;

    /**
     * @var IFolderRepository
     */
    private $folder_repository;

    /**
     * @var ISpeakerRegistrationRequestRepository
     */
    private $speaker_registration_request_repository;

    /**
     * @var ISpeakerSummitRegistrationPromoCodeRepository
     */
    private $registration_code_repository;

    /**
     * @var IEmailCreationRequestRepository
     */
    private $email_creation_request_repository;
    /**
     * @var ITransactionService
     */
    private $tx_service;


    /**
     * SpeakerService constructor.
     * @param ISpeakerRepository $speaker_repository
     * @param IMemberRepository $member_repository
     * @param ISpeakerRegistrationRequestRepository $speaker_registration_request_repository
     * @param ISpeakerSummitRegistrationPromoCodeRepository $registration_code_repository
     * @param IEmailCreationRequestRepository $email_creation_request_repository
     * @param IFolderRepository $folder_repository
     * @param ITransactionService $tx_service
     */
    public function __construct
    (
        ISpeakerRepository $speaker_repository,
        IMemberRepository $member_repository,
        ISpeakerRegistrationRequestRepository $speaker_registration_request_repository,
        ISpeakerSummitRegistrationPromoCodeRepository $registration_code_repository,
        IEmailCreationRequestRepository $email_creation_request_repository,
        IFolderRepository $folder_repository,
        ITransactionService $tx_service
    )
    {
        $this->speaker_repository                      = $speaker_repository;
        $this->member_repository                       = $member_repository;
        $this->folder_repository                       = $folder_repository;
        $this->speaker_registration_request_repository = $speaker_registration_request_repository;
        $this->registration_code_repository            = $registration_code_repository;
        $this->email_creation_request_repository       = $email_creation_request_repository;
        $this->tx_service                              = $tx_service;
    }

    /**
     * @param Summit $summit
     * @param array $data
     * @throws ValidationException
     * @return PresentationSpeaker
     */
    public function addSpeaker(Summit $summit, array $data){

        return $this->tx_service->transaction(function() use($data, $summit){

            $speaker = new PresentationSpeaker();
            $speaker->setCreatedFromApi(true);
            $member_id = 0;

            if(!isset($data['email']) && !isset($data['member_id']))
                throw
                new ValidationException
                ("you must provide an email or a member_id in order to create a speaker!");

            if(isset($data['member_id']) && intval($data['member_id']) > 0){
                $member_id = intval($data['member_id']);
                $member    =  $this->member_repository->getById($member_id);
                if(is_null($member))
                    throw new EntityNotFoundException(sprintf("member id %s does not exists!", $member_id));

                $existent_speaker = $this->speaker_repository->getByMember($member);
                if(!is_null($existent_speaker))
                    throw new ValidationException
                    (
                        sprintf
                        (
                            "member_id %s already has assigned an speaker!",
                            $member_id
                        )
                    );


                $speaker->setMember($member);
            }

            $this->updateSpeakerMainData($speaker, $data);

            if($member_id === 0 && isset($data['email'])){
                $email  = trim($data['email']);
                $member = $this->member_repository->getByEmail($email);
                if(is_null($member)){
                    $this->registerSpeaker($speaker, $email);
                }
                else
                {
                    $existent_speaker = $this->speaker_repository->getByMember($member);
                    if(!is_null($existent_speaker))
                        throw new ValidationException
                        (
                            sprintf
                            (
                                "member id %s already has assigned a speaker id %s!",
                                $member->getIdentifier(),
                                $existent_speaker->getIdentifier()
                            )
                        );
                   $speaker->setMember($member);
                }
            }

            $speaker->addSummitAssistance(
                $this->updateSummitAssistance($speaker->buildAssistanceFor($summit), $data)
            );

            $reg_code = isset($data['registration_code']) ? trim($data['registration_code']) : null;
            if(!empty($reg_code)){
                $this->registerSummitPromoCodeByValue($speaker, $summit, $reg_code);
            }
            $this->speaker_repository->add($speaker);

            $email_request = new SpeakerCreationEmailCreationRequest();
            $email_request->setSpeaker($speaker);
            $this->email_creation_request_repository->add($email_request);

            return $speaker;
        });
    }

    /**
     * @param PresentationSpeakerSummitAssistanceConfirmationRequest $summit_assistance
     * @param array $data
     * @return PresentationSpeakerSummitAssistanceConfirmationRequest
     */
    private function updateSummitAssistance(PresentationSpeakerSummitAssistanceConfirmationRequest $summit_assistance, array $data){
        $on_site_phone = isset($data['on_site_phone']) ? trim($data['on_site_phone']) : null;
        $registered    = isset($data['registered']) ? 1 : 0;
        $checked_in    = isset($data['checked_in']) ? 1 : 0;
        $confirmed     = isset($data['confirmed'])  ? 1 : 0;

        $summit_assistance->setOnSitePhone($on_site_phone);
        $summit_assistance->setRegistered($registered);
        $summit_assistance->setIsConfirmed($confirmed);
        $summit_assistance->setCheckedIn($checked_in);

        return $summit_assistance;
    }

    /**
     * @param PresentationSpeaker $speaker
     * @param string $email
     * @return SpeakerRegistrationRequest
     * @throws ValidationException
     */
    private function registerSpeaker(PresentationSpeaker $speaker, $email){

        if($this->speaker_registration_request_repository->existByEmail($email))
            throw new ValidationException(sprintf("email %s already has a Speaker Registration Request", $email));

        $registration_request = new SpeakerRegistrationRequest();
        $registration_request->setEmail($email);

        do {
            $registration_request->generateConfirmationToken();
        }while($this->speaker_registration_request_repository->existByHash($registration_request->getConfirmationHash()));

        $speaker->setRegistrationRequest($registration_request);
        return $registration_request;
    }

    /**
     * @param PresentationSpeaker $speaker
     * @param Summit $summit
     * @param string $reg_code
     * @return SpeakerSummitRegistrationPromoCode
     * @throws ValidationException
     */
    public function registerSummitPromoCodeByValue(PresentationSpeaker $speaker, Summit $summit, $reg_code){

        return $this->tx_service->transaction(function() use($speaker, $summit, $reg_code) {
            // check if our speaker already has an assigned code for this summit ...
            $existent_code = $this->registration_code_repository->getBySpeakerAndSummit($speaker, $summit);

            // we are trying to update the promo code with another one ....
            if (!is_null($existent_code) && $reg_code !== $existent_code->getCode() && $existent_code->isRedeemed()) {
                throw new ValidationException(sprintf(
                    'speaker has been already assigned to another registration code (%s) already redeemed!', $existent_code->getCode()
                ));
            }

            if(!is_null($existent_code) && $reg_code == $existent_code->getCode()) return $existent_code;

            // check if reg code is assigned already to another speaker ...
            if ($assigned_code = $this->registration_code_repository->getAssignedCode($reg_code, $summit)) {

                if($assigned_code->getSpeaker()->getId() != $speaker->getId())
                    throw new ValidationException(sprintf(
                        'there is another speaker with that code for this summit ( speaker id %s )', $assigned_code->getSpeaker()->getId()
                    ));
            }
            // check is not assigned already
            $new_code = $this->registration_code_repository->getNotAssignedCode($reg_code, $summit);

            if (is_null($new_code)) {
                // create it
                $new_code = new SpeakerSummitRegistrationPromoCode();
                $new_code->setSummit($summit);
                $new_code->setCode($reg_code);
                $new_code->setSourceAdmin();
                // create email request
                $email_request = new MemberPromoCodeEmailCreationRequest();
                $email_request->setPromoCode($new_code);
                $email_request->setEmail($speaker->getEmail());
                $email_request->setName($speaker->getFullName());
                $this->email_creation_request_repository->add($email_request);
            }

            $speaker->addPromoCode($new_code);
            if(!is_null($existent_code)){
                $speaker->removePromoCode($existent_code);
            }
            return $new_code;
        });
    }

    /**
     * @param PresentationSpeaker $speaker
     * @param array $data
     */
    private function updateSpeakerMainData(PresentationSpeaker $speaker, array $data){
        if(isset($data['title']))
            $speaker->setTitle(trim($data['title']));

        if(isset($data['bio']))
            $speaker->setBio(trim($data['bio']));

        if(isset($data['first_name']))
            $speaker->setFirstName(trim($data['first_name']));

        if(isset($data['last_name']))
            $speaker->setLastName(trim($data['last_name']));

        if(isset($data['irc']))
            $speaker->setIrcHandle(trim($data['irc']));

        if(isset($data['twitter']))
            $speaker->setTwitterName(trim($data['twitter']));

    }

    /**
     * @param Summit $summit
     * @param array $data
     * @param PresentationSpeaker $speaker
     * @return PresentationSpeaker
     * @throws ValidationException
     * @throws EntityNotFoundException
     */
    public function updateSpeaker(Summit $summit, PresentationSpeaker $speaker, array $data)
    {
       return $this->tx_service->transaction(function() use ($summit, $speaker, $data){
           $member_id = isset($data['member_id']) ? intval($data['member_id']) : null;

           if($member_id > 0)
           {
               $member = $this->member_repository->getById($member_id);
               if(is_null($member))
                   throw new EntityNotFoundException;

               $existent_speaker = $this->speaker_repository->getByMember($member);
               if($existent_speaker && $existent_speaker->getId() !== $speaker->getId())
                   throw new ValidationException
                   (
                       sprintf
                       (
                           "member_id %s already has assigned another speaker id (%s)",
                           $member_id,
                           $existent_speaker->getId()
                       )
                   );

               $speaker->setMember($member);
           }

           $this->updateSpeakerMainData($speaker, $data);

           // get summit assistance
           $summit_assistance = $speaker->getAssistanceFor($summit);
           // if does not exists create it
           if(is_null($summit_assistance)){
               $summit_assistance = $speaker->buildAssistanceFor($summit);
               $speaker->addSummitAssistance($summit_assistance);
           }

           $this->updateSummitAssistance($summit_assistance, $data);

           $reg_code = isset($data['registration_code']) ? trim($data['registration_code']) : null;
           if(!empty($reg_code)){
               $this->registerSummitPromoCodeByValue($speaker, $summit, $reg_code);
           }
           return $speaker;
       });
    }

    /**
     * @param int $speaker_id
     * @param UploadedFile $file
     * @param int $max_file_size
     * @throws ValidationException
     * @throws EntityNotFoundException
     * @return File
     */
    public function addSpeakerPhoto($speaker_id, UploadedFile $file, $max_file_size = 10485760)
    {
        return $this->tx_service->transaction(function () use ($speaker_id, $file, $max_file_size) {

            $allowed_extensions = ['png','jpg','jpeg','gif','pdf'];

            $speaker = $this->speaker_repository->getById($speaker_id);

            if (is_null($speaker)) {
                throw new EntityNotFoundException('speaker not found!');
            }

            if(!in_array($file->extension(), $allowed_extensions)){
                throw new ValidationException("file does not has a valid extension ('png','jpg','jpeg','gif','pdf').");
            }

            if($file->getSize() > $max_file_size)
            {
                throw new ValidationException(sprintf( "file exceeds max_file_size (%s MB).", ($max_file_size/1024)/1024));
            }

            $uploader = new FileUploader($this->folder_repository);
            $photo    = $uploader->build($file, 'profile-images', true);
            $speaker->setPhoto($photo);

            return $photo;
        });
    }

    /**
     * @param PresentationSpeaker $speaker_from
     * @param PresentationSpeaker $speaker_to
     * @param array $data
     * @return void
     */
    public function merge(PresentationSpeaker $speaker_from, PresentationSpeaker $speaker_to, array $data)
    {
        return $this->tx_service->transaction(function () use ($speaker_from, $speaker_to, $data) {
            // bio
            if (!isset($data['bio'])) throw new ValidationException("bio field is required");
            $speaker_id = intval($data['bio']);
            $speaker_to->setBio($speaker_id == $speaker_from->getId() ? $speaker_from->getBio() : $speaker_to->getBio());

            // first_name
            if (!isset($data['first_name'])) throw new ValidationException("first_name field is required");
            $speaker_id = intval($data['first_name']);
            $speaker_to->setFirstName($speaker_id == $speaker_from->getId() ? $speaker_from->getFirstName() : $speaker_to->getFirstName());

            // last_name
            if (!isset($data['last_name'])) throw new ValidationException("last_name field is required");
            $speaker_id = intval($data['last_name']);
            $speaker_to->setLastName($speaker_id == $speaker_from->getId() ? $speaker_from->getLastName() : $speaker_to->getLastName());

            // title
            if (!isset($data['title'])) throw new ValidationException("title field is required");
            $speaker_id = intval($data['title']);
            $speaker_to->setTitle($speaker_id == $speaker_from->getId() ? $speaker_from->getTitle() : $speaker_to->getTitle());

            // irc
            if (!isset($data['irc'])) throw new ValidationException("irc field is required");
            $speaker_id = intval($data['irc']);
            $speaker_to->setIrcHandle($speaker_id == $speaker_from->getId() ? $speaker_from->getIrcHandle() : $speaker_to->getIrcHandle());

            // twitter
            if (!isset($data['twitter'])) throw new ValidationException("twitter field is required");
            $speaker_id = intval($data['twitter']);
            $speaker_to->setTwitterName($speaker_id == $speaker_from->getId() ? $speaker_from->getTwitterName() : $speaker_to->getTwitterName());

            // pic
            try {
                if (!isset($data['pic'])) throw new ValidationException("pic field is required");
                $speaker_id = intval($data['pic']);
                $speaker_to->setPhoto($speaker_id == $speaker_from->getId() ? $speaker_from->getPhoto() : $speaker_to->getPhoto());
            }
            catch (\Exception $ex){

            }
            // registration_request
            try {
                if (!isset($data['registration_request'])) throw new ValidationException("registration_request field is required");
                $speaker_id = intval($data['registration_request']);
                $speaker_to->setRegistrationRequest($speaker_id == $speaker_from->getId() ? $speaker_from->getRegistrationRequest() : $speaker_to->getRegistrationRequest());
            }
            catch (\Exception $ex){

            }
            // member
            try {
                if (!isset($data['member'])) throw new ValidationException("member field is required");
                $speaker_id = intval($data['member']);
                $speaker_to->setMember($speaker_id == $speaker_from->getId() ? $speaker_from->getMember() : $speaker_to->getMember());
            }
            catch (\Exception $ex){

            }
            // presentations

            foreach ($speaker_from->getAllPresentations(false) as $presentation){
                $speaker_to->addPresentation($presentation);
            }

            foreach ($speaker_from->getAllModeratedPresentations(false) as $presentation){
                $speaker_to->addModeratedPresentation($presentation);
            }

            // languages

            foreach($speaker_from->getLanguages() as $language){
                $speaker_to->addLanguage($language);
            }

            // promo codes

            foreach($speaker_from->getPromoCodes() as $code){
                $speaker_to->addPromoCode($code);
            }

            // summit assistances

            foreach($speaker_from->getSummitAssistances() as $assistance){
                $speaker_to->addSummitAssistance($assistance);
            }

            // presentation links

            foreach($speaker_from->getOtherPresentationLinks() as $link){
                $speaker_to->addOtherPresentationLink($link);
            }

            // travel preferences

            foreach ($speaker_from->getTravelPreferences() as $travel_preference){
                $speaker_to->addTravelPreference($travel_preference);
            }

            // areas of expertise

            foreach ($speaker_from->getAreasOfExpertise() as $areas_of_expertise){
                $speaker_to->addAreaOfExpertise($areas_of_expertise);
            }

            // roles

            foreach ($speaker_from->getOrganizationalRoles() as $role){
                $speaker_to->addOrganizationalRole($role);
            }
            $speaker_from->clearOrganizationalRoles();

            // involvements

            foreach ($speaker_from->getActiveInvolvements() as $involvement){
                $speaker_to->addActiveInvolvement($involvement);
            }

            $speaker_from->clearActiveInvolvements();

            $this->speaker_repository->delete($speaker_from);
        });
    }
}