ExternalVendorCode/chirpstack
1
0
Fork 0
mirror of https://github.com/chirpstack/chirpstack.git synced 2025-02-11 21:05:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix ns_time + setting of JSON flag.
Some checks failed
CI / tests (postgres) (push) Has been cancelled
Details
CI / tests (sqlite) (push) Has been cancelled
Details
CI / dist (postgres) (push) Has been cancelled
Details
CI / dist (sqlite) (push) Has been cancelled
Details

Browse Source 
These lines were accidentally removed by 922a83597f8aaed089f5c6ed610d20c5aaa91102
when removing the metadata keys as part of the region refactor.
This commit is contained in:
Orne Brocaar 2025-02-03 12:46:04 +00:00
parent f6374f00f8
commit fb59f541b1
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -5,6 +5,7 @@ use std::time::Duration;
use anyhow::Result; use anyhow::Result;
use async_trait::async_trait; use async_trait::async_trait;
use chrono::Utc;
use handlebars::Handlebars; use handlebars::Handlebars;
use prometheus_client::encoding::EncodeLabelSet; use prometheus_client::encoding::EncodeLabelSet;
use prometheus_client::metrics::counter::Counter; use prometheus_client::metrics::counter::Counter;
@ -359,6 +360,11 @@ async fn message_callback(
event.v4_migrate(); event.v4_migrate();
} }
if let Some(rx_info) = &mut event.rx_info {
set_gateway_json(&rx_info.gateway_id, json);
rx_info.ns_time = Some(Utc::now().into());
}
tokio::spawn(uplink::deduplicate_uplink( tokio::spawn(uplink::deduplicate_uplink(
region_common_name, region_common_name,
region_config_id.to_string(), region_config_id.to_string(),