rwf 0.2.1

Framework for building web applications in the Rust programming language
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

//! Record HTTP requests made to the application.
//!
//! This will record the request path, response code, client IP, duration
//! and other metadata.
//!
use std::net::IpAddr;

use crate::model::{Error, FromRow, Model, ToValue, Value};

use time::OffsetDateTime;

/// HTTP request recorded by the request tracker middleware.
#[derive(Clone)]
pub struct Request {
    id: Option<i64>,
    path: String,
    method: String,
    query: serde_json::Value,
    code: i32,
    client_ip: Option<IpAddr>,
    created_at: OffsetDateTime,
    duration: f32,
}

impl FromRow for Request {
    fn from_row(row: tokio_postgres::Row) -> Result<Self, Error> {
        Ok(Self {
            id: row.try_get("id")?,
            path: row.try_get("path")?,
            method: row.try_get("method")?,
            query: row.try_get("query")?,
            code: row.try_get("code")?,
            client_ip: row.try_get("client")?,
            created_at: row.try_get("created_at")?,
            duration: row.try_get("duration")?,
        })
    }
}

impl Model for Request {
    fn id(&self) -> Value {
        self.id.to_value()
    }

    fn table_name() -> &'static str {
        "rwf_requests"
    }

    fn foreign_key() -> &'static str {
        "rwf_request_id"
    }

    fn column_names() -> &'static [&'static str] {
        &[
            "path",
            "method",
            "query",
            "code",
            "client_ip",
            "created_at",
            "duration",
        ]
    }

    fn values(&self) -> Vec<Value> {
        vec![
            self.path.to_value(),
            self.method.to_value(),
            self.query.to_value(),
            self.code.to_value(),
            self.client_ip.to_value(),
            self.created_at.to_value(),
            self.duration.to_value(),
        ]
    }
}