src/Http/Controller/Api/V2/Analytics/CollectAnalyticsAction.php line 13

Open in your IDE?
  1. <?php
  3. namespace App\Http\Controller\Api\V2\Analytics;
  5. use App\Infrastructure\Messenger\CommandBus\CommandBusInterface;
  6. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  7. use Symfony\Component\HttpFoundation\JsonResponse;
  8. use Symfony\Component\Routing\Annotation\Route;
  10. /**
  11.  * @Route("/api/v2/analytics/collect", name="api_v2_analytics_collect", methods={"PUT"}, requirements={"id":"[a-f0-9-]+"})
  12.  */
  13. class CollectAnalyticsAction extends AbstractController
  14. {
  15.     public function __invoke(
  16.         // CreateToastSessionLinkCommand $command,
  17.         // CommandBusInterface $commandBus
  18.     ): JsonResponse {
  19.         // $this->denyAccessUnlessGranted(ToastSessionVoter::ACCESS_WITH_COLLABORATORS, $session);
  21.         // $command->session = $session->getId();
  23.         // $siteParser    = new SiteParser($command->url);
  24.         // $command->name = $siteParser->getPageTitle();
  25.         // $command->icon = $siteParser->getFavicon();
  27.         // $commandBus->execute($command);
  29.         // $link = $toastSessionLinkRepository->find($command->id);
  31.         if ($_SERVER['REQUEST_METHOD'] != 'PUT') {
  32.             exit;
  33.         }
  35.         // helpers
  36.         function db_request($request, $db_Name = '')
  37.         {
  38.             // constants
  39.             $host = 'localhost';
  40.             $host_user = 'bmrmcbxy_toast';
  41.             $host_pass = 'kaphaf-zeXjac-tugge3';
  42.             $dbname = 'bmrmcbxy_toast';
  44.             // setting time zone
  45.             $default_timezone = 'Etc/GMT';
  46.             $kyiv_timezone = 'Europe/Kiev';
  47.             date_default_timezone_set($default_timezone);
  49.             // analytics table data
  50.             $analytics_table = 'usage_analytics';
  52.             if ($db_Name == '') {
  53.                 $db_Name = $dbname;
  54.             }
  56.             $link = mysqli_connect($host, $host_user, $host_pass, $db_Name);
  57.             mysqli_set_charset($link, 'utf8');
  59.             if (!$link) {
  60.                 echo "Can't connect to the database. Error code: %s\n".mysqli_connect_error();
  61.                 exit;
  62.             }// if connection error
  64.             if ($result = mysqli_query($link, $request)) {
  65.                 return $result;
  66.             } else {
  67.                 error_log('msqlERROR1:'.mysqli_error($link));
  68.                 error_log('msqlERRORrequest1: From '.$table_name.' '.$request);
  69.             }
  71.             /* Close connection */
  72.             mysqli_close($link);
  73.         }
  74.         function buildEventSavingSQLQuery($eventParameters)
  75.         {
  76.             // constants
  77.             $analytics_table = 'usage_analytics';
  78.             $autoFilledParameters = [
  79.                 'id',
  80.                 'timestamp',
  81.             ];
  83.             $keysPart = 'INSERT INTO `'.$analytics_table.'` (`id`';
  84.             $valuesPart = ') VALUES (NULL';
  86.             foreach ($eventParameters as $parameter => $value) {
  87.                 if (!in_array($parameter, $autoFilledParameters)) {
  88.                     $keysPart .= ', `'.$parameter.'`';
  89.                     $valuesPart .= ", '".$value."'";
  90.                 }
  91.             }
  93.             $sqlString = $keysPart.$valuesPart.');';
  95.             return $sqlString;
  96.         }
  98.         // operating functions
  99.         /*
  100.             $requestHeaders = [];
  101.             foreach (getallheaders() as $name => $value) {
  102.                 // echo "$name: $value\n";
  103.                 $requestHeaders[$name] = $value;
  104.             };
  105.         */
  107.         function saveEvent()
  108.         {
  109.             $requestJSONBody = file_get_contents('php://input');
  110.             $eventParameters = json_decode($requestJSONBody);
  111.             // var_dump($eventParameters);
  113.             $query = buildEventSavingSQLQuery($eventParameters);
  114.             // echo $query;
  116.             db_request($query);
  117.         }
  118.         saveEvent();
  120.         return $this->json(['success' => true]);
  121.     }
  122. }