src/Lms/UserInterface/WebApp/Controller/QuizWebhookController.php line 77

Open in your IDE?
  1. <?php
  3. namespace CodersLab\Lms\UserInterface\WebApp\Controller;
  5. use CodersLab\Lms\Modules\Learning\Application\Command\AddMaterialResultAsync;
  6. use CodersLab\Lms\Modules\Materials\Application\Query\QuizQuery;
  7. use CodersLab\Lms\Modules\Materials\Application\Service\SurveyMonkeyProxy\ProxyClient;
  8. use CodersLab\Lms\Modules\Materials\Domain\Materials;
  9. use CodersLab\Lms\Modules\Materials\Domain\Quiz\State;
  10. use CodersLab\Lms\Modules\Materials\Domain\Quizzes;
  11. use CodersLab\Lms\SharedKernel\Common\Assert;
  12. use CodersLab\Lms\SharedKernel\Common\Exception\InvalidArgumentException;
  13. use CodersLab\Lms\SharedKernel\Domain\Bus\CommandBus;
  14. use CodersLab\Lms\SharedKernel\Domain\Bus\IEventRecorder;
  15. use CodersLab\Lms\SharedKernel\Domain\Identity\Uuid;
  16. use Exception;
  17. use Symfony\Component\HttpFoundation\Request;
  18. use Symfony\Component\HttpFoundation\Response;
  19. use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
  20. use Symfony\Component\Routing\Annotation\Route;
  22. final class QuizWebhookController
  23. {
  24.     public function __construct(
  25.         private Quizzes $quizzes,
  26.         private CommandBus $commandBus,
  27.         private IEventRecorder $eventRecorder,
  28.         private ProxyClient $proxyClient,
  29.         private Materials $materials,
  30.         private QuizQuery $quizQuery
  31.     ) {
  32.     }
  34.     /**
  35.      * @Route("/webhooks/quiz/update/{quizProviderId}", name="webhook_quiz_update", methods={"GET", "POST"})
  36.      */
  37.     public function quizUpdate(Request $request): Response
  38.     {
  39.         if ($request->getMethod() === Request::METHOD_HEAD) {
  40.             return new Response();
  41.         }
  43.         $content = json_decode((string)$request->getContent(), true);
  45.         try {
  46.             Assert::isArray($content);
  47.             Assert::keyExists($content, 'object_type');
  48.             Assert::keyExists($content, 'event_type');
  49.             Assert::keyExists($content, 'object_id');
  50.             Assert::keyExists($content, 'resources');
  51.             Assert::eq($content['object_type'], 'survey');
  52.             Assert::eq($content['event_type'], 'survey_updated');
  53.             Assert::notEmpty($content['object_id']);
  54.             Assert::string($content['object_id']);
  55.             Assert::isArray($content['resources']);
  56.             Assert::keyExists($content['resources'], 'survey_id');
  57.             Assert::string($content['resources']['survey_id']);
  59.             $quiz = $this->quizzes->findByProviderId($content['resources']['survey_id']);
  60.             Assert::notNull($quiz);
  61.         } catch (InvalidArgumentException $exception) {
  62.             throw new BadRequestHttpException($exception->getMessage(), $exception);
  63.         }
  65.         if ($quiz->state()->hasDetails()) {
  66.             $quiz->subtractState(State::DETAILS());
  67.         }
  69.         $this->eventRecorder->record(...$quiz->getEventRecorder()->pullEvents());
  71.         return new Response();
  72.     }
  74.     /**
  75.      * @Route("/webhooks/quiz/result/{quizProviderId}", name="webhook_quiz_response", methods={"GET", "POST"})
  76.      */
  77.     public function quizResponse(Request $request): Response
  78.     {
  79.         if ($request->getMethod() === Request::METHOD_HEAD) {
  80.             return new Response();
  81.         }
  83.         $content = json_decode((string)$request->getContent(), true);
  84.         if ($content === null) {
  85.             throw new Exception((string)$request->getContent());
  86.         }
  88.         try {
  89.             Assert::isArray($content);
  90.             Assert::keyExists($content, 'object_type');
  91.             Assert::keyExists($content, 'event_type');
  92.             Assert::keyExists($content, 'object_id');
  93.             Assert::keyExists($content, 'resources');
  94.             Assert::eq($content['object_type'], 'response');
  95.             Assert::eq($content['event_type'], 'response_completed');
  96.             Assert::notEmpty($content['object_id']);
  97.             Assert::string($content['object_id']);
  98.             Assert::isArray($content['resources']);
  99.             Assert::keyExists($content['resources'], 'survey_id');
  100.             Assert::string($content['resources']['survey_id']);
  102.             $quiz = $this->quizzes->findByProviderId($content['resources']['survey_id']);
  103.             Assert::notNull($quiz);
  104.         } catch (InvalidArgumentException $exception) {
  105.             throw new BadRequestHttpException($exception->getMessage(), $exception);
  106.         }
  108.         $response = $this->proxyClient->getResponse(
  109.             $content['resources']['survey_id'],
  110.             $content['object_id']
  111.         );
  113.         $materials = $this->materials->findByQuizAndCourse($quiz->id(), new Uuid($response->getCourseId()));
  114.         foreach ($materials as $material) {
  115.             $command = new AddMaterialResultAsync(
  116.                 $response->getCourseId(),
  117.                 $response->getCourseInstanceId(),
  118.                 $response->getStudentId(),
  119.                 $this->quizQuery->getMaterialCriterionIdForQuiz($material->getUuid()),
  120.                 $response->getStudentId(),
  121.                 'student',
  122.                 $response->getScore()
  123.             );
  124.             $this->commandBus->dispatch($command);
  125.         }
  127.         return new Response();
  128.     }
  129. }