ExternalVendorCode/chirpstack
1
0
Fork 0
mirror of https://github.com/chirpstack/chirpstack.git synced 2025-04-09 04:14:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix clippy warnings.

Browse Source
This commit is contained in:
Orne Brocaar 2022-08-10 11:34:33 +01:00
parent 7868629533
commit ba7fc75ee6
3 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
chirpstack/src/api/device.rs
View File

@ -667,7 +667,8 @@ impl DeviceService for Device {
kind: match v.kind {
fields::MeasurementKind::COUNTER => common::MetricKind::Counter,
fields::MeasurementKind::ABSOLUTE => common::MetricKind::Absolute,
fields::MeasurementKind::GAUGE | _ => common::MetricKind::Gauge,
fields::MeasurementKind::GAUGE => common::MetricKind::Gauge,
_ => common::MetricKind::Gauge,
}
.into(),
},

2
chirpstack/src/framelog.rs
View File

@ -348,7 +348,7 @@ pub async fn get_frame_logs(
if let Err(e) = res {
// Return in case of channel error, in any other case we just log
// the error.
if let Some(_) = e.downcast_ref::<mpsc::error::SendError<api::LogItem>>() {
if e.downcast_ref::<mpsc::error::SendError<api::LogItem>>().is_some() {
return Err(e);
}

8
chirpstack/src/gateway/backend/mqtt.rs
View File

@ -311,7 +311,7 @@ async fn message_callback(region_name: &str, region_common_name: CommonName, msg
return Ok(());
}
let json = payload_is_json(&b);
let json = payload_is_json(b);
info!(
region_name = region_name,
@ -328,7 +328,7 @@ async fn message_callback(region_name: &str, region_common_name: CommonName, msg
})
.inc();
let mut event = match json {
true => serde_json::from_slice(&b)?,
true => serde_json::from_slice(b)?,
false => chirpstack_api::gw::UplinkFrame::decode(&mut Cursor::new(b))?,
};
event.v4_migrate();
@ -347,7 +347,7 @@ async fn message_callback(region_name: &str, region_common_name: CommonName, msg
})
.inc();
let mut event = match json {
true => serde_json::from_slice(&b)?,
true => serde_json::from_slice(b)?,
false => chirpstack_api::gw::GatewayStats::decode(&mut Cursor::new(b))?,
};
event.v4_migrate();
@ -367,7 +367,7 @@ async fn message_callback(region_name: &str, region_common_name: CommonName, msg
})
.inc();
let mut event = match json {
true => serde_json::from_slice(&b)?,
true => serde_json::from_slice(b)?,
false => chirpstack_api::gw::DownlinkTxAck::decode(&mut Cursor::new(b))?,
};
event.v4_migrate();