rootftp 0.1.4

A simple FTP server tool that allows you to play with files. Multiple users can share their files with each other. You can also build custom plugins see examples for more info.
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

use crate::plugin_handler::plugin_trait::Plugin;
use inotify::{EventMask, Inotify, WatchMask};
use std::{collections::HashMap, fs, path::PathBuf, thread, time::Duration};

pub fn start_watchers(
    ftpd_root: PathBuf,
    user: String,
    plugin_map: HashMap<String, (Box<dyn Plugin>, Vec<String>)>,
) {
    let plugins = plugin_map.into_iter().collect::<Vec<_>>();

    thread::spawn(move || {
        let mut inotify = Inotify::init().unwrap();
        let mut wd_map: HashMap<_, (String, String)> = HashMap::new();
        let mut buf = [0u8; 4096];

        for (plugin_name, _) in &plugins {
            let dir = ftpd_root.join(&user).join(plugin_name).join("input");
            let out_dir = ftpd_root.join(&user).join(plugin_name).join("output");

            fs::create_dir_all(&dir).ok();
            fs::create_dir_all(&out_dir).ok();
            let wd = inotify
                .watches()
                .add(
                    &dir,
                    WatchMask::CREATE | WatchMask::MOVED_TO | WatchMask::CLOSE_WRITE,
                )
                .unwrap();
            wd_map.insert(wd.clone(), (user.clone(), plugin_name.clone()));
        }

        loop {
            let events = inotify.read_events_blocking(&mut buf).unwrap();
            for ev in events {
                if !ev
                    .mask
                    .intersects(EventMask::CREATE | EventMask::MOVED_TO | EventMask::CLOSE_WRITE)
                {
                    continue;
                }
                if let Some(name) = ev.name {
                    let (user, plugin_name) = &wd_map[&ev.wd];
                    let filename = name.to_string_lossy();
                    let path = ftpd_root
                        .join(user)
                        .join(plugin_name)
                        .join("input")
                        .join(&*filename);
                    let out_path = ftpd_root.join(user).join(plugin_name).join("output");
                    if let Some((plugin, exts)) = plugins
                        .iter()
                        .find(|(n, _)| n == plugin_name)
                        .map(|(_, pe)| pe)
                    {
                        if let Some(ext) = path.extension().and_then(|s| s.to_str()) {
                            if exts.contains(&ext.to_string()) {
                                plugin.on_create(&path, &out_path)
                            }
                        }
                    }
                }
            }
            thread::sleep(Duration::from_millis(50));
        }
    });
}