sentry - routes - create validator messages

Author: elpiel

sentry/src/routes/channel.rs

@@ -905,6 +905,42 @@ pub mod validator_message {
         }))
     }
 
+    /// POST `/v5/channel/0xXXX.../validator-messages`
+    ///
+    /// Full details about the route's API and intend can be found in the [`routes`](crate::routes#post-v5channelidvalidator-messages-auth-required) module
+    ///
+    /// Request body (json): [`ValidatorMessagesCreateRequest`]
+    ///
+    /// Response: [`SuccessResponse`]
+    ///
+    /// # Examples
+    ///
+    /// Request:
+    ///
+    /// ```
+    #[doc = include_str!("../../../primitives/examples/validator_messages_create_request.rs")]
+    /// ```
+    pub async fn create_validator_messages_axum<C: Locked + 'static>(
+        Extension(app): Extension<Arc<Application<C>>>,
+        Extension(auth): Extension<Auth>,
+        Extension(channel_context): Extension<ChainOf<Channel>>,
+        Json(create_request): Json<ValidatorMessagesCreateRequest>,
+    ) -> Result<Json<SuccessResponse>, ResponseError> {
+        let channel = channel_context.context;
+
+        match channel.find_validator(auth.uid) {
+            None => Err(ResponseError::Unauthorized),
+            _ => {
+                try_join_all(create_request.messages.iter().map(|message| {
+                    insert_validator_message(&app.pool, &channel, &auth.uid, message)
+                }))
+                .await?;
+
+                Ok(Json(SuccessResponse { success: true }))
+            }
+        }
+    }
+
     /// GET `/v5/channel/0xXXX.../validator-messages`
     ///
     /// Full details about the route's API and intend can be found in the [`routes`](crate::routes#get-v5channelidvalidator-messages) module

sentry/src/routes/routers.rs

@@ -58,7 +58,7 @@ use super::{
     analytics::{analytics_axum, GET_ANALYTICS_ALLOWED_KEYS},
     channel::{
         channel_dummy_deposit_axum, channel_list_axum, channel_payout_axum,
-        validator_message::list_validator_messages_axum,
+        validator_message::{create_validator_messages_axum, list_validator_messages_axum},
     },
     units_for_slot::post_units_for_slot,
 };
@@ -149,6 +149,11 @@ pub fn channels_router_axum<C: Locked + 'static>() -> Router {
             post(channel_payout_axum::<C>)
                 .route_layer(middleware::from_fn(authentication_required::<C, _>)),
         )
+        .route(
+            "/validator-messages",
+            post(create_validator_messages_axum::<C>)
+                .route_layer(middleware::from_fn(authentication_required::<C, _>)),
+        )
         .route(
             "/validator-messages",
             get(list_validator_messages_axum::<C>),