shindo_coding_utils 0.3.1

A utils crates which will be used in various micro-services
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use async_trait::async_trait;
use chrono::{DateTime, Utc};
use sea_orm::*;
use serde::{Deserialize, Serialize};
use std::sync::Arc;

use crate::schemas::consumer_handler_performance::{ActiveModel, Entity};

#[derive(Deserialize, Serialize, Debug)]
pub struct PerformanceRecord {
    pub handled_at: DateTime<Utc>,
    pub subject: String,
    pub duration_ms: i64,
    pub status: String, // success, business_error, failed, unknown
    pub handler_name: String,
    pub error_message: Option<String>,
}

#[async_trait]
pub trait ConsumerPerformanceRepository: Send + Sync {
    async fn insert(&self, record: PerformanceRecord)
    -> Result<InsertResult<ActiveModel>, DbErr>;
}

pub struct SeaOrmConsumerPerformanceRepository {
    db_conn: Arc<DatabaseConnection>,
}

impl SeaOrmConsumerPerformanceRepository {
    pub fn new(db_conn: Arc<DatabaseConnection>) -> Self {
        Self { db_conn }
    }
}

#[async_trait]
impl ConsumerPerformanceRepository for SeaOrmConsumerPerformanceRepository {
    async fn insert(
        &self,
        record: PerformanceRecord,
    ) -> Result<InsertResult<ActiveModel>, DbErr> {
        let active_model = ActiveModel {
            handled_at: Set(record.handled_at),
            subject: Set(record.subject),
            duration_ms: Set(record.duration_ms),
            status: Set(record.status),
            handler_name: Set(record.handler_name),
            error_message: Set(record.error_message),
            ..Default::default()
        };

        let insert_result = Entity::insert(active_model).exec(&*self.db_conn).await?;
        Ok(insert_result)
    }
}