update: insert event aggregate total

Author: samparsky

sentry/src/db/event_aggregate.rs

@@ -2,11 +2,11 @@ use crate::db::DbPool;
 use bb8::RunError;
 // use bb8_postgres::tokio_postgres::types::{ToSql, FromSql};
 use chrono::{DateTime, Utc};
+use postgres_types::{FromSql, ToSql};
 use primitives::sentry::EventAggregate;
-use primitives::{ChannelId, ValidatorId};
 use primitives::BigNum;
+use primitives::{ChannelId, ValidatorId};
 use std::ops::Add;
-use postgres_types::{ToSql, FromSql};
 
 pub async fn list_event_aggregates(
     pool: &DbPool,
@@ -65,7 +65,6 @@ struct EventData {
     event_payout: String,
 }
 
-
 pub async fn insert_event_aggregate(
     pool: &DbPool,
     channel_id: &ChannelId,
@@ -83,18 +82,15 @@ pub async fn insert_event_aggregate(
             let mut total_event_payouts: BigNum = 0.into();
             for (earner, event_count) in event_counts {
                 let event_payout = aggr.event_payouts[earner].clone();
-                data.extend(vec![
-                    EventData {
-                        id: id.clone(),
-                        event_type: event_type.clone(),
-                        earner: Some(earner.clone()),
-                        event_count: event_count.to_string(),
-                        event_payout: event_payout.to_string(),
-                    }
-                    
-                ]);
-
-                // total sum 
+                data.extend(vec![EventData {
+                    id: id.clone(),
+                    event_type: event_type.clone(),
+                    earner: Some(earner.clone()),
+                    event_count: event_count.to_string(),
+                    event_payout: event_payout.to_string(),
+                }]);
+
+                // total sum
                 total_event_counts = event_count.add(&total_event_counts);
                 total_event_payouts = total_event_payouts.add(event_payout);
 
@@ -117,15 +113,13 @@ pub async fn insert_event_aggregate(
                 index += 5;
             }
             // extend with
-            data.extend(vec![
-                EventData {
-                    id: id.clone(),
-                    event_type: event_type.clone(),
-                    earner: None,
-                    event_count: total_event_counts.to_string(),
-                    event_payout: total_event_payouts.to_string(),
-                }
-            ]);
+            data.extend(vec![EventData {
+                id: id.clone(),
+                event_type: event_type.clone(),
+                earner: None,
+                event_count: total_event_counts.to_string(),
+                event_payout: total_event_payouts.to_string(),
+            }]);
 
             values.push(format!(
                 "(${}, ${}, ${}, ${}, ${})",
@@ -136,8 +130,6 @@ pub async fn insert_event_aggregate(
                 index + 5
             ));
             index += 5;
-
-
         }
     }