race test

This commit is contained in:
Aravinth Manivannan 2021-06-09 14:30:41 +05:30
parent 86b3f2cd95
commit b6873cf661
Signed by: realaravinth
GPG key ID: AD9F0F08E855ED88
3 changed files with 50 additions and 7 deletions

View file

@ -92,14 +92,18 @@ impl Handler<AddVisitor> for Master {
fn handle(&mut self, m: AddVisitor, ctx: &mut Self::Context) -> Self::Result { fn handle(&mut self, m: AddVisitor, ctx: &mut Self::Context) -> Self::Result {
let (tx, rx) = channel(); let (tx, rx) = channel();
match self.get_site(&m.0) { match self.get_site(&m.0) {
None => tx.send(Ok(None)).unwrap(), None => {
let _ = tx.send(Ok(None));
}
Some(addr) => { Some(addr) => {
let fut = async move { let fut = async move {
match addr.send(super::counter::AddVisitor).await { match addr.send(super::counter::AddVisitor).await {
Ok(val) => tx.send(Ok(Some(val))).unwrap(), Ok(val) => {
let _ = tx.send(Ok(Some(val)));
}
Err(e) => { Err(e) => {
let err: CaptchaError = e.into(); let err: CaptchaError = e.into();
tx.send(Err(err)).unwrap(); let _ = tx.send(Err(err));
} }
} }
} }

View file

@ -71,7 +71,7 @@ pub mod messages {
use crate::mcaptcha::MCaptcha; use crate::mcaptcha::MCaptcha;
/// Message to add visitor to an [MCaptcha] actor /// Message to add visitor to an [MCaptcha] actor
#[derive(Message)] #[derive(Message, Clone)]
#[rtype(result = "Receiver<CaptchaResult<Option<super::AddVisitorResult>>>")] #[rtype(result = "Receiver<CaptchaResult<Option<super::AddVisitorResult>>>")]
pub struct AddVisitor(pub String); pub struct AddVisitor(pub String);

View file

@ -52,7 +52,7 @@ impl Handler<AddVisitor> for Master {
let con = self.redis.get_client(); let con = self.redis.get_client();
let fut = async move { let fut = async move {
let res = con.add_visitor(m).await; let res = con.add_visitor(m).await;
tx.send(res).unwrap() let _ = tx.send(res);
} }
.into_actor(self); .into_actor(self);
ctx.wait(fut); ctx.wait(fut);
@ -82,12 +82,11 @@ mod tests {
use crate::master::redis::master::Master; use crate::master::redis::master::Master;
use crate::redis::RedisConfig; use crate::redis::RedisConfig;
const CAPTCHA_NAME: &str = "REDIS_MASTER_CAPTCHA_TEST";
const REDIS_URL: &str = "redis://127.0.1.1/"; const REDIS_URL: &str = "redis://127.0.1.1/";
#[actix_rt::test] #[actix_rt::test]
async fn redis_master_works() { async fn redis_master_works() {
const CAPTCHA_NAME: &str = "REDIS_MASTER_CAPTCHA_TEST";
let master = Master::new(RedisConfig::Single(REDIS_URL.into())).await; let master = Master::new(RedisConfig::Single(REDIS_URL.into())).await;
let sec_master = Master::new(RedisConfig::Single(REDIS_URL.into())).await; let sec_master = Master::new(RedisConfig::Single(REDIS_URL.into())).await;
let r = sec_master.unwrap().redis.get_client(); let r = sec_master.unwrap().redis.get_client();
@ -116,5 +115,45 @@ mod tests {
let timer_expire = std::time::Duration::new(duration, 0); let timer_expire = std::time::Duration::new(duration, 0);
actix::clock::delay_for(timer_expire).await; actix::clock::delay_for(timer_expire).await;
let visitors = r.get_visitors(CAPTCHA_NAME).await.unwrap();
assert_eq!(visitors, 0);
}
#[actix_rt::test]
async fn race_redis_master() {
const CAPTCHA_NAME: &str = "REDIS_MASTER_CAPTCHA_RACE";
let master = Master::new(RedisConfig::Single(REDIS_URL.into())).await;
let sec_master = Master::new(RedisConfig::Single(REDIS_URL.into())).await;
let r = sec_master.unwrap().redis.get_client();
assert!(master.is_ok());
let master = master.unwrap();
{
let _ = master.redis.get_client().delete_captcha(CAPTCHA_NAME).await;
}
let addr = master.start();
let mcaptcha = get_mcaptcha();
let duration = mcaptcha.get_duration();
let add_mcaptcha_msg = AddSite {
id: CAPTCHA_NAME.into(),
mcaptcha,
};
addr.send(add_mcaptcha_msg).await.unwrap();
let add_visitor_msg = AddVisitor(CAPTCHA_NAME.into());
for _ in 0..500 {
addr.send(add_visitor_msg.clone()).await.unwrap();
}
let visitors = r.get_visitors(CAPTCHA_NAME).await.unwrap();
assert_eq!(visitors, 500);
let timer_expire = std::time::Duration::new(duration, 0);
actix::clock::delay_for(timer_expire).await;
let visitors = r.get_visitors(CAPTCHA_NAME).await.unwrap();
assert_eq!(visitors, 0);
} }
} }