fix: await mqtt connected

sobird · Feb 19, 2025 · d088cb3 · d088cb3
1 parent c83aaff
commit d088cb3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/index.ts b/index.ts
@@ -14,8 +14,7 @@ import { randomWave } from '@/utils/randomWave';
 import MqttService from './services/MqttService';
 
 const mqttService = new MqttService();
-// 无需await
-mqttService.start();
+await mqttService.start();
 
 const spinner = ora({
   discardStdin: false,

diff --git a/services/MqttService.ts b/services/MqttService.ts
@@ -84,7 +84,7 @@ export default class MqttService {
     });
     mqttClient.on('message', (topic, message) => {
       const msg: MqttMessage = JSON.parse(message.toString());
-      console.log('message:', msg);
+      // console.log('message:', msg);
 
       const method = this[msg.type as keyof MqttService] as (topic: string, message: MqttMessage) => void;
       if (typeof method === 'function') {