src/Controller/Cronjob/Server/Hetzner/ServerController.php line 29

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Cronjob\Server\Hetzner;
  5. use App\Entity\SAAS\Server\Hetzner\DataCenter;
  6. use App\Entity\SAAS\Server\Hetzner\DataCenterSupportedServerTypes;
  7. use App\Entity\SAAS\Server\Hetzner\Ip;
  8. use App\Repository\SAAS\Server\Hetzner\ImageRepository;
  9. use App\Repository\SAAS\Server\Hetzner\IpRepository;
  10. use App\Repository\SAAS\Server\Hetzner\ServerRepository;
  11. use App\Service\Server\Hetzner\ServerService;
  12. use App\Service\Util\HetznerApi;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  15. use Symfony\Component\HttpFoundation\Response;
  16. use Symfony\Component\Routing\Annotation\Route;
  18. class ServerController extends AbstractController
  19. {
  20.     public EntityManagerInterface $em ;
  22.     public ServerService $service;
  23.     public function __construct(EntityManagerInterface $em , ServerService $service)
  24.     {
  25.         $this->em = $em;
  26.         $this->service = $service;
  27.     }
  28.     #[Route('/cronjobs/hetzner/server', name: 'app_cronjobs_hetzner_server')]
  29.     public function index(ServerRepository $serverRepository , ImageRepository $imageRepository , IpRepository $ipRepository): Response
  30.     {
  31.         $hetznerApi = new HetznerApi($_ENV['HETZNERAPITOKEN']);
  32.         $servers = $hetznerApi->getServers();
  33.         foreach ($servers as $server) {
  34.             if ($serverRepository->findOneBy(['systemId' => $server['id']])){
  35.                 $serverObject = $serverRepository->findOneBy(['systemId' => $server['id']]);
  36.                 if ($serverObject->isActive()){
  37.                     $serverObject->setStatus($server['status']);
  38.                     if ($serverObject->getStatus() == 'off'){
  39.                         $serverObject->setIsPowerOn(false);
  40.                     }else{
  41.                         $serverObject->setIsPowerOn(true);
  42.                     }
  43.                     $serverObject->setRescueEnabled((bool)$server['rescue_enabled']);
  44.                     $serverObject->setName($server['name']);
  45.                     if (isset($server['included_traffic']) ){
  46.                         $serverObject->setIncludedTraffic($server['included_traffic']);
  47.                     }else{
  48.                         $serverObject->setIncludedTraffic(21990232555520);
  49.                     }
  50.                     $serverObject->setOutgoingTraffic($server['outgoing_traffic']);
  51.                     $serverObject->setIngoingTraffic($server['ingoing_traffic']);
  52.                     $serverObject->setAnalytics(json_encode($this->service->getServerMetrics($serverObject)));
  53.                     $serverObject->setActions(json_encode($this->service->getServerActions($serverObject)));
  54.                     $imageObject = $imageRepository->findOneBy(['systemId' => $server['image']['id']]);
  55.                     if ($imageObject) {
  56.                         $serverObject->setimage($imageObject);
  57.                     }
  58.                     foreach ($server['public_net'] as $ipType => $ipArray) {
  59.                         if ($ipType === 'ipv4' || $ipType === 'ipv6') {
  60.                             $ipObject = $ipRepository->findOneBy(['ip' => $ipArray['ip']  , 'server' => $serverObject , 'active' => 1 , 'deletedAt' => null]);
  61.                             if (!$ipObject) {
  62.                                 $ipObject = new Ip();
  63.                                 $ipObject->setIp($ipArray['ip']);
  64.                                 $ipObject->setType($ipType);
  65.                                 $ipObject->setOwner($this->getUser());
  66.                                 $ipObject->setServer($serverObject);
  67.                                 if (is_array($ipArray['dns_ptr'])){
  68.                                     $ipObject->setName($ipArray['ip']);
  69.                                 }else{
  70.                                     $ipObject->setName($ipArray['dns_ptr']);
  71.                                 }
  72.                                 $ipObject->setIsLocked((bool)$ipArray['blocked']);
  73.                                 $ipObject->setSystemId($ipArray['id']);
  74.                                 $this->em->persist($ipObject);
  75.                             }
  76.                         }
  77.                     }
  78.                     $this->em->flush();
  79.                 }else{
  80.                     $hetznerApi->deleteServer($serverObject);
  81.                 }
  82.             }else{
  83.                 $hetznerApi->deleteServer($server['id']);
  84.             }
  85.         }
  86.         $this->em->clear();
  87.         return $this->json([
  88.             'res' => true,
  89.         ]);
  90.     }
  91. }