mints_reader.rs

...

#[tokio::main]
pub async fn read() {
    let pool = db_handler::open_connection().await;
    let mut cursor = None;
    loop {
        cursor = execute_and_get_cursor(cursor, &pool).await;
        if cursor.is_none() {
            break;
        } else {
            info!("Current cursor: {}", cursor.clone().unwrap());
        }
    }
    db_handler::close_connection(pool).await;
}

async fn execute_and_get_cursor(cursor: Option<String>, pool: &Pool<Postgres>) -> Option<String> {
    let url = if cursor.is_some() { MINTS_URL.to_owned() + "&cursor=" + cursor.unwrap().as_str() } else { String::from(MINTS_URL) };
    let response = fetch_api_response::<Mint>(url.as_str()).await;
    match response {
        Ok(mint) => {
            info!("Processing mint response");
            if !mint.result.is_empty() {
                db_handler::save_mints(mint.result, pool).await;
            }

            if !mint.cursor.is_empty() {
                return Some(mint.cursor);
            }
            None
        }
        ...
    }
}

...