Skip to content

Commit

Permalink
Update protobufs
Browse files Browse the repository at this point in the history
  • Loading branch information
jurriaan committed Jan 10, 2025
1 parent 1f83c9a commit 79ca49e
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
10 changes: 5 additions & 5 deletions src/import.rs
Original file line number Diff line number Diff line change
Expand Up @@ -187,13 +187,13 @@ async fn handle_position_payload(
txn: &mut PoolConnection<DB>,
) -> Result<(), anyhow::Error> {
if let Ok(position_payload) = Position::decode(&*data.payload) {
if position_payload.latitude_i != 0 && position_payload.longitude_i != 0 {
if position_payload.latitude_i.unwrap_or(0) != 0 && position_payload.longitude_i.unwrap_or(0) != 0 {
let timestamp = none_if_default(position_payload.timestamp).map(|_| {
position_payload.timestamp as i64 * 1000000000
+ position_payload.timestamp_millis_adjust as i64 * 1000000
});
let latitude = position_payload.latitude_i as f64 / 1e7;
let longitude = position_payload.longitude_i as f64 / 1e7;
let latitude = position_payload.latitude_i.unwrap_or(0) as f64 / 1e7;
let longitude = position_payload.longitude_i.unwrap_or(0) as f64 / 1e7;
let time = position_payload.time as i64 * 1_000_000_000;

let result = sqlx::query_as!(
Expand Down Expand Up @@ -453,8 +453,8 @@ async fn handle_waypoint_payload(
.unwrap_or_default()
};

let latitude = waypoint_payload.latitude_i as f64 / 1e7;
let longitude = waypoint_payload.longitude_i as f64 / 1e7;
let latitude = waypoint_payload.latitude_i.unwrap_or(0) as f64 / 1e7;
let longitude = waypoint_payload.longitude_i.unwrap_or(0) as f64 / 1e7;

sqlx::query!(
"INSERT INTO waypoints (
Expand Down

0 comments on commit 79ca49e

Please sign in to comment.