move api docs into module

This commit is contained in:
Brandon Thomas committed 2024-07-07 17:23:19 -04:00
1 parent 45792890b7
commit ce186179ce
12 files changed
+17 -36

No files matched your search

@@ -17,23 +17,16 @@
#[macro_use] extern crate magic_crypt;
#[macro_use] extern crate serde_derive;
use utoipa_swagger_ui::SwaggerUi;
use std::error::Error;
use std::fs::File;
use std::io::Write;
use actix_web::{App, HttpServer, middleware, web};
use actix_web::middleware::{DefaultHeaders, Logger};
use r2d2_redis::r2d2;
use r2d2_redis::redis::Commands;
use r2d2_redis::RedisConnectionManager;
use sqlx::mysql::MySqlPoolOptions;
use sqlx::MySqlPool;
use tokio::runtime::Runtime;
use utoipa::OpenApi;
use docs::api_doc::ApiDoc;
use errors::AnyhowResult;
use crate::configs::static_api_tokens::{StaticApiTokenConfig, StaticApiTokens, StaticApiTokenSet};
use crate::state::server_state::{DurableInMemoryCaches, EnvConfig, EphemeralInMemoryCaches, InMemoryCaches, RedisRateLimiters, ServerInfo, ServerState, StaticFeatureFlags, StripeSettings, TrollBans};
pub mod billing;
pub mod configs;
pub mod http_server;
@@ -42,19 +35,7 @@ pub mod state;
pub mod threads;
pub mod util;
use std::{
error::Error,
future::{self, Ready},
net::Ipv4Addr,
};
use std::fs::File;
use std::io::Write;
pub mod api_doc;
use api_doc::ApiDoc;
use futures::future::LocalBoxFuture;
use utoipa::OpenApi;
pub mod docs;
#[actix_web::main]
async fn main() -> AnyhowResult<()> {
@@ -25,7 +25,7 @@ use sqlx::MySqlPool;
use utoipa::OpenApi;
use utoipa_swagger_ui::SwaggerUi;
use api_doc::ApiDoc;
use docs::api_doc::ApiDoc;
use errors::AnyhowResult;
use crate::configs::static_api_tokens::StaticApiTokenSet;
@@ -39,7 +39,7 @@ pub mod state;
pub mod threads;
pub mod util;
pub mod api_doc;
pub mod docs;
#[actix_web::main]
async fn main() -> Result<(), impl Error> {
@@ -2,12 +2,11 @@ use actix_web::HttpRequest;
use async_trait::async_trait;
use chrono::Utc;
use log::warn;
use sqlx::MySqlPool;
use billing_component::stripe::traits::internal_user_lookup::{InternalUserLookup, InternalUserLookupError, SubscriptionKey, UserMetadata};
use users_component::session::session_checker::SessionChecker;
use crate::MySqlPool;
/// A simple Actix injectable action
#[derive(Clone)]
pub struct StripeInternalUserLookupImpl {
@@ -0,0 +1 @@
pub mod api_doc;
@@ -5,7 +5,7 @@ use actix_web::{HttpRequest, HttpResponse, Responder, web};
use crate::http_server::endpoints::flags::design_refresh_flag::build_design_refresh_cookie::build_design_refresh_cookie;
use crate::http_server::endpoints::flags::get_cookie_domain::get_set_cookie_domain;
use crate::ServerState;
use crate::state::server_state::ServerState;
pub async fn disable_design_refresh_flag_handler(
http_request: HttpRequest,
@@ -5,7 +5,7 @@ use actix_web::{HttpRequest, HttpResponse, Responder, web};
use crate::http_server::endpoints::flags::design_refresh_flag::build_design_refresh_cookie::build_design_refresh_cookie;
use crate::http_server::endpoints::flags::get_cookie_domain::get_set_cookie_domain;
use crate::ServerState;
use crate::state::server_state::ServerState;
pub async fn enable_design_refresh_flag_handler(
http_request: HttpRequest,
@@ -8,7 +8,7 @@ use log::{debug, error, warn};
use mysql_queries::queries::generic_inference::web::get_pending_inference_job_count::get_pending_inference_job_count;
use crate::http_server::web_utils::response_error_helpers::to_simple_json_error;
use crate::ServerState;
use crate::state::server_state::ServerState;
#[derive(Serialize)]
pub struct GetPendingInferenceJobSuccessResponse {
@@ -7,7 +7,7 @@ use log::warn;
use mysql_queries::queries::stats::get_on_prem_worker_stats::get_on_prem_worker_stats;
use crate::http_server::web_utils::serialize_as_json_error::serialize_as_json_error;
use crate::ServerState;
use crate::state::server_state::ServerState;
const MIN_SAMPLE_SIZE : u32 = 100;
const MAX_SAMPLE_SIZE : u32 = 10_000;
@@ -9,7 +9,7 @@ use redis_common::redis_cache_keys::RedisCacheKeys;
use crate::http_server::endpoints::stats::result_transformer::{CacheableQueueStats, database_result_to_cacheable};
use crate::http_server::web_utils::response_error_helpers::to_simple_json_error;
use crate::ServerState;
use crate::state::server_state::ServerState;
#[derive(Serialize)]
pub struct GetUnifiedQueueStatsSuccessResponse {
@@ -8,7 +8,7 @@ use log::{debug, error, warn};
use mysql_queries::queries::tts::tts_inference_jobs::get_pending_tts_inference_job_count::get_pending_tts_inference_job_count;
use crate::http_server::web_utils::response_error_helpers::to_simple_json_error;
use crate::ServerState;
use crate::state::server_state::ServerState;
#[derive(Serialize)]
pub struct Response {
@@ -22,6 +22,7 @@ use users_component::session::http::http_user_session_manager::HttpUserSessionMa
use users_component::session::session_checker::SessionChecker;
use crate::configs::app_startup::username_set::UsernameSet;
use crate::configs::static_api_tokens::StaticApiTokenSet;
use crate::http_server::endpoints::categories::tts::list_fully_computed_assigned_tts_categories::list_fully_computed_assigned_tts_categories::ModelTokensByCategoryToken;
use crate::http_server::endpoints::leaderboard::get_leaderboard::LeaderboardInfo;
use crate::http_server::endpoints::stats::result_transformer::CacheableQueueStats;
@@ -29,7 +30,6 @@ use crate::http_server::endpoints::tts::list_tts_models::TtsModelRecordForRespon
use crate::http_server::endpoints::voice_conversion::models::list_voice_conversion_models::VoiceConversionModel;
use crate::http_server::web_utils::redis_rate_limiter::RedisRateLimiter;
use crate::state::memory_cache::model_token_to_info_cache::ModelTokenToInfoCache;
use crate::StaticApiTokenSet;
use crate::threads::db_health_checker_thread::db_health_check_status::HealthCheckStatus;
use crate::util::encrypted_sort_id::SortKeyCrypto;
use crate::util::troll_user_bans::troll_user_ban_list::TrollUserBanList;