roark_rs/apis/
integrations_api.rs

1/*
2 * Roark Analytics API
3 *
4 * # Roark Analytics API - Voice AI Analytics Platform  The Roark Analytics API provides comprehensive monitoring, evaluation, and analytics capabilities for voice AI agents. This API allows developers to seamlessly integrate with the Roark platform to track call quality, analyze agent performance, and extract insights from voice interactions.  ## Key Features  - **Real-time Call Analysis**: Upload and analyze voice call recordings with AI-powered insights - **Sentiment Analysis**: Extract emotional tone, key phrases, and sentiment scores across 64+ emotions - **Agent Performance Evaluation**: Create custom evaluation jobs with configurable metrics and scoring - **Platform Integrations**: Native support for VAPI and Retell AI with webhook-based data ingestion - **Custom Analytics**: Build custom analytics pipelines with flexible data models and properties  ## Authentication  All API endpoints require Bearer token authentication. Include your API token in the Authorization header:  ``` Authorization: Bearer YOUR_API_TOKEN ```  ## Rate Limiting  The API implements rate limiting to ensure service stability. Rate limit headers are included in responses.  ## Error Handling  The API uses standard HTTP status codes and returns structured error responses with detailed error information including error types, codes, and human-readable messages.  ## Rust Code Generation  This OpenAPI specification has been optimized for Rust code generation with: - Snake_case field naming conventions - Proper nullable field handling with Option<T> - Comprehensive documentation for generated code - Type-safe enum definitions - Structured error handling
5 *
6 * The version of the OpenAPI document: 1.0.0
7 * Contact: support@roark.ai
8 * Generated by: https://openapi-generator.tech
9 */
10
11
12use reqwest;
13use serde::{Deserialize, Serialize, de::Error as _};
14use crate::{apis::ResponseContent, models};
15use super::{Error, configuration, ContentType};
16
17
18/// struct for typed errors of method [`create_retell_call`]
19#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum CreateRetellCallError {
22    Status400(models::ErrorResponse),
23    Status401(models::ErrorResponse),
24    Status403(models::ErrorResponse),
25    Status429(models::ErrorResponse),
26    Status500(models::ErrorResponse),
27    UnknownValue(serde_json::Value),
28}
29
30/// struct for typed errors of method [`create_vapi_call`]
31#[derive(Debug, Clone, Serialize, Deserialize)]
32#[serde(untagged)]
33pub enum CreateVapiCallError {
34    Status400(models::ErrorResponse),
35    Status401(models::ErrorResponse),
36    Status403(models::ErrorResponse),
37    Status429(models::ErrorResponse),
38    Status500(models::ErrorResponse),
39    UnknownValue(serde_json::Value),
40}
41
42
43/// Upload and process a Retell call recording by forwarding the call_ended webhook payload from Retell AI.
44pub async fn create_retell_call(configuration: &configuration::Configuration, retell_call_upload_request: models::RetellCallUploadRequest) -> Result<models::CreateVapiCall201Response, Error<CreateRetellCallError>> {
45    // add a prefix to parameters to efficiently prevent name collisions
46    let p_retell_call_upload_request = retell_call_upload_request;
47
48    let uri_str = format!("{}/v1/retell/call", configuration.base_path);
49    let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
50
51    if let Some(ref user_agent) = configuration.user_agent {
52        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
53    }
54    if let Some(ref token) = configuration.bearer_access_token {
55        req_builder = req_builder.bearer_auth(token.to_owned());
56    };
57    req_builder = req_builder.json(&p_retell_call_upload_request);
58
59    let req = req_builder.build()?;
60    let resp = configuration.client.execute(req).await?;
61
62    let status = resp.status();
63    let content_type = resp
64        .headers()
65        .get("content-type")
66        .and_then(|v| v.to_str().ok())
67        .unwrap_or("application/octet-stream");
68    let content_type = super::ContentType::from(content_type);
69
70    if !status.is_client_error() && !status.is_server_error() {
71        let content = resp.text().await?;
72        match content_type {
73            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
74            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::CreateVapiCall201Response`"))),
75            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::CreateVapiCall201Response`")))),
76        }
77    } else {
78        let content = resp.text().await?;
79        let entity: Option<CreateRetellCallError> = serde_json::from_str(&content).ok();
80        Err(Error::ResponseError(ResponseContent { status, content, entity }))
81    }
82}
83
84/// Upload and process a VAPI call recording by forwarding the end-of-call-report webhook payload from VAPI.
85pub async fn create_vapi_call(configuration: &configuration::Configuration, vapi_call_upload_request: models::VapiCallUploadRequest) -> Result<models::CreateVapiCall201Response, Error<CreateVapiCallError>> {
86    // add a prefix to parameters to efficiently prevent name collisions
87    let p_vapi_call_upload_request = vapi_call_upload_request;
88
89    let uri_str = format!("{}/v1/vapi/call", configuration.base_path);
90    let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
91
92    if let Some(ref user_agent) = configuration.user_agent {
93        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
94    }
95    if let Some(ref token) = configuration.bearer_access_token {
96        req_builder = req_builder.bearer_auth(token.to_owned());
97    };
98    req_builder = req_builder.json(&p_vapi_call_upload_request);
99
100    let req = req_builder.build()?;
101    let resp = configuration.client.execute(req).await?;
102
103    let status = resp.status();
104    let content_type = resp
105        .headers()
106        .get("content-type")
107        .and_then(|v| v.to_str().ok())
108        .unwrap_or("application/octet-stream");
109    let content_type = super::ContentType::from(content_type);
110
111    if !status.is_client_error() && !status.is_server_error() {
112        let content = resp.text().await?;
113        match content_type {
114            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
115            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::CreateVapiCall201Response`"))),
116            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::CreateVapiCall201Response`")))),
117        }
118    } else {
119        let content = resp.text().await?;
120        let entity: Option<CreateVapiCallError> = serde_json::from_str(&content).ok();
121        Err(Error::ResponseError(ResponseContent { status, content, entity }))
122    }
123}
124
roark_rs/apis/integrations_api.rs

roark_rs/apis/
integrations_api.rs
