Compare commits
297 Commits
bcc80c8c06
...
master
Author | SHA1 | Date | |
---|---|---|---|
a0081c03ea | |||
52ae7de998 | |||
9f919ab26d | |||
661a74f632 | |||
61072285cb | |||
f9c14fa335 | |||
0f3225c8b0 | |||
77ee9773df | |||
974fd928c7 | |||
44862d68ba | |||
70ef361c6c | |||
55053a2e37 | |||
18e336e12b | |||
98fe611be3 | |||
11878d22e8 | |||
d09483098a | |||
a01a660f99 | |||
caa33fdebf | |||
027fb1eecf | |||
68006504eb | |||
8210cbfb4f | |||
a3959d7abc | |||
9af843c287 | |||
adf7066ba0 | |||
d4c3e40abf | |||
78fc0b368c | |||
0f2e072976 | |||
a5d329eca8 | |||
b0ee9288a6 | |||
498ee9f861 | |||
e1fd104fec | |||
c6bff2d793 | |||
f2626f9987 | |||
39873cfa40 | |||
e3df9e63e6 | |||
6eb54e8653 | |||
b10caff599 | |||
80921b12fa | |||
5bdf6d03a4 | |||
73e02cd6b8 | |||
f6ed37458e | |||
082bfc5cb9 | |||
c2227c9129 | |||
eb33e93b08 | |||
2e393b8777 | |||
7daafdc1aa | |||
f3e14df55f | |||
4caa2c416b | |||
b4913054f0 | |||
8f2337c325 | |||
4ccdea317b | |||
d8ac0d1f0f | |||
652fab1511 | |||
e687f94daa | |||
ee6991c240 | |||
1efaeb9264 | |||
60f96bbc45 | |||
a3752ee654 | |||
dd39e3d7ba | |||
dc07e055f8 | |||
5ee8c7fce3 | |||
5a796fecca | |||
48fc0a03a5 | |||
8e679210ea | |||
aa1f8e12eb | |||
d33700f9ae | |||
46e689045e | |||
18c9eb7f23 | |||
9110c66f05 | |||
77c0869f74 | |||
3726f8ba2d | |||
89ca5493e1 | |||
b06926e3a5 | |||
5b7709f50a | |||
79ef24e414 | |||
d575feac81 | |||
00343abdb0 | |||
3ee3f0119b | |||
b18f18a986 | |||
e7ad0ffd4f | |||
670ceab69e | |||
9c2eedc7d1 | |||
f44d318b16 | |||
85b33a32c4 | |||
36478bd61e | |||
6f2c00b2a4 | |||
4c61610ff2 | |||
52b749c9a9 | |||
8eccffb176 | |||
35fc98e653 | |||
1f21bc5ba0 | |||
7b43701b1c | |||
5c62dd0c27 | |||
6b6ea9ea83 | |||
1d5b132e7e | |||
97f65931c8 | |||
ccb0c6cd6e | |||
4ee52e83fd | |||
296d168995 | |||
8f3ff52dda | |||
0e0af55a85 | |||
2518d202da | |||
aa7c217b6c | |||
6b699994cf | |||
e13ae9f062 | |||
77b1117fa1 | |||
daa0a9f391 | |||
f94d1b1c6b | |||
b3b1592d93 | |||
8bf7129ee1 | |||
5c841e6a85 | |||
369efd442f | |||
01c0f20cf4 | |||
c96ca68f7e | |||
8121212723 | |||
cd9867c5b0 | |||
cbc432a304 | |||
25d4d3e0f3 | |||
855ec54e83 | |||
10ab40fcd5 | |||
92d53430af | |||
4d8387a854 | |||
68b2bb8e0c | |||
02a120c220 | |||
e16167991b | |||
5101d43c05 | |||
c32536f260 | |||
e89818cc35 | |||
c7e0a6ddce | |||
4ef2f69d92 | |||
6427593fa8 | |||
3336c9e8bf | |||
97f8e85268 | |||
144d10164d | |||
8cd5e61a6a | |||
3a3110114b | |||
1b83c8fa07 | |||
9037842c0c | |||
df3724a17d | |||
31eb1977c3 | |||
61ec9f6d91 | |||
aa6d45a5e8 | |||
cb0eba7fca | |||
3e4face5c9 | |||
217e476811 | |||
76a81e0ff9 | |||
52ca4674d7 | |||
5417e70bff | |||
ba45b119a0 | |||
947aa258f8 | |||
964e01cc8d | |||
f84f8aefc1 | |||
1db549e2ee | |||
fe00953be3 | |||
a223335cee | |||
417ea655ab | |||
2c7f5c9751 | |||
04fa264e1c | |||
8716b32739 | |||
39357529e8 | |||
d7d1211ee6 | |||
19b2854f56 | |||
aa2498d1ef | |||
a8aba27c87 | |||
ca73e7b6fa | |||
6c59c4ae7b | |||
bb631188ae | |||
869ef03a9f | |||
bd16ab08c2 | |||
ad8c41ea58 | |||
b051476f9d | |||
bd22186c0f | |||
78046a9b3a | |||
f5de43a67a | |||
2861038d71 | |||
fe2b6d5dd6 | |||
f7aebd7d6a | |||
84ad543948 | |||
5a7d9e178d | |||
9020389714 | |||
4f0e2cb722 | |||
316b9efef8 | |||
3e67d0bdb3 | |||
3281bf4b36 | |||
b4c4920e48 | |||
cc14077a82 | |||
f1301f7eb0 | |||
94ae206bbf | |||
e1d2bd7f4f | |||
fc698ea66e | |||
9211b43e50 | |||
026aa1ecfd | |||
de3c18c658 | |||
d74831aa9f | |||
7da20d879b | |||
987c95221f | |||
9c64f9a2a7 | |||
6d2a2683bc | |||
80fd39dd24 | |||
85b6ca9176 | |||
0b71315321 | |||
9246ced2e1 | |||
b0c97052f5 | |||
70b1c290d0 | |||
50df3e92fd | |||
14e4ff41a9 | |||
744537a906 | |||
146a4e0885 | |||
74e1ed9ca1 | |||
ca3d2010ef | |||
a7df69cd6f | |||
446001d9ff | |||
1a7aa5dab0 | |||
8f6892e498 | |||
5c8df481ac | |||
d8e1ce7fbe | |||
5ae6f8f1bf | |||
807c2c310a | |||
ea5b072511 | |||
1f5c22828d | |||
ba1073a8bd | |||
da1c962223 | |||
dab3034206 | |||
75b97fb3e2 | |||
e9c4a4d1b4 | |||
5c4e1c5425 | |||
bcff61f1f6 | |||
9a970ce347 | |||
9e1287509a | |||
09f9a364ae | |||
30589a6e6a | |||
a87b275796 | |||
4454f4a10d | |||
0a85dc65f2 | |||
77a9c954de | |||
bf13e3ac8a | |||
7fbdd9c3d3 | |||
8c3d6240eb | |||
d344b16a8c | |||
aa6b20b202 | |||
3dfa2250ce | |||
386a4af108 | |||
76b234febb | |||
45880e212d | |||
023ab429fe | |||
0f9ad94368 | |||
d75b0287ad | |||
0f24e6dc3e | |||
94ad0398de | |||
5305083eca | |||
eef867ad19 | |||
10569459c3 | |||
4c6608bf55 | |||
aa9222bd22 | |||
191b041993 | |||
00b9bd4ab4 | |||
1c76b51a02 | |||
533b8d68b9 | |||
8678ecdb32 | |||
f817472485 | |||
46db385215 | |||
31c45adbc3 | |||
45b8c1f012 | |||
1ef5bf8848 | |||
ade396460a | |||
184a106542 | |||
74ab902180 | |||
017ce989c0 | |||
e8f1b66670 | |||
d0b34f038d | |||
9465a5b04f | |||
a09ca8805c | |||
5dbd41ab19 | |||
b8b3b48f6b | |||
08c9eee0f2 | |||
9b467bf907 | |||
e0a97d8604 | |||
b3be9a519a | |||
e8dc523264 | |||
0053dec503 | |||
84feab23c6 | |||
e14e525954 | |||
57d98e3848 | |||
e92aff4570 | |||
682036986d | |||
c7cfb71935 | |||
4f19bd9b6c | |||
329254a432 | |||
b11a265e56 | |||
d20c910cd6 | |||
4f3380b029 | |||
18dda6ef87 | |||
dbd7f119ac | |||
4c0fe6214b | |||
c96b9677ec | |||
e90fd1032b | |||
7f863b91dc |
.drone.ymlREADME.md
remote_backend
remote_frontend
.eslintrc.cjseslint.config.jspackage-lock.jsonpackage.json
renovate.jsonsrc
tsconfig.app.jsontsconfig.jsontsconfig.node.jsonvite.config.ts@ -5,7 +5,7 @@ name: default
|
||||
|
||||
steps:
|
||||
- name: frontend_build
|
||||
image: node:22
|
||||
image: node:23
|
||||
volumes:
|
||||
- name: frontend_app
|
||||
path: /tmp/frontend_build
|
||||
|
11
README.md
11
README.md
@ -1,4 +1,11 @@
|
||||
# VirtWeb Remote
|
||||
WIP project
|
||||
Web UI that allows to start and stop VMs managed by VirtWEB without having to expose the VirtWEB directly on the Internet.
|
||||
|
||||
This project aims to use the VirtWeb API to start and stop VM without directly exposing the VirtWEB API to the Internet.
|
||||
VirtWebRemote rely on OpenID to authenticate users.
|
||||
|
||||
VirtWebRemote authenticates against VirtWEB API using an API token. Both the token ID and private key are required to be able to authenticate against the VirtWEB API.
|
||||
|
||||
## Docker image options
|
||||
```bash
|
||||
docker run --rm -it pierre42100/virtweb_remote --help
|
||||
```
|
1554
remote_backend/Cargo.lock
generated
1554
remote_backend/Cargo.lock
generated
File diff suppressed because it is too large
Load Diff
@ -1,28 +1,28 @@
|
||||
[package]
|
||||
name = "remote_backend"
|
||||
version = "0.1.0"
|
||||
edition = "2021"
|
||||
edition = "2024"
|
||||
|
||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||
|
||||
[dependencies]
|
||||
log = "0.4.21"
|
||||
env_logger = "0.11.3"
|
||||
clap = { version = "4.5.4", features = ["derive", "env"] }
|
||||
serde = { version = "1.0.200", features = ["derive"] }
|
||||
light-openid = { version = "1.0.2", features = ["crypto-wrapper"] }
|
||||
basic-jwt = "0.2.0"
|
||||
actix-web = "4.5.1"
|
||||
log = "0.4.27"
|
||||
env_logger = "0.11.8"
|
||||
clap = { version = "4.5.41", features = ["derive", "env"] }
|
||||
serde = { version = "1.0.219", features = ["derive"] }
|
||||
light-openid = { version = "1.0.4", features = ["crypto-wrapper"] }
|
||||
basic-jwt = "0.3.0"
|
||||
actix-web = "4.11.0"
|
||||
actix-remote-ip = "0.1.0"
|
||||
actix-session = { version = "0.10.0", features = ["cookie-session"] }
|
||||
actix-identity = "0.7.1"
|
||||
actix-cors = "0.7.0"
|
||||
lazy_static = "1.4.0"
|
||||
anyhow = "1.0.83"
|
||||
reqwest = { version = "0.12.4", features = ["json"] }
|
||||
thiserror = "1.0.59"
|
||||
uuid = { version = "1.8.0", features = ["v4", "serde"] }
|
||||
futures-util = "0.3.30"
|
||||
lazy-regex = "3.1.0"
|
||||
mime_guess = "2.0.4"
|
||||
rust-embed = { version = "8.3.0" }
|
||||
actix-session = { version = "0.10.1", features = ["cookie-session"] }
|
||||
actix-identity = "0.8.0"
|
||||
actix-cors = "0.7.1"
|
||||
lazy_static = "1.5.0"
|
||||
anyhow = "1.0.98"
|
||||
reqwest = { version = "0.12.22", features = ["json"] }
|
||||
thiserror = "2.0.12"
|
||||
uuid = { version = "1.16.0", features = ["v4", "serde"] }
|
||||
futures-util = "0.3.31"
|
||||
lazy-regex = "3.4.1"
|
||||
mime_guess = "2.0.5"
|
||||
rust-embed = { version = "8.7.2" }
|
||||
|
@ -6,4 +6,4 @@ RUN apt-get update \
|
||||
|
||||
COPY remote_backend /usr/local/bin/remote_backend
|
||||
|
||||
ENTRYPOINT /usr/local/bin/remote_backend
|
||||
ENTRYPOINT ["/usr/local/bin/remote_backend"]
|
||||
|
@ -29,7 +29,7 @@ pub struct AppConfig {
|
||||
#[arg(
|
||||
long,
|
||||
env,
|
||||
default_value = "http://localhost:9001/.well-known/openid-configuration"
|
||||
default_value = "http://localhost:9001/dex/.well-known/openid-configuration"
|
||||
)]
|
||||
pub oidc_configuration_url: String,
|
||||
|
||||
|
@ -1,6 +1,6 @@
|
||||
use actix_remote_ip::RemoteIP;
|
||||
use actix_web::web::Data;
|
||||
use actix_web::{web, HttpResponse, Responder};
|
||||
use actix_web::{HttpResponse, Responder, web};
|
||||
use light_openid::basic_state_manager::BasicStateManager;
|
||||
|
||||
use crate::app_config::AppConfig;
|
||||
|
79
remote_backend/src/controllers/group_controller.rs
Normal file
79
remote_backend/src/controllers/group_controller.rs
Normal file
@ -0,0 +1,79 @@
|
||||
use crate::controllers::HttpResult;
|
||||
use crate::virtweb_client;
|
||||
use crate::virtweb_client::{GroupID, VMUuid};
|
||||
use actix_web::{HttpResponse, web};
|
||||
|
||||
#[derive(serde::Deserialize)]
|
||||
pub struct GroupIDInPath {
|
||||
gid: GroupID,
|
||||
}
|
||||
|
||||
#[derive(serde::Deserialize)]
|
||||
pub struct VMIDInQuery {
|
||||
vm_id: Option<VMUuid>,
|
||||
}
|
||||
|
||||
/// Get the state of one or all VM
|
||||
pub async fn vm_state(
|
||||
path: web::Path<GroupIDInPath>,
|
||||
query: web::Query<VMIDInQuery>,
|
||||
) -> HttpResult {
|
||||
Ok(HttpResponse::Ok().json(virtweb_client::group_vm_state(&path.gid, query.vm_id).await?))
|
||||
}
|
||||
|
||||
/// Start one or all VM
|
||||
pub async fn vm_start(
|
||||
path: web::Path<GroupIDInPath>,
|
||||
query: web::Query<VMIDInQuery>,
|
||||
) -> HttpResult {
|
||||
Ok(HttpResponse::Ok().json(virtweb_client::group_vm_start(&path.gid, query.vm_id).await?))
|
||||
}
|
||||
|
||||
/// Shutdown one or all VM
|
||||
pub async fn vm_shutdown(
|
||||
path: web::Path<GroupIDInPath>,
|
||||
query: web::Query<VMIDInQuery>,
|
||||
) -> HttpResult {
|
||||
Ok(HttpResponse::Ok().json(virtweb_client::group_vm_shutdown(&path.gid, query.vm_id).await?))
|
||||
}
|
||||
|
||||
/// Kill one or all VM
|
||||
pub async fn vm_kill(path: web::Path<GroupIDInPath>, query: web::Query<VMIDInQuery>) -> HttpResult {
|
||||
Ok(HttpResponse::Ok().json(virtweb_client::group_vm_kill(&path.gid, query.vm_id).await?))
|
||||
}
|
||||
|
||||
/// Reset one or all VM
|
||||
pub async fn vm_reset(
|
||||
path: web::Path<GroupIDInPath>,
|
||||
query: web::Query<VMIDInQuery>,
|
||||
) -> HttpResult {
|
||||
Ok(HttpResponse::Ok().json(virtweb_client::group_vm_reset(&path.gid, query.vm_id).await?))
|
||||
}
|
||||
|
||||
/// Suspend one or all VM
|
||||
pub async fn vm_suspend(
|
||||
path: web::Path<GroupIDInPath>,
|
||||
query: web::Query<VMIDInQuery>,
|
||||
) -> HttpResult {
|
||||
Ok(HttpResponse::Ok().json(virtweb_client::group_vm_suspend(&path.gid, query.vm_id).await?))
|
||||
}
|
||||
|
||||
/// Resume one or all VM
|
||||
pub async fn vm_resume(
|
||||
path: web::Path<GroupIDInPath>,
|
||||
query: web::Query<VMIDInQuery>,
|
||||
) -> HttpResult {
|
||||
Ok(HttpResponse::Ok().json(virtweb_client::group_vm_resume(&path.gid, query.vm_id).await?))
|
||||
}
|
||||
|
||||
/// Screenshot one or all VM
|
||||
pub async fn vm_screenshot(
|
||||
path: web::Path<GroupIDInPath>,
|
||||
query: web::Query<VMIDInQuery>,
|
||||
) -> HttpResult {
|
||||
let screenshot = virtweb_client::group_vm_screenshot(&path.gid, query.vm_id).await?;
|
||||
|
||||
Ok(HttpResponse::Ok()
|
||||
.insert_header(("content-type", "image/png"))
|
||||
.body(screenshot))
|
||||
}
|
@ -1,11 +1,11 @@
|
||||
use actix_web::HttpResponse;
|
||||
use actix_web::body::BoxBody;
|
||||
use actix_web::http::StatusCode;
|
||||
use actix_web::HttpResponse;
|
||||
use std::error::Error;
|
||||
use std::fmt::{Display, Formatter};
|
||||
use std::io::ErrorKind;
|
||||
|
||||
pub mod auth_controller;
|
||||
pub mod group_controller;
|
||||
pub mod server_controller;
|
||||
pub mod static_controller;
|
||||
pub mod sys_info_controller;
|
||||
@ -37,7 +37,7 @@ impl actix_web::error::ResponseError for HttpErr {
|
||||
}
|
||||
}
|
||||
fn error_response(&self) -> HttpResponse<BoxBody> {
|
||||
log::error!("Error while processing request! {}", self);
|
||||
log::error!("Error while processing request! {self}");
|
||||
|
||||
HttpResponse::InternalServerError().body("Failed to execute request!")
|
||||
}
|
||||
@ -51,7 +51,7 @@ impl From<anyhow::Error> for HttpErr {
|
||||
|
||||
impl From<Box<dyn Error>> for HttpErr {
|
||||
fn from(value: Box<dyn Error>) -> Self {
|
||||
HttpErr::Err(std::io::Error::new(ErrorKind::Other, value.to_string()).into())
|
||||
HttpErr::Err(std::io::Error::other(value.to_string()).into())
|
||||
}
|
||||
}
|
||||
|
||||
@ -81,7 +81,7 @@ impl From<reqwest::header::ToStrError> for HttpErr {
|
||||
|
||||
impl From<actix_web::Error> for HttpErr {
|
||||
fn from(value: actix_web::Error) -> Self {
|
||||
HttpErr::Err(std::io::Error::new(ErrorKind::Other, value.to_string()).into())
|
||||
HttpErr::Err(std::io::Error::other(value.to_string()).into())
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -1,6 +1,8 @@
|
||||
use crate::app_config::AppConfig;
|
||||
use crate::controllers::HttpResult;
|
||||
use crate::extractors::auth_extractor::AuthExtractor;
|
||||
use crate::virtweb_client;
|
||||
use crate::virtweb_client::{GroupID, VMCaps, VMInfo};
|
||||
use actix_web::HttpResponse;
|
||||
|
||||
#[derive(serde::Serialize)]
|
||||
@ -15,3 +17,75 @@ pub async fn config(auth: AuthExtractor) -> HttpResult {
|
||||
disable_auth: AppConfig::get().unsecure_disable_login,
|
||||
}))
|
||||
}
|
||||
|
||||
#[derive(Default, Debug, serde::Serialize)]
|
||||
pub struct Rights {
|
||||
groups: Vec<GroupInfo>,
|
||||
vms: Vec<VMInfoAndCaps>,
|
||||
sys_info: bool,
|
||||
}
|
||||
|
||||
#[derive(Debug, serde::Serialize)]
|
||||
pub struct GroupInfo {
|
||||
id: GroupID,
|
||||
vms: Vec<VMInfo>,
|
||||
#[serde(flatten)]
|
||||
caps: VMCaps,
|
||||
}
|
||||
|
||||
#[derive(Debug, serde::Serialize)]
|
||||
pub struct VMInfoAndCaps {
|
||||
#[serde(flatten)]
|
||||
info: VMInfo,
|
||||
#[serde(flatten)]
|
||||
caps: VMCaps,
|
||||
}
|
||||
|
||||
pub async fn rights() -> HttpResult {
|
||||
let rights = virtweb_client::get_token_info().await?;
|
||||
|
||||
let mut res = Rights {
|
||||
groups: vec![],
|
||||
vms: vec![],
|
||||
sys_info: rights.can_retrieve_system_info(),
|
||||
};
|
||||
|
||||
for g in rights.list_groups() {
|
||||
let group_vms = virtweb_client::group_vm_info(&g).await?;
|
||||
|
||||
res.groups.push(GroupInfo {
|
||||
id: g.clone(),
|
||||
vms: group_vms,
|
||||
caps: VMCaps {
|
||||
can_get_state: rights.is_route_allowed("GET", &g.route_vm_state(None)),
|
||||
can_start: rights.is_route_allowed("GET", &g.route_vm_start(None)),
|
||||
can_shutdown: rights.is_route_allowed("GET", &g.route_vm_shutdown(None)),
|
||||
can_kill: rights.is_route_allowed("GET", &g.route_vm_kill(None)),
|
||||
can_reset: rights.is_route_allowed("GET", &g.route_vm_reset(None)),
|
||||
can_suspend: rights.is_route_allowed("GET", &g.route_vm_suspend(None)),
|
||||
can_resume: rights.is_route_allowed("GET", &g.route_vm_resume(None)),
|
||||
can_screenshot: rights.is_route_allowed("GET", &g.route_vm_screenshot(None)),
|
||||
},
|
||||
})
|
||||
}
|
||||
|
||||
for v in rights.list_vm() {
|
||||
let vm_info = virtweb_client::vm_info(v).await?;
|
||||
|
||||
res.vms.push(VMInfoAndCaps {
|
||||
info: vm_info,
|
||||
caps: VMCaps {
|
||||
can_get_state: rights.is_route_allowed("GET", &v.route_state()),
|
||||
can_start: rights.is_route_allowed("GET", &v.route_start()),
|
||||
can_shutdown: rights.is_route_allowed("GET", &v.route_shutdown()),
|
||||
can_kill: rights.is_route_allowed("GET", &v.route_kill()),
|
||||
can_reset: rights.is_route_allowed("GET", &v.route_reset()),
|
||||
can_suspend: rights.is_route_allowed("GET", &v.route_suspend()),
|
||||
can_resume: rights.is_route_allowed("GET", &v.route_resume()),
|
||||
can_screenshot: rights.is_route_allowed("GET", &v.route_screenshot()),
|
||||
},
|
||||
})
|
||||
}
|
||||
|
||||
Ok(HttpResponse::Ok().json(res))
|
||||
}
|
||||
|
@ -18,7 +18,7 @@ mod serve_static_debug {
|
||||
|
||||
#[cfg(not(debug_assertions))]
|
||||
mod serve_static_release {
|
||||
use actix_web::{web, HttpResponse, Responder};
|
||||
use actix_web::{HttpResponse, Responder, web};
|
||||
use rust_embed::RustEmbed;
|
||||
|
||||
#[derive(RustEmbed)]
|
||||
|
@ -2,20 +2,6 @@ use crate::controllers::HttpResult;
|
||||
use crate::virtweb_client;
|
||||
use actix_web::HttpResponse;
|
||||
|
||||
#[derive(serde::Serialize)]
|
||||
struct SysInfoStatus {
|
||||
allowed: bool,
|
||||
}
|
||||
|
||||
/// Check if system info can be retrieved
|
||||
pub async fn config() -> HttpResult {
|
||||
let info = virtweb_client::get_token_info().await?;
|
||||
|
||||
Ok(HttpResponse::Ok().json(SysInfoStatus {
|
||||
allowed: info.can_retrieve_system_info(),
|
||||
}))
|
||||
}
|
||||
|
||||
/// Get current system status
|
||||
pub async fn status() -> HttpResult {
|
||||
Ok(HttpResponse::Ok().json(virtweb_client::get_server_info().await?))
|
||||
|
@ -3,55 +3,7 @@
|
||||
use crate::controllers::HttpResult;
|
||||
use crate::virtweb_client;
|
||||
use crate::virtweb_client::VMUuid;
|
||||
use actix_web::{web, HttpResponse};
|
||||
|
||||
#[derive(Debug, serde::Serialize)]
|
||||
pub struct VMInfoAndCaps {
|
||||
uiid: VMUuid,
|
||||
name: String,
|
||||
description: Option<String>,
|
||||
architecture: String,
|
||||
memory: usize,
|
||||
number_vcpu: usize,
|
||||
can_get_state: bool,
|
||||
can_start: bool,
|
||||
can_shutdown: bool,
|
||||
can_kill: bool,
|
||||
can_reset: bool,
|
||||
can_suspend: bool,
|
||||
can_resume: bool,
|
||||
can_screenshot: bool,
|
||||
}
|
||||
|
||||
/// Get the list of VMs that can be controlled by VirtWeb remote
|
||||
pub async fn list() -> HttpResult {
|
||||
let rights = virtweb_client::get_token_info().await?;
|
||||
|
||||
let mut res = vec![];
|
||||
|
||||
for v in rights.list_vm() {
|
||||
let vm_info = virtweb_client::vm_info(v).await?;
|
||||
|
||||
res.push(VMInfoAndCaps {
|
||||
uiid: vm_info.uuid,
|
||||
name: vm_info.name,
|
||||
description: vm_info.description.clone(),
|
||||
architecture: vm_info.architecture.to_string(),
|
||||
memory: vm_info.memory,
|
||||
number_vcpu: vm_info.number_vcpu,
|
||||
can_get_state: rights.is_route_allowed("GET", &v.route_state()),
|
||||
can_start: rights.is_route_allowed("GET", &v.route_start()),
|
||||
can_shutdown: rights.is_route_allowed("GET", &v.route_shutdown()),
|
||||
can_kill: rights.is_route_allowed("GET", &v.route_kill()),
|
||||
can_reset: rights.is_route_allowed("GET", &v.route_reset()),
|
||||
can_suspend: rights.is_route_allowed("GET", &v.route_suspend()),
|
||||
can_resume: rights.is_route_allowed("GET", &v.route_resume()),
|
||||
can_screenshot: rights.is_route_allowed("GET", &v.route_screenshot()),
|
||||
})
|
||||
}
|
||||
|
||||
Ok(HttpResponse::Ok().json(res))
|
||||
}
|
||||
use actix_web::{HttpResponse, web};
|
||||
|
||||
#[derive(serde::Deserialize)]
|
||||
pub struct ReqPath {
|
||||
|
@ -1,7 +1,7 @@
|
||||
use actix_identity::Identity;
|
||||
use actix_web::dev::Payload;
|
||||
use actix_web::{Error, FromRequest, HttpMessage, HttpRequest};
|
||||
use futures_util::future::{ready, Ready};
|
||||
use futures_util::future::{Ready, ready};
|
||||
use std::fmt::Display;
|
||||
|
||||
pub struct AuthExtractor {
|
||||
|
@ -1,18 +1,19 @@
|
||||
use actix_cors::Cors;
|
||||
use actix_identity::config::LogoutBehaviour;
|
||||
use actix_identity::IdentityMiddleware;
|
||||
use actix_identity::config::LogoutBehaviour;
|
||||
use actix_remote_ip::RemoteIPConfig;
|
||||
use actix_session::storage::CookieSessionStore;
|
||||
use actix_session::SessionMiddleware;
|
||||
use actix_session::storage::CookieSessionStore;
|
||||
use actix_web::cookie::{Key, SameSite};
|
||||
use actix_web::middleware::Logger;
|
||||
use actix_web::web::Data;
|
||||
use actix_web::{web, App, HttpServer};
|
||||
use actix_web::{App, HttpServer, web};
|
||||
use light_openid::basic_state_manager::BasicStateManager;
|
||||
use remote_backend::app_config::AppConfig;
|
||||
use remote_backend::constants;
|
||||
use remote_backend::controllers::{
|
||||
auth_controller, server_controller, static_controller, sys_info_controller, vm_controller,
|
||||
auth_controller, group_controller, server_controller, static_controller, sys_info_controller,
|
||||
vm_controller,
|
||||
};
|
||||
use remote_backend::middlewares::auth_middleware::AuthChecker;
|
||||
use std::time::Duration;
|
||||
@ -82,8 +83,44 @@ async fn main() -> std::io::Result<()> {
|
||||
"/api/auth/sign_out",
|
||||
web::get().to(auth_controller::sign_out),
|
||||
)
|
||||
.route(
|
||||
"/api/server/rights",
|
||||
web::get().to(server_controller::rights),
|
||||
)
|
||||
// Groups routes
|
||||
.route(
|
||||
"/api/group/{gid}/vm/state",
|
||||
web::get().to(group_controller::vm_state),
|
||||
)
|
||||
.route(
|
||||
"/api/group/{gid}/vm/start",
|
||||
web::get().to(group_controller::vm_start),
|
||||
)
|
||||
.route(
|
||||
"/api/group/{gid}/vm/shutdown",
|
||||
web::get().to(group_controller::vm_shutdown),
|
||||
)
|
||||
.route(
|
||||
"/api/group/{gid}/vm/kill",
|
||||
web::get().to(group_controller::vm_kill),
|
||||
)
|
||||
.route(
|
||||
"/api/group/{gid}/vm/reset",
|
||||
web::get().to(group_controller::vm_reset),
|
||||
)
|
||||
.route(
|
||||
"/api/group/{gid}/vm/suspend",
|
||||
web::get().to(group_controller::vm_suspend),
|
||||
)
|
||||
.route(
|
||||
"/api/group/{gid}/vm/resume",
|
||||
web::get().to(group_controller::vm_resume),
|
||||
)
|
||||
.route(
|
||||
"/api/group/{gid}/vm/screenshot",
|
||||
web::get().to(group_controller::vm_screenshot),
|
||||
)
|
||||
// VM routes
|
||||
.route("/api/vm/list", web::get().to(vm_controller::list))
|
||||
.route("/api/vm/{uid}/state", web::get().to(vm_controller::state))
|
||||
.route("/api/vm/{uid}/start", web::get().to(vm_controller::start))
|
||||
.route(
|
||||
@ -102,10 +139,6 @@ async fn main() -> std::io::Result<()> {
|
||||
web::get().to(vm_controller::screenshot),
|
||||
)
|
||||
// Sys info routes
|
||||
.route(
|
||||
"/api/sysinfo/config",
|
||||
web::get().to(sys_info_controller::config),
|
||||
)
|
||||
.route(
|
||||
"/api/sysinfo/status",
|
||||
web::get().to(sys_info_controller::status),
|
||||
|
@ -1,4 +1,4 @@
|
||||
use std::future::{ready, Ready};
|
||||
use std::future::{Ready, ready};
|
||||
use std::rc::Rc;
|
||||
|
||||
use crate::app_config::AppConfig;
|
||||
@ -7,8 +7,8 @@ use crate::extractors::auth_extractor::AuthExtractor;
|
||||
use actix_web::body::EitherBody;
|
||||
use actix_web::dev::Payload;
|
||||
use actix_web::{
|
||||
dev::{forward_ready, Service, ServiceRequest, ServiceResponse, Transform},
|
||||
Error, FromRequest, HttpResponse,
|
||||
dev::{Service, ServiceRequest, ServiceResponse, Transform, forward_ready},
|
||||
};
|
||||
use futures_util::future::LocalBoxFuture;
|
||||
|
||||
|
@ -1,6 +1,7 @@
|
||||
use crate::app_config::AppConfig;
|
||||
use crate::utils::time;
|
||||
use lazy_regex::regex;
|
||||
use std::collections::HashMap;
|
||||
use std::fmt::Display;
|
||||
use std::str::FromStr;
|
||||
use thiserror::Error;
|
||||
@ -12,9 +13,105 @@ pub enum VirtWebClientError {
|
||||
InvalidStatusCode(u16),
|
||||
}
|
||||
|
||||
#[derive(Eq, PartialEq, Debug, Copy, Clone, serde::Serialize, serde::Deserialize)]
|
||||
#[derive(Eq, PartialEq, Debug, Clone, serde::Serialize, serde::Deserialize)]
|
||||
pub struct GroupID(String);
|
||||
|
||||
impl GroupID {
|
||||
pub fn route_vm_info(&self) -> String {
|
||||
format!("/api/group/{}/vm/info", self.0)
|
||||
}
|
||||
|
||||
pub fn route_vm_state(&self, vm: Option<VMUuid>) -> String {
|
||||
format!(
|
||||
"/api/group/{}/vm/state{}",
|
||||
self.0,
|
||||
match vm {
|
||||
None => "".to_string(),
|
||||
Some(id) => format!("?vm_id={}", id.0),
|
||||
}
|
||||
)
|
||||
}
|
||||
pub fn route_vm_start(&self, vm: Option<VMUuid>) -> String {
|
||||
format!(
|
||||
"/api/group/{}/vm/start{}",
|
||||
self.0,
|
||||
match vm {
|
||||
None => "".to_string(),
|
||||
Some(id) => format!("?vm_id={}", id.0),
|
||||
}
|
||||
)
|
||||
}
|
||||
pub fn route_vm_shutdown(&self, vm: Option<VMUuid>) -> String {
|
||||
format!(
|
||||
"/api/group/{}/vm/shutdown{}",
|
||||
self.0,
|
||||
match vm {
|
||||
None => "".to_string(),
|
||||
Some(id) => format!("?vm_id={}", id.0),
|
||||
}
|
||||
)
|
||||
}
|
||||
pub fn route_vm_suspend(&self, vm: Option<VMUuid>) -> String {
|
||||
format!(
|
||||
"/api/group/{}/vm/suspend{}",
|
||||
self.0,
|
||||
match vm {
|
||||
None => "".to_string(),
|
||||
Some(id) => format!("?vm_id={}", id.0),
|
||||
}
|
||||
)
|
||||
}
|
||||
pub fn route_vm_resume(&self, vm: Option<VMUuid>) -> String {
|
||||
format!(
|
||||
"/api/group/{}/vm/resume{}",
|
||||
self.0,
|
||||
match vm {
|
||||
None => "".to_string(),
|
||||
Some(id) => format!("?vm_id={}", id.0),
|
||||
}
|
||||
)
|
||||
}
|
||||
pub fn route_vm_kill(&self, vm: Option<VMUuid>) -> String {
|
||||
format!(
|
||||
"/api/group/{}/vm/kill{}",
|
||||
self.0,
|
||||
match vm {
|
||||
None => "".to_string(),
|
||||
Some(id) => format!("?vm_id={}", id.0),
|
||||
}
|
||||
)
|
||||
}
|
||||
pub fn route_vm_reset(&self, vm: Option<VMUuid>) -> String {
|
||||
format!(
|
||||
"/api/group/{}/vm/reset{}",
|
||||
self.0,
|
||||
match vm {
|
||||
None => "".to_string(),
|
||||
Some(id) => format!("?vm_id={}", id.0),
|
||||
}
|
||||
)
|
||||
}
|
||||
pub fn route_vm_screenshot(&self, vm: Option<VMUuid>) -> String {
|
||||
format!(
|
||||
"/api/group/{}/vm/screenshot{}",
|
||||
self.0,
|
||||
match vm {
|
||||
None => "".to_string(),
|
||||
Some(id) => format!("?vm_id={}", id.0),
|
||||
}
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Eq, PartialEq, Debug, Copy, Clone, serde::Serialize, serde::Deserialize, Hash)]
|
||||
pub struct VMUuid(Uuid);
|
||||
|
||||
#[derive(Default, serde::Deserialize, serde::Serialize)]
|
||||
pub struct TreatmentResult {
|
||||
ok: usize,
|
||||
failed: usize,
|
||||
}
|
||||
|
||||
impl VMUuid {
|
||||
pub fn route_info(&self) -> String {
|
||||
format!("/api/vm/{}", self.0)
|
||||
@ -69,7 +166,7 @@ pub struct TokenClaims {
|
||||
pub nonce: String,
|
||||
}
|
||||
|
||||
#[derive(serde::Deserialize, Debug)]
|
||||
#[derive(serde::Deserialize, serde::Serialize, Debug)]
|
||||
pub struct VMInfo {
|
||||
pub uuid: VMUuid,
|
||||
pub name: String,
|
||||
@ -79,6 +176,18 @@ pub struct VMInfo {
|
||||
pub number_vcpu: usize,
|
||||
}
|
||||
|
||||
#[derive(serde::Deserialize, serde::Serialize, Debug)]
|
||||
pub struct VMCaps {
|
||||
pub can_get_state: bool,
|
||||
pub can_start: bool,
|
||||
pub can_shutdown: bool,
|
||||
pub can_kill: bool,
|
||||
pub can_reset: bool,
|
||||
pub can_suspend: bool,
|
||||
pub can_resume: bool,
|
||||
pub can_screenshot: bool,
|
||||
}
|
||||
|
||||
#[derive(serde::Deserialize, serde::Serialize, Debug)]
|
||||
pub struct VMState {
|
||||
pub state: String,
|
||||
@ -147,6 +256,16 @@ impl TokenInfo {
|
||||
false
|
||||
}
|
||||
|
||||
/// List the groups with access
|
||||
pub fn list_groups(&self) -> Vec<GroupID> {
|
||||
self.rights
|
||||
.iter()
|
||||
.filter(|r| r.verb == "GET")
|
||||
.filter(|r| regex!("^/api/group/[^/]+/vm/info$").is_match(&r.path))
|
||||
.map(|r| GroupID(r.path.split("/").nth(3).unwrap().to_string()))
|
||||
.collect::<Vec<_>>()
|
||||
}
|
||||
|
||||
/// List the virtual machines with access
|
||||
pub fn list_vm(&self) -> Vec<VMUuid> {
|
||||
self.rights
|
||||
@ -168,12 +287,13 @@ async fn request<D: Display>(uri: D) -> anyhow::Result<reqwest::Response> {
|
||||
let url = format!("{}{}", AppConfig::get().virtweb_base_url, uri);
|
||||
log::debug!("Will query {uri}...");
|
||||
|
||||
let uri = uri.to_string();
|
||||
let jwt = TokenClaims {
|
||||
sub: AppConfig::get().virtweb_token_id.to_string(),
|
||||
iat: time() - 60 * 2,
|
||||
exp: time() + 60 * 3,
|
||||
verb: "GET".to_string(),
|
||||
path: uri.to_string(),
|
||||
path: uri.split_once('?').map(|s| s.0).unwrap_or(&uri).to_string(),
|
||||
nonce: Uuid::new_v4().to_string(),
|
||||
};
|
||||
let jwt = AppConfig::get().token_private_key().sign_jwt(&jwt)?;
|
||||
@ -260,6 +380,73 @@ pub async fn vm_screenshot(id: VMUuid) -> anyhow::Result<Vec<u8>> {
|
||||
.to_vec())
|
||||
}
|
||||
|
||||
/// Get the VM of a group
|
||||
pub async fn group_vm_info(id: &GroupID) -> anyhow::Result<Vec<VMInfo>> {
|
||||
json_request(id.route_vm_info()).await
|
||||
}
|
||||
|
||||
/// Get the state of one or all VMs of a group
|
||||
pub async fn group_vm_state(
|
||||
id: &GroupID,
|
||||
vm_id: Option<VMUuid>,
|
||||
) -> anyhow::Result<HashMap<VMUuid, String>> {
|
||||
json_request(id.route_vm_state(vm_id)).await
|
||||
}
|
||||
|
||||
/// Start one or all VMs of a group
|
||||
pub async fn group_vm_start(
|
||||
id: &GroupID,
|
||||
vm_id: Option<VMUuid>,
|
||||
) -> anyhow::Result<TreatmentResult> {
|
||||
json_request(id.route_vm_start(vm_id)).await
|
||||
}
|
||||
|
||||
/// Shutdown one or all VMs of a group
|
||||
pub async fn group_vm_shutdown(
|
||||
id: &GroupID,
|
||||
vm_id: Option<VMUuid>,
|
||||
) -> anyhow::Result<TreatmentResult> {
|
||||
json_request(id.route_vm_shutdown(vm_id)).await
|
||||
}
|
||||
|
||||
/// Kill one or all VMs of a group
|
||||
pub async fn group_vm_kill(id: &GroupID, vm_id: Option<VMUuid>) -> anyhow::Result<TreatmentResult> {
|
||||
json_request(id.route_vm_kill(vm_id)).await
|
||||
}
|
||||
|
||||
/// Reset one or all VMs of a group
|
||||
pub async fn group_vm_reset(
|
||||
id: &GroupID,
|
||||
vm_id: Option<VMUuid>,
|
||||
) -> anyhow::Result<TreatmentResult> {
|
||||
json_request(id.route_vm_reset(vm_id)).await
|
||||
}
|
||||
|
||||
/// Suspend one or all VMs of a group
|
||||
pub async fn group_vm_suspend(
|
||||
id: &GroupID,
|
||||
vm_id: Option<VMUuid>,
|
||||
) -> anyhow::Result<TreatmentResult> {
|
||||
json_request(id.route_vm_suspend(vm_id)).await
|
||||
}
|
||||
|
||||
/// Resume one or all VMs of a group
|
||||
pub async fn group_vm_resume(
|
||||
id: &GroupID,
|
||||
vm_id: Option<VMUuid>,
|
||||
) -> anyhow::Result<TreatmentResult> {
|
||||
json_request(id.route_vm_resume(vm_id)).await
|
||||
}
|
||||
|
||||
/// Get the screenshot of one or all VMs of a group
|
||||
pub async fn group_vm_screenshot(id: &GroupID, vm_id: Option<VMUuid>) -> anyhow::Result<Vec<u8>> {
|
||||
Ok(request(id.route_vm_screenshot(vm_id))
|
||||
.await?
|
||||
.bytes()
|
||||
.await?
|
||||
.to_vec())
|
||||
}
|
||||
|
||||
/// Get current server information
|
||||
pub async fn get_server_info() -> anyhow::Result<SystemInfo> {
|
||||
json_request("/api/server/info").await
|
||||
|
@ -1,18 +0,0 @@
|
||||
module.exports = {
|
||||
root: true,
|
||||
env: { browser: true, es2020: true },
|
||||
extends: [
|
||||
'eslint:recommended',
|
||||
'plugin:@typescript-eslint/recommended',
|
||||
'plugin:react-hooks/recommended',
|
||||
],
|
||||
ignorePatterns: ['dist', '.eslintrc.cjs'],
|
||||
parser: '@typescript-eslint/parser',
|
||||
plugins: ['react-refresh'],
|
||||
rules: {
|
||||
'react-refresh/only-export-components': [
|
||||
'warn',
|
||||
{ allowConstantExport: true },
|
||||
],
|
||||
},
|
||||
}
|
28
remote_frontend/eslint.config.js
Normal file
28
remote_frontend/eslint.config.js
Normal file
@ -0,0 +1,28 @@
|
||||
import js from '@eslint/js'
|
||||
import globals from 'globals'
|
||||
import reactHooks from 'eslint-plugin-react-hooks'
|
||||
import reactRefresh from 'eslint-plugin-react-refresh'
|
||||
import tseslint from 'typescript-eslint'
|
||||
|
||||
export default tseslint.config(
|
||||
{ ignores: ['dist'] },
|
||||
{
|
||||
extends: [js.configs.recommended, ...tseslint.configs.recommended],
|
||||
files: ['**/*.{ts,tsx}'],
|
||||
languageOptions: {
|
||||
ecmaVersion: 2020,
|
||||
globals: globals.browser,
|
||||
},
|
||||
plugins: {
|
||||
'react-hooks': reactHooks,
|
||||
'react-refresh': reactRefresh,
|
||||
},
|
||||
rules: {
|
||||
...reactHooks.configs.recommended.rules,
|
||||
'react-refresh/only-export-components': [
|
||||
'warn',
|
||||
{ allowConstantExport: true },
|
||||
],
|
||||
},
|
||||
},
|
||||
)
|
4937
remote_frontend/package-lock.json
generated
4937
remote_frontend/package-lock.json
generated
File diff suppressed because it is too large
Load Diff
@ -10,22 +10,25 @@
|
||||
"preview": "vite preview"
|
||||
},
|
||||
"dependencies": {
|
||||
"@fluentui/react-components": "^9.49.2",
|
||||
"@fluentui/react-icons": "^2.0.239",
|
||||
"filesize": "^10.1.1",
|
||||
"react": "^18.2.0",
|
||||
"react-dom": "^18.2.0"
|
||||
"@fluentui/react-components": "^9.66.6",
|
||||
"@fluentui/react-icons": "^2.0.305",
|
||||
"filesize": "^10.1.6",
|
||||
"react": "^18.3.1",
|
||||
"react-dom": "^18.3.1"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@types/react": "^18.2.66",
|
||||
"@types/react-dom": "^18.2.22",
|
||||
"@typescript-eslint/eslint-plugin": "^8.0.0",
|
||||
"@typescript-eslint/parser": "^8.2.0",
|
||||
"@vitejs/plugin-react": "^4.2.1",
|
||||
"eslint": "^8.57.0",
|
||||
"eslint-plugin-react-hooks": "^4.6.0",
|
||||
"eslint-plugin-react-refresh": "^0.4.6",
|
||||
"typescript": "^5.2.2",
|
||||
"vite": "^5.2.11"
|
||||
"@eslint/js": "^9.30.1",
|
||||
"@types/react": "^18.3.23",
|
||||
"@types/react-dom": "^18.3.7",
|
||||
"@typescript-eslint/eslint-plugin": "^8.36.0",
|
||||
"@typescript-eslint/parser": "^8.36.0",
|
||||
"@vitejs/plugin-react": "^4.6.0",
|
||||
"eslint": "^9.26.0",
|
||||
"eslint-plugin-react-hooks": "^5.2.0",
|
||||
"eslint-plugin-react-refresh": "^0.4.20",
|
||||
"globals": "^16.3.0",
|
||||
"typescript": "^5.8.3",
|
||||
"typescript-eslint": "^8.36.0",
|
||||
"vite": "^6.3.5"
|
||||
}
|
||||
}
|
||||
|
@ -5,6 +5,8 @@ import {
|
||||
typographyStyles,
|
||||
} from "@fluentui/react-components";
|
||||
import {
|
||||
AppsListDetailFilled,
|
||||
AppsListDetailRegular,
|
||||
DesktopFilled,
|
||||
DesktopRegular,
|
||||
InfoFilled,
|
||||
@ -12,12 +14,13 @@ import {
|
||||
bundleIcon,
|
||||
} from "@fluentui/react-icons";
|
||||
import React from "react";
|
||||
import { ServerApi } from "./api/ServerApi";
|
||||
import { Rights, ServerApi } from "./api/ServerApi";
|
||||
import { AuthRouteWidget } from "./routes/AuthRouteWidget";
|
||||
import { AsyncWidget } from "./widgets/AsyncWidget";
|
||||
import { MainMenu } from "./widgets/MainMenu";
|
||||
import { SystemInfoWidget } from "./widgets/SystemInfoWidget";
|
||||
import { VirtualMachinesWidget } from "./widgets/VirtualMachinesWidget";
|
||||
import { GroupsWidget } from "./widgets/GroupsWidget";
|
||||
|
||||
const useStyles = makeStyles({
|
||||
title: typographyStyles.title2,
|
||||
@ -27,6 +30,8 @@ const InfoIcon = bundleIcon(InfoFilled, InfoRegular);
|
||||
|
||||
const DesktopIcon = bundleIcon(DesktopFilled, DesktopRegular);
|
||||
|
||||
const AppListIcon = bundleIcon(AppsListDetailFilled, AppsListDetailRegular);
|
||||
|
||||
export function App() {
|
||||
return (
|
||||
<AsyncWidget
|
||||
@ -40,45 +45,79 @@ export function App() {
|
||||
}
|
||||
|
||||
function AppInner(): React.ReactElement {
|
||||
const styles = useStyles();
|
||||
const [tab, setTab] = React.useState<"vm" | "info">("vm");
|
||||
|
||||
if (!ServerApi.Config.authenticated && !ServerApi.Config.disable_auth)
|
||||
return <AuthRouteWidget />;
|
||||
|
||||
return <AuthenticatedApp />;
|
||||
}
|
||||
|
||||
function AuthenticatedApp(): React.ReactElement {
|
||||
const styles = useStyles();
|
||||
const [tab, setTab] = React.useState<"group" | "vm" | "info">("group");
|
||||
|
||||
const [rights, setRights] = React.useState<Rights | undefined>();
|
||||
|
||||
const load = async () => {
|
||||
const rights = await ServerApi.GetRights();
|
||||
setRights(rights);
|
||||
|
||||
if (rights!.groups.length > 0) setTab("group");
|
||||
else if (rights!.vms.length > 0) setTab("vm");
|
||||
else setTab("info");
|
||||
};
|
||||
|
||||
return (
|
||||
<div
|
||||
style={{
|
||||
width: "95%",
|
||||
maxWidth: "1000px",
|
||||
margin: "50px auto",
|
||||
<AsyncWidget
|
||||
loadKey={1}
|
||||
load={load}
|
||||
errMsg="Failed to retrieve application rights!"
|
||||
build={() => {
|
||||
return (
|
||||
<div
|
||||
style={{
|
||||
width: "95%",
|
||||
maxWidth: "1000px",
|
||||
margin: "50px auto",
|
||||
}}
|
||||
>
|
||||
<span className={styles.title}>VirtWebRemote</span>
|
||||
<div
|
||||
style={{
|
||||
display: "flex",
|
||||
justifyContent: "space-between",
|
||||
marginTop: "30px",
|
||||
}}
|
||||
>
|
||||
<TabList
|
||||
selectedValue={tab}
|
||||
onTabSelect={(_, d) => setTab(d.value as any)}
|
||||
>
|
||||
{rights!.groups.length > 0 && (
|
||||
<Tab value="group" icon={<AppListIcon />}>
|
||||
Groups
|
||||
</Tab>
|
||||
)}
|
||||
{rights!.vms.length > 0 && (
|
||||
<Tab value="vm" icon={<DesktopIcon />}>
|
||||
Virtual machines
|
||||
</Tab>
|
||||
)}
|
||||
{rights!.sys_info && (
|
||||
<Tab value="info" icon={<InfoIcon />}>
|
||||
System info
|
||||
</Tab>
|
||||
)}
|
||||
</TabList>
|
||||
<div>
|
||||
<MainMenu />
|
||||
</div>
|
||||
</div>
|
||||
{tab === "group" && <GroupsWidget rights={rights!} />}
|
||||
{tab === "vm" && <VirtualMachinesWidget rights={rights!} />}
|
||||
{tab === "info" && <SystemInfoWidget />}
|
||||
</div>
|
||||
);
|
||||
}}
|
||||
>
|
||||
<span className={styles.title}>VirtWebRemote</span>
|
||||
<div
|
||||
style={{
|
||||
display: "flex",
|
||||
justifyContent: "space-between",
|
||||
marginTop: "30px",
|
||||
}}
|
||||
>
|
||||
<TabList
|
||||
selectedValue={tab}
|
||||
onTabSelect={(_, d) => setTab(d.value as any)}
|
||||
>
|
||||
<Tab value="vm" icon={<DesktopIcon />}>
|
||||
Virtual machines
|
||||
</Tab>
|
||||
<Tab value="info" icon={<InfoIcon />}>
|
||||
System info
|
||||
</Tab>
|
||||
</TabList>
|
||||
<div>
|
||||
<MainMenu />
|
||||
</div>
|
||||
</div>
|
||||
{tab === "vm" && <VirtualMachinesWidget />}
|
||||
{tab === "info" && <SystemInfoWidget />}
|
||||
</div>
|
||||
/>
|
||||
);
|
||||
}
|
||||
|
107
remote_frontend/src/api/GroupApi.ts
Normal file
107
remote_frontend/src/api/GroupApi.ts
Normal file
@ -0,0 +1,107 @@
|
||||
import { APIClient } from "./ApiClient";
|
||||
import { VMGroup } from "./ServerApi";
|
||||
import { VMInfo, VMState } from "./VMApi";
|
||||
|
||||
export interface GroupVMState {
|
||||
[key: string]: VMState;
|
||||
}
|
||||
|
||||
export interface TreatmentResult {
|
||||
ok: number;
|
||||
failed: number;
|
||||
}
|
||||
|
||||
export class GroupApi {
|
||||
/**
|
||||
* Get the state of the VMs of a group
|
||||
*/
|
||||
static async State(g: VMGroup): Promise<GroupVMState> {
|
||||
return (
|
||||
await APIClient.exec({ method: "GET", uri: `/group/${g.id}/vm/state` })
|
||||
).data;
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to start the VM of a group
|
||||
*/
|
||||
static async StartVM(g: VMGroup, vm?: VMInfo): Promise<TreatmentResult> {
|
||||
return (
|
||||
await APIClient.exec({
|
||||
method: "GET",
|
||||
uri: `/group/${g.id}/vm/start` + (vm ? `?vm_id=${vm.uuid}` : ""),
|
||||
})
|
||||
).data;
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to suspend the VM of a group
|
||||
*/
|
||||
static async SuspendVM(g: VMGroup, vm?: VMInfo): Promise<TreatmentResult> {
|
||||
return (
|
||||
await APIClient.exec({
|
||||
method: "GET",
|
||||
uri: `/group/${g.id}/vm/suspend` + (vm ? `?vm_id=${vm.uuid}` : ""),
|
||||
})
|
||||
).data;
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to resume the VM of a group
|
||||
*/
|
||||
static async ResumeVM(g: VMGroup, vm?: VMInfo): Promise<TreatmentResult> {
|
||||
return (
|
||||
await APIClient.exec({
|
||||
method: "GET",
|
||||
uri: `/group/${g.id}/vm/resume` + (vm ? `?vm_id=${vm.uuid}` : ""),
|
||||
})
|
||||
).data;
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to shutdown the VM of a group
|
||||
*/
|
||||
static async ShutdownVM(g: VMGroup, vm?: VMInfo): Promise<TreatmentResult> {
|
||||
return (
|
||||
await APIClient.exec({
|
||||
method: "GET",
|
||||
uri: `/group/${g.id}/vm/shutdown` + (vm ? `?vm_id=${vm.uuid}` : ""),
|
||||
})
|
||||
).data;
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to kill the VM of a group
|
||||
*/
|
||||
static async KillVM(g: VMGroup, vm?: VMInfo): Promise<TreatmentResult> {
|
||||
return (
|
||||
await APIClient.exec({
|
||||
method: "GET",
|
||||
uri: `/group/${g.id}/vm/kill` + (vm ? `?vm_id=${vm.uuid}` : ""),
|
||||
})
|
||||
).data;
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to reset the VM of a group
|
||||
*/
|
||||
static async ResetVM(g: VMGroup, vm?: VMInfo): Promise<TreatmentResult> {
|
||||
return (
|
||||
await APIClient.exec({
|
||||
method: "GET",
|
||||
uri: `/group/${g.id}/vm/reset` + (vm ? `?vm_id=${vm.uuid}` : ""),
|
||||
})
|
||||
).data;
|
||||
}
|
||||
|
||||
/**
|
||||
* Request a screenshot of the VM of group
|
||||
*/
|
||||
static async ScreenshotVM(g: VMGroup, vm?: VMInfo): Promise<Blob> {
|
||||
return (
|
||||
await APIClient.exec({
|
||||
method: "GET",
|
||||
uri: `/group/${g.id}/vm/screenshot` + (vm ? `?vm_id=${vm.uuid}` : ""),
|
||||
})
|
||||
).data;
|
||||
}
|
||||
}
|
@ -1,10 +1,24 @@
|
||||
import { APIClient } from "./ApiClient";
|
||||
import { VMCaps, VMInfo, VMInfoAndCaps } from "./VMApi";
|
||||
|
||||
export interface ServerConfig {
|
||||
authenticated: boolean;
|
||||
disable_auth: boolean;
|
||||
}
|
||||
|
||||
export interface Rights {
|
||||
groups: VMGroup[];
|
||||
vms: VMInfoAndCaps[];
|
||||
sys_info: boolean;
|
||||
}
|
||||
|
||||
export type VMGroup = VMGroupInfo & VMCaps;
|
||||
|
||||
export interface VMGroupInfo {
|
||||
id: string;
|
||||
vms: VMInfo[];
|
||||
}
|
||||
|
||||
let config: ServerConfig | null = null;
|
||||
|
||||
export class ServerApi {
|
||||
@ -27,4 +41,16 @@ export class ServerApi {
|
||||
if (config === null) throw new Error("Missing configuration!");
|
||||
return config;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get application rights
|
||||
*/
|
||||
static async GetRights(): Promise<Rights> {
|
||||
return (
|
||||
await APIClient.exec({
|
||||
uri: "/server/rights",
|
||||
method: "GET",
|
||||
})
|
||||
).data;
|
||||
}
|
||||
}
|
||||
|
@ -1,9 +1,5 @@
|
||||
import { APIClient } from "./ApiClient";
|
||||
|
||||
export interface SysInfoConfig {
|
||||
allowed: boolean;
|
||||
}
|
||||
|
||||
export interface LoadAverage {
|
||||
one: number;
|
||||
five: number;
|
||||
@ -24,14 +20,6 @@ export interface SysInfoStatus {
|
||||
}
|
||||
|
||||
export class SysInfoApi {
|
||||
/**
|
||||
* Get system info configuration (ie. check if it allowed)
|
||||
*/
|
||||
static async GetConfig(): Promise<SysInfoConfig> {
|
||||
return (await APIClient.exec({ method: "GET", uri: "/sysinfo/config" }))
|
||||
.data;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get system status
|
||||
*/
|
||||
|
@ -1,12 +1,15 @@
|
||||
import { APIClient } from "./ApiClient";
|
||||
|
||||
export interface VMInfo {
|
||||
uiid: string;
|
||||
uuid: string;
|
||||
name: string;
|
||||
description?: string;
|
||||
architecture: string;
|
||||
memory: number;
|
||||
number_vcpu: number;
|
||||
}
|
||||
|
||||
export interface VMCaps {
|
||||
can_get_state: boolean;
|
||||
can_start: boolean;
|
||||
can_shutdown: boolean;
|
||||
@ -17,6 +20,8 @@ export interface VMInfo {
|
||||
can_screenshot: boolean;
|
||||
}
|
||||
|
||||
export type VMInfoAndCaps = VMInfo & VMCaps;
|
||||
|
||||
export type VMState =
|
||||
| "NoState"
|
||||
| "Running"
|
||||
@ -29,19 +34,12 @@ export type VMState =
|
||||
| "Other";
|
||||
|
||||
export class VMApi {
|
||||
/**
|
||||
* Get the list of VM that can be managed by this console
|
||||
*/
|
||||
static async GetList(): Promise<VMInfo[]> {
|
||||
return (await APIClient.exec({ method: "GET", uri: "/vm/list" })).data;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the state of a VM
|
||||
*/
|
||||
static async State(vm: VMInfo): Promise<VMState> {
|
||||
return (
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uiid}/state` })
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uuid}/state` })
|
||||
).data.state;
|
||||
}
|
||||
|
||||
@ -49,42 +47,42 @@ export class VMApi {
|
||||
* Request to start VM
|
||||
*/
|
||||
static async StartVM(vm: VMInfo): Promise<void> {
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uiid}/start` });
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uuid}/start` });
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to suspend VM
|
||||
*/
|
||||
static async SuspendVM(vm: VMInfo): Promise<void> {
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uiid}/suspend` });
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uuid}/suspend` });
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to resume VM
|
||||
*/
|
||||
static async ResumeVM(vm: VMInfo): Promise<void> {
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uiid}/resume` });
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uuid}/resume` });
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to shutdown VM
|
||||
*/
|
||||
static async ShutdownVM(vm: VMInfo): Promise<void> {
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uiid}/shutdown` });
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uuid}/shutdown` });
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to kill VM
|
||||
*/
|
||||
static async KillVM(vm: VMInfo): Promise<void> {
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uiid}/kill` });
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uuid}/kill` });
|
||||
}
|
||||
|
||||
/**
|
||||
* Request to reset VM
|
||||
*/
|
||||
static async ResetVM(vm: VMInfo): Promise<void> {
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uiid}/reset` });
|
||||
await APIClient.exec({ method: "GET", uri: `/vm/${vm.uuid}/reset` });
|
||||
}
|
||||
|
||||
/**
|
||||
@ -93,7 +91,7 @@ export class VMApi {
|
||||
static async Screenshot(vm: VMInfo): Promise<Blob> {
|
||||
return (
|
||||
await APIClient.exec({
|
||||
uri: `/vm/${vm.uiid}/screenshot`,
|
||||
uri: `/vm/${vm.uuid}/screenshot`,
|
||||
method: "GET",
|
||||
})
|
||||
).data;
|
||||
|
@ -20,7 +20,7 @@ type ThemeContext = { theme: Theme; set: (theme: Theme) => void };
|
||||
const ThemeContextK = React.createContext<ThemeContext | null>(null);
|
||||
|
||||
export function ThemeProvider(p: React.PropsWithChildren): React.ReactElement {
|
||||
const [theme, setTheme] = React.useState<Theme>("highcontrast");
|
||||
const [theme, setTheme] = React.useState<Theme>("teamsdark");
|
||||
|
||||
let fluentTheme = teamsHighContrastTheme;
|
||||
switch (theme) {
|
||||
|
177
remote_frontend/src/widgets/GroupVMAction.tsx
Normal file
177
remote_frontend/src/widgets/GroupVMAction.tsx
Normal file
@ -0,0 +1,177 @@
|
||||
import { Button, Spinner, Toolbar, Tooltip } from "@fluentui/react-components";
|
||||
import {
|
||||
ArrowResetRegular,
|
||||
PauseRegular,
|
||||
PlayCircleRegular,
|
||||
PlayFilled,
|
||||
PowerRegular,
|
||||
StopRegular,
|
||||
} from "@fluentui/react-icons";
|
||||
import React from "react";
|
||||
import { GroupApi, TreatmentResult } from "../api/GroupApi";
|
||||
import { VMGroup } from "../api/ServerApi";
|
||||
import { VMInfo, VMState } from "../api/VMApi";
|
||||
import { useAlert } from "../hooks/providers/AlertDialogProvider";
|
||||
import { useConfirm } from "../hooks/providers/ConfirmDialogProvider";
|
||||
import { useToast } from "../hooks/providers/ToastProvider";
|
||||
|
||||
export function GroupVMAction(p: {
|
||||
group: VMGroup;
|
||||
state?: VMState;
|
||||
vm?: VMInfo;
|
||||
}): React.ReactElement {
|
||||
return (
|
||||
<Toolbar>
|
||||
<GroupVMButton
|
||||
enabled={p.group.can_start}
|
||||
icon={<PlayFilled />}
|
||||
tooltip="Start"
|
||||
group={p.group}
|
||||
vm={p.vm}
|
||||
allowedStates={["Shutdown", "Shutoff", "Crashed"]}
|
||||
currState={p.state}
|
||||
needConfirm={false}
|
||||
action={GroupApi.StartVM}
|
||||
/>
|
||||
<GroupVMButton
|
||||
enabled={p.group.can_suspend}
|
||||
icon={<PauseRegular />}
|
||||
tooltip="Suspend"
|
||||
group={p.group}
|
||||
vm={p.vm}
|
||||
allowedStates={["Running"]}
|
||||
currState={p.state}
|
||||
needConfirm={true}
|
||||
action={GroupApi.SuspendVM}
|
||||
/>
|
||||
<GroupVMButton
|
||||
enabled={p.group.can_resume}
|
||||
icon={<PlayCircleRegular />}
|
||||
tooltip="Resume"
|
||||
group={p.group}
|
||||
vm={p.vm}
|
||||
allowedStates={["Paused", "PowerManagementSuspended"]}
|
||||
currState={p.state}
|
||||
needConfirm={false}
|
||||
action={GroupApi.ResumeVM}
|
||||
/>
|
||||
<GroupVMButton
|
||||
enabled={p.group.can_shutdown}
|
||||
icon={<PowerRegular />}
|
||||
tooltip="Shutdown"
|
||||
group={p.group}
|
||||
vm={p.vm}
|
||||
allowedStates={["Running"]}
|
||||
currState={p.state}
|
||||
needConfirm={true}
|
||||
action={GroupApi.ShutdownVM}
|
||||
/>
|
||||
<GroupVMButton
|
||||
enabled={p.group.can_kill}
|
||||
icon={<StopRegular />}
|
||||
tooltip="Kill"
|
||||
group={p.group}
|
||||
vm={p.vm}
|
||||
allowedStates={[
|
||||
"Running",
|
||||
"Paused",
|
||||
"PowerManagementSuspended",
|
||||
"Blocked",
|
||||
]}
|
||||
currState={p.state}
|
||||
needConfirm={true}
|
||||
action={GroupApi.KillVM}
|
||||
/>
|
||||
<GroupVMButton
|
||||
enabled={p.group.can_reset}
|
||||
icon={<ArrowResetRegular />}
|
||||
tooltip="Reset"
|
||||
group={p.group}
|
||||
vm={p.vm}
|
||||
allowedStates={[
|
||||
"Running",
|
||||
"Paused",
|
||||
"PowerManagementSuspended",
|
||||
"Blocked",
|
||||
]}
|
||||
currState={p.state}
|
||||
needConfirm={true}
|
||||
action={GroupApi.ResetVM}
|
||||
/>
|
||||
</Toolbar>
|
||||
);
|
||||
}
|
||||
|
||||
function GroupVMButton(p: {
|
||||
enabled: boolean;
|
||||
icon: React.ReactElement;
|
||||
action: (group: VMGroup, vm?: VMInfo) => Promise<TreatmentResult>;
|
||||
tooltip: string;
|
||||
currState?: VMState;
|
||||
allowedStates: VMState[];
|
||||
group: VMGroup;
|
||||
vm?: VMInfo;
|
||||
needConfirm: boolean;
|
||||
}): React.ReactElement {
|
||||
const toast = useToast();
|
||||
const confirm = useConfirm();
|
||||
const alert = useAlert();
|
||||
|
||||
const [running, setRunning] = React.useState(false);
|
||||
|
||||
const target = p.vm
|
||||
? `the VM ${p.vm.name}`
|
||||
: `all the VM of the group ${p.group.id}`;
|
||||
|
||||
const allowed =
|
||||
!p.vm || (p.currState && p.allowedStates.includes(p.currState));
|
||||
|
||||
const perform = async () => {
|
||||
if (running || !allowed) return;
|
||||
try {
|
||||
if (
|
||||
(!p.vm || p.needConfirm) &&
|
||||
!(await confirm(
|
||||
`Do you want to perform ${p.tooltip} action on ${target}?`,
|
||||
`Confirmation`,
|
||||
p.tooltip
|
||||
))
|
||||
) {
|
||||
return;
|
||||
}
|
||||
|
||||
setRunning(true);
|
||||
|
||||
const result = await p.action(p.group, p.vm);
|
||||
|
||||
toast(
|
||||
p.tooltip,
|
||||
`${p.tooltip} action on ${target}: ${result.ok} OK / ${result.failed} Failed`,
|
||||
"success"
|
||||
);
|
||||
} catch (e) {
|
||||
console.error("Failed to perform group action!", e);
|
||||
|
||||
alert(`Failed to perform ${p.tooltip} action on ${target}: ${e}`);
|
||||
} finally {
|
||||
setRunning(false);
|
||||
}
|
||||
};
|
||||
|
||||
if (!p.enabled) return <></>;
|
||||
|
||||
return (
|
||||
<Tooltip
|
||||
content={`${p.tooltip} ${target}`}
|
||||
relationship="description"
|
||||
withArrow
|
||||
>
|
||||
<Button
|
||||
icon={running ? <Spinner size="tiny" /> : p.icon}
|
||||
onClick={allowed ? perform : undefined}
|
||||
disabled={!allowed}
|
||||
appearance="subtle"
|
||||
/>
|
||||
</Tooltip>
|
||||
);
|
||||
}
|
171
remote_frontend/src/widgets/GroupsWidget.tsx
Normal file
171
remote_frontend/src/widgets/GroupsWidget.tsx
Normal file
@ -0,0 +1,171 @@
|
||||
import {
|
||||
Button,
|
||||
Card,
|
||||
Dialog,
|
||||
DialogActions,
|
||||
DialogBody,
|
||||
DialogContent,
|
||||
DialogSurface,
|
||||
DialogTitle,
|
||||
DialogTrigger,
|
||||
Table,
|
||||
TableBody,
|
||||
TableCell,
|
||||
TableCellActions,
|
||||
TableCellLayout,
|
||||
TableHeader,
|
||||
TableHeaderCell,
|
||||
TableRow,
|
||||
Title3,
|
||||
Tooltip,
|
||||
} from "@fluentui/react-components";
|
||||
import { Desktop24Regular, ScreenshotRegular } from "@fluentui/react-icons";
|
||||
import { filesize } from "filesize";
|
||||
import React from "react";
|
||||
import { GroupApi, GroupVMState } from "../api/GroupApi";
|
||||
import { Rights, VMGroup } from "../api/ServerApi";
|
||||
import { VMInfo } from "../api/VMApi";
|
||||
import { useToast } from "../hooks/providers/ToastProvider";
|
||||
import { GroupVMAction } from "./GroupVMAction";
|
||||
import { VMLiveScreenshot } from "./VMLiveScreenshot";
|
||||
|
||||
export function GroupsWidget(p: { rights: Rights }): React.ReactElement {
|
||||
return (
|
||||
<>
|
||||
{p.rights.groups.map((g) => (
|
||||
<GroupInfo group={g} />
|
||||
))}
|
||||
</>
|
||||
);
|
||||
}
|
||||
|
||||
function GroupInfo(p: { group: VMGroup }): React.ReactElement {
|
||||
const toast = useToast();
|
||||
|
||||
const [state, setState] = React.useState<GroupVMState | undefined>();
|
||||
const [screenshotVM, setScreenshotVM] = React.useState<VMInfo | undefined>();
|
||||
|
||||
const load = async () => {
|
||||
const newState = await GroupApi.State(p.group);
|
||||
if (state !== newState) setState(newState);
|
||||
};
|
||||
|
||||
const screenshot = (vm: VMInfo) => {
|
||||
setScreenshotVM(vm);
|
||||
};
|
||||
|
||||
React.useEffect(() => {
|
||||
const interval = setInterval(async () => {
|
||||
try {
|
||||
if (p.group.can_get_state) await load();
|
||||
} catch (e) {
|
||||
console.error(e);
|
||||
toast(
|
||||
"Error",
|
||||
`Failed to refresh group ${p.group.id} VMs status!`,
|
||||
"error"
|
||||
);
|
||||
}
|
||||
}, 1000);
|
||||
return () => clearInterval(interval);
|
||||
});
|
||||
|
||||
return (
|
||||
<>
|
||||
<Card
|
||||
style={{
|
||||
margin: "50px 10px",
|
||||
display: "flex",
|
||||
flexDirection: "column",
|
||||
}}
|
||||
>
|
||||
<div style={{ display: "flex", justifyContent: "space-between" }}>
|
||||
<Title3 style={{ marginLeft: "10px" }}>{p.group.id}</Title3>
|
||||
<GroupVMAction group={p.group} />
|
||||
</div>
|
||||
<Table sortable>
|
||||
<TableHeader>
|
||||
<TableRow>
|
||||
<TableHeaderCell>VM</TableHeaderCell>
|
||||
<TableHeaderCell>Resources</TableHeaderCell>
|
||||
<TableHeaderCell>State</TableHeaderCell>
|
||||
<TableHeaderCell>Actions</TableHeaderCell>
|
||||
</TableRow>
|
||||
</TableHeader>
|
||||
<TableBody>
|
||||
{p.group.vms.map((item) => (
|
||||
<TableRow key={item.uuid}>
|
||||
<TableCell>
|
||||
<TableCellLayout
|
||||
media={<Desktop24Regular />}
|
||||
appearance="primary"
|
||||
description={item.description}
|
||||
>
|
||||
{item.name}
|
||||
</TableCellLayout>
|
||||
<TableCellActions>
|
||||
{state?.[item.uuid] === "Running" && (
|
||||
<Tooltip
|
||||
relationship="description"
|
||||
content={"Take a screenshot of the VM screen"}
|
||||
withArrow
|
||||
>
|
||||
<Button
|
||||
icon={<ScreenshotRegular />}
|
||||
appearance="subtle"
|
||||
aria-label="Edit"
|
||||
disabled={!p.group.can_screenshot}
|
||||
onClick={() => screenshot(item)}
|
||||
/>
|
||||
</Tooltip>
|
||||
)}
|
||||
</TableCellActions>
|
||||
</TableCell>
|
||||
<TableCell>
|
||||
{item.architecture} • RAM :{" "}
|
||||
{filesize(item.memory)} •{" "}
|
||||
{item.number_vcpu} vCPU
|
||||
</TableCell>
|
||||
<TableCell>{state?.[item.uuid] ?? ""}</TableCell>
|
||||
<TableCell>
|
||||
<GroupVMAction
|
||||
group={p.group}
|
||||
state={state?.[item.uuid]}
|
||||
vm={item}
|
||||
/>
|
||||
</TableCell>
|
||||
</TableRow>
|
||||
))}
|
||||
</TableBody>
|
||||
</Table>
|
||||
</Card>
|
||||
<Dialog
|
||||
open={!!screenshotVM}
|
||||
onOpenChange={(_event, _data) => {
|
||||
if (!screenshotVM) setScreenshotVM(undefined);
|
||||
}}
|
||||
>
|
||||
<DialogSurface>
|
||||
<DialogBody>
|
||||
<DialogTitle>
|
||||
<em>{screenshotVM?.name}</em> screen
|
||||
</DialogTitle>
|
||||
<DialogContent>
|
||||
<VMLiveScreenshot vm={screenshotVM!} group={p.group} />
|
||||
</DialogContent>
|
||||
<DialogActions>
|
||||
<DialogTrigger disableButtonEnhancement>
|
||||
<Button
|
||||
appearance="secondary"
|
||||
onClick={() => setScreenshotVM(undefined)}
|
||||
>
|
||||
Close
|
||||
</Button>
|
||||
</DialogTrigger>
|
||||
</DialogActions>
|
||||
</DialogBody>
|
||||
</DialogSurface>
|
||||
</Dialog>
|
||||
</>
|
||||
);
|
||||
}
|
@ -1,47 +1,13 @@
|
||||
import React from "react";
|
||||
import { SysInfoApi, SysInfoConfig, SysInfoStatus } from "../api/SysInfoApi";
|
||||
import { AsyncWidget } from "./AsyncWidget";
|
||||
import { SectionContainer } from "./SectionContainer";
|
||||
import { Field, ProgressBar } from "@fluentui/react-components";
|
||||
import { filesize } from "filesize";
|
||||
import { format_duration } from "../utils/time_utils";
|
||||
import React from "react";
|
||||
import { SysInfoApi, SysInfoStatus } from "../api/SysInfoApi";
|
||||
import { useToast } from "../hooks/providers/ToastProvider";
|
||||
import { format_duration } from "../utils/time_utils";
|
||||
import { AsyncWidget } from "./AsyncWidget";
|
||||
import { SectionContainer } from "./SectionContainer";
|
||||
|
||||
export function SystemInfoWidget(): React.ReactElement {
|
||||
const [config, setConfig] = React.useState<SysInfoConfig | undefined>();
|
||||
|
||||
const load = async () => {
|
||||
setConfig(await SysInfoApi.GetConfig());
|
||||
};
|
||||
|
||||
return (
|
||||
<SectionContainer>
|
||||
<AsyncWidget
|
||||
loadKey={1}
|
||||
load={load}
|
||||
errMsg="Failed to check system configuration!"
|
||||
loadingMessage="Checking server configuration..."
|
||||
build={() =>
|
||||
config?.allowed ? (
|
||||
<SystemInfoWidgetInner />
|
||||
) : (
|
||||
<SystemInfoWidgetUnavailable />
|
||||
)
|
||||
}
|
||||
/>
|
||||
</SectionContainer>
|
||||
);
|
||||
}
|
||||
|
||||
function SystemInfoWidgetUnavailable(): React.ReactElement {
|
||||
return (
|
||||
<p style={{ textAlign: "center" }}>
|
||||
Unfortunatley, system information is available. (not enough privileges)
|
||||
</p>
|
||||
);
|
||||
}
|
||||
|
||||
function SystemInfoWidgetInner(): React.ReactElement {
|
||||
const toast = useToast();
|
||||
|
||||
const [status, setStatus] = React.useState<SysInfoStatus | undefined>();
|
||||
@ -63,49 +29,51 @@ function SystemInfoWidgetInner(): React.ReactElement {
|
||||
});
|
||||
|
||||
return (
|
||||
<AsyncWidget
|
||||
loadKey={1}
|
||||
load={load}
|
||||
loadingMessage="Loading system status..."
|
||||
errMsg="Failed to load system status!"
|
||||
build={() => (
|
||||
<div
|
||||
style={{
|
||||
display: "flex",
|
||||
flexDirection: "row",
|
||||
alignItems: "center",
|
||||
justifyContent: "center",
|
||||
}}
|
||||
>
|
||||
<Field
|
||||
validationMessage={`${filesize(
|
||||
status!.system.used_memory
|
||||
)} of memory used out of ${filesize(
|
||||
status!.system.available_memory + status!.system.used_memory
|
||||
)}`}
|
||||
validationState="none"
|
||||
style={{ flex: 2 }}
|
||||
<SectionContainer>
|
||||
<AsyncWidget
|
||||
loadKey={1}
|
||||
load={load}
|
||||
loadingMessage="Loading system status..."
|
||||
errMsg="Failed to load system status!"
|
||||
build={() => (
|
||||
<div
|
||||
style={{
|
||||
display: "flex",
|
||||
flexDirection: "row",
|
||||
alignItems: "center",
|
||||
justifyContent: "center",
|
||||
}}
|
||||
>
|
||||
<ProgressBar
|
||||
value={
|
||||
status!.system.used_memory /
|
||||
(status!.system.available_memory + status!.system.used_memory)
|
||||
}
|
||||
/>
|
||||
</Field>
|
||||
<div style={{ width: "20px" }}></div>
|
||||
<div style={{ flex: 1 }}>
|
||||
<p>
|
||||
Load average: {status!.system.load_average.one}{" "}
|
||||
{status!.system.load_average.five}{" "}
|
||||
{status!.system.load_average.fifteen}
|
||||
</p>
|
||||
<UptimeWidget uptime={status!.system.uptime} />
|
||||
Number physical cores: {status!.system.physical_core_count}
|
||||
<Field
|
||||
validationMessage={`${filesize(
|
||||
status!.system.used_memory
|
||||
)} of memory used out of ${filesize(
|
||||
status!.system.available_memory + status!.system.used_memory
|
||||
)}`}
|
||||
validationState="none"
|
||||
style={{ flex: 2 }}
|
||||
>
|
||||
<ProgressBar
|
||||
value={
|
||||
status!.system.used_memory /
|
||||
(status!.system.available_memory + status!.system.used_memory)
|
||||
}
|
||||
/>
|
||||
</Field>
|
||||
<div style={{ width: "20px" }}></div>
|
||||
<div style={{ flex: 1 }}>
|
||||
<p>
|
||||
Load average: {status!.system.load_average.one}{" "}
|
||||
{status!.system.load_average.five}{" "}
|
||||
{status!.system.load_average.fifteen}
|
||||
</p>
|
||||
<UptimeWidget uptime={status!.system.uptime} />
|
||||
Number physical cores: {status!.system.physical_core_count}
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
)}
|
||||
/>
|
||||
)}
|
||||
/>
|
||||
</SectionContainer>
|
||||
);
|
||||
}
|
||||
|
||||
|
@ -1,8 +1,13 @@
|
||||
import React from "react";
|
||||
import { GroupApi } from "../api/GroupApi";
|
||||
import { VMGroup } from "../api/ServerApi";
|
||||
import { VMApi, VMInfo } from "../api/VMApi";
|
||||
import { useToast } from "../hooks/providers/ToastProvider";
|
||||
|
||||
export function VMLiveScreenshot(p: { vm: VMInfo }): React.ReactElement {
|
||||
export function VMLiveScreenshot(p: {
|
||||
vm: VMInfo;
|
||||
group?: VMGroup;
|
||||
}): React.ReactElement {
|
||||
const toast = useToast();
|
||||
|
||||
const [screenshotURL, setScreenshotURL] = React.useState<
|
||||
@ -14,7 +19,9 @@ export function VMLiveScreenshot(p: { vm: VMInfo }): React.ReactElement {
|
||||
React.useEffect(() => {
|
||||
const refresh = async () => {
|
||||
try {
|
||||
const screenshot = await VMApi.Screenshot(p.vm);
|
||||
const screenshot = p.group
|
||||
? await GroupApi.ScreenshotVM(p.group, p.vm)
|
||||
: await VMApi.Screenshot(p.vm);
|
||||
const u = URL.createObjectURL(screenshot);
|
||||
setScreenshotURL(u);
|
||||
} catch (e) {
|
||||
|
@ -21,10 +21,10 @@ import {
|
||||
} from "@fluentui/react-icons";
|
||||
import { filesize } from "filesize";
|
||||
import React from "react";
|
||||
import { VMApi, VMInfo, VMState } from "../api/VMApi";
|
||||
import { Rights } from "../api/ServerApi";
|
||||
import { VMApi, VMInfo, VMInfoAndCaps, VMState } from "../api/VMApi";
|
||||
import { useConfirm } from "../hooks/providers/ConfirmDialogProvider";
|
||||
import { useToast } from "../hooks/providers/ToastProvider";
|
||||
import { AsyncWidget } from "./AsyncWidget";
|
||||
import { SectionContainer } from "./SectionContainer";
|
||||
import { VMLiveScreenshot } from "./VMLiveScreenshot";
|
||||
|
||||
@ -33,43 +33,28 @@ const useStyles = makeStyles({
|
||||
caption1: typographyStyles.caption1,
|
||||
});
|
||||
|
||||
export function VirtualMachinesWidget(): React.ReactElement {
|
||||
const [list, setList] = React.useState<VMInfo[] | undefined>();
|
||||
const load = async () => {
|
||||
setList(await VMApi.GetList());
|
||||
};
|
||||
|
||||
export function VirtualMachinesWidget(p: {
|
||||
rights: Rights;
|
||||
}): React.ReactElement {
|
||||
return (
|
||||
<SectionContainer>
|
||||
<AsyncWidget
|
||||
loadKey={1}
|
||||
load={load}
|
||||
loadingMessage="Loading the list virtual machines..."
|
||||
errMsg="Failed to load the list of virtual machines!"
|
||||
build={() => <VirtualMachinesWidgetInner list={list!} />}
|
||||
/>
|
||||
<div
|
||||
style={{
|
||||
display: "flex",
|
||||
flexDirection: "row",
|
||||
flexWrap: "wrap",
|
||||
justifyContent: "center",
|
||||
}}
|
||||
>
|
||||
{p.rights.vms.map((v, n) => (
|
||||
<VMWidget key={n} vm={v} />
|
||||
))}
|
||||
</div>
|
||||
</SectionContainer>
|
||||
);
|
||||
}
|
||||
|
||||
function VirtualMachinesWidgetInner(p: { list: VMInfo[] }): React.ReactElement {
|
||||
return (
|
||||
<div
|
||||
style={{
|
||||
display: "flex",
|
||||
flexDirection: "row",
|
||||
flexWrap: "wrap",
|
||||
justifyContent: "center",
|
||||
}}
|
||||
>
|
||||
{p.list.map((v, n) => (
|
||||
<VMWidget key={n} vm={v} />
|
||||
))}{" "}
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
function VMWidget(p: { vm: VMInfo }): React.ReactElement {
|
||||
function VMWidget(p: { vm: VMInfoAndCaps }): React.ReactElement {
|
||||
const toast = useToast();
|
||||
|
||||
const [state, setState] = React.useState<VMState | undefined>();
|
||||
@ -122,7 +107,7 @@ function VMWidget(p: { vm: VMInfo }): React.ReactElement {
|
||||
}
|
||||
/>
|
||||
<p className={styles.caption1} style={{ margin: "0px auto" }}>
|
||||
{p.vm.architecture} • RAM : {filesize(p.vm.memory * 1000 * 1000)}{" "}
|
||||
{p.vm.architecture} • RAM : {filesize(p.vm.memory)}{" "}
|
||||
• {p.vm.number_vcpu} vCPU
|
||||
</p>
|
||||
|
||||
@ -204,7 +189,10 @@ function VMWidget(p: { vm: VMInfo }): React.ReactElement {
|
||||
);
|
||||
}
|
||||
|
||||
function VMPreview(p: { vm: VMInfo; state?: VMState }): React.ReactElement {
|
||||
function VMPreview(p: {
|
||||
vm: VMInfoAndCaps;
|
||||
state?: VMState;
|
||||
}): React.ReactElement {
|
||||
const styles = useStyles();
|
||||
if (!p.vm.can_screenshot || p.state !== "Running") {
|
||||
return (
|
||||
|
26
remote_frontend/tsconfig.app.json
Normal file
26
remote_frontend/tsconfig.app.json
Normal file
@ -0,0 +1,26 @@
|
||||
{
|
||||
"compilerOptions": {
|
||||
"tsBuildInfoFile": "./node_modules/.tmp/tsconfig.app.tsbuildinfo",
|
||||
"target": "ES2020",
|
||||
"useDefineForClassFields": true,
|
||||
"lib": ["ES2020", "DOM", "DOM.Iterable"],
|
||||
"module": "ESNext",
|
||||
"skipLibCheck": true,
|
||||
|
||||
/* Bundler mode */
|
||||
"moduleResolution": "bundler",
|
||||
"allowImportingTsExtensions": true,
|
||||
"isolatedModules": true,
|
||||
"moduleDetection": "force",
|
||||
"noEmit": true,
|
||||
"jsx": "react-jsx",
|
||||
|
||||
/* Linting */
|
||||
"strict": true,
|
||||
"noUnusedLocals": true,
|
||||
"noUnusedParameters": true,
|
||||
"noFallthroughCasesInSwitch": true,
|
||||
"noUncheckedSideEffectImports": true
|
||||
},
|
||||
"include": ["src"]
|
||||
}
|
@ -1,25 +1,7 @@
|
||||
{
|
||||
"compilerOptions": {
|
||||
"target": "ES2020",
|
||||
"useDefineForClassFields": true,
|
||||
"lib": ["ES2020", "DOM", "DOM.Iterable"],
|
||||
"module": "ESNext",
|
||||
"skipLibCheck": true,
|
||||
|
||||
/* Bundler mode */
|
||||
"moduleResolution": "bundler",
|
||||
"allowImportingTsExtensions": true,
|
||||
"resolveJsonModule": true,
|
||||
"isolatedModules": true,
|
||||
"noEmit": true,
|
||||
"jsx": "react-jsx",
|
||||
|
||||
/* Linting */
|
||||
"strict": true,
|
||||
"noUnusedLocals": true,
|
||||
"noUnusedParameters": true,
|
||||
"noFallthroughCasesInSwitch": true
|
||||
},
|
||||
"include": ["src"],
|
||||
"references": [{ "path": "./tsconfig.node.json" }]
|
||||
"files": [],
|
||||
"references": [
|
||||
{ "path": "./tsconfig.app.json" },
|
||||
{ "path": "./tsconfig.node.json" }
|
||||
]
|
||||
}
|
||||
|
@ -1,11 +1,24 @@
|
||||
{
|
||||
"compilerOptions": {
|
||||
"composite": true,
|
||||
"skipLibCheck": true,
|
||||
"tsBuildInfoFile": "./node_modules/.tmp/tsconfig.node.tsbuildinfo",
|
||||
"target": "ES2022",
|
||||
"lib": ["ES2023"],
|
||||
"module": "ESNext",
|
||||
"skipLibCheck": true,
|
||||
|
||||
/* Bundler mode */
|
||||
"moduleResolution": "bundler",
|
||||
"allowSyntheticDefaultImports": true,
|
||||
"strict": true
|
||||
"allowImportingTsExtensions": true,
|
||||
"isolatedModules": true,
|
||||
"moduleDetection": "force",
|
||||
"noEmit": true,
|
||||
|
||||
/* Linting */
|
||||
"strict": true,
|
||||
"noUnusedLocals": true,
|
||||
"noUnusedParameters": true,
|
||||
"noFallthroughCasesInSwitch": true,
|
||||
"noUncheckedSideEffectImports": true
|
||||
},
|
||||
"include": ["vite.config.ts"]
|
||||
}
|
||||
|
@ -1,7 +1,7 @@
|
||||
import { defineConfig } from 'vite'
|
||||
import react from '@vitejs/plugin-react'
|
||||
|
||||
// https://vitejs.dev/config/
|
||||
// https://vite.dev/config/
|
||||
export default defineConfig({
|
||||
plugins: [react()],
|
||||
})
|
||||
|
@ -1,9 +1,3 @@
|
||||
{
|
||||
"$schema": "https://docs.renovatebot.com/renovate-schema.json",
|
||||
"packageRules": [
|
||||
{
|
||||
"matchUpdateTypes": ["major", "minor", "patch"],
|
||||
"automerge": true
|
||||
}
|
||||
]
|
||||
"extends": ["local>renovate/presets"]
|
||||
}
|
Reference in New Issue
Block a user