diff --git a/jirs-server/src/ws/mod.rs b/jirs-server/src/ws/mod.rs index f053721b..297a36a7 100644 --- a/jirs-server/src/ws/mod.rs +++ b/jirs-server/src/ws/mod.rs @@ -7,6 +7,7 @@ use actix_web::web::Data; use actix_web::{get, web, Error, HttpRequest, HttpResponse}; use actix_web_actors::ws; use futures::executor::block_on; +use futures::SinkExt; use jirs_data::{ProjectId, Token, UserId, WsMsg}; @@ -266,35 +267,34 @@ impl StreamHandler> for WebSocketActor { } } -trait MessageHandler { - fn try_message(&self) -> Option - where - M: Message; -} - impl WebSocketActor { fn try_handle_message( &mut self, msg: WsMsg, - ctx: ::Context, - ) -> WsResult { - use invitations::*; + _ctx: &mut ::Context, + ) -> WsResult + where + Self: Actor, + { + match msg { + WsMsg::InvitationSendRequest { name, email } => { + use invitations::*; - Ok(None) - // match msg { - // WsMsg::InvitationSendRequest { name, email } => self.handle( - // CreateInvitation { - // name: name.clone(), - // email: email.clone(), - // }, - // ctx, - // ), - // WsMsg::InvitationListRequest => self.handle(ListInvitation, ctx), - // WsMsg::InvitationAcceptRequest(id) => Ok(None), - // WsMsg::InvitationRevokeRequest(id) => self.handle(RevokeInvitation { id: *id }, ctx), - // WsMsg::InvitedUsersRequest => Ok(None), - // _ => Ok(None), - // } + let m = CreateInvitation { + name: name.clone(), + email: email.clone(), + }; + // Handler::handle(&mut self, m, _ctx); + Ok(None) + // Handler::::handle(&mut self, m, _ctx) + // >.handle(m, ctx) + } + // WsMsg::InvitationListRequest => self.handle(ListInvitation, ctx), + // WsMsg::InvitationAcceptRequest(id) => Ok(None), + // WsMsg::InvitationRevokeRequest(id) => self.handle(RevokeInvitation { id: *id }, ctx), + // WsMsg::InvitedUsersRequest => Ok(None), + _ => Ok(None), + } } }