From c24e09f0c7d805f9e524cea85c559fd552a02bc4 Mon Sep 17 00:00:00 2001
From: xboard <xboard@xboard.one>
Date: Mon, 16 Mar 2026 02:28:28 +0800
Subject: [PATCH] fix: correct node_sync queue assignment in horizon

---
 app/Jobs/NodeUserSyncJob.php | 2 +-
 config/horizon.php           | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/app/Jobs/NodeUserSyncJob.php b/app/Jobs/NodeUserSyncJob.php
index 45e8542..f49e108 100644
--- a/app/Jobs/NodeUserSyncJob.php
+++ b/app/Jobs/NodeUserSyncJob.php
@@ -22,7 +22,7 @@ class NodeUserSyncJob implements ShouldQueue
         private readonly string $action,
         private readonly ?int $oldGroupId = null
     ) {
-        $this->onQueue('notification');
+        $this->onQueue('node_sync');
     }
 
     public function handle(): void
diff --git a/config/horizon.php b/config/horizon.php
index 3959444..fde7487 100644
--- a/config/horizon.php
+++ b/config/horizon.php
@@ -60,7 +60,7 @@ return [
 
     'prefix' => env(
         'HORIZON_PREFIX',
-        Str::slug(env('APP_NAME', 'laravel'), '_').'_horizon:'
+        Str::slug(env('APP_NAME', 'laravel'), '_') . '_horizon:'
     ),
 
     /*
@@ -192,7 +192,7 @@ return [
             ],
             'notification' => [
                 'connection' => 'redis',
-                'queue' => ['send_email', 'send_telegram', 'send_email_mass'],
+                'queue' => ['send_email', 'send_telegram', 'send_email_mass', 'node_sync'],
                 'balance' => 'auto',
                 'autoScalingStrategy' => 'size',
                 'minProcesses' => 1,
@@ -214,6 +214,7 @@ return [
                     'send_email_mass',
                     'send_telegram',
                     'user_alive_sync',
+                    'node_sync'
                 ],
                 'balance' => 'auto',
                 'minProcesses' => 1,