File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -224,13 +224,17 @@ impl BackendVariant for UdpBackend {
224224 self . fc_settings = Some ( settings) ;
225225 }
226226 DownlinkMessage :: Telemetry ( time, message) if message. len ( ) != 0 => {
227- if interpret_buffer_with_schema ( & LORA_SCHEMA , message. as_slice ( ) , time) . is_ok ( ) {
228- self . data_store . ingest_message ( & LORA_SCHEMA , time, message) ;
227+ // if interpret_buffer_with_schema(&LORA_SCHEMA, message.as_slice(), time).is_ok() {
228+ // self.data_store.ingest_message(&LORA_SCHEMA, time, message);
229229 // } else if interpret_buffer_with_schema(&USB_SCHEMA, message.as_slice(), time).is_ok() {
230230 // self.data_store.ingest_message(&USB_SCHEMA, time, message);
231- } else {
232- error ! ( "Could not identify DownlinkMessage as LORA_SCHEMA nor as USB_SCHEMA, ignoring" ) ;
233- }
231+ // } else {
232+ // error!("Could not identify DownlinkMessage as LORA_SCHEMA nor as USB_SCHEMA, ignoring");
233+ // }
234+
235+ // FIXME: choose one on the following lines before compiling
236+ self . data_store . ingest_message ( & LORA_SCHEMA , time, message) ;
237+ // self.data_store.ingest_message(&USB_SCHEMA, time, message);
234238 }
235239 _ => {
236240 // TODO: metrics via downlink message
You can’t perform that action at this time.
0 commit comments