O01eg/sendxmppd-rs - Change UCY2DO3DQ2WE55CVVJYMHINBWCZYPCSZ5Q2EHMZNNZIU5LPCJNSAC

Try to read request body

Created by O01eg on December 18, 2018

UCY2DO3DQ2WE55CVVJYMHINBWCZYPCSZ5Q2EHMZNNZIU5LPCJNSAC

Dependencies

In channels

main

Change contents

Replacement in src/main.rs at line 27 [5.17]
∅:D[3.4066] → [4.53:89]
```
use tokio::prelude::{Future, Sink};
```
[3.4066]
[3.4092]
```
use tokio::prelude::{Future, Sink, Stream};
```

Replacement in src/main.rs at line 45 [5.17]

∅:D[4.266] → [2.0:59]

∅:D[2.59] → [4.303:398]

∅:D[4.303] → [4.303:398]

    type Error = Box<dyn std::error::Error + Sync + Send>;
    type Future = Box<dyn Future<Item = Response<Self::ResBody>, Error = Self::Error> + Send>;

[4.266]

[4.398]

    type Error = Box<dyn std::error::Error + Sync + Send + 'static>;
    type Future = Box<dyn Future<Item = Response<Self::ResBody>, Error = Self::Error> + Send + 'static>;

Replacement in src/main.rs at line 66 [5.17]

∅:D[2.143] → [2.143:238]

∅:D[2.238] → [4.1241:1303]

∅:D[4.1241] → [4.1241:1303]

                        .map_err(|e| Box::new(e) as Box<dyn std::error::Error + Sync + Send>),
                )) as Box<Future<Item = _, Error = _> + Send>

[2.143]

[4.1303]

                        .map_err(|e| Box::new(e) as Box<dyn std::error::Error + Sync + Send + 'static>),
                )) as Box<Future<Item = _, Error = _> + Send + 'static>

Replacement in src/main.rs at line 70 [5.17]

∅:D[4.1346] → [4.1346:1384]

                info!("Got request");

[4.1346]

[4.1384]

                info!("Got request. Reading body...");

Replacement in src/main.rs at line 72 [5.17]

∅:D[4.1410] → [4.1410:2213]

                    self.cmd_send
                        .clone()
                        .send(XmppCommand { xmpp_to })
                        .then(|r| match r {
                            Ok(_) => {
                                tokio::prelude::future::ok(Response::new(Body::from("Accepted")))
                            }
                            Err(e) => {
                                error!("Command sent error: {}", e);
                                tokio::prelude::future::result(
                                    Response::builder()
                                        .status(hyper::StatusCode::BAD_REQUEST)
                                        .body(Body::from(format!("Command sent error: {}", e))),
                                )
                            }

[4.1410]

[2.239]

                    /*req.into_body()
                        .map_err(|e| Box::new(e) as Box<dyn std::error::Error + Sync + Send + 'static>)
                        .fold(String::new(), |acc, ch| {
                            std::str::from_utf8(&*ch).map(|s| {
                                acc.push_str(s);
                                acc
                            })

Replacement in src/main.rs at line 80 [5.17]

∅:D[2.266] → [2.266:361]

∅:D[2.361] → [4.2241:2302]

∅:D[4.2241] → [4.2241:2302]

                        .map_err(|e| Box::new(e) as Box<dyn std::error::Error + Sync + Send>),
                ) as Box<Future<Item = _, Error = _> + Send>

[2.266]

[4.2302]

                        .and_then(|msg: String| {*/
                            self.cmd_send
                                .clone()
                                .send(XmppCommand { xmpp_to })
                                .then(|r| match r {
                                    Ok(_) => tokio::prelude::future::ok(Response::new(Body::from(
                                        "Accepted",
                                    ))),
                                    Err(e) => {
                                        error!("Command sent error: {}", e);
                                        tokio::prelude::future::result(
                                            Response::builder()
                                                .status(hyper::StatusCode::BAD_REQUEST)
                                                .body(Body::from(format!(
                                                    "Command sent error: {}",
                                                    e
                                                ))),
                                        )
                                    }
                                })
                                .map_err(|e| {
                                    Box::new(e) as Box<dyn std::error::Error + Sync + Send + 'static>
                                })
                       // }),
                ) as Box<Future<Item = _, Error = _> + Send + 'static>

Replacement in src/main.rs at line 117 [5.17]

∅:D[4.2532] → [2.362:421]

    type Error = Box<dyn std::error::Error + Sync + Send>;

[4.2532]

[4.2569]

    type Error = Box<dyn std::error::Error + Sync + Send + 'static>;