use clap::Parser;
use megalib::SessionHandle;
use std::process;
use tracing_subscriber::{EnvFilter, fmt};
#[derive(Debug, Parser)]
#[command(name = "upload")]
struct Args {
#[arg(short = 'e', long)]
email: String,
#[arg(short = 'p', long)]
password: String,
#[arg(long)]
proxy: Option<String>,
local_file: String,
remote_path: String,
}
fn init_tracing() {
let filter = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("off"));
fmt().with_env_filter(filter).with_target(false).init();
}
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
init_tracing();
let args = Args::parse();
println!("Logging in...");
let session = if let Some(proxy) = &args.proxy {
SessionHandle::login_with_proxy(&args.email, &args.password, proxy).await?
} else {
SessionHandle::login(&args.email, &args.password).await?
};
let info = session.account_info().await?;
println!("Logged in as: {}", info.email);
println!("Refreshing filesystem...");
session.refresh().await?;
println!("Uploading {} to {}...", args.local_file, args.remote_path);
match session
.upload_by_path(&args.local_file, &args.remote_path)
.await
{
Ok(node) => {
println!("Upload complete!");
println!("Created node: {} ({} bytes)", node.name, node.size);
}
Err(e) => {
eprintln!("Error: {:?}", e);
process::exit(1);
}
}
Ok(())
}