src/Controller/DebugController.php line 65

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Service\Features;
  6. use Symfony\Bundle\FrameworkBundle\Console\Application;
  7. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  8. use Symfony\Component\Console\Input\ArrayInput;
  9. use Symfony\Component\Console\Output\BufferedOutput;
  10. use Symfony\Component\Console\Output\NullOutput;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\HttpKernel\Exception\UnauthorizedHttpException;
  13. use Symfony\Component\HttpKernel\KernelInterface;
  14. use Symfony\Component\Routing\Annotation\Route;
  16. class DebugController extends AbstractController
  17. {
  18.     private KernelInterface $kernel;
  19.     private Application $application;
  21.     public function __construct(KernelInterface $kernel)
  22.     {
  23.         $this->kernel = $kernel;
  25.         $this->application = new Application($this->kernel);
  26.         $this->application->setAutoExit(false);
  27.     }
  29.     #[Route(path: '/debug-features/', name: 'debug.task.debug_features')]
  30.     public function debugFeatures(Features $features): Response
  31.     {
  32.         $this->assertAvailable();
  34.         $features = [];
  35.         foreach ($_ENV as $k => $v) {
  36.             if(str_starts_with($k, 'FEATURE'))
  37.                 $features[$k] = $v;
  38.         }
  39.         ksort($features);
  41.         return $this->json($features);
  42.     }
  44.     #[Route(path: '/task-charge-placed/', name: 'debug.task.charge_placements')]
  45.     public function taskChargePlacements(): Response
  46.     {
  47.         return $this->getResponse($this->runCommand('sales:profile-saloon:adboard:charge'));
  48.     }
  50.     #[Route(path: '/task-charge-hidden/', name: 'debug.task.charge_hidings')]
  51.     public function taskChargeHidings(): Response
  52.     {
  53.         return $this->getResponse($this->runCommand('sales:profile:hiding:charge'));
  54.     }
  56.     #[Route(path: '/task-profiles-rotate/', name: 'debug.task.profiles.rotate')]
  57.     public function taskProfilesRotate(): Response
  58.     {
  59.         $output = $this->runCommand('sales:profile:adboard:rotate');
  61.         return $this->getResponse($output);
  62.     }
  64.     #[Route(path: '/task-saloons-rotate/', name: 'debug.task.saloons.rotate')]
  65.     public function taskSaloonsRotate(): Response
  66.     {
  67.         $output = $this->runCommand('sales:saloon:adboard:rotate');
  69.         return $this->getResponse($output);
  70.     }
  72.     #[Route(path: '/task-rotate/', name: 'debug.task.rotate')]
  73.     public function taskRotate(): Response
  74.     {
  75.         $output = $this->runCommand('sales:profile:adboard:rotate');
  76.         $output .= $this->runCommand('sales:saloon:adboard:rotate');
  78.         return $this->getResponse($output);
  79.     }
  81.     #[Route(path: '/task-profiles-rotate-free/', name: 'debug.task.profiles.rotate_free')]
  82.     public function taskProfilesRotateFree(): Response
  83.     {
  84.         return $this->getResponse($this->runCommand('sales:profile:adboard:rotate-free'));
  85.     }
  87.     #[Route(path: '/task-profiles-align/', name: 'debug.task.profiles.align')]
  88.     public function taskProfilesAlign(): Response
  89.     {
  90.         $output = $this->runCommand('sales:profile:adboard:align-positions');
  92.         return $this->getResponse($output);
  93.     }
  95.     #[Route(path: '/task-profiles-delete-rejected-on-moderation/', name: 'debug.task.profiles.delete_rejected_on_moderation')]
  96.     public function taskProfilesDeleteRejectedOnModeration(): Response
  97.     {
  98.         return $this->getResponse($this->runCommand('update:profiles:delete-rejected-on-moderation', [], ['interval' => '5 MINUTE']));
  99.     }
  101.     #[Route(path: '/task-users-set-trusted/', name: 'debug.task.users.set_trusted')]
  102.     public function taskUsersSetTrusted(): Response
  103.     {
  104.         return $this->getResponse($this->runCommand('update:users:set-trusted'));
  105.     }
  107.     #[Route(path: '/task-users-low-balance-notification/', name: 'debug.task.users.low_balance_notification')]
  108.     public function taskUsersLowBalanceNotification(): Response
  109.     {
  110.         return $this->getResponse($this->runCommand('sales:user:low-balance:notify'));
  111.     }
  113.     #[Route(path: '/task-persist-ctr-values-permanent/', name: 'debug.task.profile_ctr.persist_permanent')]
  114.     public function taskPersistCtrValuesPermanent(): Response
  115.     {
  116.         return $this->getResponse($this->runCommand('maintenance:profile-ctr:persist-permanent'));
  117.     }
  119.     #[Route(path: '/task-clear-ctr-values-cache/', name: 'debug.task.profile_ctr.clear_cache')]
  120.     public function taskClearCtrValuesCache(): Response
  121.     {
  122.         return $this->getResponse($this->runCommand('maintenance:profile-ctr:clear-cache'));
  123.     }
  125.     #[Route(path: '/task-top-100-refresh/', name: 'debug.task.top_100.refresh')]
  126.     public function taskTop100Refresh(): Response
  127.     {
  128.         return $this->getResponse($this->runCommand('maintenance:top-100:refresh'));
  129.     }
  131.     #[Route(path: '/process-bulk-background-actions/', name: 'debug.task.background.bulk.process_actions')]
  132.     public function taskProcessBulkBackgroundAction(): Response
  133.     {
  134.         set_time_limit(300);
  135.         $this->runCommand('account:bulk-queue:process');
  136.         return $this->getResponse('OK');
  137.     }
  139.     #[Route(path: '/process-bulk-background-actions-via-consumer/', name: 'debug.task.background.bulk.process_actions_via_consumer')]
  140.     public function taskProcessBulkBackgroundActionViaConsumer(): Response
  141.     {
  142.         set_time_limit(600);
  143.         $this->runCommand('messenger:consume');
  144.         return $this->getResponse('OK');
  145.     }
  147.     #[Route(path: '/process-video-transcoding/', name: 'debug.task.background.process_video_transcoding')]
  148.     public function taskProcessVideoTranscoding(): Response
  149.     {
  150.         set_time_limit(600);
  151.         $this->runCommand('messenger:consume', ['receivers' => ['transcoding']], ['limit' => 1]);
  152.         return $this->getResponse('OK');
  153.     }
  155.     #[Route(path: '/process-test-data-dummy-profiles-create/', name: 'debug.task.test-data.dummy-profiles.create')]
  156.     public function taskCreateDummyProfiles(): Response
  157.     {
  158.         set_time_limit(600);
  159.         return $this->getResponse($this->runCommand('test-data:dummy-profiles:create', ['default_user' => true]));
  160.     }
  162.     #[Route(path: '/task-hide-free-unapproved-placements/', name: 'debug.task.hide_free_unapproved_placements')]
  163.     public function taskHideFreeUnapprovedPlacements(): Response
  164.     {
  165.         return $this->getResponse($this->runCommand('update:profiles:hide-free-unapproved-placements'));
  166.     }
  168.     #[Route(path: '/genereate-profiles-export/', name: 'debug.task.export.create')]
  169.     public function taskCreateProfilesExport(): Response
  170.     {
  171.         set_time_limit(600);
  172.         return $this->getResponse($this->runCommand('export:profiles', [], [
  173.             'city' => 'moscow',
  174.             'price_gte' => 15000,
  175.         ]));
  176.     }
  178.     #[Route(path: '/task-stations-update/', name: 'debug.task.stations_update')]
  179.     public function taskStationsUpdate(): Response
  180.     {
  181.         return $this->getResponse($this->runCommand('stations:update'));
  182.     }
  184.     #[Route(path: '/task-set-seo-phone-numbers-to-profiles/', name: 'debug.task.set_seo_phone_numbers_to_profiles')]
  185.     public function taskSetSeoPhoneNumbersToProfiles(): Response
  186.     {
  187.         return $this->getResponse($this->runCommand('maintenance:seo:set-phones-to-profiles'));
  188.     }
  190.     #[Route(path: '/task-set-seo-phone-numbers-to-saloons/', name: 'debug.task.set_seo_phone_numbers_to_saloons')]
  191.     public function taskSetSeoPhoneNumbersToSaloons(): Response
  192.     {
  193.         return $this->getResponse($this->runCommand('maintenance:seo:set-phones-to-saloons'));
  194.     }
  196.     protected function assertAvailable()
  197.     {
  198.         if($this->kernel->getEnvironment() != 'dev'
  199.             && $this->kernel->getEnvironment() != 'review')
  200.             throw new UnauthorizedHttpException('Not available');
  201.     }
  203.     protected function runCommand(string $command, array $arguments = [], array $options = []): string
  204.     {
  205.         $this->assertAvailable();
  207.         $arrayInput = [
  208.             'command' => $command,
  209.         ];
  211.         foreach ($arguments as $k => $v)
  212.             $arrayInput[$k] = $v;
  214.         foreach ($options as $k => $v)
  215.             $arrayInput['--'.$k] = $v;
  217.         $input = new ArrayInput($arrayInput);
  218.         $output = new BufferedOutput();
  219.         $this->application->run($input, $output);
  221.         return $output->fetch();
  222.     }
  224.     protected function getResponse(string $output): Response
  225.     {
  226.         return new Response($output, headers: ['Content-Type' => 'text/plain; charset=utf-8']);
  227.     }
  228. }