ouverture-core 0.1.0

A next-generation music player and manager library
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

pub mod config;
pub mod database;
pub mod library;
pub mod logger;
pub mod music;
pub mod server;

use config::Config;
use pg_embed::pg_errors::PgEmbedErrorType;
use server::Server;
use std::{error::Error, path::Path};

use database::*;
use pg_embed::pg_errors::PgEmbedError;
use pg_embed::pg_errors::PgEmbedErrorType::*;

use color_eyre::eyre::eyre;
use color_eyre::Result;
use log::{debug, error, info, warn};

pub async fn start(config: Config) -> Result<()> {
    info!("Ouverture server started");

    //encase ouverture within a scope, so that everything is dropped before the final "stopped"
    let status = {
        let mut pg = setup_db(config.clone()).await?;

        let res = start_db(&mut pg, config.clone()).await;
        if let Err(e) = res {
            warn!(
                "Retrying to start the database (may happen when the last process was interrupted)"
            );
            debug!("failed to start the database once {e}");
            if format!("{:?}", e).contains("PgStartFailure") {
                // failed to start db, may be due to lockfile presence and interrupt of the last ouverture server
                // let's retry once
                pg = setup_db(config.clone()).await?;
                start_db(&mut pg, config.clone()).await?;
            }
        }
        // test_db(config).await;

        let server_exit_status = Server::start(&config).await;

        debug!("stopping database");
        let res = pg.stop_db().await;
        match res {
            Err(e) => error!("failed to stop database {:?}", e),
            _ => (),
        };
        server_exit_status
    };

    info!("Ouverture server stopped");
    status
}