6341660898

Committed 28 Sep 2023 04:28PM UTC coverage: 35.579% (+0.9%) from 34.699%

Build # 6341660898

Build Type

push

github

Committed by

fabioDMFerreira

Commit Message

lint: fix issue on news_websocket_processor

Run Details

1 of 1 new or added line in 1 file covered. (100.0%)

3127 of 8789 relevant lines covered (35.58%)

22.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

10.0

/users/src/services/event_service.rs

use async_trait::async_trait;
use mockall::automock;
use rdkafka::producer::FutureProducer;
use utils::{broker, error::BrokerError};

use crate::models::user::User;

#[automock]
#[async_trait]
pub trait EventService: Send + Sync {
    async fn user_created(&self, user: User) -> Result<(), BrokerError>;
}

pub struct KafkaEventService {
    producer: FutureProducer,
}

impl KafkaEventService {
    pub fn new(producer: FutureProducer) -> Self {
        KafkaEventService { producer }
    }
}

#[async_trait]
impl EventService for KafkaEventService {
    async fn user_created(&self, user: User) -> Result<(), BrokerError> {
        let json_string = serde_json::to_string(&user).unwrap();

        let delivery_status =
            broker::send_message_to_topic(self.producer.clone(), "user_created", json_string);

        match delivery_status.await {
            Err((err, _)) => {
                return Err(BrokerError {
                    message: err.to_string(),
                })
            }
            Ok(_) => return Ok(()),
        }
    }
}

1	use async_trait::async_trait;
2	use mockall::automock;
3	use rdkafka::producer::FutureProducer;
4	use utils::{broker, error::BrokerError};
5
6	use crate::models::user::User;
7
8	#[automock]	572✔
9	#[async_trait]
10	pub trait EventService: Send + Sync {
11	async fn user_created(&self, user: User) -> Result<(), BrokerError>;	60✔
12	}
13
14	pub struct KafkaEventService {
15	producer: FutureProducer,
16	}
17
18	impl KafkaEventService {
19	pub fn new(producer: FutureProducer) -> Self {	×
20	KafkaEventService { producer }	×
21	}	×
22	}
23
24	#[async_trait]
25	impl EventService for KafkaEventService {
26	async fn user_created(&self, user: User) -> Result<(), BrokerError> {	×
27	let json_string = serde_json::to_string(&user).unwrap();	×
28
29	let delivery_status =	×
30	broker::send_message_to_topic(self.producer.clone(), "user_created", json_string);	×
31		×
32	match delivery_status.await {	×
33	Err((err, _)) => {	×
34	return Err(BrokerError {	×
35	message: err.to_string(),	×
36	})	×
37	}	×
38	Ok(_) => return Ok(()),	×
39	}
40	}	×
41	}	×

fabioDMFerreira / rust-events-oriented-arch / 6341660898

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous