fts-server 0.3.0

A RESTful flow trading API server
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

#![allow(unused_macros)]

use std::{any::Any, marker::PhantomData};

use fts_core::{models::Config, ports::MarketRepository};
use fts_sqlite::db::Database as simple_database;
use rstest_reuse::template;
// use pg_backend::db::initialize_db;
// use testcontainers_modules::{
//     postgres::Postgres,
//     testcontainers::{runners::AsyncRunner, ImageExt},
// };

// pub async fn launch_pg_backend() -> (impl MarketRepository, Box<dyn Any>) {
//     let node = Postgres::default().with_tag("17").start().await.unwrap();
//     let connection_string = &format!(
//         "postgres://postgres:postgres@localhost:{}/postgres",
//         node.get_host_port_ipv4(5432).await.unwrap()
//     );
//     let db = initialize_db(&connection_string)
//         .await
//         .expect("could not initialize database");

//     (db, Box::new(node))
// }

pub async fn launch_simple_backend() -> (impl MarketRepository, Box<dyn Any>) {
    let db = simple_database::open(
        None,
        Some(Config {
            trade_rate: std::time::Duration::from_secs(60 * 60),
        }),
    )
    .expect("could not open in-memory db");

    (db, Box::new(PhantomData::<()>))
}

// This creates a testing "template" to allow for the injection of each backend
// implementation

#[template]
#[rstest]
//#[case::pg(launch_pg_backend())]
#[case::sqlite(launch_simple_backend())]
#[tokio::test]
pub async fn all_backends(
    #[case] backend: impl Future<Output = (impl MarketRepository, Box<dyn Any>)>,
) -> () {
}