added console frontend to separated packages inside this repo

.github/workflows/release.yml

@@ -214,7 +214,7 @@ jobs:
         with:
           use-cross: ${{ matrix.cross }}
           command: build
-          args: --verbose --release --package ${{ env.APP_NAME }} --target ${{ matrix.target }} --features embed_static
+          args: --verbose --release --package ${{ env.APP_NAME }} --target ${{ matrix.target }}
 
       - name: Build record tool
         if: matrix.build_record_tool

.gitignore

@@ -3,4 +3,5 @@ tarpaulin-report.html
 .atm0s
 /maxminddb-data
 .vscode
-book
+book
+*.db

Cargo.toml

@@ -11,6 +11,7 @@ members = [
     "packages/media_secure",
     "packages/media_gateway",
     "packages/audio_mixer",
+    "packages/media_console_front",
     "packages/media_connector",
     "packages/media_record",
     "packages/media_codecs",

bin/Cargo.toml

@@ -19,6 +19,7 @@ sans-io-runtime = { workspace = true }
 atm0s-sdn = { workspace = true }
 media-server-protocol = { path = "../packages/protocol", features = ["quinn-rpc"] }
 media-server-secure = { path = "../packages/media_secure" }
+media-console-front = { path = "../packages/media_console_front", optional = true }
 media-server-runner = { path = "../packages/media_runner", optional = true }
 media-server-gateway = { path = "../packages/media_gateway", optional = true }
 media-server-connector = { path = "../packages/media_connector", optional = true }
@@ -36,19 +37,16 @@ derive_more = { workspace = true, features = ["full"] }
 rcgen = { version = "0.13", optional = true }
 maxminddb = { version = "0.24", optional = true }
 sysinfo = { version = "0.32", optional = true }
-hex = { version = "0.4", optional = true }
-mime_guess = { version = "2.0", optional = true }
 reqwest = { version = "0.12", features = ["json"]}
 sentry = "0.34"
 
 [features]
 default = ["console", "gateway", "media", "connector", "standalone", "cert_utils"]
 standalone = ["console", "gateway", "media", "connector"]
-gateway = ["media-server-gateway", "media-server-connector", "quinn_vnet", "node_metrics", "maxminddb", "rust-embed", "media-server-multi-tenancy"]
-media = ["media-server-runner", "media-server-record", "quinn_vnet", "node_metrics"]
-console = []
+gateway = ["media-server-gateway", "media-server-connector", "quinn_vnet", "node_metrics", "maxminddb",  "media-server-multi-tenancy", "media-server-utils/embed-files", "rust-embed"]
+media = ["media-server-runner", "media-server-record", "quinn_vnet", "node_metrics", "media-server-utils/embed-files", "rust-embed"]
+console = ["media-console-front", "media-server-utils/embed-files", "rust-embed"]
 connector = ["quinn_vnet", "media-server-connector", "media-server-utils", "media-server-multi-tenancy"]
 cert_utils = ["rcgen", "rustls"]
 quinn_vnet = ["rustls", "quinn"]
 node_metrics = ["sysinfo"]
-embed_static = ["rust-embed", "hex", "mime_guess"]

bin/src/http.rs

@@ -9,16 +9,12 @@ use media_server_protocol::protobuf::cluster_connector::MediaConnectorServiceCli
 use media_server_protocol::rpc::quinn::{QuinnClient, QuinnStream};
 use media_server_protocol::transport::{RpcReq, RpcRes};
 use media_server_secure::{MediaEdgeSecure, MediaGatewaySecure};
-#[cfg(not(feature = "embed_static"))]
-use poem::endpoint::StaticFilesEndpoint;
 use poem::{listener::TcpListener, middleware::Cors, EndpointExt, Route, Server};
 use poem_openapi::types::{ToJSON, Type};
 use poem_openapi::OpenApiService;
 use poem_openapi::{types::ParseFromJSON, Object};
 use serde::Deserialize;
 use tokio::sync::mpsc::Sender;
-#[cfg(feature = "embed_static")]
-use utils::EmbeddedFilesEndpoint;
 
 mod api_console;
 mod api_media;
@@ -27,16 +23,11 @@ mod api_node;
 mod api_token;
 mod utils;
 
-#[cfg(feature = "embed_static")]
+#[cfg(feature = "gateway")]
 #[derive(rust_embed::RustEmbed)]
 #[folder = "public/media"]
 pub struct PublicMediaFiles;
 
-#[cfg(feature = "embed_static")]
-#[derive(rust_embed::RustEmbed)]
-#[folder = "public/console"]
-pub struct PublicConsoleFiles;
-
 #[derive(Debug, Default, Object, Deserialize)]
 pub struct Pagination {
     pub total: usize,
@@ -98,13 +89,8 @@ pub async fn run_console_http_server(
 
     let ctx = api_console::ConsoleApisCtx { secure, storage, connector };
 
-    #[cfg(not(feature = "embed_static"))]
-    let console_panel = StaticFilesEndpoint::new("./public/console/").index_file("index.html");
-    #[cfg(feature = "embed_static")]
-    let console_panel = EmbeddedFilesEndpoint::<PublicConsoleFiles>::new();
-
     let route = Route::new()
-        .nest("/", console_panel)
+        .nest("/", media_console_front::frontend_app())
         //node
         .nest("/api/node/", node_service)
         .nest("/api/node/ui", node_ui)
@@ -189,10 +175,10 @@ pub async fn run_gateway_http_server<ES: 'static + MediaEdgeSecure + Send + Sync
     let rtpengine_ui = rtpengine_service.swagger_ui();
     let rtpengine_spec = rtpengine_service.spec();
 
-    #[cfg(not(feature = "embed_static"))]
-    let samples = StaticFilesEndpoint::new("./public/media/").index_file("index.html");
-    #[cfg(feature = "embed_static")]
-    let samples = EmbeddedFilesEndpoint::<PublicMediaFiles>::new();
+    #[cfg(debug_assertions)]
+    let samples = poem::endpoint::StaticFilesEndpoint::new("./public/media/").index_file("index.html");
+    #[cfg(not(debug_assertions))]
+    let samples = media_server_utils::EmbeddedFilesEndpoint::<PublicMediaFiles>::new();
 
     let route = Route::new()
         .nest("/samples", samples)
@@ -324,10 +310,10 @@ pub async fn run_media_http_server<ES: 'static + MediaEdgeSecure + Send + Sync,
     let rtpengine_ui = rtpengine_service.swagger_ui();
     let rtpengine_spec = rtpengine_service.spec();
 
-    #[cfg(not(feature = "embed_static"))]
-    let samples = StaticFilesEndpoint::new("./public/media/").index_file("index.html");
-    #[cfg(feature = "embed_static")]
-    let samples = EmbeddedFilesEndpoint::<PublicMediaFiles>::new();
+    #[cfg(debug_assertions)]
+    let samples = poem::endpoint::StaticFilesEndpoint::new("./public/media/").index_file("index.html");
+    #[cfg(not(debug_assertions))]
+    let samples = media_server_utils::EmbeddedFilesEndpoint::<PublicMediaFiles>::new();
 
     let route = route
         .nest("/samples", samples)

bin/src/http/api_console/user.rs

@@ -18,7 +18,7 @@ pub struct Apis;
 #[OpenApi]
 impl Apis {
     /// login with user credentials
-    #[oai(path = "/user/login", method = "post")]
+    #[oai(path = "/login", method = "post")]
     async fn user_login(&self, Data(ctx): Data<&ConsoleApisCtx>, body: Json<UserLoginReq>) -> Json<Response<UserLoginRes>> {
         if ctx.secure.validate_secret(&body.secret) {
             Json(Response {

bin/src/http/utils/mod.rs

@@ -1,13 +1,9 @@
-#[cfg(feature = "embed_static")]
-mod embedded_files;
 mod payload_protobuf;
 mod payload_sdp;
 mod remote_ip;
 mod token;
 mod user_agent;
 
-#[cfg(feature = "embed_static")]
-pub use embedded_files::*;
 pub use payload_protobuf::*;
 pub use payload_sdp::*;
 pub use remote_ip::*;

packages/media_console_front/Cargo.toml

@@ -0,0 +1,11 @@
+[package]
+name = "media-console-front"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+poem = { version = "3.0", features = [] }
+rust-embed = { version = "8.0", features = ["compression"] }
+reqwest = { version = "0.12" }
+log = { workspace = true }
+media-server-utils = { path = "../media_utils", features = ["embed-files"] }

packages/media_console_front/build.rs

@@ -0,0 +1,21 @@
+use std::process::Command;
+
+fn main() {
+    // Build Vite project when compiling in release mode
+    if !cfg!(debug_assertions) {
+        Command::new("pnpm")
+            .current_dir(format!("{}/react-app", env!("CARGO_MANIFEST_DIR")))
+            .args(&["install"])
+            .stdout(std::process::Stdio::inherit())
+            .stderr(std::process::Stdio::inherit())
+            .status()
+            .expect("Failed to install Vite project");
+        Command::new("pnpm")
+            .current_dir(format!("{}/react-app", env!("CARGO_MANIFEST_DIR")))
+            .args(&["run", "build"])
+            .stdout(std::process::Stdio::inherit())
+            .stderr(std::process::Stdio::inherit())
+            .status()
+            .expect("Failed to build Vite project");
+    }
+}

packages/media_console_front/react-app/.env.example

@@ -0,0 +1 @@
+VITE_APP_API_URL=

packages/media_console_front/react-app/.gitignore

@@ -0,0 +1,26 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+pnpm-debug.log*
+lerna-debug.log*
+
+node_modules
+dist
+dist-ssr
+*.local
+
+# Editor directories and files
+.vscode/*
+!.vscode/extensions.json
+.idea
+.DS_Store
+*.suo
+*.ntvs*
+*.njsproj
+*.sln
+*.sw?
+
+.env

packages/media_console_front/react-app/.prettierignore

@@ -0,0 +1 @@
+

packages/media_console_front/react-app/.prettierrc

@@ -0,0 +1,18 @@
+{
+  "singleQuote": true,
+  "semi": false,
+  "printWidth": 125,
+  "bracketSameLine": false,
+  "embeddedLanguageFormatting": "auto",
+  "htmlWhitespaceSensitivity": "css",
+  "insertPragma": false,
+  "jsxSingleQuote": false,
+  "proseWrap": "preserve",
+  "quoteProps": "as-needed",
+  "requirePragma": false,
+  "tabWidth": 2,
+  "trailingComma": "es5",
+  "vueIndentScriptAndStyle": false,
+  "plugins": ["prettier-plugin-organize-imports", "prettier-plugin-tailwindcss", "prettier-plugin-packagejson"],
+  "tailwindFunctions": ["cn", "tv", "cx", "clsx", "cva"]
+}