WIP: mock repository

Parameters had been passed in wrong order. Added strong types to prevent
a repeat.

Cargo.toml

@@ -3,7 +3,7 @@ resolver = "2"
 members = ["crates/cli", "crates/server", "crates/config", "crates/git"]
 
 [workspace.package]
-version = "0.5.0"
+version = "0.5.1"
 edition = "2021"
 
 [workspace.lints.clippy]

crates/server/src/actors/repo/webhook.rs

@@ -194,9 +194,6 @@ impl Handler<WebhookMessage> for RepoActor {
             );
             return;
         }
-        let id = msg.id();
-        let span = tracing::info_span!("handle", ?id);
-        let _guard = span.enter();
         let body = msg.body();
         match serde_json::from_str::<Push>(body.as_str()) {
             Err(err) => warn!(?err, ?body, "Not a 'push'"),

crates/server/src/actors/webhook/message.rs

@@ -1,23 +1,18 @@
 //
 use actix::prelude::*;
 use git_next_config::RepoAlias;
-use ulid::Ulid;
 
 use crate::actors::repo::webhook::WebhookAuth;
 
 #[derive(Message, Debug, Clone, derive_more::Constructor)]
 #[rtype(result = "()")]
 pub struct WebhookMessage {
-    id: Id,
     // forge // TODO: differentiate between multiple forges
     repo_alias: RepoAlias,
     authorisation: WebhookAuth,
     body: Body,
 }
 impl WebhookMessage {
-    pub const fn id(&self) -> &Id {
-        &self.id
-    }
     pub const fn repo_alias(&self) -> &RepoAlias {
         &self.repo_alias
     }
@@ -29,9 +24,6 @@ impl WebhookMessage {
     }
 }
 
-#[derive(Clone, Copy, Debug, derive_more::Constructor)]
-pub struct Id(Ulid);
-
 #[derive(Clone, Debug, derive_more::Constructor)]
 pub struct Body(String);
 impl Body {

crates/server/src/actors/webhook/server.rs

@@ -4,7 +4,6 @@ use actix::prelude::*;
 
 use git_next_config::RepoAlias;
 use tracing::{info, warn};
-use ulid::Ulid;
 use warp::reject::Rejection;
 
 use crate::actors::{repo::webhook::WebhookAuth, webhook::message::WebhookMessage};
@@ -34,14 +33,16 @@ pub async fn start(
                 let repo_alias = RepoAlias::new(path);
                 let bytes = body.to_vec();
                 let body = message::Body::new(String::from_utf8_lossy(&bytes).to_string());
-                let id = message::Id::new(Ulid::new());
+                headers.get("Authorization").map_or_else(
-                match headers.get("Authorization") {
+                    || {
-                    Some(authorisation_header) => {
+                        warn!("No Authorization header");
-                        info!(?id, ?repo_alias, ?authorisation_header, "Received webhook",);
+                        Err(warp::reject())
+                    },
+                    |authorisation_header| {
+                        info!(?repo_alias, ?authorisation_header, "Received webhook",);
                         match parse_auth(authorisation_header) {
                             Ok(authorisation) => {
-                                let message =
+                                let message = WebhookMessage::new(repo_alias, authorisation, body);
-                                    WebhookMessage::new(id, repo_alias, authorisation, body);
                                 recipient
                                     .try_send(message)
                                     .map(|_| {
@@ -58,12 +59,8 @@ pub async fn start(
                                 Err(warp::reject())
                             }
                         }
-                    }
+                    },
-                    _ => {
+                )
-                        warn!("No Authorization header");
-                        Err(warp::reject())
-                    }
-                }
             },
         );