mtp-mount 0.1.0

Mount MTP devices as local filesystems via FUSE
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

mod buffer;
mod error;
mod fs;
mod inode;

use clap::Parser;

use crate::fs::MtpFs;

/// Mount MTP devices as local filesystems via FUSE.
#[derive(Parser, Debug)]
#[command(version, about)]
struct Cli {
    /// Directory where the MTP device will be mounted
    mountpoint: String,

    /// Device serial number (uses first available device if omitted)
    #[arg(short, long)]
    device: Option<String>,

    /// Run in foreground instead of daemonizing
    #[arg(short, long, default_value_t = true)]
    foreground: bool,

    /// Mount the device as read-only
    #[arg(short, long)]
    read_only: bool,
}

fn main() {
    env_logger::init();

    let cli = Cli::parse();

    let device_label = cli.device.as_deref().unwrap_or("first available device");
    println!("Mounting {device_label} at {}...", cli.mountpoint);

    let rt = tokio::runtime::Runtime::new().expect("failed to create tokio runtime");
    let handle = rt.handle().clone();

    let device = rt.block_on(async {
        if let Some(serial) = &cli.device {
            mtp_rs::MtpDevice::open_by_serial(serial).await
        } else {
            mtp_rs::MtpDevice::open_first().await
        }
    });

    let device = match device {
        Ok(d) => d,
        Err(e) => {
            eprintln!("Failed to open MTP device: {e}");
            std::process::exit(1);
        }
    };

    let mtp_fs = MtpFs::new(device, cli.read_only, handle);
    let mount_options = mtp_fs.mount_options();

    let mut config = fuser::Config::default();
    config.mount_options = mount_options;

    println!("Mounted. Press Ctrl+C to unmount.");

    if let Err(e) = fuser::mount2(mtp_fs, &cli.mountpoint, &config) {
        eprintln!("Mount failed: {e}");
        std::process::exit(1);
    }
}