src/Controller/UrlsearchController.php line 26

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\Routing\Annotation\Route;
  8. use Symfony\Component\HttpFoundation\Request;
  9. use Google\Cloud\Storage\StorageClient;
  10. use App\Entity\UrlUpdate;
  11. use App\Repository\UrlUpdateRepository;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Doctrine\Bundle\DoctrineBundle\Registry;
  15. class UrlsearchController extends AbstractController
  16. {
  17.     #[Route('/urlsearch', name: 'app_urlsearch')]
  18.     public function index(): Response
  19.     {
  20.         return $this->render('urlsearch/index.html.twig', [
  21.             'controller_name' => 'UrlsearchController',
  22.         ]);
  23.     }
  25.     #[Route('/update', name: 'app_appupdate')]
  26.     public function updateurl(Request $request): Response
  27.     {
  28.     $jsonsend = $request->getContent();
  30.         if(!$this->isJson($jsonsend)){
  31.                 return $this->returnError();
  32.         }
  34.         $json = json_decode($jsonsend, true);
  36.     $response = new Response();
  38.     $varFile = 'test.txt';
  39.     if(!isset($json['test'])){
  40.             return $this->returnError();
  41.     }
  43.     $varDir = 'test';
  44.     if($json['test'] == '0'){
  45.         $varFile = 'prod.txt';
  46.         $varDir = 'prod';
  47.     }
  49.     $timeconteggio = file_get_contents($varFile);
  52.     $storage = new StorageClient([
  53.                 'keyFilePath' => 'bulgari-303613-d1e8adbe4a39.json', 
  54.         ]);
  56.         $bucket = $storage->bucket('change2app');
  57.         $array_3D = [];
  58.         $crc = uniqid() . uniqid();
  60.         $storage->registerStreamWrapper();
  61.         $sapMemo = '';
  62.         $datetimemax = 0;
  64.     $index_data = file_get_contents("index_data.json");
  65.         $jsonSap = json_decode($index_data, true);
  67.         for($i=0; $i<count($jsonSap); $i++){
  68.                 $sapCheck = $jsonSap[$i]["sap"];
  69.                 $datetimeupd = $jsonSap[$i]["time"];
  70.                 if(!file_exists($varDir  . "/" . $sapCheck . ".txt") || $datetimeupd != file_get_contents($varDir  . "/" . $sapCheck . ".txt")){
  71.             if(!file_exists("acl_check/" . $sapCheck . ".txt") || file_exists("exported/" . $sapCheck . ".txt")){
  72.                 $array_3D[] = array(
  73.                                 "sap" => strtoupper($sapCheck),
  74.                                     "url" => "https://www.change2.app/include.js?SAP=" . $sapCheck . "&CRC=" . $crc
  75.                             );
  76.                 file_put_contents($varDir  . "/" . $sapCheck . ".txt", $datetimeupd);
  77.             }
  78.         }
  79.     }
  81.     $response->setContent(
  82.         json_encode([
  83.                 'status' => 'success',
  84.                 'code' => '200',
  85.                 'result' => $array_3D
  86.         ])
  87.         );
  88.         $response->headers->set('Content-Type', 'application/json');
  90.         file_put_contents($varFile, $datetimemax);
  91.         return $response;
  92.     die();
  94.     /*
  95.     $options = ['suffix' => 'configurator_settings.json'];
  96.         foreach ($bucket->objects($options) as $object) {
  97.                 $stringUrl = $object->name();
  98.                 $sapCheck = explode('/', $stringUrl);
  99.                 $datetimeupd = strtotime($object->info()['updated']);
  101.                 if($sapMemo != $sapCheck[0]){
  102.                         $sapMemo = $sapCheck[0];
  104.                         $object_exist = $bucket->object($sapCheck[0] . '/configurator_settings.json');
  105.             $object_exist2 = $bucket->object($sapCheck[0] . '/__settings__.js');
  106.                         if($object_exist->exists() && $object_exist2->exists()){
  108.                                 $datetimeupdExist = strtotime($object_exist->info()['updated']);
  109.                                 if($datetimemax < $datetimeupdExist){
  110.                                         $datetimemax = $datetimeupdExist;
  111.                                 }
  112.                                 $contents = file_get_contents('gs://change2app/' . $sapCheck[0] . '/configurator_settings.json');
  113.                                 $json_check = json_decode($contents,true);
  114.                                 if(isset($json_check['player3D']) && intval($json_check['player3D']) == 1){
  115.                     if($timeconteggio < $datetimeupdExist){
  116.                                             $array_3D[] = array(
  117.                                                     "sap" => $sapCheck[0],
  118.                                                     "url" => "https://www.change2.app/include.js?SAP=" . $sapCheck[0] . "&CRC=" . $crc
  119.                                             );
  120.                     }
  121.                 }
  123.                         }
  124.                 }
  125.         }
  129.         $response->setContent(
  130.         json_encode([
  131.                 'status' => 'success',
  132.                 'code' => '200',
  133.                 'result' => $array_3D
  134.         ])
  135.            );
  136.         $response->headers->set('Content-Type', 'application/json');
  138.     file_put_contents($varFile, $datetimemax);
  139.     return $response;
  140.     */
  141.     }
  143.     #[Route('/fromto', name: 'app_fromto')]
  144.     public function fromto(Request $request): Response
  145.     {
  146.         $jsonsend = $request->getContent();
  148.         if(!$this->isJson($jsonsend)){
  149.                 return $this->returnError();
  150.         }
  152.         $json = json_decode($jsonsend, true);
  154.         $response = new Response();
  156.         if(!isset($json['from']) || !isset($json['to'])){
  157.                 return $this->returnError();
  158.         }
  161.     $storage = new StorageClient([
  162.                 'keyFilePath' => 'bulgari-303613-d1e8adbe4a39.json', 
  163.         ]);
  165.         $bucket = $storage->bucket('change2app');
  166.         $array_3D = [];
  167.         $crc = uniqid() . uniqid();
  169.         $storage->registerStreamWrapper();
  170.         $sapMemo = '';
  171.         $datetimemax = 0;
  173.     $index_data = file_get_contents("index_data.json");
  174.     $jsonSap = json_decode($index_data, true);
  176.     for($i=0; $i<count($jsonSap); $i++){
  177.         $sapCheck = $jsonSap[$i]["sap"];
  178.         $datetimeupd = $jsonSap[$i]["time"];
  179.         if($json['from'] <= $datetimeupd && $json['to'] >= $datetimeupd){
  180.             if(!file_exists("acl_check/" . $sapCheck . ".txt") || file_exists("exported/" . $sapCheck . ".txt")){
  181.                 $array_3D[] = array(
  182.                                     "sap" => strtoupper($sapCheck),
  183.                                         "url" => "https://www.change2.app/include.js?SAP=" . $sapCheck . "&CRC=" . $crc
  184.                                 );
  185.             }
  186.         }
  187.     }
  189.     $response->setContent(
  190.         json_encode([
  191.                 'status' => 'success',
  192.                 'code' => '200',
  193.                 'result' => $array_3D
  194.         ])
  195.         );
  196.         $response->headers->set('Content-Type', 'application/json');
  197.         return $response;
  198.     }
  202.     #[Route('/create_index', name: 'create_index')]
  203.     public function create_index(UrlUpdateRepository $urlUpdateRepository): Response
  204.     {
  205.         $storage = new StorageClient([
  206.                 'keyFilePath' => 'bulgari-303613-d1e8adbe4a39.json', 
  207.         ]);
  209.         $bucket = $storage->bucket('change2app');
  210.         $array_3D = [];
  212.         $storage->registerStreamWrapper();
  213.         $sapMemo = '';
  214.         $datetimemax = 0;
  216.     $indexingCheck = file_get_contents("indexing.txt");
  217.     if($indexingCheck == "1"){
  218.         die("sta gia girando");
  219.     }
  221.     file_put_contents("indexing.txt", "1");
  222.     $index_data = file_get_contents("index_data.json");
  224.         foreach ($bucket->objects() as $object) {
  225.                 $stringUrl = $object->name();
  226.                 $sapCheck = explode('/', $stringUrl);
  227.                 $datetimeupd = strtotime($object->info()['updated']);
  229.                 if($sapMemo != $sapCheck[0]){
  230.                         $sapMemo = $sapCheck[0];
  232.                         $object_exist = $bucket->object($sapCheck[0] . '/configurator_settings.json');
  233.                         if($object_exist->exists()){
  235.                                 $datetimeupdExist = strtotime($object_exist->info()['updated']);
  236.                                 $contents = file_get_contents('gs://change2app/' . $sapCheck[0] . '/configurator_settings.json');
  237.                                 $json_check = json_decode($contents,true);
  238.                                 if(isset($json_check['player3D']) && intval($json_check['player3D']) == 1){
  239.                                         $array_3D[] = array(
  240.                                                 "sap" => $sapCheck[0],
  241.                         "time" => $datetimeupdExist
  242.                                         );
  243.                                 }
  244.                 //controllo se devo ricreare l'acl e controllare l'errore del file index.html
  245.                 //if(strpos($index_data, '{"sap":"' . $sapCheck[0] . '","time":' . $datetimeupdExist . '}') !== false){
  246.                     //nessuna novita
  247.                 //}else{
  248.                     file_put_contents("time_check/" . $sapCheck[0] . ".txt", $datetimeupdExist);
  249.                     file_put_contents("acl_check/" . $sapCheck[0] . ".txt", $datetimeupdExist);
  250.                 //}
  251.                         }
  252.                 }
  253.         }
  255.     file_put_contents("index_data.json", json_encode($array_3D));
  256.     file_put_contents("indexing.txt", "0");
  258.         die('fine');
  259.     }
  262.     #[Route('/create_acl', name: 'create_acl')]
  263.     public function create_acl(UrlUpdateRepository $urlUpdateRepository): Response
  264.     {
  265.         $storage = new StorageClient([
  266.                 'keyFilePath' => 'bulgari-303613-d1e8adbe4a39.json', 
  267.         ]);
  269.         $bucket = $storage->bucket('change2app');
  270.         $array_3D = [];
  272.         $storage->registerStreamWrapper();
  273.         $sapMemo = '';
  274.         $datetimemax = 0;
  276.     $files_time = scandir("acl_check");
  277.     if(count($files_time) > 2){
  278.         $sap = str_replace('.txt', '', $files_time[count($files_time)-1]);
  279.         //$sap = "br859769";
  280.         
  281.         $options = ["prefix" => $sap . "/"];
  282.         echo $sap;
  283.         $object_exist = $bucket->object($sap . '/__settings__.js');
  284.                    $object_exist2 = $bucket->object($sap . '/index.html');
  285.         
  286.         //if($object_exist2->exists()){
  287.         if(!$object_exist->exists() && $object_exist2->exists()){
  288.             $contents = file_get_contents('gs://change2app/' . $sap . '/index.html');
  289.             $content_elaborate = str_replace('</script>', '', str_replace('<script>', '', $contents));
  290.             $content_elaborate = str_replace('CONFIG_FILENAME = ASSET_PREFIX   ', 'CONFIG_FILENAME = ASSET_PREFIX + ', $content_elaborate);
  291.             
  292.             $ret = explode(PHP_EOL, $content_elaborate);
  293.             for($z=0; $z<count($ret); $z++){
  294.                 if(strpos($ret[$z], 'ASSET_PREFIX = "') !== false){
  295.                     $ret[$z] = 'ASSET_PREFIX = "";';
  296.                 }
  297.             }
  299.             $content_elaborate = implode(PHP_EOL, $ret);
  300.             //die($content_elaborate);
  301.             //$stream_data = fopen('data://text/plain,' . $content_elaborate, 'r');
  302.             //die($stream_data);
  303.             file_put_contents("tmp_upload.txt", $content_elaborate);
  304.             $bucket->upload(fopen("tmp_upload.txt", 'r'), [
  305.                     'name' => $sap . '/__settings__.js',
  306.                 ]);
  307.             //$object_exist2->delete();
  308.         }
  310.         foreach ($bucket->objects($options) as $object) {
  311.             $acl = $object->acl();
  312.             $checkAclOk = 0;
  313.             foreach ($acl->get() as $item) {
  314.                 if($item['entity'] == 'allUsers' && $item['role'] == 'READER'){
  315.                     $checkAclOk = 1;
  316.                 }
  317.                 }
  318.             if($checkAclOk == 0){
  319.                 $object->update(['acl' => []], ['predefinedAcl' => 'PUBLICREAD']);
  320.             }
  321.         }
  322.         //die();
  323.         unlink("acl_check/" . $sap . ".txt");
  324.         file_put_contents("exported/" . $sap . ".txt", "1");
  325.     }
  326.     die("fine");
  327.     }
  331.     #[Route('/check_update', name: 'app_check_update')]
  332.     public function checkupdate(UrlUpdateRepository $urlUpdateRepository): Response
  333.     {
  334.     $storage = new StorageClient([
  335.         'keyFilePath' => 'bulgari-303613-d1e8adbe4a39.json', 
  336.     ]);
  338.     $bucket = $storage->bucket('change2app');
  339.     $array_3D = [];
  340.     $array_3D_date = [];
  341.     $crc = uniqid() . uniqid();
  343.     $storage->registerStreamWrapper();
  344.     $sapMemo = '';
  345.     $datetimemax = 0;
  347.     foreach ($bucket->objects() as $object) {
  348.         $stringUrl = $object->name();
  349.         $sapCheck = explode('/', $stringUrl);
  350.         $datetimeupd = strtotime($object->info()['updated']);
  351.         
  352.         if($sapMemo != $sapCheck[0]){
  353.             $sapMemo = $sapCheck[0];
  355.             $object_exist = $bucket->object($sapCheck[0] . '/configurator_settings.json');
  356.             if($object_exist->exists()){
  358.                 $datetimeupdExist = strtotime($object_exist->info()['updated']);
  359.                 if($datetimemax < $datetimeupdExist){
  360.                                 $datetimemax = $datetimeupdExist;
  361.                         }
  362.                 $contents = file_get_contents('gs://change2app/' . $sapCheck[0] . '/configurator_settings.json');
  363.                 $json_check = json_decode($contents,true);
  364.                 if(isset($json_check['player3D']) && intval($json_check['player3D']) == 1){
  365.                     $array_3D[] = array(
  366.                                             "sap" => $sapCheck[0],
  367.                                             "url" => "https://www.change2.app/include.js?SAP=" . $sapCheck[0] . "&CRC=" . $crc
  368.                                     );
  370.                     //$urlUpdate = $urlUpdateRepository->findOneBy(array('sap' => $sapCheck[0], 'url' => $stringUrl));
  371.                             //if (!$urlUpdate){
  372.                                 //    $urlUpdate = new UrlUpdate();
  373.                                 //    $urlUpdate->setSap($sapCheck[0]);
  374.                                 //    $urlUpdate->setUrl($stringUrl);
  375.                             //}
  376.                     //if($sapCheck[0] == '41273' || $sapCheck[0] == 'core' || $sapCheck[0] == 'core' || $sapCheck[0] == 'AN858365' || $sapCheck[0] == '41252'){
  377.                         //$object->update(['acl' => []], ['predefinedAcl' => 'PUBLICREAD']);
  378.                     //}
  379.                     //echo $sapCheck[0] . ' - ' . $datetimeupd . ' - ' . $object->info()['updated'] . ' - ' . $stringUrl . PHP_EOL;
  380.                 }
  381.             }
  382.         }
  384.         if($object->name() != 'include.js'){
  385.             $object->update(['acl' => []], ['predefinedAcl' => 'PUBLICREAD']);
  386.         }
  387.     }
  388.     print_r($array_3D);
  389.     echo $datetimemax;
  390.     die('ok');
  391.     }
  393.     public function returnError(){
  394.                 $response = new Response();
  395.             $response->setContent(
  396.                         json_encode([
  397.                                 'status' => 'error',
  398.                                 'code' => '403',
  399.                                 'message' => 'Invalid JSON'
  400.                         ])
  401.                 );
  402.         $response->headers->set('Content-Type', 'application/json');
  403.         return $response;
  404.     }
  406.     function isJson($string)
  407.     {
  408.                 json_decode($string);
  409.                 return (json_last_error() == JSON_ERROR_NONE);
  410.     }
  411. }