Merge pull request #14 from spiralover/feat/cache

feat(cache): advanced cache & fixed auth issues

.dockerignore

@@ -3,5 +3,5 @@
 /.github
 /.gitignore
 #/apps
-#/core
+#/cosmic
 /target

.github/workflows/test.yml

@@ -20,4 +20,4 @@ jobs:
     - name: Run Clippy
       run: cargo clippy --all-targets --all-features
     - name: Run Tests
-      run: cargo test --workspace --verbose --exclude core
+      run: cargo test --workspace --verbose --exclude cosmic

Cargo.toml

@@ -1,7 +1,7 @@
 [workspace]
 resolver="2"
 members = [
-    "core",
+    "cosmic",
     "apps/user",
     "apps/executor"
 ]
@@ -28,6 +28,7 @@ futures = "0.3"
 actix-multipart = "0.6.0"
 strum_macros = "0.25.1"
 jsonwebtoken = "9.1.0"
+mobc = { version = "0.8", features = ["tokio"] }
 serde = { version = "1.0", features = ["derive"] }
 uuid = { version = "1", features = ["v4", "serde"] }
 chrono = { version = "0.4", features = ["serde"] }

apps/executor/Cargo.toml

@@ -19,5 +19,5 @@ redis = { workspace = true }
 futures-util = { workspace = true }
 diesel = { workspace = true }
 reqwest = { workspace = true }
-core = { path = "../../core" }
+cosmic = { path = "../../cosmic" }
 

apps/executor/Dockerfile

@@ -45,7 +45,7 @@ WORKDIR /var/www/mailer/apps/executor
 # copy files
 COPY apps/executor/.env.example .env
 
-RUN rm apps core docs examples .github -rf
+RUN rm apps cosmic docs examples .github -rf
 
 # Copy our built binary
 COPY --from=build /target/release/executor /usr/local/bin/executor

apps/executor/src/background_service.rs

@@ -3,7 +3,7 @@ use log::info;
 use crate::queue_handler::{
     handle_awaiting_queue, handle_failure_queue, handle_processing_queue, handle_success_queue,
 };
-use core::app_state::AppState;
+use cosmic::app_state::AppState;
 
 pub(crate) fn create_background_service(app: &AppState, name: String, features_per_worker: i8) {
     info!("preparing thread: {}", name.clone());

apps/executor/src/http/mod.rs

@@ -1,6 +1,6 @@
 use crate::http::system_controller::system_controller;
-use core::http::kernel::{Controller, Route};
-use core::http::middlewares::auth_middleware::AuthMiddleware;
+use cosmic::http::kernel::{Controller, Route};
+use cosmic::http::middlewares::auth_middleware::AuthMiddleware;
 
 pub(crate) mod system_controller;
 

apps/executor/src/http/system_controller.rs

@@ -1,14 +1,14 @@
 use actix_web::get;
 use actix_web::web::ServiceConfig;
 
-use core::enums::app_message::AppMessage;
-use core::results::HttpResult;
+use cosmic::enums::app_message::AppMessage;
+use cosmic::results::HttpResult;
 
 pub(crate) fn system_controller(cfg: &mut ServiceConfig) {
     cfg.service(docker_test);
 }
 
 #[get("docker-health-check")]
 async fn docker_test() -> HttpResult {
-    AppMessage::SuccessMessage("received").ok()
+    AppMessage::SuccessMessageStr("received").ok()
 }