Startsida Utforska Hjälp
Logga in
DragonOS-Community
/
triagebot
spegling av https://github.com/DragonOS-Community/triagebot.git
4
0
Fork 0
Filer Ärenden 0 Wiki
Bläddra i källkod

Respond to GitHub with a specific message if we ignored a request

Mark Rousskov 5 år sedan
förälder
80a2a67138
incheckning
3f10006ac4
2 ändrade filer med 7 tillägg och 8 borttagningar
Delad Vy Visa Diff Statistik
  1. 3 3
      src/lib.rs
  2. 4 5
      src/main.rs

+ 3 - 3
src/lib.rs
Visa fil 

@@ -81,7 +81,7 @@ pub async fn webhook(
 
     event: EventName,
 
     payload: String,
 
     ctx: &handlers::Context,
 
-) -> Result<(), WebhookError> {
 
+) -> Result<bool, WebhookError> {
 
     let event = match event {
 
         EventName::PullRequestReview => {
 
             let payload = deserialize_payload::<github::PullRequestReviewEvent>(&payload)
 
@@ -143,7 +143,7 @@ pub async fn webhook(
 
         }
 
         // Other events need not be handled
 
         EventName::Other => {
 
-            return Ok(());
 
+            return Ok(false);
 
         }
 
     };
 
     if let Err(err) = handlers::handle(&ctx, &event).await {
 
@@ -162,5 +162,5 @@ pub async fn webhook(
 
             }
 
         }
 
     }
 
-    Ok(())
 
+    Ok(true)
 
 }

+ 4 - 5
src/main.rs
Visa fil 

@@ -141,17 +141,16 @@ async fn serve_req(req: Request<Body>, ctx: Arc<Context>) -> Result<Response<Bod
 
     };
 
 
     match triagebot::webhook(event, payload, &ctx).await {
 
-        Ok(()) => {}
 
+        Ok(true) => Ok(Response::new(Body::from("processed request"))),
 
+        Ok(false) => Ok(Response::new(Body::from("ignored request"))),
 
         Err(err) => {
 
             log::error!("request failed: {:?}", err);
 
-            return Ok(Response::builder()
 
+            Ok(Response::builder()
 
                 .status(StatusCode::INTERNAL_SERVER_ERROR)
 
                 .body(Body::from(format!("request failed: {:?}", err)))
 
-                .unwrap());
 
+                .unwrap())
 
         }
 
     }
 
-
 
-    Ok(Response::new(Body::from("processed request")))
 
 }
 
 
 async fn run_server(addr: SocketAddr) -> anyhow::Result<()> {