superdesk / web-publisher

src/SWP/Bundle/CoreBundle/Controller/DefaultController.php

Indentation +186 added lines, -186 removed lines

@@ -33,40 +33,40 @@ 
 
 class DefaultController extends AbstractController {
 
-  private CachedTenantContextInterface $tenantContext;
-  private MetaFactoryInterface $metaFactory;
-  private Context $templateEngineContext;
-  private RouteFactoryInterface $routeFactory;
+    private CachedTenantContextInterface $tenantContext;
+    private MetaFactoryInterface $metaFactory;
+    private Context $templateEngineContext;
+    private RouteFactoryInterface $routeFactory;
 
-  public function __construct(
-      CachedTenantContextInterface $tenantContext,
-      MetaFactoryInterface         $metaFactory,
-      Context                      $templateEngineContext,
-      RouteFactoryInterface        $routeFactory
-  ) {
+    public function __construct(
+        CachedTenantContextInterface $tenantContext,
+        MetaFactoryInterface         $metaFactory,
+        Context                      $templateEngineContext,
+        RouteFactoryInterface        $routeFactory
+    ) {
     $this->tenantContext = $tenantContext;
     $this->metaFactory = $metaFactory;
     $this->templateEngineContext = $templateEngineContext;
     $this->routeFactory = $routeFactory;
-  }
+    }
 
-  /**
-   * @Route("/", methods={"GET","POST"}, name="homepage")
-   */
-  public function indexAction(Request $request): Response {
+    /**
+     * @Route("/", methods={"GET","POST"}, name="homepage")
+     */
+    public function indexAction(Request $request): Response {
     /** @var TenantInterface $currentTenant */
     $currentTenant = $this->tenantContext->getTenant();
     $route = $currentTenant->getHomepage();
 
     if (null === $route) {
-      /** @var RouteInterface $route */
-      $route = $this->routeFactory->create();
-      $route->setStaticPrefix('/');
-      $route->setName('Homepage');
-      $route->setType('content');
-      $route->setTemplateName('index.html.twig');
-      $route->setCacheTimeInSeconds(360);
-      $request->attributes->set(DynamicRouter::ROUTE_KEY, $route);
+        /** @var RouteInterface $route */
+        $route = $this->routeFactory->create();
+        $route->setStaticPrefix('/');
+        $route->setName('Homepage');
+        $route->setType('content');
+        $route->setTemplateName('index.html.twig');
+        $route->setCacheTimeInSeconds(360);
+        $request->attributes->set(DynamicRouter::ROUTE_KEY, $route);
     }
 
     $this->templateEngineContext->setCurrentPage($this->metaFactory->create($route));
@@ -75,195 +75,195 @@ 
     $response->headers->set('Content-Type', 'text/html; charset=UTF-8');
 
     return $this->render('index.html.twig', [], $response);
-  }
+    }
 
-  /**
-   * @Route("/api/system/health", methods={"GET"}, name="system_health")
-   */
-  public function healthCheck(
-      Connection $connection,
-      ElasticaClient $elasticaClient,
-      AdapterInterface $cachePool
-  ): JsonResponse {
-      $status = [
-          'application_name' => 'Publisher',
-          'postgres' => 'red',
-          'elasticsearch' => 'red',
-          'memcached' => 'red',
-          'rabbitmq' => 'red',
-          'supervisor' => 'red',
-      ];
+    /**
+     * @Route("/api/system/health", methods={"GET"}, name="system_health")
+     */
+    public function healthCheck(
+        Connection $connection,
+        ElasticaClient $elasticaClient,
+        AdapterInterface $cachePool
+    ): JsonResponse {
+        $status = [
+            'application_name' => 'Publisher',
+            'postgres' => 'red',
+            'elasticsearch' => 'red',
+            'memcached' => 'red',
+            'rabbitmq' => 'red',
+            'supervisor' => 'red',
+        ];
 
-      // Check PostgreSQL
-      try {
-          $connection->connect();
-          if ($connection->isConnected()) {
-              $status['postgres'] = 'green';
-          }
-      } catch (\Throwable $e) {
-          // Log error for debugging
-          error_log('PostgreSQL health check failed: ' . $e->getMessage());
-          $status['postgres'] = 'red';
-      }
+        // Check PostgreSQL
+        try {
+            $connection->connect();
+            if ($connection->isConnected()) {
+                $status['postgres'] = 'green';
+            }
+        } catch (\Throwable $e) {
+            // Log error for debugging
+            error_log('PostgreSQL health check failed: ' . $e->getMessage());
+            $status['postgres'] = 'red';
+        }
 
-      // Check Elasticsearch
-      try {
-          $elasticaClient->getStatus();
-          $status['elasticsearch'] = 'green';
-      } catch (\Throwable $e) {
-          // Log error for debugging
-          error_log('Elasticsearch health check failed: ' . $e->getMessage());
-          $status['elasticsearch'] = 'red';
-      }
+        // Check Elasticsearch
+        try {
+            $elasticaClient->getStatus();
+            $status['elasticsearch'] = 'green';
+        } catch (\Throwable $e) {
+            // Log error for debugging
+            error_log('Elasticsearch health check failed: ' . $e->getMessage());
+            $status['elasticsearch'] = 'red';
+        }
 
-      // Check Memcached (Symfony Cache)
-      try {
-          // First check if we can connect to Memcached directly
-          $memcached = new \Memcached();
-          $memcached->addServer('localhost', 11211);
+        // Check Memcached (Symfony Cache)
+        try {
+            // First check if we can connect to Memcached directly
+            $memcached = new \Memcached();
+            $memcached->addServer('localhost', 11211);
           
-          // Test basic connectivity
-          if ($memcached->getVersion() === false) {
-              throw new \Exception('Cannot connect to Memcached server');
-          }
+            // Test basic connectivity
+            if ($memcached->getVersion() === false) {
+                throw new \Exception('Cannot connect to Memcached server');
+            }
           
-          // Test cache operations
-          $cacheKey = 'health_check_' . uniqid();
-          $cacheItem = $cachePool->getItem($cacheKey);
-          $cacheItem->set('ok');
-          $cachePool->save($cacheItem);
+            // Test cache operations
+            $cacheKey = 'health_check_' . uniqid();
+            $cacheItem = $cachePool->getItem($cacheKey);
+            $cacheItem->set('ok');
+            $cachePool->save($cacheItem);
           
-          // Verify the item was saved
-          $savedItem = $cachePool->getItem($cacheKey);
-          if (!$savedItem->isHit()) {
-              throw new \Exception('Cache item was not saved successfully');
-          }
+            // Verify the item was saved
+            $savedItem = $cachePool->getItem($cacheKey);
+            if (!$savedItem->isHit()) {
+                throw new \Exception('Cache item was not saved successfully');
+            }
           
-          $cachePool->deleteItem($cacheKey);
-          $status['memcached'] = 'green';
-      } catch (\Throwable $e) {
-          // Log error for debugging
-          error_log('Memcached health check failed: ' . $e->getMessage());
-          $status['memcached'] = 'red';
-      }
+            $cachePool->deleteItem($cacheKey);
+            $status['memcached'] = 'green';
+        } catch (\Throwable $e) {
+            // Log error for debugging
+            error_log('Memcached health check failed: ' . $e->getMessage());
+            $status['memcached'] = 'red';
+        }
 
-      // Check RabbitMQ using php-amqp extension
-      try {
-          $amqp = new \AMQPConnection([
-              'host'     => $_ENV['RABBIT_MQ_HOST'] ?? 'localhost',
-              'port'     => (int)($_ENV['RABBIT_MQ_PORT'] ?? 5672),
-              'login'    => $_ENV['RABBIT_MQ_USER'] ?? 'guest',
-              'password' => $_ENV['RABBIT_MQ_PASSWORD'] ?? 'guest',
-              'vhost'    => $_ENV['RABBIT_MQ_VHOST'] ?? '/',
-          ]);
-          $amqp->connect();
-          if ($amqp->isConnected()) {
-              $status['rabbitmq'] = 'green';
-          }
-      } catch (\Throwable $e) {
-          // Log error for debugging
-          error_log('RabbitMQ health check failed: ' . $e->getMessage());
-          $status['rabbitmq'] = 'red';
-      }
+        // Check RabbitMQ using php-amqp extension
+        try {
+            $amqp = new \AMQPConnection([
+                'host'     => $_ENV['RABBIT_MQ_HOST'] ?? 'localhost',
+                'port'     => (int)($_ENV['RABBIT_MQ_PORT'] ?? 5672),
+                'login'    => $_ENV['RABBIT_MQ_USER'] ?? 'guest',
+                'password' => $_ENV['RABBIT_MQ_PASSWORD'] ?? 'guest',
+                'vhost'    => $_ENV['RABBIT_MQ_VHOST'] ?? '/',
+            ]);
+            $amqp->connect();
+            if ($amqp->isConnected()) {
+                $status['rabbitmq'] = 'green';
+            }
+        } catch (\Throwable $e) {
+            // Log error for debugging
+            error_log('RabbitMQ health check failed: ' . $e->getMessage());
+            $status['rabbitmq'] = 'red';
+        }
 
-      // Check Supervisor processes
-      try {
-          $process = new \Symfony\Component\Process\Process(['supervisorctl', 'status', 'messenger-consume:*']);
-          $process->setTimeout(10);
-          $process->run();
+        // Check Supervisor processes
+        try {
+            $process = new \Symfony\Component\Process\Process(['supervisorctl', 'status', 'messenger-consume:*']);
+            $process->setTimeout(10);
+            $process->run();
           
-          // Log the raw output for debugging
-          error_log('Supervisor command output: ' . $process->getOutput());
-          error_log('Supervisor command error: ' . $process->getErrorOutput());
-          error_log('Supervisor command exit code: ' . $process->getExitCode());
+            // Log the raw output for debugging
+            error_log('Supervisor command output: ' . $process->getOutput());
+            error_log('Supervisor command error: ' . $process->getErrorOutput());
+            error_log('Supervisor command exit code: ' . $process->getExitCode());
           
-          if ($process->isSuccessful()) {
-              $output = $process->getOutput();
-              $lines = explode(PHP_EOL, trim($output));
-              $runningProcesses = 0;
-              $totalProcesses = 0;
+            if ($process->isSuccessful()) {
+                $output = $process->getOutput();
+                $lines = explode(PHP_EOL, trim($output));
+                $runningProcesses = 0;
+                $totalProcesses = 0;
               
-              foreach ($lines as $line) {
-                  $line = trim($line);
-                  if ($line) {
-                      $totalProcesses++;
-                      // Check for various running states
-                      if (stripos($line, 'RUNNING') !== false || 
+                foreach ($lines as $line) {
+                    $line = trim($line);
+                    if ($line) {
+                        $totalProcesses++;
+                        // Check for various running states
+                        if (stripos($line, 'RUNNING') !== false || 
                           stripos($line, 'STARTING') !== false ||
                           stripos($line, 'BACKOFF') !== false) {
-                          $runningProcesses++;
-                      }
-                  }
-              }
+                            $runningProcesses++;
+                        }
+                    }
+                }
               
-              error_log("Supervisor check - Total processes: $totalProcesses, Running processes: $runningProcesses");
+                error_log("Supervisor check - Total processes: $totalProcesses, Running processes: $runningProcesses");
               
-              if ($totalProcesses > 0 && $runningProcesses === $totalProcesses) {
-                  $status['supervisor'] = 'green';
-              } else {
-                  $status['supervisor'] = 'red';
-              }
-          } else {
-              // Try alternative command if the first one fails
-              $process2 = new \Symfony\Component\Process\Process(['supervisorctl', 'status']);
-              $process2->setTimeout(10);
-              $process2->run();
+                if ($totalProcesses > 0 && $runningProcesses === $totalProcesses) {
+                    $status['supervisor'] = 'green';
+                } else {
+                    $status['supervisor'] = 'red';
+                }
+            } else {
+                // Try alternative command if the first one fails
+                $process2 = new \Symfony\Component\Process\Process(['supervisorctl', 'status']);
+                $process2->setTimeout(10);
+                $process2->run();
               
-              error_log('Alternative supervisor command output: ' . $process2->getOutput());
+                error_log('Alternative supervisor command output: ' . $process2->getOutput());
               
-              if ($process2->isSuccessful()) {
-                  $output = $process2->getOutput();
-                  $lines = explode(PHP_EOL, trim($output));
-                  $runningProcesses = 0;
-                  $totalProcesses = 0;
+                if ($process2->isSuccessful()) {
+                    $output = $process2->getOutput();
+                    $lines = explode(PHP_EOL, trim($output));
+                    $runningProcesses = 0;
+                    $totalProcesses = 0;
                   
-                  foreach ($lines as $line) {
-                      $line = trim($line);
-                      if ($line && stripos($line, 'messenger-consume') !== false) {
-                          $totalProcesses++;
-                          if (stripos($line, 'RUNNING') !== false || 
+                    foreach ($lines as $line) {
+                        $line = trim($line);
+                        if ($line && stripos($line, 'messenger-consume') !== false) {
+                            $totalProcesses++;
+                            if (stripos($line, 'RUNNING') !== false || 
                               stripos($line, 'STARTING') !== false ||
                               stripos($line, 'BACKOFF') !== false) {
-                              $runningProcesses++;
-                          }
-                      }
-                  }
+                                $runningProcesses++;
+                            }
+                        }
+                    }
                   
-                  error_log("Alternative supervisor check - Total messenger processes: $totalProcesses, Running processes: $runningProcesses");
+                    error_log("Alternative supervisor check - Total messenger processes: $totalProcesses, Running processes: $runningProcesses");
                   
-                  if ($totalProcesses > 0 && $runningProcesses === $totalProcesses) {
-                      $status['supervisor'] = 'green';
-                  } else {
-                      $status['supervisor'] = 'red';
-                  }
-              } else {
-                  $status['supervisor'] = 'red';
-              }
-          }
-      } catch (\Throwable $e) {
-          // Log error for debugging
-          error_log('Supervisor health check failed: ' . $e->getMessage());
-          $status['supervisor'] = 'red';
-      }
+                    if ($totalProcesses > 0 && $runningProcesses === $totalProcesses) {
+                        $status['supervisor'] = 'green';
+                    } else {
+                        $status['supervisor'] = 'red';
+                    }
+                } else {
+                    $status['supervisor'] = 'red';
+                }
+            }
+        } catch (\Throwable $e) {
+            // Log error for debugging
+            error_log('Supervisor health check failed: ' . $e->getMessage());
+            $status['supervisor'] = 'red';
+        }
 
-      // Determine overall status
-      $redServices = 0;
-      $totalServices = count($status) - 1; // Exclude application_name from count
+        // Determine overall status
+        $redServices = 0;
+        $totalServices = count($status) - 1; // Exclude application_name from count
       
-      foreach ($status as $service => $serviceStatus) {
-          if ($service !== 'application_name' && $serviceStatus === 'red') {
-              $redServices++;
-          }
-      }
+        foreach ($status as $service => $serviceStatus) {
+            if ($service !== 'application_name' && $serviceStatus === 'red') {
+                $redServices++;
+            }
+        }
       
-      if ($redServices === 0) {
-          $status['status'] = 'green';
-      } elseif ($redServices === $totalServices) {
-          $status['status'] = 'red';
-      } else {
-          $status['status'] = 'orange';
-      }
+        if ($redServices === 0) {
+            $status['status'] = 'green';
+        } elseif ($redServices === $totalServices) {
+            $status['status'] = 'red';
+        } else {
+            $status['status'] = 'orange';
+        }
 
-      return new JsonResponse($status);
-  }
+        return new JsonResponse($status);
+    }
 }

Spacing +11 added lines, -11 removed lines

@@ -102,7 +102,7 @@ 
           }
       } catch (\Throwable $e) {
           // Log error for debugging
-          error_log('PostgreSQL health check failed: ' . $e->getMessage());
+          error_log('PostgreSQL health check failed: '.$e->getMessage());
           $status['postgres'] = 'red';
       }
 
@@ -112,7 +112,7 @@ 
           $status['elasticsearch'] = 'green';
       } catch (\Throwable $e) {
           // Log error for debugging
-          error_log('Elasticsearch health check failed: ' . $e->getMessage());
+          error_log('Elasticsearch health check failed: '.$e->getMessage());
           $status['elasticsearch'] = 'red';
       }
 
@@ -128,7 +128,7 @@ 
           }
           
           // Test cache operations
-          $cacheKey = 'health_check_' . uniqid();
+          $cacheKey = 'health_check_'.uniqid();
           $cacheItem = $cachePool->getItem($cacheKey);
           $cacheItem->set('ok');
           $cachePool->save($cacheItem);
@@ -143,7 +143,7 @@ 
           $status['memcached'] = 'green';
       } catch (\Throwable $e) {
           // Log error for debugging
-          error_log('Memcached health check failed: ' . $e->getMessage());
+          error_log('Memcached health check failed: '.$e->getMessage());
           $status['memcached'] = 'red';
       }
 
@@ -151,7 +151,7 @@ 
       try {
           $amqp = new \AMQPConnection([
               'host'     => $_ENV['RABBIT_MQ_HOST'] ?? 'localhost',
-              'port'     => (int)($_ENV['RABBIT_MQ_PORT'] ?? 5672),
+              'port'     => (int) ($_ENV['RABBIT_MQ_PORT'] ?? 5672),
               'login'    => $_ENV['RABBIT_MQ_USER'] ?? 'guest',
               'password' => $_ENV['RABBIT_MQ_PASSWORD'] ?? 'guest',
               'vhost'    => $_ENV['RABBIT_MQ_VHOST'] ?? '/',
@@ -162,7 +162,7 @@ 
           }
       } catch (\Throwable $e) {
           // Log error for debugging
-          error_log('RabbitMQ health check failed: ' . $e->getMessage());
+          error_log('RabbitMQ health check failed: '.$e->getMessage());
           $status['rabbitmq'] = 'red';
       }
 
@@ -173,9 +173,9 @@ 
           $process->run();
           
           // Log the raw output for debugging
-          error_log('Supervisor command output: ' . $process->getOutput());
-          error_log('Supervisor command error: ' . $process->getErrorOutput());
-          error_log('Supervisor command exit code: ' . $process->getExitCode());
+          error_log('Supervisor command output: '.$process->getOutput());
+          error_log('Supervisor command error: '.$process->getErrorOutput());
+          error_log('Supervisor command exit code: '.$process->getExitCode());
           
           if ($process->isSuccessful()) {
               $output = $process->getOutput();
@@ -209,7 +209,7 @@ 
               $process2->setTimeout(10);
               $process2->run();
               
-              error_log('Alternative supervisor command output: ' . $process2->getOutput());
+              error_log('Alternative supervisor command output: '.$process2->getOutput());
               
               if ($process2->isSuccessful()) {
                   $output = $process2->getOutput();
@@ -242,7 +242,7 @@ 
           }
       } catch (\Throwable $e) {
           // Log error for debugging
-          error_log('Supervisor health check failed: ' . $e->getMessage());
+          error_log('Supervisor health check failed: '.$e->getMessage());
           $status['supervisor'] = 'red';
       }