Optimized connection to db

app/common/Command/UpdateIp.php

@@ -8,6 +8,7 @@ use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 use ProVM\Service\Remote;
+use Symfony\Component\Console\Style\SymfonyStyle;
 
 #[AsCommand(
     name: 'update',
@@ -22,8 +23,13 @@ class UpdateIp extends Command
 
     public function execute(InputInterface $input, OutputInterface $output): int
     {
+        $io = new SymfonyStyle($input, $output);
+        $io->title('Update IP');
+
         try {
+            $io->info('Obtaining IP and updating database');
             $this->service->update();
+            $io->info('Done');
             return Command::SUCCESS;
         } catch (PDOException $e) {
             $this->logger->warning($e);

app/common/Command/Watch.php

@@ -7,6 +7,7 @@ use Psr\Log\LoggerInterface;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Style\SymfonyStyle;
 use function Safe\shell_exec;
 
 #[AsCommand(
@@ -15,27 +16,35 @@ use function Safe\shell_exec;
 )]
 class Watch extends Command
 {
-    public function __construct(protected string $period, string $name = 'watch')
+    public function __construct(protected string $command, protected string $period, protected LoggerInterface $logger, string $name = 'watch')
     {
         parent::__construct($name);
     }
 
     public function execute(InputInterface $input, OutputInterface $output): int
     {
+        $io = new SymfonyStyle($input, $output);
+        $io->title('Watch');
+
         $period = new DateInterval($this->period);
         $current = new DateTimeImmutable();
+        $io->info('Starting');
         while(true) {
             $now = new DateTimeImmutable();
             if ($now->diff($current) === $period) {
+                $io->info('Running Update');
                 $this->runUpdate();
                 $current = $now;
             }
+            $wait = (new DateTimeImmutable((new DateTimeImmutable())->format('Y-m-d H:i:0')))->add(new DateInterval('PT1M'));
+            time_sleep_until($wait->getTimestamp());
         }
         return Command::SUCCESS;
     }
     protected function runUpdate(): void
     {
-        $command = '/app/bin/console update';
+        $command = "{$this->command} update";
+        $this->logger->info("Running '{$command}'");
         shell_exec($command);
     }
 }

app/common/Service/Connector.php

@@ -0,0 +1,41 @@
+<?php
+namespace ProVM\Service;
+
+use PDO;
+use PDOException;
+use Psr\Log\LoggerInterface;
+
+class Connector
+{
+    public function __construct(protected string $host, protected string $name, protected string $username, protected string $password, protected string $retries, protected LoggerInterface $logger) {}
+
+    protected PDO $connection;
+
+    /**
+     * @throws PDOException
+     */
+    public function connect(): PDO
+    {
+        if (!isset($this->connection)) {
+            $this->logger->debug('Connecting');
+            $r = 0;
+            $exception = null;
+            while($r < $this->retries) {
+                try {
+                    $dsn = "mysql:host={$this->host};dbname={$this->name}";
+                    $this->connection = new PDO($dsn, $this->username, $this->password);
+                    return $this->connection;
+                } catch (PDOException $e) {
+                    $this->logger->debug('Retrying');
+                    if ($exception !== null) {
+                        $e = new PDOException($e->getMessage(), $e->getCode(), $exception);
+                    }
+                    $exception = $e;
+                }
+                $r ++;
+            }
+            throw $exception;
+        }
+        return $this->connection;
+    }
+}

app/common/Service/Ipify.php

@@ -22,6 +22,7 @@ class Ipify
         if (!isset($json->ip)) {
             throw new Exception('Missing `ip` in JSON response');
         }
+        $this->logger->debug("Current IP: {$json->ip}");
         return $json->ip;
     }
 }

app/common/Service/Repository.php

@@ -6,28 +6,28 @@ use Psr\Log\LoggerInterface;
 
 class Repository
 {
-    public function __construct(protected PDO $connection, protected string $table, protected LoggerInterface $logger) {}
+    public function __construct(protected Connector $connector, protected string $table, protected LoggerInterface $logger) {}
 
     public function update(string $ip): void
     {
         $this->logger->debug('Updating Database');
 
         $old_ip = $this->getOld();
-        $this->logger->debug($old_ip);
+        $this->logger->debug("Old IP: {$old_ip}");
 
         if ($old_ip === $ip) {
             $this->logger->debug('No change in IP');
             return;
         }
 
-        $this->doUpdate();
+        $this->doUpdate($ip);
         $this->logger->debug('Updated IP');
     }
 
     protected function getOld(): string
     {
         $query = "SELECT `ip` FROM `{$this->table}` WHERE `host` = ?";
-        $statement = $this->connection->prepare($query);
+        $statement = $this->connector->connect()->prepare($query);
         $statement->execute(['vialdelamaza']);
 
         return $statement->fetch()['ip'];
@@ -35,7 +35,7 @@ class Repository
     protected function doUpdate(string $ip): void
     {
         $query = "UPDATE `remote_ip` SET `ip` = ?, `updated` = CURRENT_TIMESTAMP() WHERE `host` = ?";
-        $statement = $this->connection->prepare($query);
+        $statement = $this->connector->connect()->prepare($query);
         $statement->execute([$ip, 'vialdelamaza']);
     }
 }