fix: Trigger basex updates on gk udpates

Author: kumy

website/db/migrations/20251015210000_merge_notifications_migrations.php

@@ -99,6 +99,10 @@ public function up(): void {
 
         // 6. Add AMQP triggers for instant notifications
         $this->execute('
+            CREATE TRIGGER after_99_notify_amqp_geokrety
+            AFTER INSERT ON geokrety.gk_geokrety
+            FOR EACH ROW EXECUTE FUNCTION notify_queues.amqp_notify_id();
+
             CREATE TRIGGER after_99_notify_amqp_moves
             AFTER INSERT ON geokrety.gk_moves
             FOR EACH ROW EXECUTE FUNCTION notify_queues.amqp_notify_id();
@@ -112,6 +116,7 @@ public function up(): void {
     public function down(): void {
         // 1. Remove AMQP triggers
         $this->execute('
+            DROP TRIGGER IF EXISTS after_99_notify_amqp_geokrety ON geokrety.gk_geokrety;
             DROP TRIGGER IF EXISTS after_99_notify_amqp_moves ON geokrety.gk_moves;
             DROP TRIGGER IF EXISTS after_99_notify_amqp_moves_comments ON geokrety.gk_moves_comments;
         ');

website/workers/basex-sync.php

@@ -58,14 +58,12 @@ protected function processMessage(AMQPMessage $msg): void {
             $this->log(self::LOG_DEBUG, 'Message received', $data);
 
             switch ($data['kind']) {
-                // TODO?
-                // case 'gk_geokrety':
-                //     $this->handleGeokret((int) $data['id']);
-                //     break;
-                // TODO?
-                // case 'gk_moves_comments':
-                //     $this->handleMoveComment((int) $data['id']);
-                //     break;
+                case 'gk_geokrety':
+                    $this->handleGeokret((int) $data['id']);
+                    break;
+                case 'gk_moves_comments':
+                    $this->handleMoveComment((int) $data['id']);
+                    break;
                 case 'gk_moves':
                     $this->handleMove((int) $data['id']);
                     break;