use anyhow::Result;
use bytes::Bytes;
use reqwest::Method;
use crate::{
common::model::BangumiClient,
module::model::{Paged, SimpleImageType},
};
use super::model::{PersonCharacter, PersonDetail, PersonSearch, PersonSubject};
impl BangumiClient {
pub async fn search_persons(
&self,
limit: Option<u32>,
offset: Option<u32>,
payload: Option<PersonSearch>,
) -> Result<Paged<PersonDetail>> {
let url = format!("{}/v0/search/persons", self.base_path);
let mut request_builder = self.request_builder(Method::POST, &url);
if let Some(ref param_value) = limit {
request_builder = request_builder.query(&[("limit", ¶m_value)]);
}
if let Some(ref param_value) = offset {
request_builder = request_builder.query(&[("offset", ¶m_value)]);
}
request_builder = request_builder.json(&payload);
let res = self.request_send(request_builder).await?.json().await?;
Ok(res)
}
pub async fn get_person(&self, person_id: u32) -> Result<PersonDetail> {
let url = format!("{}/v0/persons/{person_id}", self.base_path);
let request_builder = self.request_builder(Method::GET, &url);
let res = self.request_send(request_builder).await?.json().await?;
Ok(res)
}
pub async fn get_person_image(&self, person_id: u32, r#type: SimpleImageType) -> Result<Bytes> {
let url = format!("{}/v0/persons/{person_id}/image", self.base_path);
let mut request_builder = self.request_builder(Method::GET, &url);
request_builder = request_builder.query(&[("type", &r#type)]);
let res = self.request_send(request_builder).await?.bytes().await?;
Ok(res)
}
pub async fn get_person_subjects(&self, person_id: u32) -> Result<Vec<PersonSubject>> {
let url = format!("{}/v0/persons/{person_id}/subjects", self.base_path);
let request_builder = self.request_builder(Method::GET, &url);
let res = self.request_send(request_builder).await?.json().await?;
Ok(res)
}
pub async fn get_person_characters(&self, person_id: u32) -> Result<Vec<PersonCharacter>> {
let url = format!("{}/v0/persons/{person_id}/characters", self.base_path);
let request_builder = self.request_builder(Method::GET, &url);
let res = self.request_send(request_builder).await?.json().await?;
Ok(res)
}
pub async fn collect_person(&self, person_id: u32) -> Result<()> {
let url = format!("{}/v0/persons/{person_id}/collect", self.base_path);
let request_builder = self.request_builder(Method::POST, &url);
let _res = self.request_send(request_builder).await?;
Ok(())
}
pub async fn uncollect_person(&self, person_id: u32) -> Result<()> {
let url = format!("{}/v0/persons/{person_id}/collect", self.base_path);
let request_builder = self.request_builder(Method::DELETE, &url);
let _res = self.request_send(request_builder).await?;
Ok(())
}
}