sentry - Improve docs & create InsertEventsRequest

Author: elpiel

primitives/Cargo.toml

@@ -21,8 +21,10 @@ postgres = ["bytes", "tokio-postgres", "deadpool-postgres"]
 test-util = []
 
 [[example]]
-name = "channel_list_query"
-required-features = ["test-util"]
+name = "analytics_query"
+
+[[example]]
+name = "analytics_response"
 
 [[example]]
 name = "campaign_list_query"
@@ -32,10 +34,17 @@ required-features = ["test-util"]
 name = "campaign_list_response"
 required-features = ["test-util"]
 
+[[example]]
+name = "channel_list_query"
+required-features = ["test-util"]
+
 [[example]]
 name = "create_campaign"
 required-features = ["test-util"]
 
+[[example]]
+name = "modify_campaign"
+
 [dependencies]
 # (De)Serialization
 serde = { version = "1.0", features = ["derive"] }

primitives/examples/analytics_query.rs

@@ -41,8 +41,16 @@ fn main() {
 
     // Query with all possible fields (publisher/advertiser/admin)
     {
-        let query_str = "limit=200&eventType=CLICK&metric=paid&segmentBy=country&timeframe=week&start=2022-08-04+09:00:00.000000000+UTC&campaignId=0x936da01f9abd4d9d80c702af85c822a8&adUnit=QmcUVX7fvoLMM93uN2bD3wGTH8MXSxeL8hojYfL2Lhp7mR&adSlot=Qmasg8FrbuSQpjFu3kRnZF9beg8rEBFrqgi1uXDRwCbX5f&adSlotType=legacy_300x100&advertiser=0xDd589B43793934EF6Ad266067A0d1D4896b0dff0&publisher=0xE882ebF439207a70dDcCb39E13CA8506c9F45fD9\
-        &hostname=localhost&country=Bulgaria&osName=Windows&chains[0]=1&chains[1]=1337";
+        let query_str = "limit=200&eventType=CLICK&metric=paid&segmentBy=country\
+        &timeframe=week&start=2022-08-04+09:00:00.000000000+UTC\
+        &campaignId=0x936da01f9abd4d9d80c702af85c822a8\
+        &adUnit=QmcUVX7fvoLMM93uN2bD3wGTH8MXSxeL8hojYfL2Lhp7mR\
+        &adSlot=Qmasg8FrbuSQpjFu3kRnZF9beg8rEBFrqgi1uXDRwCbX5f\
+        &adSlotType=legacy_300x100\
+        &advertiser=0xDd589B43793934EF6Ad266067A0d1D4896b0dff0\
+        &publisher=0xE882ebF439207a70dDcCb39E13CA8506c9F45fD9\
+        &hostname=localhost&country=Bulgaria&osName=Windows\
+        &chains[0]=1&chains[1]=1337";
         let query: AnalyticsQuery = serde_qs::from_str(query_str).unwrap();
 
         assert_eq!(query.limit, 200);

primitives/examples/create_campaign.rs

@@ -3,15 +3,15 @@ use serde_json::json;
 use std::str::FromStr;
 
 fn main() {
-    // CreateCampaign in an HTTP request
+    // CreateCampaign in an HTTP request.
+    // A CampaignId will be randomly generated for the newly created Campaign.
     {
         let create_campaign = CreateCampaign::from_campaign_erased(DUMMY_CAMPAIGN.clone(), None);
 
-        let create_campaign_str =
+        let _create_campaign_str =
             serde_json::to_string(&create_campaign).expect("should serialize");
 
         let create_campaign_json = json!({
-            "id":null,
             "channel":{
                 "leader":"0x80690751969B234697e9059e04ed72195c3507fa",
                 "follower":"0xf3f583AEC5f7C030722Fe992A5688557e1B86ef7",
@@ -34,7 +34,10 @@ fn main() {
                 }
             ],
             "title":"Dummy Campaign",
-            "pricingBounds":{"CLICK":{"min":"0","max":"0"},"IMPRESSION":{"min":"1","max":"10"}},
+            "pricingBounds":{
+                "CLICK":{"min":"0","max":"0"},
+                "IMPRESSION":{"min":"1","max":"10"}
+            },
             "eventSubmission":{"allow":[]},
             "targetingRules":[],
             "created":1612162800000_u64,
@@ -43,6 +46,7 @@ fn main() {
 
         let create_campaign_json =
             serde_json::to_string(&create_campaign_json).expect("should serialize");
+
         let deserialized: CreateCampaign =
             serde_json::from_str(&create_campaign_json).expect("should deserialize");
 

primitives/examples/modify_campaign.rs

@@ -1,6 +1,5 @@
 use primitives::{sentry::campaign_modify::ModifyCampaign, unified_num::FromWhole, UnifiedNum};
 use serde_json::json;
-use std::str::FromStr;
 
 fn main() {
     {

primitives/src/sentry.rs

@@ -319,9 +319,10 @@ pub struct FetchedAnalytics {
     pub segment: Option<String>,
 }
 
-// Response returned when getting Analytics - an array of FetchedAnalytics
-//
-/// # Examples:
+/// Response returned when getting Analytics which returns the [`FetchedAnalytics`].
+///
+/// # Examples
+///
 /// ```
 #[doc = include_str!("../examples/analytics_response.rs")]
 /// ```
@@ -651,6 +652,13 @@ pub struct ValidationErrorResponse {
     pub validation: Vec<String>,
 }
 
+/// Request body for posting new [`Event`]s to a [`Campaign`](crate::Campaign).
+#[derive(Serialize, Deserialize, Clone, Debug, PartialEq, Eq)]
+#[serde(rename_all = "camelCase")]
+pub struct InsertEventsRequest {
+    pub events: Vec<Event>,
+}
+
 pub mod channel_list {
     use crate::{ChainId, Channel, ValidatorId};
     use serde::{Deserialize, Serialize};

sentry/src/routes.rs

@@ -106,7 +106,8 @@
 //!
 //! Request body (json): [`ValidatorMessagesCreateRequest`](primitives::sentry::ValidatorMessagesCreateRequest)
 //!
-//! Example:
+//! ##### Examples:
+//!
 //! ```json
 //! {
 //!     "messages": [
@@ -231,14 +232,20 @@
 //! **Authentication is required** to validate [`Campaign.creator`](primitives::Campaign::creator) == [`Auth.uid`](crate::Auth::uid)
 //!
 //! It will make sure the `Channel` is created if new and it will update
-//! the spendable amount using the [`Adapter`]`::get_deposit()`.
+//! the spendable amount using the [`Adapter.get_deposit()`](adapter::client::Locked::get_deposit).
 //!
 //! The route is handled by [`campaign::create_campaign()`].
 //!
 //! Request body (json): [`CreateCampaign`][primitives::sentry::campaign_create::CreateCampaign]
 //!
 //! Response: [`Campaign`]
 //!
+//! ##### Examples
+//!
+//! ```
+#![doc = include_str!("../../primitives/examples/create_campaign.rs")]
+//! ```
+//!
 //! #### POST `/v5/campaign/:id` (auth required)
 //!
 //! Modify the [`Campaign`]. Request must be sent by the [`Campaign.creator`](primitives::Campaign::creator).
@@ -251,22 +258,20 @@
 //!
 //! Response: [`Campaign`]
 //!
+//! ##### Examples
+//!
+//! ```
+#![doc = include_str!("../../primitives/examples/modify_campaign.rs")]
+//! ```
+//!
 //! #### POST `/v5/campaign/:id/events`
 //!
 //! Add new [`Event`]s (`IMPRESSION`s & `CLICK`s) to the [`Campaign`].
 //! Applies [`Campaign.event_submission`] rules and additional validation using [`check_access()`].
 //!
 //! The route is handled by [`campaign::insert_events::handle_route()`].
 //!
-//! Request body (json):
-//!
-//! ```json
-//! {
-//!     "events": [
-//!         // Events
-//!    ]
-//! }
-//! ```
+//! Request body (json): [`InsertEventsRequest`](primitives::sentry::InsertEventsRequest)
 //!
 //! Response: [`SuccessResponse`]
 //!
@@ -294,6 +299,20 @@
 //!
 //! Response: [`AnalyticsResponse`]
 //!
+//! ##### Examples
+//!
+//! Query:
+//!
+//! ```
+#![doc = include_str!("../../primitives/examples/analytics_query.rs")]
+//! ```
+//!
+//! Response:
+//!
+//! ```
+#![doc = include_str!("../../primitives/examples/analytics_response.rs")]
+//! ```
+//!
 //! #### GET `/v5/analytics/for-publisher` (auth required)
 //!
 //! Returns all analytics where the currently authenticated address [`Auth.uid`](crate::Auth::uid) is a **publisher**.
@@ -306,6 +325,10 @@
 //!
 //! Response: [`AnalyticsResponse`]
 //!
+//! ##### Examples
+//!
+//! See [GET `/v5/analytics`](#get-v5analytics)
+//!
 //! #### GET `/v5/analytics/for-advertiser` (auth required)
 //!
 //! Returns all analytics where the currently authenticated address [`Auth.uid`](crate::Auth::uid) is an **advertiser**.
@@ -318,6 +341,10 @@
 //!
 //! Response: [`AnalyticsResponse`]
 //!
+//! ##### Examples
+//!
+//! See [GET `/v5/analytics`](#get-v5analytics)
+//!
 //! #### GET `/v5/analytics/for-admin` (auth required)
 //!
 //! Admin access to the analytics with no restrictions on the keys for filtering.
@@ -332,6 +359,10 @@
 //!
 //! Response: [`AnalyticsResponse`]
 //!
+//! ##### Examples
+//!
+//! See [GET `/v5/analytics`](#get-v5analytics)
+//!
 //! [`Adapter`]: adapter::Adapter
 //! [`Address`]: primitives::Address
 //! [`AllowedKey`]: primitives::analytics::query::AllowedKey

sentry/src/routes/campaign.rs

@@ -593,8 +593,6 @@ pub mod update_campaign {
 
 pub mod insert_events {
 
-    use std::collections::HashMap;
-
     use crate::{
         access::{self, check_access},
         analytics,
@@ -608,7 +606,7 @@ pub mod insert_events {
     use hyper::{Body, Request, Response};
     use primitives::{
         balances::{Balances, CheckedState, OverflowError},
-        sentry::{Event, SuccessResponse},
+        sentry::{Event, SuccessResponse, InsertEventsRequest},
         Address, Campaign, CampaignId, ChainOf, DomainError, UnifiedNum, ValidatorDesc,
     };
     use slog::{error, Logger};
@@ -642,9 +640,9 @@ pub mod insert_events {
 
     /// POST `/v5/campaign/:id/events`
     ///
-    /// The expected request body is `Vec<[Event](primitives::Event)>`
+    /// Request body (json): [`InsertEventsRequest`]
     ///
-    /// The expected Response is [`SuccessResponse`](primitives::sentry::SuccessResponse)
+    /// Response: [`SuccessResponse`]
     pub async fn handle_route<C: Locked + 'static>(
         req: Request<Body>,
         app: &Application<C>,
@@ -663,17 +661,13 @@ pub mod insert_events {
             .expect("request should have a Campaign loaded");
 
         let body_bytes = hyper::body::to_bytes(req_body).await?;
-        let mut request_body = serde_json::from_slice::<HashMap<String, Vec<Event>>>(&body_bytes)?;
-
-        let events = request_body
-            .remove("events")
-            .ok_or_else(|| ResponseError::BadRequest("invalid request".to_string()))?;
+        let request_body = serde_json::from_slice::<InsertEventsRequest>(&body_bytes)?;
 
-        let processed = process_events(app, auth, session, campaign_context, events).await?;
+        process_events(app, auth, session, campaign_context, request_body.events).await?;
 
         Ok(Response::builder()
             .header("Content-type", "application/json")
-            .body(serde_json::to_string(&SuccessResponse { success: processed })?.into())
+            .body(serde_json::to_string(&SuccessResponse { success: true })?.into())
             .unwrap())
     }
 
@@ -683,7 +677,7 @@ pub mod insert_events {
         session: &Session,
         campaign_context: &ChainOf<Campaign>,
         events: Vec<Event>,
-    ) -> Result<bool, ResponseError> {
+    ) -> Result<(), ResponseError> {
         let campaign = &campaign_context.context;
 
         // handle events - check access
@@ -732,7 +726,7 @@ pub mod insert_events {
             events_success,
         );
 
-        Ok(true)
+        Ok(())
     }
 
     /// Max retries is `5` after which an error logging message will be recorded.