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
|
pub mod postgres;
pub mod error;
use std::error::Error;
use futures::TryFutureExt;
pub use error::DatabaseError;
use proto::touchpad::common::v1;
use crate::hub::Output;
type Result<T> = std::result::Result<T, DatabaseError>;
#[async_trait::async_trait]
pub trait DatabaseClient {
async fn get_swimmer(&self, id: u32) -> Result<v1::Swimmer>;
async fn add_swimmer(&self, swimmer: &v1::Swimmer) -> Result<()>;
async fn get_team(&self, id: u32) -> Result<v1::Team>;
async fn add_team(&self, team: &v1::Team) -> Result<()>;
async fn get_meet(&self, id: u32) -> Result<v1::SwimMeet>;
async fn add_meet(&self, meet: &v1::SwimMeet) -> Result<()>;
async fn get_event(&self, id: u32) -> Result<v1::Event>;
async fn get_event_by_number(&self, meet_id: u32, number: u32) -> Result<v1::Event>;
async fn add_event(&self, event: &v1::Event) -> Result<()>;
}
#[async_trait::async_trait]
impl<T> Output for T
where
T: DatabaseClient + Sync {
async fn add_swimmer(&self, swimmer: &v1::Swimmer) -> std::result::Result<(), Box<dyn Error>> {
self.add_swimmer(swimmer).err_into().await
}
async fn add_team(&self, team: &v1::Team) -> std::result::Result<(), Box<dyn Error>> {
self.add_team(team).err_into().await
}
async fn add_meet(&self, meet: &v1::SwimMeet) -> std::result::Result<(), Box<dyn Error>> {
self.add_meet(meet).err_into().await
}
async fn upsert_event(&self, event: &v1::Event) -> std::result::Result<(), Box<dyn std::error::Error>> {
self.add_event(event).err_into().await
}
}
|
