<?php

/*
 * This file is part of the Maestro Project.
 * Copyright (C) Compos Juliot
 */

namespace App\Application\Event\EventListener;

use App\Application\Message\UserLogMessage;
use App\Domain\Entity\UserProject;
use Symfony\Component\HttpKernel\Event\RequestEvent;
use Symfony\Component\Messenger\MessageBusInterface;
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpStamp;
use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;

class UserLogListener
{
    protected $tokenStorage;
    protected $messageBus;

    public function __construct(TokenStorageInterface $tokenStorage, MessageBusInterface $messageBus)
    {
        $this->tokenStorage = $tokenStorage;
        $this->messageBus = $messageBus;
    }

    public function onKernelRequest(RequestEvent $event)
    {
        $request = $event->getRequest();
        $method = $request->getMethod();

        if ('GET' != $method && $this->tokenStorage->getToken() != null) {
            $user = $this->tokenStorage->getToken()->getUser();

            if ($user instanceof UserProject) {
                $content = json_decode($request->getContent(), true);

                $message = new UserLogMessage(
                    $user->getUserId(),
                    $request->attributes->get('_controller'),
                    $method,
                    $request->getClientIp(),
                    $request->getPathInfo(),
                    $content ? $content : [],
                    $request->request->all()
                );

                $this->messageBus->dispatch(
                    $message,
                    [new AmqpStamp('execute_user_log_projects')]
                );
            }
        }
    }
}