ap2i/src/Service/Shop/ShopService.php

<?php

declare(strict_types=1);

namespace App\Service\Shop;

use App\ApiResources\Organization\OrganizationCreationRequest;
use App\ApiResources\Shop\NewStructureArtistPremiumTrialRequest;
use App\Entity\Organization\Organization;
use App\Entity\Organization\Subdomain;
use App\Entity\Shop\ShopRequest;
use App\Enum\Access\AccessIdsEnum;
use App\Enum\Organization\SettingsProductEnum;
use App\Enum\Shop\ShopRequestStatus;
use App\Enum\Shop\ShopRequestType;
use App\Message\Message\Shop\NewStructureArtistPremiumTrial;
use App\Service\Dolibarr\DolibarrApiService;
use App\Service\Dolibarr\DolibarrUtils;
use App\Service\Mailer\Mailer;
use App\Service\Mailer\Model\NewStructureArtistPremiumTrialRequestValidationModel;
use App\Service\Organization\OrganizationFactory;
use App\Service\Utils\DatesUtils;
use App\Service\Utils\UrlBuilder;
use Doctrine\DBAL\Exception;
use Doctrine\ORM\EntityManagerInterface;
use Doctrine\ORM\Exception\ORMException;
use Doctrine\ORM\OptimisticLockException;
use libphonenumber\PhoneNumberUtil;
use Psr\Log\LoggerInterface;
use Symfony\Component\Mailer\Exception\TransportExceptionInterface;
use Symfony\Component\Messenger\Exception\ExceptionInterface;
use Symfony\Component\Messenger\MessageBusInterface;
use Symfony\Component\Serializer\SerializerInterface;
use Symfony\Component\Uid\Uuid;

/**
 * Service for managing shop requests.
 *
 * This service handles various shop-related operations.
 * It provides functionality for:
 * - Registering new shop requests
 * - Validating and processing shop requests
 * - Creating organizations based on trial requests
 * - Starting premium trials for organizations
 * - Generating subdomains from structure names
 */
class ShopService
{
    protected PhoneNumberUtil $phoneNumberUtil;

    public function __construct(
        private EntityManagerInterface $entityManager,
        private Mailer $mailer,
        private string $publicBaseUrl,
        private OrganizationFactory $organizationFactory,
        private SerializerInterface $serializer,
        private LoggerInterface $logger,
        private MessageBusInterface $messageBus,
        private Trial $trial,
    ) {
        $this->phoneNumberUtil = PhoneNumberUtil::getInstance();
    }

    /**
     * A new shop request has been submitted.
     * Register the request, and send the validation link by email.
     *
     * @param array<string, mixed> $data
     *
     * @throws TransportExceptionInterface
     */
    public function registerNewShopRequest(ShopRequestType $type, array $data): ShopRequest
    {
        $this->controlShopRequestData($type, $data);
        $request = $this->createRequest($type, $data);
        $this->sendRequestValidationLink($request);

        return $request;
    }

    /**
     * Validate the shop request based on its type.
     * For NEW_STRUCTURE_ARTIST_PREMIUM_TRIAL, check if the organization already exists.
     * For other types, throw an error.
     *
     * @param array<string, mixed> $data
     */
    protected function controlShopRequestData(ShopRequestType $type, NewStructureArtistPremiumTrialRequest|array $data): void
    {
        // @phpstan-ignore-next-line identical.alwaysTrue
        if ($type === ShopRequestType::NEW_STRUCTURE_ARTIST_PREMIUM_TRIAL) {
            /** @var NewStructureArtistPremiumTrialRequest $request */
            $request = $data;
            $this->validateNewStructureArtistPremiumTrialRequest($request);
        } else {
            throw new \RuntimeException('request type not supported');
        }
    }

    /**
     * Validate the request and dispatch the appropriate job based on the request type.
     *
     * @throws \RuntimeException|ExceptionInterface
     */
    public function processShopRequest(ShopRequest $shopRequest): void
    {
        // Dispatch appropriate job based on request type
        switch ($shopRequest->getType()->value) {
            case ShopRequestType::NEW_STRUCTURE_ARTIST_PREMIUM_TRIAL->value:
                $this->messageBus->dispatch(
                    new NewStructureArtistPremiumTrial($shopRequest->getToken())
                );
                break;
            default:
                throw new \RuntimeException('request type not supported');
        }

        $shopRequest->setStatus(ShopRequestStatus::VALIDATED);
        $this->entityManager->persist($shopRequest);
        $this->entityManager->flush();
    }

    /**
     * Create and persist a new ShopRequest entity.
     *
     * @param array<string, mixed> $data
     */
    protected function createRequest(ShopRequestType $type, array $data): ShopRequest
    {
        $shopRequest = new ShopRequest();
        $shopRequest->setToken(Uuid::v4()->toRfc4122());
        $shopRequest->setType($type);
        $shopRequest->setData($data);

        $this->entityManager->persist($shopRequest);
        $this->entityManager->flush();

        return $shopRequest;
    }

    /**
     * Send validation email with link.
     *
     * @throws TransportExceptionInterface
     */
    protected function sendRequestValidationLink(ShopRequest $shopRequest): void
    {
        $validationUrl = UrlBuilder::concat(
            $this->publicBaseUrl,
            ['/api/public/shop/validate', $shopRequest->getToken()]
        );

        $data = $shopRequest->getData();

        $model = new NewStructureArtistPremiumTrialRequestValidationModel();
        $model
            ->setToken($shopRequest->getToken())
            ->setRepresentativeEmail($data['representativeEmail'] ?? '')
            ->setRepresentativeFirstName($data['representativeFirstName'] ?? '')
            ->setRepresentativeLastName($data['representativeLastName'] ?? '')
            ->setStructureName($data['structureName'] ?? '')
            ->setValidationUrl($validationUrl)
            ->setSenderId(AccessIdsEnum::ADMIN_2IOPENSERVICE->value);

        $this->mailer->main($model);

        $shopRequest->setStatus(ShopRequestStatus::ACTIVATION_LINK_SENT);
        $this->entityManager->persist($shopRequest);
        $this->entityManager->flush();
    }

    /**
     * Handles the processing of a new structure artist premium trial request.
     *
     * @param string $token The token identifying the shop request
     *
     * @throws Exception
     * @throws \JsonException
     * @throws ORMException
     * @throws OptimisticLockException
     */
    public function handleNewStructureArtistPremiumTrialRequest(string $token): void
    {
        // Retrieve the ShopRequest entity using its token
        $shopRequest = $this->entityManager->find(ShopRequest::class, $token);

        if (!$shopRequest) {
            $this->logger->error('Cannot find ShopRequest with token: '.$token);

            return;
        }

        // Convert the stored JSON data to a NewStructureArtistPremiumTrialRequest object
        $data = $shopRequest->getData();
        $trialRequest = $this->serializer->deserialize(
            json_encode($data),
            NewStructureArtistPremiumTrialRequest::class,
            'json'
        );

        $organization = $this->createOrganization($trialRequest);

        // Start the artist premium trial
        $this->trial->startArtistPremiumTrialForNewStructure($organization, $trialRequest);

        $this->logger->info('Successfully processed NewStructureArtistPremiumTrial for token: '.$token);
    }

    /**
     * Creates a new organization based on a trial request.
     *
     * @param NewStructureArtistPremiumTrialRequest $trialRequest The trial request containing organization data
     *
     * @return Organization The created organization
     */
    protected function createOrganization(NewStructureArtistPremiumTrialRequest $trialRequest): Organization
    {
        // Generate an OrganizationCreationRequest object
        $organizationCreationRequest = $this->createOrganizationCreationRequestFromTrialRequest($trialRequest);

        // Create the organization
        return $this->organizationFactory->create($organizationCreationRequest);
    }

    /**
     * Vérifie la validité d'une requête d'essai artist premium pour une nouvelle structure.
     */
    protected function validateNewStructureArtistPremiumTrialRequest(
        NewStructureArtistPremiumTrialRequest $request,
    ): void {
        // Validate phone number
        if (!$this->phoneNumberUtil->isPossibleNumber($request->getRepresentativePhone())) {
            throw new \RuntimeException('Invalid phone number');
        }

        // Check if organization already exists
        $organizationCreationRequest = $this->createOrganizationCreationRequestFromTrialRequest($request, true);
        $this->organizationFactory->interruptIfOrganizationExists($organizationCreationRequest);
    }

    /**
     * Creates an OrganizationCreationRequest from a NewStructureArtistPremiumTrialRequest.
     *
     * @param NewStructureArtistPremiumTrialRequest $trialRequest The trial request containing organization data
     *
     * @return OrganizationCreationRequest The created organization creation request
     * @throws \Exception
     */
    protected function createOrganizationCreationRequestFromTrialRequest(
        NewStructureArtistPremiumTrialRequest $trialRequest,
    ): OrganizationCreationRequest {
        $organizationCreationRequest = new OrganizationCreationRequest();
        $organizationCreationRequest->setName($trialRequest->getStructureName());
        $organizationCreationRequest->setStreetAddress1($trialRequest->getAddress());
        $organizationCreationRequest->setStreetAddress2($trialRequest->getAddressComplement());
        $organizationCreationRequest->setPostalCode($trialRequest->getPostalCode());
        $organizationCreationRequest->setCity($trialRequest->getCity());
        $organizationCreationRequest->setEmail($trialRequest->getStructureEmail());
        $organizationCreationRequest->setPrincipalType($trialRequest->getStructureType());
        $organizationCreationRequest->setLegalStatus($trialRequest->getLegalStatus());
        $organizationCreationRequest->setSiretNumber($trialRequest->getSiren());
        $organizationCreationRequest->setPhoneNumber($trialRequest->getRepresentativePhone());
        $organizationCreationRequest->setSubdomain($trialRequest->getStructureIdentifier());

        // Set default values
        $organizationCreationRequest->setProduct(SettingsProductEnum::FREEMIUM);
        $organizationCreationRequest->setCreateWebsite(false);
        $organizationCreationRequest->setClient(false);
        $organizationCreationRequest->setCreationDate(DatesUtils::new());

        return $organizationCreationRequest;
    }

}