added route for cryptocurrencies

Cargo.toml

@@ -17,6 +17,8 @@ env_logger = "0.10.0"
 tokio-cron-scheduler = "0.9.4"
 async-trait = "0.1.73"
 chrono = { version = "0.4.31", features = ["serde"] }
+actix = "0.13.1"
+actix-web = "4.4.0"
 
 error.path = "libs/error"
 sdks.path = "libs/sdks"

api/Cargo.toml

@@ -16,6 +16,8 @@ config.workspace = true
 env_logger.workspace = true
 tokio-cron-scheduler.workspace = true
 async-trait.workspace = true
+actix.workspace = true
+actix-web.workspace = true
 
 [[bin]]
 path = "src/main.rs"

api/src/api/cryptocurrencies/contract.rs

@@ -1,4 +1,12 @@
+use error::Result;
+use store::objects::CryptoCurrencyView;
+
 #[async_trait]
-pub trait DbRepository{
+pub trait DbRepositoryContract{
+ async fn get_cryptocurrencies(&self) -> Result<Vec<CryptoCurrencyView>>;
+}
 
+#[async_trait]
+pub trait CryptocurrenciesContract{
+ async fn get_cryptocurrencies(&self) -> Result<Vec<CryptoCurrencyView>>;
 }

api/src/api/cryptocurrencies/domain.rs

@@ -0,0 +1,14 @@
+use super::contract::{CryptocurrenciesContract, DbRepositoryContract};
+use error::Result;
+use store::objects::CryptoCurrencyView;
+
+pub struct Cryptocurrencies<A: DbRepositoryContract> {
+ pub(super) repository: A,
+}
+
+#[async_trait]
+impl<A: DbRepositoryContract + Send + Sync> CryptocurrenciesContract for Cryptocurrencies<A> {
+ async fn get_cryptocurrencies(&self) -> Result<Vec<CryptoCurrencyView>> {
+ self.repository.get_cryptocurrencies().await
+ }
+}

api/src/api/cryptocurrencies/handlers/get.rs

@@ -0,0 +1,11 @@
+use actix_web::{web::Data, HttpResponse};
+use error::Result;
+
+use crate::api::cryptocurrencies::contract::CryptocurrenciesContract;
+
+pub async fn get_cryptocurrencies<S: CryptocurrenciesContract>(
+ service: Data<S>,
+) -> Result<HttpResponse> {
+ let value = service.get_cryptocurrencies().await?;
+ Ok(HttpResponse::Ok().json(value))
+}

api/src/api/cryptocurrencies/handlers/mod.rs

@@ -0,0 +1,2 @@
+mod get;
+pub use get::get_cryptocurrencies;

api/src/api/cryptocurrencies/mod.rs

@@ -1,4 +1,24 @@
+use std::sync::Arc;
+
+use actix_web::web::{self, resource, Data, ServiceConfig};
+use sea_orm::DatabaseConnection;
+
+use self::{domain::Cryptocurrencies, handlers::*, repository::PgRepository};
+
 mod contract;
-mod repository;
 mod domain;
-mod handlers;
+mod handlers;
+mod repository;
+
+pub fn setup(conn: Arc<DatabaseConnection>, config: &mut ServiceConfig) {
+ let state = Cryptocurrencies {
+ repository: PgRepository::new(conn),
+ };
+
+ config.app_data(Data::new(state));
+
+ config.service(
+ resource("/api/{version}/crypto")
+ .route(web::get().to(get_cryptocurrencies::<Cryptocurrencies<PgRepository>>)),
+ );
+}

api/src/api/cryptocurrencies/repository.rs

@@ -1,6 +1,14 @@
-use sea_orm::{DatabaseConnection, EntityTrait, QueryFilter, ColumnTrait, QuerySelect};
+use error::{Error, Result};
+use sea_orm::{
+ sea_query::Expr, ColumnTrait, DatabaseConnection, EntityTrait, JoinType, QueryFilter,
+ QuerySelect, RelationTrait, SelectColumns,
+};
 use std::sync::Arc;
-use store::{cryptocurrencies, github_projects, github_repositories, issues};
+use store::{
+ cryptocurrencies, github_projects, github_repositories, issues, objects::CryptoCurrencyView,
+};
+
+use super::contract::DbRepositoryContract;
 
 pub struct PgRepository {
  conn: Arc<DatabaseConnection>,
@@ -12,41 +20,38 @@ impl PgRepository {
  }
 }
 
-impl PgRepository {
- pub fn fetch(&self) {
- let query = github_projects::Entity::find()
+#[async_trait]
+impl DbRepositoryContract for PgRepository {
+ async fn get_cryptocurrencies(&self) -> Result<Vec<CryptoCurrencyView>> {
+ github_projects::Entity::find()
  .inner_join(cryptocurrencies::Entity)
  .left_join(github_repositories::Entity)
+ .join_rev(
+ JoinType::LeftJoin,
+ issues::Relation::GithubRepositories.def(),
+ )
  .filter(github_repositories::Column::RepositoryName.is_not_null())
  .group_by(cryptocurrencies::Column::Id)
  .group_by(cryptocurrencies::Column::Name)
  .group_by(cryptocurrencies::Column::CoingeckoId)
- .group_by(cryptocurrencies::Column::Github )
- .group_by(github_projects::Column::Name) ;
+ .group_by(cryptocurrencies::Column::Github)
+ .group_by(github_projects::Column::Name)
+ .select_only()
+ .columns([
+ cryptocurrencies::Column::Id,
+ cryptocurrencies::Column::Name,
+ cryptocurrencies::Column::CoingeckoId,
+ ])
+ .select_column_as(cryptocurrencies::Column::Github, "github_id")
+ .column_as(github_projects::Column::Name, "github")
+ .expr(Expr::cust_with_expr(
+ "array_agg(distinct $1) as repositories",
+ github_repositories::Column::RepositoryName.into_expr(),
+ ))
+ .column_as(issues::Column::Id.count(), "issues")
+ .into_model::<CryptoCurrencyView>()
+ .all(self.conn.as_ref())
+ .await
+ .map_err(Error::from)
  }
-}
-/*
-select
- c.id,
- c."name",
- c.coingecko_id,
- c.github,
- gp."name",
- array_agg(gr.repository_name),
- count(i)
-from
- cryptocurrencies c
-inner join github_projects gp on
- gp.id = c.github
-left join github_repositories gr on
- gr.project = gp.id
-left join issues i on
- i.repository = gr.id
-where gr.repository_name notnull
-group by 
- c.id,
- c."name",
- c.coingecko_id,
- c.github,
- gp."name"
-*/
+}

api/src/api/mod.rs

@@ -1 +1,25 @@
-mod cryptocurrencies;
+use std::sync::Arc;
+
+use actix_web::{dev::Server, web::ServiceConfig, App, HttpServer};
+use sea_orm::DatabaseConnection;
+
+mod cryptocurrencies;
+
+pub fn create_api(conn: Arc<DatabaseConnection>) -> Server {
+ let workers = match config::get_default("IS_DEV", "false").as_str() == "true" {
+ true => 1,
+ false => config::get_default("ACTIX_WORKERS", "8")
+ .parse()
+ .unwrap_or(8),
+ };
+
+ HttpServer::new(move || App::new().configure(|config| configure_routes(conn.clone(), config)))
+ .workers(workers)
+ .bind(("localhost", 1111))
+ .expect("Unable to start sever")
+ .run()
+}
+
+fn configure_routes(conn: Arc<DatabaseConnection>, config: &mut ServiceConfig) {
+ cryptocurrencies::setup(conn, config);
+}

api/src/lib.rs

@@ -5,4 +5,7 @@ extern crate log;
 extern crate async_trait;
 
 pub mod jobs;
-mod api;
+mod api;
+
+pub use jobs::setup as setup_jobs; 
+pub use api::create_api;

api/src/main.rs

@@ -1,9 +1,7 @@
-use std::{sync::Arc, time::Duration};
-
-use api::jobs;
+use api::{create_api, setup_jobs};
 use config::dotenv_init;
 use sea_orm::Database;
-use tokio::time::interval;
+use std::sync::Arc;
 
 #[tokio::main]
 async fn main() {
@@ -16,10 +14,7 @@ async fn main() {
  let pool = Database::connect(db_url).await.unwrap();
  let sea_pool = Arc::new(pool);
 
- let _handles = jobs::setup(sea_pool);
+ let _handles = setup_jobs(sea_pool.clone());
 
- let mut period = interval(Duration::from_millis(100));
- loop {
- period.tick().await;
- }
+ create_api(sea_pool).await.expect("Error starting server");
 }

libs/config/src/lib.rs

@@ -9,3 +9,7 @@ pub fn get(key: &str) -> Result<String> {
 pub fn dotenv_init() {
  dotenv::dotenv().expect("Error running reading dotenv");
 }
+
+pub fn get_default(key: &str, default: &str) -> String{
+ get(key).unwrap_or(default.to_owned())
+}

libs/error/Cargo.toml

@@ -6,6 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+actix-web.workspace = true
 reqwest.workspace = true
 sea-orm.workspace = true
 serde_json.workspace = true

libs/error/src/actix.rs

@@ -0,0 +1,10 @@
+use actix_web::{HttpResponse, ResponseError};
+
+use crate::Error;
+
+impl ResponseError for Error {
+ fn error_response(&self) -> HttpResponse {
+ println!("{}", self);
+ HttpResponse::Ok().finish()
+ }
+}

libs/error/src/lib.rs

@@ -1,5 +1,7 @@
 use thiserror::Error;
 
+mod actix;
+
 pub type Result<T> = std::result::Result<T, Error>;
 
 #[derive(Error, Debug)]

libs/store/Cargo.toml

@@ -7,3 +7,4 @@ edition = "2021"
 
 [dependencies]
 sea-orm.workspace =true
+serde.workspace = true

libs/store/src/lib.rs

@@ -1,8 +1,6 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.3
+#[macro_use] extern crate serde;
 
-pub mod prelude;
+mod migrations;
+pub mod objects;
 
-pub mod cryptocurrencies;
-pub mod github_projects;
-pub mod github_repositories;
-pub mod issues;
+pub use migrations::*;

libs/store/src/migrations/mod.rs

@@ -0,0 +1,8 @@
+//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.3
+
+pub mod prelude;
+
+pub mod cryptocurrencies;
+pub mod github_projects;
+pub mod github_repositories;
+pub mod issues;

libs/store/src/objects/cryptocurrencies.rs

@@ -0,0 +1,12 @@
+use sea_orm::{prelude::Uuid, FromQueryResult};
+
+#[derive(FromQueryResult, Serialize)]
+pub struct CryptoCurrencyView {
+ pub id: Uuid,
+ pub name: String,
+ pub coingecko_id: String,
+ pub github_id: Uuid,
+ pub github: String,
+ pub repositories: Vec<String>,
+ pub issues: i64,
+}

libs/store/src/objects/mod.rs

@@ -0,0 +1,2 @@
+mod cryptocurrencies;
+pub use cryptocurrencies::CryptoCurrencyView;