WJPC: Sync only non-connected players

MySpeedPuzzling · Sep 19, 2024 · 07a08de · 07a08de
1 parent aacb6f4
commit 07a08de
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 3 deletions.
diff --git a/src/ConsoleCommands/SyncWjpcRemotePlayersConsoleCommands.php b/src/ConsoleCommands/SyncWjpcRemotePlayersConsoleCommands.php
@@ -42,11 +42,11 @@ protected function execute(InputInterface $input, OutputInterface $output): int
         }
 
         if ($participantId === null) {
-            $connectedParticipants = $this->getWjpcParticipants->getConnectedParticipants();
+            $notSyncedParticipants = $this->getWjpcParticipants->getConnectedParticipantsWithoutRemoteId();
 
-            foreach ($connectedParticipants as $participant) {
+            foreach ($notSyncedParticipants as $participantId) {
                 $this->messageBus->dispatch(
-                    new UpdateWjpcPlayerId($participant->participantId),
+                    new UpdateWjpcPlayerId($participantId),
                 );
             }
         }

diff --git a/src/Query/GetWjpcParticipants.php b/src/Query/GetWjpcParticipants.php
@@ -71,6 +71,30 @@ public function mappingToPlayers(): array
         return $results;
     }
 
+    /**
+     * @return array<string>
+     */
+    public function getConnectedParticipantsWithoutRemoteId(): array
+    {
+        $query = <<<SQL
+SELECT 
+    wjpc_participant.id AS participant_id
+FROM 
+    wjpc_participant
+INNER JOIN 
+    player ON player.id = wjpc_participant.player_id
+WHERE 
+    wjpc_participant.player_id IS NOT NULL AND wjpc_participant.remote_id IS NULL
+SQL;
+
+        /** @var array<string> $participants */
+        $participants = $this->database
+            ->executeQuery($query)
+            ->fetchFirstColumn();
+
+        return $participants;
+    }
+
     /**
      * @return array<ConnectedWjpcParticipant>
      */