Compare commits
2 Commits
60478dbf27
...
5b9ff9213f
Author | SHA1 | Date |
---|---|---|
Astro | 5b9ff9213f | |
Astro | 669f9b4e52 |
|
@ -112,7 +112,16 @@ impl Post {
|
|||
url: actor.url.unwrap_or(actor.id),
|
||||
bot: actor.actor_type != "Person",
|
||||
},
|
||||
tags: self.tag,
|
||||
tags: self.tag.into_iter().filter_map(|mut tag| {
|
||||
while tag.name.chars().next() == Some('#') {
|
||||
tag.name.remove(0);
|
||||
}
|
||||
if tag.name.len() > 0 {
|
||||
Some(tag)
|
||||
} else {
|
||||
None
|
||||
}
|
||||
}).collect(),
|
||||
sensitive: self.sensitive,
|
||||
mentions: vec![],
|
||||
language,
|
||||
|
|
|
@ -1,9 +1,8 @@
|
|||
use std::{
|
||||
sync::Arc,
|
||||
time::{Instant, SystemTime},
|
||||
time::SystemTime,
|
||||
};
|
||||
use http::StatusCode;
|
||||
use metrics::histogram;
|
||||
use serde::Serialize;
|
||||
use sigh::{PrivateKey, SigningConfig, alg::RsaSha256};
|
||||
use super::{digest, error::Error};
|
||||
|
@ -43,20 +42,14 @@ pub async fn send_raw(
|
|||
.header("digest", digest_header)
|
||||
.body(body.as_ref().clone())
|
||||
.map_err(Error::HttpReq)?;
|
||||
let t1 = Instant::now();
|
||||
SigningConfig::new(RsaSha256, private_key, key_id)
|
||||
.sign(&mut req)?;
|
||||
let t2 = Instant::now();
|
||||
let req: reqwest::Request = req.try_into()?;
|
||||
let res = client.execute(req)
|
||||
.await?;
|
||||
let t3 = Instant::now();
|
||||
histogram!("relay_http_request_duration", t2 - t1);
|
||||
if res.status() >= StatusCode::OK && res.status() < StatusCode::MULTIPLE_CHOICES {
|
||||
histogram!("relay_http_response_duration", t3 - t2, "res" => "ok", "host" => host);
|
||||
Ok(())
|
||||
} else {
|
||||
histogram!("relay_http_response_duration", t3 - t2, "res" => "err", "host" => host);
|
||||
tracing::error!("send_raw {} response HTTP {}", url, res.status());
|
||||
let response = res.text().await?;
|
||||
Err(Error::Response(response))
|
||||
|
|
Loading…
Reference in New Issue