matrix/authentication-service
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-authentication-service.git synced 2025-11-20 12:02:22 +03:00
Code Activity

Update mas-iana-codegen to use reqwest

Browse Source
This commit is contained in:
Quentin Gliech
2024-07-01 18:38:38 +02:00
parent 925f85c2c2
commit cd7f69e93b
4 changed files with 192 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
crates/iana-codegen/src/traits.rs
View File

@@ -15,7 +15,6 @@
use anyhow::Context;
use async_trait::async_trait;
use convert_case::{Case, Casing};
use hyper::http;
use serde::de::DeserializeOwned;
use super::Client;
@@ -74,23 +73,23 @@ pub trait EnumEntry: DeserializeOwned + Send + Sync {
async fn fetch(client: &Client) -> anyhow::Result<Vec<(&'static str, EnumMember)>> {
tracing::info!("Fetching CSV");
let request = http::Request::get(Self::URL)
.header("User-Agent", "mas-iana-codegen/0.1")
.body(hyper::Body::empty())?;
let response = client
.request(request)
.get(Self::URL)
.header("User-Agent", "mas-iana-codegen/0.1")
.send()
.await
.context(format!("can't the CSV at {}", Self::URL))?;
let status = response.status();
anyhow::ensure!(status.is_success(), "HTTP status code is not 200: {status}");
let body = hyper::body::to_bytes(response.into_body())
let body = response
.text()
.await
.context(format!("can't the CSV body at {}", Self::URL))?;
let parsed: Result<Vec<_>, _> = csv::Reader::from_reader(body.as_ref())
let parsed: Result<Vec<_>, _> = csv::Reader::from_reader(body.as_bytes())
.into_deserialize()
.filter_map(|item: Result<Self, _>| {
item.map(|item| {