src/Service/MQTTClient.php

@@ -72,6 +72,8 @@ class MQTTClient
         if ($rider == null)
             return;
 
+        /*
+        // NOTE: this is for the old rider app
         // check if rider has sessions
         $sessions = $rider->getSessions();
         if (count($sessions) == 0)
@@ -84,5 +86,9 @@ class MQTTClient
             $channel = self::RIDER_PREFIX . $sess_id;
             $this->publish($channel, json_encode($payload));
         }
+        */
+
+        // NOTE: this is for the new rider app
+        $this->publish('rider/' . $rider->getID(), json_encode($payload));
     }
 }