Add websockets into the api scope

diff --git a/server/src/main.rs b/server/src/main.rs
index 6abb22439e67883d8e14dc6d9449b96b10e2b5de..c92770f2a6147540c60c49a049c78fa574d02397 100644 (file)
--- a/server/src/main.rs
+++ b/server/src/main.rs
@@ -8,7 +8,7 @@ use diesel::r2d2::{ConnectionManager, Pool};
 use diesel::PgConnection;
 use lemmy_server::{
   rate_limit::{rate_limiter::RateLimiter, RateLimit},
-  routes::{api, federation, feeds, index, nodeinfo, webfinger, websocket},
+  routes::{api, federation, feeds, index, nodeinfo, webfinger},
   settings::Settings,
   websocket::server::*,
 };
@@ -59,7 +59,6 @@ async fn main() -> io::Result<()> {
       .configure(index::config)
       .configure(nodeinfo::config)
       .configure(webfinger::config)
-      .configure(websocket::config)
       // static files
       .service(actix_files::Files::new(
         "/static",

diff --git a/server/src/routes/api.rs b/server/src/routes/api.rs
index 3ef8ca510d7371aa1e641dc21cfb326350568052..025c6e0a70ac9d47c09b8fa870fa6d7073dcc497 100644 (file)
--- a/server/src/routes/api.rs
+++ b/server/src/routes/api.rs
@@ -10,6 +10,8 @@ use actix_web::guard;
 pub fn config(cfg: &mut web::ServiceConfig, rate_limit: &RateLimit) {
   cfg.service(
     web::scope("/api/v1")
+      // Websockets
+      .service(web::resource("/ws").to(super::websocket::chat_route))
       // Site
       .service(
         web::scope("/site")

diff --git a/server/src/routes/websocket.rs b/server/src/routes/websocket.rs
index c6bca9aa0d6fd146d4c8a51c87b35284520b284a..eb1575906224dd8dfe3ebf57545191dafa937e1a 100644 (file)
--- a/server/src/routes/websocket.rs
+++ b/server/src/routes/websocket.rs
@@ -2,17 +2,13 @@ use super::*;
 use crate::websocket::server::*;
 use actix_web::{Error, Result};
 
-pub fn config(cfg: &mut web::ServiceConfig) {
-  cfg.service(web::resource("/api/v1/ws").to(chat_route));
-}
-
 /// How often heartbeat pings are sent
 const HEARTBEAT_INTERVAL: Duration = Duration::from_secs(5);
 /// How long before lack of client response causes a timeout
 const CLIENT_TIMEOUT: Duration = Duration::from_secs(10);
 
 /// Entry point for our route
-async fn chat_route(
+pub async fn chat_route(
   req: HttpRequest,
   stream: web::Payload,
   chat_server: web::Data<Addr<ChatServer>>,