hop-cli 0.2.61

Interact with Hop in your terminal
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
80
81
82
83
84
85
86

use std::convert::Infallible;

use anyhow::{Context, Result};
use console::Term;
use hyper::{Body, Request, Response};
use tokio::sync::mpsc::Sender;

use super::WEB_PAYMENTS_URL;
use crate::commands::payment::utils::{format_payment_methods, get_all_payment_methods};
use crate::state::http::HttpClient;
use crate::utils::browser::listen_for_callback;
use crate::utils::urlify;

pub async fn get_payment_method_from_user(http: &HttpClient) -> Result<String> {
    loop {
        let payment_methods = get_all_payment_methods(http).await?;
        let mut payment_methods_fmt = format_payment_methods(&payment_methods, false)?;
        payment_methods_fmt.push("New payment method".to_string());

        let payment_method_idx = dialoguer::Select::new()
            .with_prompt("Select a payment method")
            .items(&payment_methods_fmt)
            .default(0)
            .interact()?;

        if payment_method_idx == payment_methods_fmt.len() - 1 {
            let _ = Term::stderr().clear_last_lines(1);

            let port = portpicker::pick_unused_port().with_context(|| {
                "Could not find an unused port. Please make sure you have at least one port available."
            })?;

            let url = format!(
                "{WEB_PAYMENTS_URL}?{}",
                ["callback", &format!("http://localhost:{port}/payment")].join("=")
            );

            if let Err(why) = webbrowser::open(&url) {
                log::error!("Could not open web a browser: {why}",);
                log::info!(
                    "Please open this URL in your browser: {}",
                    urlify(WEB_PAYMENTS_URL)
                );

                log::info!("Press enter to continue...");
                let _ = std::io::stdin().read_line(&mut String::new());
                Term::stderr().clear_last_lines(4)?;
            } else {
                log::info!("A browser window should have opened. If not, please open this URL in your browser: {}", urlify(&url));
                log::info!("Waiting for payment method to be created...");

                listen_for_callback(port, 10, |req, sender| {
                    Box::pin(request_handler(req, sender))
                })
                .await?;
            }

            // clear 3 because 2 logs and 1 new line
            let _ = Term::stdout().clear_last_lines(3);
        } else {
            return Ok(payment_methods[payment_method_idx].id.clone());
        }
    }
}

async fn request_handler(
    req: Request<Body>,
    sender: Sender<String>,
) -> Result<Response<Body>, Infallible> {
    let path = req.uri().path();

    // payment method created
    if path == "/payment" {
        sender.send("Payment method created".to_string()).await.ok();

        return Ok(Response::builder()
            .status(200)
            .body("Payment method created".into())
            .unwrap());
    }

    Ok(Response::builder()
        .status(400)
        .body("Bad request".into())
        .unwrap())
}