From e75a341241313f53f607a97d3c291cce9717c7e9 Mon Sep 17 00:00:00 2001
From: Valentin Brandl <vbrandl@riseup.net>
Date: Sun, 28 Jul 2019 17:07:15 +0200
Subject: [PATCH] Debug endpoint

---
 backend/src/cdn.rs  | 20 +++++++++++++++++++-
 backend/src/main.rs | 19 ++++++++++---------
 2 files changed, 29 insertions(+), 10 deletions(-)

diff --git a/backend/src/cdn.rs b/backend/src/cdn.rs
index 68a1552..39a0623 100644
--- a/backend/src/cdn.rs
+++ b/backend/src/cdn.rs
@@ -2,7 +2,7 @@ use crate::{
     service::Service,
     statics::{self, CF_ZONE_IDENT},
 };
-use actix_web::{http::header, Error};
+use actix_web::{http::header, Error, HttpResponse};
 use awc::Client;
 use futures::Future;
 
@@ -13,6 +13,24 @@ impl Cloudflare {
         &CF_ZONE_IDENT
     }
 
+    pub(crate) fn dbg<T: Service>(
+        client: &Client,
+        file: &str,
+    ) -> impl Future<Item = HttpResponse, Error = Error> {
+        client
+            .post(format!(
+                "https://api.cloudflare.com/client/v4/zones/{}/purge_cache",
+                Self::identifier()
+            ))
+            .header(header::USER_AGENT, statics::USER_AGENT.as_str())
+            .header("X-Auth-Email", Self::auth_email())
+            .header("X-Auth-Key", Self::auth_key())
+            .content_type("application/json")
+            .send_json(&CfPurgeRequest::singleton::<T>(file))
+            .from_err()
+            .and_then(|response| HttpResponse::build(response.status()).streaming(response))
+    }
+
     pub(crate) fn purge_cache<T: Service>(
         client: &Client,
         file: &str,
diff --git a/backend/src/main.rs b/backend/src/main.rs
index 25d67bd..6fc3d79 100644
--- a/backend/src/main.rs
+++ b/backend/src/main.rs
@@ -104,6 +104,13 @@ fn purge_cache<T: Service>(
         .map(|success| HttpResponse::Ok().body(success.to_string()))
 }
 
+fn dbg<T: Service>(
+    client: web::Data<Client>,
+    file: web::Path<String>,
+) -> impl Future<Item = HttpResponse, Error = Error> {
+    Cloudflare::dbg::<T>(&client, &file)
+}
+
 fn main() -> Result<()> {
     std::env::set_var("RUST_LOG", "actix_server=info,actix_web=trace");
     pretty_env_logger::init();
@@ -118,26 +125,20 @@ fn main() -> Result<()> {
                 "/github/{user}/{repo}/{commit}/{file:.*}",
                 web::get().to_async(handle_request::<Github>),
             )
-            .route(
-                "/github/{file:.*}",
-                web::delete().to_async(purge_cache::<Github>),
-            )
+            .route("/github/{file:.*}", web::delete().to_async(dbg::<Github>))
             .route(
                 "/bitbucket/{user}/{repo}/{commit}/{file:.*}",
                 web::get().to_async(handle_request::<Bitbucket>),
             )
             .route(
                 "/bitbucket//{file:.*}",
-                web::delete().to_async(purge_cache::<Bitbucket>),
+                web::delete().to_async(dbg::<Bitbucket>),
             )
             .route(
                 "/gitlab/{user}/{repo}/{commit}/{file:.*}",
                 web::get().to_async(handle_request::<GitLab>),
             )
-            .route(
-                "/gitlab/{file:.*}",
-                web::delete().to_async(purge_cache::<GitLab>),
-            )
+            .route("/gitlab/{file:.*}", web::delete().to_async(dbg::<GitLab>))
             .service(actix_files::Files::new("/", "public").index_file("index.html"))
     })
     .workers(OPT.workers)