various fixes + move channel_list to primitives::sentry

Author: elpiel

primitives/src/sentry.rs

@@ -215,6 +215,40 @@ impl fmt::Display for ChannelReport {
     }
 }
 
+pub mod channel_list {
+    use crate::ValidatorId;
+    use chrono::serde::ts_seconds::deserialize as ts_seconds;
+    use chrono::{DateTime, Utc};
+    use serde::Deserialize;
+
+    #[derive(Debug, Deserialize)]
+    pub struct ChannelListQuery {
+        #[serde(default = "default_page")]
+        pub page: u64,
+        /// filters the list on `valid_until >= valid_until_ge`
+        /// It should be the same timestamp format as the `Channel.valid_until`: **seconds**
+        #[serde(
+            deserialize_with = "ts_seconds",
+            default = "Utc::now",
+            rename = "validUntil"
+        )]
+        pub valid_until_ge: DateTime<Utc>,
+        pub creator: Option<String>,
+        /// filters the channels containing a specific validator if provided
+        pub validator: Option<ValidatorId>,
+    }
+
+    #[derive(Debug, Deserialize)]
+    #[serde(rename_all = "camelCase")]
+    pub struct LastApprovedQuery {
+        pub with_heartbeat: Option<String>,
+    }
+
+    fn default_page() -> u64 {
+        0
+    }
+}
+
 #[cfg(feature = "postgres")]
 mod postgres {
     use super::{

primitives/src/targeting.rs

@@ -36,7 +36,7 @@ impl Input {
             "advertiserId" => Ok(Value::String(self.global.advertiser_id.clone())),
             "country" => Ok(Value::String(self.global.country.clone())),
             "eventType" => Ok(Value::String(self.global.event_type.clone())),
-            "campaignId" => Ok(Value::String(self.global.campiagn_id.clone())),
+            "campaignId" => Ok(Value::String(self.global.campaign_id.clone())),
             "campaignTotalSpent" => Ok(Value::String(self.global.campaign_total_spent.clone())),
             "campaignSecondsActive" => {
                 Ok(Value::Number(self.global.campaign_seconds_active.into()))
@@ -102,7 +102,7 @@ pub struct Global {
     pub advertiser_id: String,
     pub country: String,
     pub event_type: String,
-    pub campiagn_id: String,
+    pub campaign_id: String,
     pub campaign_total_spent: String,
     pub campaign_seconds_active: u64,
     pub campaign_seconds_duration: u64,

sentry/src/db/event_aggregate.rs

@@ -13,7 +13,7 @@ use primitives::BigNum;
 use primitives::{Channel, ChannelId, ValidatorId};
 use std::ops::Add;
 
-pub async fn lastest_approve_state(
+pub async fn latest_approve_state(
     pool: &DbPool,
     channel: &Channel,
 ) -> Result<Option<ApproveStateValidatorMessage>, RunError<bb8_postgres::tokio_postgres::Error>> {
@@ -108,7 +108,7 @@ pub async fn list_event_aggregates(
                 let statement = format!(
                     "
                         WITH aggregates AS (
-                            SELECT 
+                            SELECT
                                 channel_id,
                                 created,
                                 event_type,
@@ -124,7 +124,7 @@ pub async fn list_event_aggregates(
                                         jsonb_build_object(
                                             earner, payout
                                         )
-                                    )    
+                                    )
                                 )
                                 as data
                             FROM event_aggregates WHERE {} GROUP BY channel_id, event_type, created ORDER BY created DESC LIMIT {}

sentry/src/routes/channel.rs

@@ -1,20 +1,20 @@
-use self::channel_list::{ChannelListQuery, LastApprovedQuery};
-use crate::db::event_aggregate::{lastest_approve_state, latest_heartbeats, latest_new_state};
+use crate::db::event_aggregate::{latest_approve_state, latest_heartbeats, latest_new_state};
 use crate::db::{get_channel_by_id, insert_channel, insert_validator_messages, list_channels};
-use crate::success_response;
-use crate::Application;
-use crate::ResponseError;
-use crate::RouteParams;
-use crate::{Auth, Session};
+use crate::{success_response, Application, Auth, ResponseError, RouteParams, Session};
 use bb8::RunError;
 use bb8_postgres::tokio_postgres::error;
 use futures::future::try_join_all;
 use hex::FromHex;
 use hyper::{Body, Request, Response};
-use primitives::adapter::Adapter;
-use primitives::sentry::{Event, LastApproved, LastApprovedResponse, SuccessResponse};
-use primitives::validator::MessageTypes;
-use primitives::{Channel, ChannelId};
+use primitives::{
+    adapter::Adapter,
+    sentry::{
+        channel_list::{ChannelListQuery, LastApprovedQuery},
+        Event, LastApproved, LastApprovedResponse, SuccessResponse,
+    },
+    validator::MessageTypes,
+    Channel, ChannelId,
+};
 use slog::error;
 use std::collections::HashMap;
 
@@ -130,7 +130,7 @@ pub async fn last_approved<A: Adapter>(
         )
         .expect("should build response");
 
-    let approve_state = match lastest_approve_state(&app.pool, &channel).await? {
+    let approve_state = match latest_approve_state(&app.pool, &channel).await? {
         Some(approve_state) => approve_state,
         None => return Ok(default_response),
     };
@@ -139,7 +139,7 @@ pub async fn last_approved<A: Adapter>(
         MessageTypes::ApproveState(approve_state) => approve_state.state_root,
         _ => {
             error!(&app.logger, "{}", "failed to retrieve approved"; "module" => "last_approved");
-            return Err(ResponseError::BadRequest("an error occured".to_string()));
+            return Err(ResponseError::BadRequest("an error occurred".to_string()));
         }
     };
 
@@ -252,37 +252,3 @@ pub async fn create_validator_messages<A: Adapter + 'static>(
         }
     }
 }
-
-mod channel_list {
-    use chrono::serde::ts_seconds::deserialize as ts_seconds;
-    use chrono::{DateTime, Utc};
-    use primitives::ValidatorId;
-    use serde::Deserialize;
-
-    #[derive(Debug, Deserialize)]
-    pub(super) struct ChannelListQuery {
-        #[serde(default = "default_page")]
-        pub page: u64,
-        /// filters the list on `valid_until >= valid_until_ge`
-        /// It should be the same timestamp format as the `Channel.valid_until`: **seconds**
-        #[serde(
-            deserialize_with = "ts_seconds",
-            default = "Utc::now",
-            rename = "validUntil"
-        )]
-        pub valid_until_ge: DateTime<Utc>,
-        pub creator: Option<String>,
-        /// filters the channels containing a specific validator if provided
-        pub validator: Option<ValidatorId>,
-    }
-
-    #[derive(Debug, Deserialize)]
-    #[serde(rename_all = "camelCase")]
-    pub(super) struct LastApprovedQuery {
-        pub with_heartbeat: Option<String>,
-    }
-
-    fn default_page() -> u64 {
-        0
-    }
-}