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

mod message;
mod reader;
mod subscriber;
mod writer;

pub use message::Message;
use reader::Reader;
use sqlx::PgPool;
use subscriber::Subscriber;
use writer::Writer;

pub struct MessageDb<'a> {
  pub reader: Reader<'a>,
  pub subscriber: Subscriber<'a>,
  pub writer: Writer<'a>,
}

impl<'a> MessageDb<'a> {
  pub fn new(pool: &'a PgPool) -> Self {
    Self {
      reader: Reader::new(&pool),
      writer: Writer::new(&pool),
      subscriber: Subscriber::new(&pool),
    }
  }
}