eventify-http-server 0.0.0-reserved

Ethereum Indexer/Event listener
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
77
78
79

use secrecy::Secret;
use sqlx::{Connection, Executor, PgConnection, PgPool};
use uuid::Uuid;

pub struct TestApp {
    pub address: String,
    pub port: u16,
    pub db_pool: PgPool,
}

/// Run the server as a background task
pub async fn spawn_app() -> TestApp {
    //Lazy::force(&TRACING);

    // Randomise configuration to ensure test isolation
    let configuration = {
        //let mut c = get_configuration().expect("Failed to read configuration.");
        let mut c = eventify_http_server::Settings {
            application: eventify_http_server::ApplicationSettings {
                host: String::from("localhost"),
                port: 0,
                worker_threads: 1,
            },
            database: eventify_primitives::DatabaseSettings {
                host: String::from("localhost"),
                port: 5432,
                username: String::from("postgres"),
                password: Secret::new(String::from("password")),
                database_name: String::from(""),
                require_ssl: false,
            },
        };

        // Use a different database for each test case
        c.database.database_name = Uuid::new_v4().to_string();
        // Use a random OS port
        c.application.port = 0;

        c
    };

    // Create and migrate the database
    configure_database(&configuration.database).await;

    // Launch the application as a background task
    let application = eventify_http_server::startup::Application::build(configuration.clone())
        .await
        .expect("Failed to build application.");
    let application_port = application.port();
    let _ = tokio::spawn(application.run_until_stopped());

    TestApp {
        address: format!("http://localhost:{}", application_port),
        port: application_port,
        db_pool: eventify_http_server::startup::get_connection_pool(&configuration.database),
    }
}

async fn configure_database(config: &eventify_primitives::DatabaseSettings) -> PgPool {
    // Create database
    let mut connection = PgConnection::connect_with(&config.without_db())
        .await
        .expect("Failed to connect to Postgres");
    connection
        .execute(&*format!(r#"CREATE DATABASE "{}";"#, config.database_name))
        .await
        .expect("Failed to create database.");

    // Migrate database
    let connection_pool = PgPool::connect_with(config.with_db())
        .await
        .expect("Failed to connect to Postgres.");
    sqlx::migrate!("../../migrations/rdms/postgres/")
        .run(&connection_pool)
        .await
        .expect("Failed to migrate the database");

    connection_pool
}