flep 0.2.0

File transfer protocol (FTP) library
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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

//! Routines for handling commands.

mod user;
mod pass;
mod pwd;
mod cwd;
mod cdup;
mod list;
mod syst;
mod feat;
mod ty;
mod passive;
mod active;
mod quit;
mod retr;
mod mkd;

use Error;
use server::client::{ClientState, Action};
use server::Server;
use protocol;

/// Handles a command sent to a server from a client.
pub fn command(client: &mut ClientState,
               command: &protocol::CommandKind,
               server: &mut Server) -> Result<Action, Error> {
    use protocol::CommandKind::*;

    debug!("received command: {:?}", command);

    match *command {
        // User attempting to log in.
        USER(ref user) => self::user::handle(user, client, server),
        PASS(ref pass) => self::pass::handle(pass, client, server),
        PWD(..) => self::pwd::handle(client),
        CWD(ref cwd) => self::cwd::handle(cwd, client),
        CDUP(..) => self::cdup::handle(client),
        MKD(ref mkd) => self::mkd::handle(mkd, client, server),
        LIST(ref list) => self::list::handle(list, client, server),
        // ClientState requesting information about the server system.
        SYST(..) => self::syst::handle(),
        FEAT(..) => self::feat::handle(),
        TYPE(ref ty) => self::ty::handle(ty, client),
        PASV(..) => self::passive::handle_pasv(client),
        EPSV(..) => self::passive::handle_epsv(client),
        PORT(ref port) => self::active::handle_port(port, client),
        QUIT(..) => self::quit::handle(),
        RETR(ref retr) => self::retr::handle(retr, client, server),
        EPRT(..) => self::unimplemented("EPRT"),
        ABOR(..) => self::unimplemented("ABOR"),
        ACCT(..) => self::unimplemented("ACCT"),
        ADAT(..) => self::unimplemented("ADAT"),
        ALLO(..) => self::unimplemented("ALLO"),
        APPE(..) => self::unimplemented("APPE"),
        AUTH(..) => self::unimplemented("AUTH"),
        CCC(..) => self::unimplemented("CCC"),
        CONF(..) => self::unimplemented("CONF"),
        DELE(..) => self::unimplemented("DELE"),
        ENC(..) => self::unimplemented("ENC"),
        HELP(..) => self::unimplemented("HELP"),
        HOST(..) => self::unimplemented("HOST"),
        LANG(..) => self::unimplemented("LANG"),
        LPRT(..) => self::unimplemented("LPRT"),
        LPSV(..) => self::unimplemented("LPSV"),
        MDTM(..) => self::unimplemented("MDTM"),
        MIC(..) => self::unimplemented("MIC"),
        MLSD(..) => self::unimplemented("MLSD"),
        MLST(..) => self::unimplemented("MLST"),
        MODE(..) => self::unimplemented("MODE"),
        NLST(..) => self::unimplemented("NLST"),
        NOOP(..) => self::unimplemented("NOOP"),
        OPTS(..) => self::unimplemented("OPTS"),
        PBSZ(..) => self::unimplemented("PBSZ"),
        PROT(..) => self::unimplemented("PROT"),
        REIN(..) => self::unimplemented("REIN"),
        REST(..) => self::unimplemented("REST"),
        RMD(..) => self::unimplemented("RMD"),
        RNFR(..) => self::unimplemented("RNFR"),
        RNTO(..) => self::unimplemented("RNTO"),
        SITE(..) => self::unimplemented("SITE"),
        SIZE(..) => self::unimplemented("SIZE"),
        SMNT(..) => self::unimplemented("SMNT"),
        STAT(..) => self::unimplemented("STAT"),
        STOR(..) => self::unimplemented("STOR"),
        STOU(..) => self::unimplemented("STOU"),
        STRU(..) => self::unimplemented("STRU"),
        XCUP(..) => self::unimplemented("XCUP"),
        XMKD(..) => self::unimplemented("XMKD"),
        XPWD(..) => self::unimplemented("XPWD"),
        XRCP(..) => self::unimplemented("XRCP"),
        XRMD(..) => self::unimplemented("XRMD"),
        XRSQ(..) => self::unimplemented("XRSQ"),
        XSEM(..) => self::unimplemented("XSEM"),
        XSEN(..) => self::unimplemented("XSEN"),
    }
}

/// Generate a reply for an unimplemented command.
fn unimplemented(command_name: &'static str) -> Result<Action, Error> {
    Err(protocol::Error::from_kind(protocol::ErrorKind::UnimplementedCommand(
        command_name.to_string(),
    )).into())
}