mirror of
https://github.com/rojo-rbx/rojo.git
synced 2026-04-21 21:25:16 +00:00
5d62bf9b60
* Upgrade dependencies, oneshot channel ref * New service style? * Fix warning * A server is running again * Working server with async blocks * UI working again * Finish upgrade * Bump MSRV to 1.46.0 for if/match in const fn * Update the README as part of this
62 lines
1.7 KiB
Rust
62 lines
1.7 KiB
Rust
//! Defines the Rojo web interface. This is what the Roblox Studio plugin
|
|
//! communicates with. Eventually, we'll make this API stable, produce better
|
|
//! documentation for it, and open it up for other consumers.
|
|
|
|
mod api;
|
|
mod assets;
|
|
pub mod interface;
|
|
mod ui;
|
|
mod util;
|
|
|
|
use std::convert::Infallible;
|
|
use std::net::SocketAddr;
|
|
use std::sync::Arc;
|
|
|
|
use hyper::{
|
|
server::Server,
|
|
service::{make_service_fn, service_fn},
|
|
Body, Request,
|
|
};
|
|
use tokio::runtime::Runtime;
|
|
|
|
use crate::serve_session::ServeSession;
|
|
|
|
pub struct LiveServer {
|
|
serve_session: Arc<ServeSession>,
|
|
}
|
|
|
|
impl LiveServer {
|
|
pub fn new(serve_session: Arc<ServeSession>) -> Self {
|
|
LiveServer { serve_session }
|
|
}
|
|
|
|
pub fn start(self, address: SocketAddr) {
|
|
let serve_session = Arc::clone(&self.serve_session);
|
|
|
|
let make_service = make_service_fn(move |_conn| {
|
|
let serve_session = Arc::clone(&serve_session);
|
|
|
|
async {
|
|
let service = move |req: Request<Body>| {
|
|
let serve_session = Arc::clone(&serve_session);
|
|
|
|
async move {
|
|
if req.uri().path().starts_with("/api") {
|
|
Ok::<_, Infallible>(api::call(serve_session, req).await)
|
|
} else {
|
|
Ok::<_, Infallible>(ui::call(serve_session, req).await)
|
|
}
|
|
}
|
|
};
|
|
|
|
Ok::<_, Infallible>(service_fn(service))
|
|
}
|
|
});
|
|
|
|
let rt = Runtime::new().unwrap();
|
|
let _guard = rt.enter();
|
|
let server = Server::bind(&address).serve(make_service);
|
|
rt.block_on(server).unwrap();
|
|
}
|
|
}
|