{"header":{"message":"Manage xmpp connection in cmd processing loop","description":null,"timestamp":"2018-10-28T13:32:37Z","authors":[{"email":"o01eg@yandex.ru","name":"O01eg"}]},"hash":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC","authors":[],"deps":{"hashes":[["F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC","Manage xmpp connection in cmd processing loop"],["AA",null],["7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC","Process leftover commands"],["6DSWVNSYTGYN33VFBLXK655PFELW5ED2IFB2IZVHM4X277QRVUFAC","Launch single-thread executor on own thread"],["PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC","Use env logger. Implement command loop"],["FVVPKFTLD5VOGVDF7MOSSKQ3KPCT4HDGTNTTC6I6B4TWXOTPCJ7AC","Initial commit"],["AVBHYHOA3PGALA7WNBMKYV3BOPJTBPJEMECMEVM5YFI2KZSNE5OQC","Stop xmpp thread by shudown"]],"deps":["7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC"],"known":["AVBHYHOA3PGALA7WNBMKYV3BOPJTBPJEMECMEVM5YFI2KZSNE5OQC","FVVPKFTLD5VOGVDF7MOSSKQ3KPCT4HDGTNTTC6I6B4TWXOTPCJ7AC","PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC","6DSWVNSYTGYN33VFBLXK655PFELW5ED2IFB2IZVHM4X277QRVUFAC"]},"hunks":[{"Edit":{"inode":{"change":3,"pos":10},"path":"src/xmpp.rs","line":3,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":117}],"down_context":[{"change":3,"pos":117}],"flag":"","start":0,"end":316,"inode":{"change":3,"pos":10}}},"contents":[{"Add":{"text":"","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:0"}},{"Add":{"text":"pub struct XmppConnection {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:28"}},{"Add":{"text":" jid: String,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:45"}},{"Add":{"text":" password: String,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:67"}},{"Add":{"text":" inner: Option<()>,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:90"}},{"Add":{"text":"}","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:92"}},{"Add":{"text":"","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:93"}},{"Add":{"text":"impl XmppConnection {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:115"}},{"Add":{"text":" fn new(jid: &str, password: &str) -> XmppConnection {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:173"}},{"Add":{"text":" XmppConnection {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:198"}},{"Add":{"text":" jid: jid.to_owned(),","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:231"}},{"Add":{"text":" password: password.to_owned(),","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:274"}},{"Add":{"text":" inner: None,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:299"}},{"Add":{"text":" }","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:309"}},{"Add":{"text":" }","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:315"}}]}},{"Edit":{"inode":{"change":3,"pos":10},"path":"src/xmpp.rs","line":19,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":118}],"down_context":[{"change":3,"pos":118}],"flag":"","start":317,"end":652,"inode":{"change":3,"pos":10}}},"contents":[{"Add":{"text":" /// connects if nothing connected","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:354"}},{"Add":{"text":" /// Error shoud be !","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:379"}},{"Add":{"text":" fn connect(self) -> impl Future {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:444"}},{"Add":{"text":" let inner = self.inner.unwrap_or_else(|| ());","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:498"}},{"Add":{"text":"","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:499"}},{"Add":{"text":" future::ok(XmppConnection {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:535"}},{"Add":{"text":" jid: self.jid,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:562"}},{"Add":{"text":" password: self.password,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:599"}},{"Add":{"text":" inner: Some(inner),","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:631"}},{"Add":{"text":" })","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:642"}},{"Add":{"text":" }","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:648"}},{"Add":{"text":"}","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:650"}},{"Add":{"text":"","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:651"}}]}},{"Edit":{"inode":{"change":3,"pos":10},"path":"src/xmpp.rs","line":37,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":217}],"down_context":[{"change":3,"pos":217}],"flag":"","start":653,"end":679,"inode":{"change":3,"pos":10}}},"contents":[{"Add":{"text":" conn: XmppConnection,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:678"}}]}},{"Replacement":{"inode":{"change":3,"pos":10},"path":"src/xmpp.rs","line":41,"ins":{"up_context":[{"change":3,"pos":243}],"down_context":[{"change":3,"pos":355}],"flag":"","start":680,"end":865,"inode":{"change":3,"pos":10}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":243},"to":{"change":3,"start":243,"end":355},"introduced_by":3}],"inode":{"change":3,"pos":10}},"ins_contents":[{"Add":{"text":" fn new(cmd_recv: Receiver, signal: F, conn: XmppConnection) -> XmppState {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:774"}},{"Add":{"text":" XmppState {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:794"}},{"Add":{"text":" cmd_recv,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:816"}},{"Add":{"text":" signal,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:836"}},{"Add":{"text":" conn,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:854"}},{"Add":{"text":" }","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:864"}}],"del_contents":[{"Del":{"text":" fn new(cmd_recv: Receiver, signal: F) -> XmppState {","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:315"}},{"Del":{"text":" XmppState { cmd_recv, signal }","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:354"}}]}},{"Replacement":{"inode":{"change":3,"pos":10},"path":"src/xmpp.rs","line":50,"ins":{"up_context":[{"change":3,"pos":364}],"down_context":[{"change":3,"pos":388}],"flag":"","start":866,"end":899,"inode":{"change":3,"pos":10}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":364},"to":{"change":3,"start":364,"end":388},"introduced_by":3}],"inode":{"change":3,"pos":10}},"ins_contents":[{"Add":{"text":"pub fn xmpp_process(","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:898"}}],"del_contents":[{"Del":{"text":"pub fn xmpp_process(","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:387"}}]}},{"Edit":{"inode":{"change":3,"pos":10},"path":"src/xmpp.rs","line":53,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":440}],"down_context":[{"change":3,"pos":440}],"flag":"","start":900,"end":935,"inode":{"change":3,"pos":10}}},"contents":[{"Add":{"text":" jid: &str,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:914"}},{"Add":{"text":" password: &str,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:934"}}]}},{"Replacement":{"inode":{"change":3,"pos":10},"path":"src/xmpp.rs","line":62,"ins":{"up_context":[{"change":3,"pos":627}],"down_context":[{"change":3,"pos":1591}],"flag":"","start":936,"end":2875,"inode":{"change":3,"pos":10}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":627},"to":{"change":3,"start":627,"end":771},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":771},"to":{"change":2,"start":0,"end":44},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":44},"to":{"change":3,"start":816,"end":858},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":816},"to":{"change":3,"start":816,"end":858},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":858},"to":{"change":2,"start":45,"end":113},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":113},"to":{"change":3,"start":914,"end":1113},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":914},"to":{"change":3,"start":914,"end":1113},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1113},"to":{"change":2,"start":114,"end":158},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":158},"to":{"change":3,"start":1158,"end":1257},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1158},"to":{"change":3,"start":1158,"end":1257},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1257},"to":{"change":2,"start":159,"end":227},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":227},"to":{"change":3,"start":1313,"end":1591},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1313},"to":{"change":3,"start":1313,"end":1591},"introduced_by":3}],"inode":{"change":3,"pos":10}},"ins_contents":[{"Add":{"text":" let conn = XmppConnection::new(jid, password);","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:986"}},{"Add":{"text":"","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:987"}},{"Add":{"text":" future::loop_fn(XmppState::new(cmd_recv, signal, conn), |s| {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1053"}},{"Add":{"text":" let XmppState {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1077"}},{"Add":{"text":" cmd_recv,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1099"}},{"Add":{"text":" signal,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1119"}},{"Add":{"text":" conn,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1137"}},{"Add":{"text":" } = s;","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1152"}},{"Add":{"text":" signal","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1167"}},{"Add":{"text":" .select2(conn.connect().and_then(|conn| {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1221"}},{"Add":{"text":" cmd_recv","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1246"}},{"Add":{"text":" .into_future()","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1281"}},{"Add":{"text":" .map_err(|_| {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1316"}},{"Add":{"text":" error!(\"Got error on recv cmd\");","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1373"}},{"Add":{"text":" tokio::io::Error::new(tokio::io::ErrorKind::Other, \"Receive cmd error\")","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1469"}},{"Add":{"text":" }).map(|f| (f, conn))","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1511"}},{"Add":{"text":" })).then(|r| {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1538"}},{"Add":{"text":" match r {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1564"}},{"Add":{"text":" Ok(Either::A((_x, b))) => {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1612"}},{"Add":{"text":" // got signal, breaks","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1658"}},{"Add":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1))))","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1745"}},{"Add":{"text":" as Box>","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1809"}},{"Add":{"text":" }","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1831"}},{"Add":{"text":" Ok(Either::B((x, a))) => {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1878"}},{"Add":{"text":" // got cmd, continue","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:1923"}},{"Add":{"text":" Box::new(future::ok(future::Loop::Continue(XmppState::new(","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2006"}},{"Add":{"text":" (x.0).1,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2043"}},{"Add":{"text":" a,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2074"}},{"Add":{"text":" x.1,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2107"}},{"Add":{"text":" )))) as Box>","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2172"}},{"Add":{"text":" }","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2194"}},{"Add":{"text":" Err(Either::A((e, b))) => {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2242"}},{"Add":{"text":" // got signal error, breaks","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2294"}},{"Add":{"text":" error!(\"Signal error: {}\", e);","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2349"}},{"Add":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1))))","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2436"}},{"Add":{"text":" as Box>","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2500"}},{"Add":{"text":" }","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2522"}},{"Add":{"text":" Err(Either::B((_e, _a))) => {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2572"}},{"Add":{"text":" // got cmd error, its bad","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2622"}},{"Add":{"text":" Box::new(future::err(tokio::io::Error::new(","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2690"}},{"Add":{"text":" tokio::io::ErrorKind::Other,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2747"}},{"Add":{"text":" \"Cmd error\",","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2788"}},{"Add":{"text":" ))) as Box>","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2852"}},{"Add":{"text":" }","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2874"}}],"del_contents":[{"Del":{"text":" future::loop_fn(XmppState::new(cmd_recv, signal), |s| {","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:686"}},{"Del":{"text":" s.signal.select2(s.cmd_recv.into_future()).then(|r| {","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:748"}},{"Del":{"text":" match r {","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:770"}},{"Del":{"text":" Ok(Either::A((_x, b))) => {","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:43"}},{"Del":{"text":" // got signal, breaks","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:857"}},{"Del":{"text":" future::ok(future::Loop::Break(b.into_inner()))","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:112"}},{"Del":{"text":" }","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:931"}},{"Del":{"text":" Ok(Either::B((x, a))) => {","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:974"}},{"Del":{"text":" // got cmd, continue","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1015"}},{"Del":{"text":" future::ok(future::Loop::Continue(XmppState::new(x.1, a)))","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1094"}},{"Del":{"text":" }","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1112"}},{"Del":{"text":" Err(Either::A((e, b))) => {","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:157"}},{"Del":{"text":" // got signal error, breaks","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1205"}},{"Del":{"text":" error!(\"Signal error: {}\", e);","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1256"}},{"Del":{"text":" future::ok(future::Loop::Break(b.into_inner()))","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:226"}},{"Del":{"text":" }","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1330"}},{"Del":{"text":" Err(Either::B((_e, _a))) => {","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1376"}},{"Del":{"text":" // got cmd error, its bad","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1422"}},{"Del":{"text":" future::err(tokio::io::Error::new(","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1477"}},{"Del":{"text":" tokio::io::ErrorKind::Other,","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1530"}},{"Del":{"text":" \"Cmd error\",","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1567"}},{"Del":{"text":" ))","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1590"}}]}},{"Edit":{"inode":{"change":3,"pos":10},"path":"src/xmpp.rs","line":107,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1609}],"down_context":[{"change":3,"pos":1609}],"flag":"","start":2876,"end":3612,"inode":{"change":3,"pos":10}}},"contents":[{"Add":{"text":" })","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2890"}},{"Add":{"text":" }).and_then(","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2907"}},{"Add":{"text":" |(opt_cmd_recv, _conn): (Option>, XmppConnection)| {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:2990"}},{"Add":{"text":" if let Some(mut cmd_recv) = opt_cmd_recv {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3045"}},{"Add":{"text":" // process left commands","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3086"}},{"Add":{"text":" info!(\"Stop accepting commands\");","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3136"}},{"Add":{"text":" cmd_recv.close();","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3170"}},{"Add":{"text":" Box::new(cmd_recv.for_each(|_cmd| future::ok(())).map_err(|_| {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3250"}},{"Add":{"text":" tokio::io::Error::new(tokio::io::ErrorKind::Other, \"cmd receiver last error\")","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3348"}},{"Add":{"text":" })) as Box>","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3420"}},{"Add":{"text":" } else {","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3441"}},{"Add":{"text":" Box::new(future::err(tokio::io::Error::new(","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3501"}},{"Add":{"text":" tokio::io::ErrorKind::Other,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3550"}},{"Add":{"text":" \"cmd receiver gone\",","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3591"}},{"Add":{"text":" )))","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3611"}}]}},{"Replacement":{"inode":{"change":3,"pos":10},"path":"src/xmpp.rs","line":123,"ins":{"up_context":[{"change":3,"pos":1623}],"down_context":[{"change":3,"pos":276}],"flag":"","start":3613,"end":3630,"inode":{"change":3,"pos":10}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":1623},"to":{"change":3,"start":1623,"end":1634},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1623},"to":{"change":3,"start":1623,"end":1634},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1634},"to":{"change":2,"start":228,"end":875},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":875},"to":{"change":3,"start":1634,"end":1641},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1634},"to":{"change":3,"start":1634,"end":1641},"introduced_by":3}],"inode":{"change":3,"pos":10}},"ins_contents":[{"Add":{"text":" },","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3623"}},{"Add":{"text":" )","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3629"}}],"del_contents":[{"Del":{"text":" })","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1633"}},{"Del":{"text":" }).and_then(|opt_cmd_recv: Option>| {","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:291"}},{"Del":{"text":" if let Some(mut cmd_recv) = opt_cmd_recv {","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:342"}},{"Del":{"text":" // process left commands","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:379"}},{"Del":{"text":" info!(\"Stop accepting commands\");","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:425"}},{"Del":{"text":" cmd_recv.close();","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:455"}},{"Del":{"text":" Box::new(cmd_recv.for_each(|_cmd| future::ok(())).map_err(|_| {","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:531"}},{"Del":{"text":" tokio::io::Error::new(tokio::io::ErrorKind::Other, \"cmd receiver last error\")","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:625"}},{"Del":{"text":" })) as Box>","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:693"}},{"Del":{"text":" } else {","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:710"}},{"Del":{"text":" Box::new(future::err(tokio::io::Error::new(","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:766"}},{"Del":{"text":" tokio::io::ErrorKind::Other,","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:811"}},{"Del":{"text":" \"cmd receiver gone\",","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:848"}},{"Del":{"text":" )))","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:864"}},{"Del":{"text":" }","pos":"7OTSYQ4Z34N5AOSBCMN63M7WA4DYKFAY5B7SB25BG3IHE6FCUKLAC:874"}},{"Del":{"text":" })","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:1640"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":87,"ins":{"up_context":[{"change":3,"pos":3038}],"down_context":[{"change":3,"pos":3112}],"flag":"","start":3631,"end":3811,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":3038},"to":{"change":3,"start":3038,"end":3112},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" ctrt.block_on(xmpp_process(","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3666"}},{"Add":{"text":" ctrl_c.clone().map(|_| ()),","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3706"}},{"Add":{"text":" cmd_recv,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3728"}},{"Add":{"text":" &config.account.jid,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3761"}},{"Add":{"text":" &config.account.password,","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3799"}},{"Add":{"text":" ))","pos":"F5UQL2FBQIM7TRVPVCFT3JBPZ6O75SKL6IRWR7RX6BWPVNRA7PFAC:3810"}}],"del_contents":[{"Del":{"text":" ctrt.block_on(xmpp_process(ctrl_c.clone().map(|_| ()), cmd_recv))","pos":"PHPCAQ6ZOH64J22YO3LAHZDZ6IWRKDT4CRRC4Y2I5ADERWPBRWIQC:3111"}}]}}],"owner":"O01eg","repo":"sendxmppd-rs","token":"8XSQAEBvcZA1Ipn92/UQQR6hnBE4CR94HEmPCOlbvy8=","login":null}

…

Dependencies

Change contents

Review