use reqwest;
use serde::{Deserialize, Serialize};
use crate::{apis::ResponseContent, models};
use super::{Error, configuration};
#[derive(Clone, Debug)]
pub struct CreateRealtimeTranscriptionParams {
pub account_sid: String,
pub call_sid: String,
pub name: Option<String>,
pub track: Option<String>,
pub status_callback_url: Option<String>,
pub status_callback_method: Option<String>,
pub inbound_track_label: Option<String>,
pub outbound_track_label: Option<String>,
pub partial_results: Option<bool>,
pub language_code: Option<String>,
pub transcription_engine: Option<String>,
pub profanity_filter: Option<bool>,
pub speech_model: Option<String>,
pub hints: Option<String>,
pub enable_automatic_punctuation: Option<bool>
}
#[derive(Clone, Debug)]
pub struct DeleteRecordingTranscriptionParams {
pub account_sid: String,
pub recording_sid: String,
pub sid: String
}
#[derive(Clone, Debug)]
pub struct DeleteTranscriptionParams {
pub account_sid: String,
pub sid: String
}
#[derive(Clone, Debug)]
pub struct FetchRecordingTranscriptionParams {
pub account_sid: String,
pub recording_sid: String,
pub sid: String
}
#[derive(Clone, Debug)]
pub struct FetchTranscriptionParams {
pub account_sid: String,
pub sid: String
}
#[derive(Clone, Debug)]
pub struct ListRecordingTranscriptionParams {
pub account_sid: String,
pub recording_sid: String,
pub page_size: Option<i32>,
pub page: Option<i32>,
pub page_token: Option<String>
}
#[derive(Clone, Debug)]
pub struct ListTranscriptionParams {
pub account_sid: String,
pub page_size: Option<i32>,
pub page: Option<i32>,
pub page_token: Option<String>
}
#[derive(Clone, Debug)]
pub struct UpdateRealtimeTranscriptionParams {
pub account_sid: String,
pub call_sid: String,
pub sid: String,
pub status: String
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum CreateRealtimeTranscriptionError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteRecordingTranscriptionError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteTranscriptionError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum FetchRecordingTranscriptionError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum FetchTranscriptionError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum ListRecordingTranscriptionError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum ListTranscriptionError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum UpdateRealtimeTranscriptionError {
UnknownValue(serde_json::Value),
}
pub async fn create_realtime_transcription(configuration: &configuration::Configuration, params: CreateRealtimeTranscriptionParams) -> Result<models::ApiPeriodV2010PeriodAccountPeriodCallPeriodRealtimeTranscription, Error<CreateRealtimeTranscriptionError>> {
let local_var_configuration = configuration;
let account_sid = params.account_sid;
let call_sid = params.call_sid;
let name = params.name;
let track = params.track;
let status_callback_url = params.status_callback_url;
let status_callback_method = params.status_callback_method;
let inbound_track_label = params.inbound_track_label;
let outbound_track_label = params.outbound_track_label;
let partial_results = params.partial_results;
let language_code = params.language_code;
let transcription_engine = params.transcription_engine;
let profanity_filter = params.profanity_filter;
let speech_model = params.speech_model;
let hints = params.hints;
let enable_automatic_punctuation = params.enable_automatic_punctuation;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/2010-04-01/Accounts/{AccountSid}/Calls/{CallSid}/Transcriptions.json", local_var_configuration.base_path, AccountSid=crate::apis::urlencode(account_sid), CallSid=crate::apis::urlencode(call_sid));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_auth_conf) = local_var_configuration.basic_auth {
local_var_req_builder = local_var_req_builder.basic_auth(local_var_auth_conf.0.to_owned(), local_var_auth_conf.1.to_owned());
};
let mut local_var_form_params = std::collections::HashMap::new();
if let Some(local_var_param_value) = name {
local_var_form_params.insert("Name", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = track {
local_var_form_params.insert("Track", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = status_callback_url {
local_var_form_params.insert("StatusCallbackUrl", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = status_callback_method {
local_var_form_params.insert("StatusCallbackMethod", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = inbound_track_label {
local_var_form_params.insert("InboundTrackLabel", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = outbound_track_label {
local_var_form_params.insert("OutboundTrackLabel", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = partial_results {
local_var_form_params.insert("PartialResults", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = language_code {
local_var_form_params.insert("LanguageCode", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = transcription_engine {
local_var_form_params.insert("TranscriptionEngine", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = profanity_filter {
local_var_form_params.insert("ProfanityFilter", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = speech_model {
local_var_form_params.insert("SpeechModel", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = hints {
local_var_form_params.insert("Hints", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = enable_automatic_punctuation {
local_var_form_params.insert("EnableAutomaticPunctuation", local_var_param_value.to_string());
}
local_var_req_builder = local_var_req_builder.form(&local_var_form_params);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<CreateRealtimeTranscriptionError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn delete_recording_transcription(configuration: &configuration::Configuration, params: DeleteRecordingTranscriptionParams) -> Result<(), Error<DeleteRecordingTranscriptionError>> {
let local_var_configuration = configuration;
let account_sid = params.account_sid;
let recording_sid = params.recording_sid;
let sid = params.sid;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/2010-04-01/Accounts/{AccountSid}/Recordings/{RecordingSid}/Transcriptions/{Sid}.json", local_var_configuration.base_path, AccountSid=crate::apis::urlencode(account_sid), RecordingSid=crate::apis::urlencode(recording_sid), Sid=crate::apis::urlencode(sid));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_auth_conf) = local_var_configuration.basic_auth {
local_var_req_builder = local_var_req_builder.basic_auth(local_var_auth_conf.0.to_owned(), local_var_auth_conf.1.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<DeleteRecordingTranscriptionError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn delete_transcription(configuration: &configuration::Configuration, params: DeleteTranscriptionParams) -> Result<(), Error<DeleteTranscriptionError>> {
let local_var_configuration = configuration;
let account_sid = params.account_sid;
let sid = params.sid;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/2010-04-01/Accounts/{AccountSid}/Transcriptions/{Sid}.json", local_var_configuration.base_path, AccountSid=crate::apis::urlencode(account_sid), Sid=crate::apis::urlencode(sid));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_auth_conf) = local_var_configuration.basic_auth {
local_var_req_builder = local_var_req_builder.basic_auth(local_var_auth_conf.0.to_owned(), local_var_auth_conf.1.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<DeleteTranscriptionError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn fetch_recording_transcription(configuration: &configuration::Configuration, params: FetchRecordingTranscriptionParams) -> Result<models::ApiPeriodV2010PeriodAccountPeriodRecordingPeriodRecordingTranscription, Error<FetchRecordingTranscriptionError>> {
let local_var_configuration = configuration;
let account_sid = params.account_sid;
let recording_sid = params.recording_sid;
let sid = params.sid;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/2010-04-01/Accounts/{AccountSid}/Recordings/{RecordingSid}/Transcriptions/{Sid}.json", local_var_configuration.base_path, AccountSid=crate::apis::urlencode(account_sid), RecordingSid=crate::apis::urlencode(recording_sid), Sid=crate::apis::urlencode(sid));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_auth_conf) = local_var_configuration.basic_auth {
local_var_req_builder = local_var_req_builder.basic_auth(local_var_auth_conf.0.to_owned(), local_var_auth_conf.1.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<FetchRecordingTranscriptionError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn fetch_transcription(configuration: &configuration::Configuration, params: FetchTranscriptionParams) -> Result<models::ApiPeriodV2010PeriodAccountPeriodTranscription, Error<FetchTranscriptionError>> {
let local_var_configuration = configuration;
let account_sid = params.account_sid;
let sid = params.sid;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/2010-04-01/Accounts/{AccountSid}/Transcriptions/{Sid}.json", local_var_configuration.base_path, AccountSid=crate::apis::urlencode(account_sid), Sid=crate::apis::urlencode(sid));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_auth_conf) = local_var_configuration.basic_auth {
local_var_req_builder = local_var_req_builder.basic_auth(local_var_auth_conf.0.to_owned(), local_var_auth_conf.1.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<FetchTranscriptionError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn list_recording_transcription(configuration: &configuration::Configuration, params: ListRecordingTranscriptionParams) -> Result<models::ListRecordingTranscriptionResponse, Error<ListRecordingTranscriptionError>> {
let local_var_configuration = configuration;
let account_sid = params.account_sid;
let recording_sid = params.recording_sid;
let page_size = params.page_size;
let page = params.page;
let page_token = params.page_token;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/2010-04-01/Accounts/{AccountSid}/Recordings/{RecordingSid}/Transcriptions.json", local_var_configuration.base_path, AccountSid=crate::apis::urlencode(account_sid), RecordingSid=crate::apis::urlencode(recording_sid));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref local_var_str) = page_size {
local_var_req_builder = local_var_req_builder.query(&[("PageSize", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = page {
local_var_req_builder = local_var_req_builder.query(&[("Page", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = page_token {
local_var_req_builder = local_var_req_builder.query(&[("PageToken", &local_var_str.to_string())]);
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_auth_conf) = local_var_configuration.basic_auth {
local_var_req_builder = local_var_req_builder.basic_auth(local_var_auth_conf.0.to_owned(), local_var_auth_conf.1.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<ListRecordingTranscriptionError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn list_transcription(configuration: &configuration::Configuration, params: ListTranscriptionParams) -> Result<models::ListTranscriptionResponse, Error<ListTranscriptionError>> {
let local_var_configuration = configuration;
let account_sid = params.account_sid;
let page_size = params.page_size;
let page = params.page;
let page_token = params.page_token;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/2010-04-01/Accounts/{AccountSid}/Transcriptions.json", local_var_configuration.base_path, AccountSid=crate::apis::urlencode(account_sid));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref local_var_str) = page_size {
local_var_req_builder = local_var_req_builder.query(&[("PageSize", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = page {
local_var_req_builder = local_var_req_builder.query(&[("Page", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = page_token {
local_var_req_builder = local_var_req_builder.query(&[("PageToken", &local_var_str.to_string())]);
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_auth_conf) = local_var_configuration.basic_auth {
local_var_req_builder = local_var_req_builder.basic_auth(local_var_auth_conf.0.to_owned(), local_var_auth_conf.1.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<ListTranscriptionError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn update_realtime_transcription(configuration: &configuration::Configuration, params: UpdateRealtimeTranscriptionParams) -> Result<models::ApiPeriodV2010PeriodAccountPeriodCallPeriodRealtimeTranscription, Error<UpdateRealtimeTranscriptionError>> {
let local_var_configuration = configuration;
let account_sid = params.account_sid;
let call_sid = params.call_sid;
let sid = params.sid;
let status = params.status;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/2010-04-01/Accounts/{AccountSid}/Calls/{CallSid}/Transcriptions/{Sid}.json", local_var_configuration.base_path, AccountSid=crate::apis::urlencode(account_sid), CallSid=crate::apis::urlencode(call_sid), Sid=crate::apis::urlencode(sid));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_auth_conf) = local_var_configuration.basic_auth {
local_var_req_builder = local_var_req_builder.basic_auth(local_var_auth_conf.0.to_owned(), local_var_auth_conf.1.to_owned());
};
let mut local_var_form_params = std::collections::HashMap::new();
local_var_form_params.insert("Status", status.to_string());
local_var_req_builder = local_var_req_builder.form(&local_var_form_params);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<UpdateRealtimeTranscriptionError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}