use chrono::{Duration, Utc};
use open_payments::client::api::AuthenticatedResources;
use open_payments::client::utils::get_resource_server_url;
use open_payments::client::OpClientError;
use open_payments::snippets::utils::{create_authenticated_client, get_env_var, load_env};
use open_payments::types::{resource::CreateIncomingPaymentRequest, Amount};
#[tokio::main]
async fn main() -> open_payments::client::Result<()> {
load_env().map_err(|e| OpClientError::Other(e.to_string()))?;
let client = create_authenticated_client()?;
let gnap_token = get_env_var("INCOMING_PAYMENT_ACCESS_TOKEN")?;
let wallet_address_url = get_env_var("WALLET_ADDRESS_URL")?;
let resource_server_url = get_resource_server_url(&wallet_address_url)?;
let expires_at = Utc::now()
.checked_add_signed(Duration::minutes(10000))
.unwrap();
let request = CreateIncomingPaymentRequest {
wallet_address: wallet_address_url,
incoming_amount: Some(Amount {
value: "1000".to_string(),
asset_code: "EUR".to_string(),
asset_scale: 2u8,
}),
expires_at: Some(expires_at),
metadata: None,
};
println!(
"Incoming payment create request JSON: {}",
serde_json::to_string_pretty(&request)?
);
let payment = client
.incoming_payments()
.create(&resource_server_url, &request, Some(&gnap_token))
.await?;
println!("Created incoming payment: {:#?}", payment);
Ok(())
}