Translate to monolithic architecture

Signed-off-by: Nikolaos Karaolidis <nick@karaolidis.com>

backend/src/routes/assets.rs

@@ -0,0 +1,115 @@
+use crate::database;
+use crate::database::assets::update_asset_trading;
+use crate::pool::AlpacaPool;
+use crate::types::{Asset, Class, Exchange};
+use apca::api::v2::asset::{self, Symbol};
+use axum::{extract::Path, http::StatusCode, Extension, Json};
+use serde::Deserialize;
+use sqlx::{
+    types::{time::OffsetDateTime, Uuid},
+    PgPool,
+};
+
+pub async fn get_assets(
+    Extension(database_pool): Extension<PgPool>,
+) -> Result<(StatusCode, Json<Vec<Asset>>), StatusCode> {
+    let assets = database::assets::get_assets(&database_pool)
+        .await
+        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;
+
+    Ok((StatusCode::OK, Json(assets)))
+}
+
+pub async fn get_asset(
+    Extension(database_pool): Extension<PgPool>,
+    Path(symbol): Path<String>,
+) -> Result<(StatusCode, Json<Asset>), StatusCode> {
+    let asset = database::assets::get_asset(&database_pool, &symbol)
+        .await
+        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;
+
+    match asset {
+        Some(asset) => Ok((StatusCode::OK, Json(asset))),
+        None => Err(StatusCode::NOT_FOUND),
+    }
+}
+
+#[allow(dead_code)]
+#[derive(Deserialize)]
+pub struct AddAssetRequest {
+    symbol: String,
+    trading: Option<bool>,
+}
+
+pub async fn add_asset(
+    Extension(database_pool): Extension<PgPool>,
+    Extension(alpaca_pool): Extension<AlpacaPool>,
+    Json(request): Json<AddAssetRequest>,
+) -> Result<(StatusCode, Json<Asset>), StatusCode> {
+    if database::assets::get_asset(&database_pool, &request.symbol)
+        .await
+        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?
+        .is_some()
+    {
+        return Err(StatusCode::CONFLICT);
+    }
+
+    let asset = alpaca_pool
+        .get()
+        .await
+        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?
+        .issue::<asset::Get>(&Symbol::Sym(request.symbol))
+        .await
+        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;
+
+    let asset = Asset {
+        id: Uuid::parse_str(&asset.id.to_string())
+            .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?,
+        symbol: asset.symbol,
+        class: Class::from(asset.class) as Class,
+        exchange: Exchange::from(asset.exchange) as Exchange,
+        trading: request.trading.unwrap_or(false),
+        date_added: OffsetDateTime::now_utc(),
+    };
+
+    let asset = database::assets::add_asset(&database_pool, asset)
+        .await
+        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;
+
+    Ok((StatusCode::CREATED, Json(asset)))
+}
+
+#[allow(dead_code)]
+#[derive(Deserialize)]
+pub struct UpdateAssetRequest {
+    trading: bool,
+}
+
+pub async fn update_asset(
+    Extension(database_pool): Extension<PgPool>,
+    Path(symbol): Path<String>,
+    Json(request): Json<UpdateAssetRequest>,
+) -> Result<(StatusCode, Json<Asset>), StatusCode> {
+    let asset = update_asset_trading(&database_pool, &symbol, request.trading)
+        .await
+        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;
+
+    match asset {
+        Some(asset) => Ok((StatusCode::OK, Json(asset))),
+        None => Err(StatusCode::NOT_FOUND),
+    }
+}
+
+pub async fn delete_asset(
+    Extension(database_pool): Extension<PgPool>,
+    Path(symbol): Path<String>,
+) -> Result<(StatusCode, Json<Asset>), StatusCode> {
+    let asset = database::assets::delete_asset(&database_pool, &symbol)
+        .await
+        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;
+
+    match asset {
+        Some(asset) => Ok((StatusCode::NO_CONTENT, Json(asset))),
+        None => Err(StatusCode::NOT_FOUND),
+    }
+}