@@ -86,10 +86,11 @@ var MqttService = {
86
86
self . errorLogged = true ;
87
87
} ) ;
88
88
client . on ( 'message' , function ( topic , message ) {
89
- self . parse ( rule , message . toString ( ) ) ; // message is Buffer, thus .toString()
90
- // Eventer.addStatus( {type:'trigger', source:rule.type, id:rule.name, text:message.toString()} );
91
- Eventer . addStatus ( { type :'info' , source :rule . type , id :rule . name , text :message . toString ( ) } ) ;
92
- log . msg ( "MqttService: message: topic:" , topic , "message:" , message . toString ( ) ) ;
89
+ log . msg ( "MqttService: message: topic:" , topic , "message:" , message . toString ( ) ) ;
90
+ // parse() will fill out Eventer.addStatus() for us
91
+ self . parse ( rule , message . toString ( ) ) ; // message is Buffer, thus .toString()
92
+ // Eventer.addStatus( {type:'trigger', source:rule.type, id:rule.name, text:message.toString()} );
93
+ //Eventer.addStatus( {type:'info', source:rule.type, id:rule.name, text:message.toString()} );
93
94
} ) ;
94
95
rule . client = client ;
95
96
} ) ;
@@ -114,6 +115,7 @@ var MqttService = {
114
115
} ,
115
116
116
117
/**
118
+ * (FIXME: Copied from scriptService.parse(), pull these out into single common one)
117
119
* Parse the output from a MQTT response.
118
120
* Plays patterns if match.
119
121
* Sends log messages with source & id of rule.
@@ -172,7 +174,11 @@ var MqttService = {
172
174
Eventer . addStatus ( { type :'error' , source :rule . type , id :rule . name , text :'invalid color ' + json . color } ) ;
173
175
}
174
176
}
177
+ else {
178
+
179
+ }
175
180
} catch ( error ) {
181
+ log . msg ( "error:" , error )
176
182
Eventer . addStatus ( { type :'error' , source :rule . type , id :rule . name , text :error . message } ) ;
177
183
}
178
184
}
0 commit comments