piyushxcoder
/
lupt
mirror of https://github.com/PiyushXCoder/lupt.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Renamed few stuffs

This commit is contained in:
Piyush मिश्रः 2023-06-18 12:12:24 +05:30
parent 8326f8f284
commit 4e05d9a84d
7 changed files with 51 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/broker_messages/mod.rs
View File

@ -21,5 +21,5 @@ use dev::MessageResponse;
// use dev::ResponseChannel; // use dev::ResponseChannel;
pub mod pind; pub mod pind;
pub mod responses;
pub mod sansad; pub mod sansad;
pub mod util;

8
src/broker_messages/pind.rs
View File

@ -16,7 +16,7 @@
*/ */
//! Messages to be sent between Actors //! Messages to be sent between Actors
use super::util::Resp; use super::responses::ResultResponse;
use super::*; use super::*;
//################################################## For ChatPinnd ################################################## //################################################## For ChatPinnd ##################################################
@ -24,7 +24,7 @@ use super::*;
/// Request to Kaksh with its kunjika /// Request to Kaksh with its kunjika
#[derive(Clone, Message)] #[derive(Clone, Message)]
#[rtype(result = "Resp")] #[rtype(result = "ResultResponse")]
pub struct JoinKaksh { pub struct JoinKaksh {
pub kaksh_kunjika: String, pub kaksh_kunjika: String,
pub length: Option<usize>, pub length: Option<usize>,
@ -35,7 +35,7 @@ pub struct JoinKaksh {
/// Request to connect Random vayakti /// Request to connect Random vayakti
#[derive(Clone, Message)] #[derive(Clone, Message)]
#[rtype(result = "Resp")] #[rtype(result = "ResultResponse")]
pub struct JoinRandom { pub struct JoinRandom {
pub addr: Addr<WsSansad>, pub addr: Addr<WsSansad>,
pub kunjika: String, pub kunjika: String,
@ -44,7 +44,7 @@ pub struct JoinRandom {
} }
/// Request to connect Random Next vayakti /// Request to connect Random Next vayakti
#[derive(Clone, Message)] #[derive(Clone, Message)]
#[rtype(result = "Resp")] #[rtype(result = "ResultResponse")]
pub struct JoinRandomNext { pub struct JoinRandomNext {
pub kaksh_kunjika: String, pub kaksh_kunjika: String,
pub kunjika: String, pub kunjika: String,

2
src/broker_messages/util.rs → src/broker_messages/responses.rs
View File

@ -17,7 +17,7 @@
// //################################################## Helper ################################################## // //################################################## Helper ##################################################
#[derive(Debug)] #[derive(Debug)]
pub enum Resp { pub enum ResultResponse {
Ok, Ok,
Err(String), Err(String),
None, None,

2
src/chat_pinnd/mod.rs
View File

@ -25,7 +25,7 @@ use std::{collections::HashMap, vec};
use actix::prelude::*; use actix::prelude::*;
use actix_broker::BrokerSubscribe; use actix_broker::BrokerSubscribe;
use crate::{broker_messages as ms, broker_messages::util::Resp, ws_sansad}; use crate::{broker_messages as ms, broker_messages::responses::ResultResponse, ws_sansad};
#[allow(dead_code)] #[allow(dead_code)]
pub struct ChatPinnd { pub struct ChatPinnd {

50
src/chat_pinnd/user.rs
View File

@ -28,7 +28,7 @@ impl Handler<ms::pind::JoinKaksh> for ChatPinnd {
.iter() .iter()
.position(|vk| vk.kunjika == msg.kunjika) .position(|vk| vk.kunjika == msg.kunjika)
{ {
return MessageResult(Resp::Err("Kunjika already exist".to_owned())); return MessageResult(ResultResponse::Err("Kunjika already exist".to_owned()));
} }
if let Some(_) = self.kaksh.iter().position(|(_, g)| { if let Some(_) = self.kaksh.iter().position(|(_, g)| {
@ -37,7 +37,7 @@ impl Handler<ms::pind::JoinKaksh> for ChatPinnd {
None => false, None => false,
} }
}) { }) {
return MessageResult(Resp::Err("Kunjika already exist".to_owned())); return MessageResult(ResultResponse::Err("Kunjika already exist".to_owned()));
} }
// check if kaksh exist and add user // check if kaksh exist and add user
@ -47,7 +47,9 @@ impl Handler<ms::pind::JoinKaksh> for ChatPinnd {
// check if kaksh have no space left // check if kaksh have no space left
if let Some(n) = kaksh.length { if let Some(n) = kaksh.length {
if kaksh.loog.len() >= n { if kaksh.loog.len() >= n {
return MessageResult(Resp::Err("Kaksh have no space".to_owned())); return MessageResult(ResultResponse::Err(
"Kaksh have no space".to_owned(),
));
} }
} }
@ -80,7 +82,7 @@ impl Handler<ms::pind::JoinKaksh> for ChatPinnd {
} }
} }
MessageResult(Resp::Ok) MessageResult(ResultResponse::Ok)
} }
} }
@ -97,7 +99,7 @@ impl Handler<ms::pind::JoinRandom> for ChatPinnd {
.iter() .iter()
.position(|vk| vk.kunjika == msg.kunjika) .position(|vk| vk.kunjika == msg.kunjika)
{ {
return MessageResult(Resp::Err("Kunjika already exist".to_owned())); return MessageResult(ResultResponse::Err("Kunjika already exist".to_owned()));
} }
if let Some(_) = self.kaksh.iter().position(|(_, g)| { if let Some(_) = self.kaksh.iter().position(|(_, g)| {
@ -106,7 +108,7 @@ impl Handler<ms::pind::JoinRandom> for ChatPinnd {
None => false, None => false,
} }
}) { }) {
return MessageResult(Resp::Err("Kunjika already exist".to_owned())); return MessageResult(ResultResponse::Err("Kunjika already exist".to_owned()));
} }
// Check if watch list is empty // Check if watch list is empty
@ -117,7 +119,7 @@ impl Handler<ms::pind::JoinRandom> for ChatPinnd {
name: msg.name, name: msg.name,
tags: msg.tags, tags: msg.tags,
}); });
return MessageResult(Resp::None); return MessageResult(ResultResponse::None);
} }
// connect person with tag // connect person with tag
@ -136,7 +138,7 @@ impl Handler<ms::pind::JoinRandom> for ChatPinnd {
name: msg.name, name: msg.name,
tags: msg.tags, tags: msg.tags,
}); });
return MessageResult(Resp::None); return MessageResult(ResultResponse::None);
} }
} }
} else { } else {
@ -185,7 +187,7 @@ impl Handler<ms::pind::JoinRandom> for ChatPinnd {
kaksh_kunjika: group_kunjika, kaksh_kunjika: group_kunjika,
}); });
MessageResult(Resp::Ok) MessageResult(ResultResponse::Ok)
} }
} }
@ -195,12 +197,20 @@ impl Handler<ms::pind::JoinRandomNext> for ChatPinnd {
fn handle(&mut self, msg: ms::pind::JoinRandomNext, _: &mut Self::Context) -> Self::Result { fn handle(&mut self, msg: ms::pind::JoinRandomNext, _: &mut Self::Context) -> Self::Result {
let kaksh = match self.kaksh.get_mut(&msg.kaksh_kunjika) { let kaksh = match self.kaksh.get_mut(&msg.kaksh_kunjika) {
Some(v) => v, Some(v) => v,
None => return MessageResult(Resp::Err("Failed to join, check entries!".to_owned())), None => {
return MessageResult(ResultResponse::Err(
"Failed to join, check entries!".to_owned(),
))
}
}; };
let loog_i = match kaksh.loog.iter().position(|a| a.kunjika == msg.kunjika) { let loog_i = match kaksh.loog.iter().position(|a| a.kunjika == msg.kunjika) {
Some(v) => v, Some(v) => v,
None => return MessageResult(Resp::Err("Failed to join, check entries!".to_owned())), None => {
return MessageResult(ResultResponse::Err(
"Failed to join, check entries!".to_owned(),
))
}
}; };
let addr; let addr;
@ -211,12 +221,16 @@ impl Handler<ms::pind::JoinRandomNext> for ChatPinnd {
let loog = match kaksh.loog.get(loog_i) { let loog = match kaksh.loog.get(loog_i) {
Some(v) => v, Some(v) => v,
None => { None => {
return MessageResult(Resp::Err("Failed to join, check entries!".to_owned())) return MessageResult(ResultResponse::Err(
"Failed to join, check entries!".to_owned(),
))
} }
}; };
if let None = loog.tags { if let None = loog.tags {
return MessageResult(Resp::Err("You are not a randome vyakti!".to_owned())); return MessageResult(ResultResponse::Err(
"You are not a randome vyakti!".to_owned(),
));
} }
addr = loog.addr.clone(); addr = loog.addr.clone();
@ -224,7 +238,9 @@ impl Handler<ms::pind::JoinRandomNext> for ChatPinnd {
tags = match loog.tags.clone() { tags = match loog.tags.clone() {
Some(v) => v, Some(v) => v,
None => { None => {
return MessageResult(Resp::Err("Failed to join, check entries!".to_owned())) return MessageResult(ResultResponse::Err(
"Failed to join, check entries!".to_owned(),
))
} }
}; };
} }
@ -246,7 +262,7 @@ impl Handler<ms::pind::JoinRandomNext> for ChatPinnd {
name, name,
tags, tags,
}); });
return MessageResult(Resp::None); return MessageResult(ResultResponse::None);
} }
// connect person with tag or to zero // connect person with tag or to zero
let pos = if tags.len() > 0 { let pos = if tags.len() > 0 {
@ -264,7 +280,7 @@ impl Handler<ms::pind::JoinRandomNext> for ChatPinnd {
name, name,
tags, tags,
}); });
return MessageResult(Resp::None); return MessageResult(ResultResponse::None);
} }
} }
} else { } else {
@ -318,7 +334,7 @@ impl Handler<ms::pind::JoinRandomNext> for ChatPinnd {
kaksh_kunjika: group_kunjika, kaksh_kunjika: group_kunjika,
}); });
MessageResult(Resp::Ok) MessageResult(ResultResponse::Ok)
} }
} }

2
src/ws_sansad/mod.rs
View File

@ -29,7 +29,7 @@ use std::time::{Duration, Instant};
use crate::{ use crate::{
broker_messages as ms, broker_messages as ms,
broker_messages::util::Resp, broker_messages::responses::ResultResponse,
chat_pinnd::ChatPinnd, chat_pinnd::ChatPinnd,
validator::{validate, Validation as vl}, validator::{validate, Validation as vl},
}; };

20
src/ws_sansad/users.rs
View File

@ -98,7 +98,7 @@ impl WsSansad {
}; };
// request // request
let result: Resp = ChatPinnd::from_registry() let result: ResultResponse = ChatPinnd::from_registry()
.send(ms::pind::JoinKaksh { .send(ms::pind::JoinKaksh {
kaksh_kunjika: kaksh_kunjika.to_owned(), kaksh_kunjika: kaksh_kunjika.to_owned(),
length, length,
@ -110,8 +110,8 @@ impl WsSansad {
.unwrap(); .unwrap();
match result { match result {
Resp::Err(err) => self.send_err_response(&err), ResultResponse::Err(err) => self.send_err_response(&err),
Resp::Ok => { ResultResponse::Ok => {
self.isthiti = Isthiti::Kaksh(kaksh_kunjika); self.isthiti = Isthiti::Kaksh(kaksh_kunjika);
self.addr self.addr
.clone() .clone()
@ -189,7 +189,7 @@ impl WsSansad {
}; };
// request // request
let result: Resp = ChatPinnd::from_registry() let result: ResultResponse = ChatPinnd::from_registry()
.send(ms::pind::JoinRandom { .send(ms::pind::JoinRandom {
addr: self.addr.clone().unwrap(), addr: self.addr.clone().unwrap(),
kunjika: kunjika.to_owned(), kunjika: kunjika.to_owned(),
@ -200,8 +200,8 @@ impl WsSansad {
.unwrap(); .unwrap();
match result { match result {
Resp::Err(err) => self.send_err_response(&err), ResultResponse::Err(err) => self.send_err_response(&err),
Resp::Ok => { ResultResponse::Ok => {
self.addr self.addr
.clone() .clone()
.unwrap() .unwrap()
@ -210,7 +210,7 @@ impl WsSansad {
}); });
self.kunjika = kunjika; self.kunjika = kunjika;
} }
Resp::None => { ResultResponse::None => {
self.addr.clone().unwrap().do_send(ms::sansad::WsResponse { self.addr.clone().unwrap().do_send(ms::sansad::WsResponse {
result: "watch".to_owned(), result: "watch".to_owned(),
message: "Watchlist".to_owned(), message: "Watchlist".to_owned(),
@ -243,7 +243,7 @@ impl WsSansad {
}; };
// request // request
let result: Resp = ChatPinnd::from_registry() let result: ResultResponse = ChatPinnd::from_registry()
.send(ms::pind::JoinRandomNext { .send(ms::pind::JoinRandomNext {
kunjika: self.kunjika.to_owned(), kunjika: self.kunjika.to_owned(),
kaksh_kunjika: kaksh_kunjika.to_owned(), kaksh_kunjika: kaksh_kunjika.to_owned(),
@ -252,8 +252,8 @@ impl WsSansad {
.unwrap(); .unwrap();
match result { match result {
Resp::Err(err) => self.send_err_response(&err), ResultResponse::Err(err) => self.send_err_response(&err),
Resp::None => { ResultResponse::None => {
self.addr.clone().unwrap().do_send(ms::sansad::WsResponse { self.addr.clone().unwrap().do_send(ms::sansad::WsResponse {
result: "watch".to_owned(), result: "watch".to_owned(),
message: "Watchlist".to_owned(), message: "Watchlist".to_owned(),