Function dispatch

gitrs_server/src/dispatch/git_command/log/mod.rs:26–63

(connection_state: state::Connection)

}

pub fn dispatch(connection_state: state::Connection) -> DispatchFuture {
    use self::ErrorReason::{RepoHasNoCommits, RepoPathNotSet};
    use error::protocol::{Error, ProcessError::{Encoding, Failed, Parsing}};

    match connection_state.repo_path.clone() {
        Some(repo_path) => Box::new(
            git::new_command_with_repo_path(&repo_path)
                .arg("log")
                .arg("--format=sha %H%nparents %P%nauthor %an%nemail %ae%ndate %ai%nsummary %s%ndescription %b%x00%x00")
                .output_async()
                .then(|result| match result {
                    Ok(output) => match str::from_utf8(&output.stdout) {
                        Ok(output) => future::ok((String::from(output), connection_state)),
                        Err(_) => future::err((Error::Process(Encoding), connection_state)),
                    },
                    Err(_) => future::err((Error::Process(Failed), connection_state)),
                })
                .and_then(|(result, connection_state)| -> DispatchFuture {
                    if result.len() == 0 {
                        return Box::new(send_message(
                            connection_state,
                            OutboundMessage::Error(RepoHasNoCommits)
                        ));
                    }

                    match parse_log(&result) {
                        Ok(log) => Box::new(
                            send_message(connection_state, OutboundMessage::Success { log })
                        ),
                        Err(_) => Box::new(
                            future::err((Error::Process(Parsing), connection_state))
                        ),
                    }
                }),
        ),
        None => Box::new(send_message(connection_state, OutboundMessage::Error(RepoPathNotSet))),
    }
}