From bb16a5b7d24a3cbf70c27fcab8cc313cf4d0708e Mon Sep 17 00:00:00 2001
From: alemi <me@alemi.dev>
Date: Sat, 13 Apr 2024 03:21:25 +0200
Subject: [PATCH] fix: return response rather than parsing

so that deliveries work
---
 src/server/dispatcher.rs |  2 +-
 src/server/fetcher.rs    | 22 ++++++++++------------
 2 files changed, 11 insertions(+), 13 deletions(-)

diff --git a/src/server/dispatcher.rs b/src/server/dispatcher.rs
index 29241f5..e404666 100644
--- a/src/server/dispatcher.rs
+++ b/src/server/dispatcher.rs
@@ -98,7 +98,7 @@ async fn worker(db: DatabaseConnection, domain: String, poll_interval: u64, mut
 			continue;
 		};
 
-		if let Err(e) = Fetcher::request::<()>(
+		if let Err(e) = Fetcher::request(
 			Method::POST, &delivery.target,
 			Some(&serde_json::to_string(&payload).unwrap()),
 			&delivery.actor, &key, &domain
diff --git a/src/server/fetcher.rs b/src/server/fetcher.rs
index 69f88db..e80faad 100644
--- a/src/server/fetcher.rs
+++ b/src/server/fetcher.rs
@@ -3,7 +3,7 @@ use std::collections::BTreeMap;
 use base64::Engine;
 use http_signature_normalization::Config;
 use openssl::{hash::MessageDigest, pkey::{PKey, Private}, sign::Signer};
-use reqwest::{header::{CONTENT_TYPE, USER_AGENT}, Method};
+use reqwest::{header::{CONTENT_TYPE, USER_AGENT}, Method, Response};
 use sea_orm::{DatabaseConnection, EntityTrait, IntoActiveModel};
 
 use crate::{model, VERSION};
@@ -22,14 +22,14 @@ impl Fetcher {
 		Fetcher { db, domain, key: PKey::private_key_from_pem(key.as_bytes()).unwrap() }
 	}
 
-	pub async fn request<T: serde::de::DeserializeOwned>(
+	pub async fn request(
 		method: reqwest::Method,
 		url: &str,
 		payload: Option<&str>,
 		from: &str,
 		key: &PKey<Private>,
 		domain: &str,
-	) -> reqwest::Result<T> {
+	) -> reqwest::Result<Response> {
 		let host = Context::server(url);
 		let date = chrono::Utc::now().format("%a, %d %b %Y %H:%M:%S GMT").to_string(); // lmao @ "GMT"
 		let path = url.replace("https://", "").replace("http://", "").replace(&host, "");
@@ -87,9 +87,7 @@ impl Fetcher {
 			.header("Signature", signature_header)
 			.send()
 			.await?
-			.error_for_status()?
-			.json()
-			.await
+			.error_for_status()
 	}
 
 	pub async fn user(&self, id: &str) -> crate::Result<model::user::Model> {
@@ -97,9 +95,9 @@ impl Fetcher {
 			return Ok(x); // already in db, easy
 		}
 
-		let user = Self::request::<serde_json::Value>(
+		let user = Self::request(
 			Method::GET, id, None, &format!("https://{}", self.domain), &self.key, &self.domain,
-		).await?;
+		).await?.json::<serde_json::Value>().await?;
 		let user_model = model::user::Model::new(&user)?;
 
 		model::user::Entity::insert(user_model.clone().into_active_model())
@@ -113,9 +111,9 @@ impl Fetcher {
 			return Ok(x); // already in db, easy
 		}
 
-		let activity = Self::request::<serde_json::Value>(
+		let activity = Self::request(
 			Method::GET, id, None, &format!("https://{}", self.domain), &self.key, &self.domain,
-		).await?;
+		).await?.json::<serde_json::Value>().await?;
 		let activity_model = model::activity::Model::new(&activity)?;
 
 		model::activity::Entity::insert(activity_model.clone().into_active_model())
@@ -129,9 +127,9 @@ impl Fetcher {
 			return Ok(x); // already in db, easy
 		}
 
-		let object = Self::request::<serde_json::Value>(
+		let object = Self::request(
 			Method::GET, id, None, &format!("https://{}", self.domain), &self.key, &self.domain,
-		).await?;
+		).await?.json::<serde_json::Value>().await?;
 		let object_model = model::object::Model::new(&object)?;
 
 		model::object::Entity::insert(object_model.clone().into_active_model())