Lines
98 %
Functions
71.43 %
Branches
100 %
use std::{collections::HashMap, error::Error as StdError, sync::Arc};
use axum::{response::IntoResponse, Router};
use serde::{Deserialize, Serialize};
use sylvia_iot_corelib::{
constants::DbEngine,
http::{Json, Query},
};
use crate::{
libs::config::{self, Config},
models::{self, ConnOptions, Model, MongoDbOptions, SqliteOptions},
pub mod oauth2;
mod v1;
/// The resources used by this service.
#[derive(Clone)]
pub struct State {
/// The scope root path for the service.
///
/// For example `/auth`, the APIs are
/// - `http://host:port/auth/oauth2/xxx`
/// - `http://host:port/auth/api/v1/user/xxx`
/// - `http://host:port/auth/api/v1/client/xxx`
pub scope_path: &'static str,
/// The scopes for accessing APIs.
pub api_scopes: HashMap<String, Vec<String>>,
/// Jinja2 templates.
pub templates: HashMap<String, String>,
/// The database model.
pub model: Arc<dyn Model>,
}
/// The sylvia-iot module specific error codes in addition to standard
/// [`sylvia_iot_corelib::err::ErrResp`].
pub struct ErrReq;
/// Query parameters for `GET /version`
#[derive(Deserialize)]
pub struct GetVersionQuery {
q: Option<String>,
#[derive(Serialize)]
struct GetVersionRes<'a> {
data: GetVersionResData<'a>,
struct GetVersionResData<'a> {
name: &'a str,
version: &'a str,
const SERV_NAME: &'static str = env!("CARGO_PKG_NAME");
const SERV_VER: &'static str = env!("CARGO_PKG_VERSION");
impl ErrReq {
pub const USER_EXIST: (u16, &'static str) = (400, "err_auth_user_exist");
pub const USER_NOT_EXIST: (u16, &'static str) = (400, "err_auth_user_not_exist");
/// To create resources for the service.
pub async fn new_state(
scope_path: &'static str,
conf: &Config,
) -> Result<State, Box<dyn StdError>> {
let conf = config::apply_default(conf);
let db_opts = match conf.db.as_ref().unwrap().engine.as_ref().unwrap().as_str() {
DbEngine::MONGODB => {
let conf = conf.db.as_ref().unwrap().mongodb.as_ref().unwrap();
ConnOptions::MongoDB(MongoDbOptions {
url: conf.url.as_ref().unwrap().to_string(),
db: conf.database.as_ref().unwrap().to_string(),
pool_size: conf.pool_size,
})
_ => {
let conf = conf.db.as_ref().unwrap().sqlite.as_ref().unwrap();
ConnOptions::Sqlite(SqliteOptions {
path: conf.path.as_ref().unwrap().to_string(),
let model = models::new(&db_opts).await?;
Ok(State {
scope_path: match scope_path.len() {
0 => "/",
_ => scope_path,
},
api_scopes: conf.api_scopes.as_ref().unwrap().clone(),
templates: conf.templates.as_ref().unwrap().clone(),
model,
/// To register service URIs in the specified root path.
pub fn new_service(state: &State) -> Router {
Router::new().nest(
&state.scope_path,
Router::new()
.nest("/oauth2", oauth2::new_service(state))
.merge(v1::auth::new_service("/api/v1/auth", state))
.merge(v1::user::new_service("/api/v1/user", state))
.merge(v1::client::new_service("/api/v1/client", state)),
)
pub async fn get_version(Query(query): Query<GetVersionQuery>) -> impl IntoResponse {
if let Some(q) = query.q.as_ref() {
match q.as_str() {
"name" => return SERV_NAME.into_response(),
"version" => return SERV_VER.into_response(),
_ => (),
Json(GetVersionRes {
data: GetVersionResData {
name: SERV_NAME,
version: SERV_VER,
.into_response()