{"header":{"message":"Process self-presence via new processing code","description":null,"timestamp":"2018-12-30T09:05:15Z","authors":[{"email":"o01eg@yandex.ru","name":"O01eg"}]},"hash":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC","authors":[],"deps":{"hashes":[["HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC","Process self-presence via new processing code"],["AA",null],["QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC","Use failure instead Box"],["FVVPKFTLD5VOGVDF7MOSSKQ3KPCT4HDGTNTTC6I6B4TWXOTPCJ7AC","Initial commit"],["H7R7Y3FQHYR44R65YLHUAL6SSSFEMLDJTKBXMG6M7N6GDMHEDYNQC","Use new processing code to wait online"],["L77O4T7MWBZXKAKH5ZEMWNNACSOZMI42D7VTG4DUFTR4RH5BAXAQC","Formatting and fixes"],["IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC","Update deps"],["PBRUH4BJGPVY2F4C6SS7F5ZTQJAEBKZVEXCT7EOQRA25DT4MMZEAC","Rename optional XmppConnection to MaybeXmppConnection"],["MOXHYSQ35EU5ENKNVE2N75HR2GQRF6QVL4K64CLOV2USASDE5R2QC","Use more common error type\\n\\nMove to failure::Error after https://github.com/rust-lang-nursery/failure/pull/283 landed."],["TDOR5XQUFRE2LRXML25IJ7A6CIZPFSRES7FQCXDBMIOV4JE2O6OAC","Accept destination"],["ZI4GJ72VMCBV6EQAO4PIKCGXV6ASUYOTGPRVSIGCKDBCDNRQNUFAC","Add message to xmpp command"],["ZJ4QKTJROEJK2RSY4JS7EDJMUAVXBYVXZPFIXUC5BZGVPLP5XMJAC","Fixed body reading"],["FV6BJ5K64QG63YI2PTII44ZEBAYNJBQZ5FSBHW65EPHGBKFGUW4AC","Send self-presence and store account info in Rc so it willbe used in some future in parallel"],["UCY2DO3DQ2WE55CVVJYMHINBWCZYPCSZ5Q2EHMZNNZIU5LPCJNSAC","Try to read request body"],["3GEU7TC7VMBZOSUXQ7II5IGRDGGQCJOLBKFZYUIOGWTKM56ETINQC","Welcome to 2018!"],["5OBTKGDLRGZ4K4373CVGBF53LRECXQ7OW45PW43MJLBU622OKMTQC","Update deps"],["EOHEZXX3TBKGJTOMXEPAPHLAJSATRXNY4AIL63BE4VG3HFNWARVQC","Move request processing to structure"],["X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC","Use different structure for established xmpp connection"],["5A5UVGNMHEYI62XUENBEPSRJ7M3MBULYITRDOEYYA5ZDUMFBB6ZQC","Move receiver closing logic out of xmpp processing"],["OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC","Move online to XmppConnection"],["QWE26TMV6A5VUQLWG5ZMKHMH4NFZIQMVVXQJMPP42JUMM66C3VOQC","update deps"],["O2GM5J4FSOXLTJURP2K6JMCBRAJ2JPJ723A43CR6AT2VQQQYRHFQC","Don't split xmpp receiving and sending"],["AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC","Use shared future for signal everywhere"],["VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC","Move XMPP to separate dir"],["NDDQQP2PSYH5YNU5EHFRUFACLJURWAHFZQNOIQNJCWHRSB7A3N6QC","Update deps"],["XGP44R5HBQAHBXEJKN4AB77OZ32B32FPUHSUILZDVNO4QLUOTW6QC","Rework stopping xmpp connection"],["BTOZT4JPYXPTMXBSKQGXZ3K46UNACE65RIKAGPLUH3OIRVV7WBKAC","Use failure"]],"deps":["QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC"],"known":["AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC","BTOZT4JPYXPTMXBSKQGXZ3K46UNACE65RIKAGPLUH3OIRVV7WBKAC","EOHEZXX3TBKGJTOMXEPAPHLAJSATRXNY4AIL63BE4VG3HFNWARVQC","FVVPKFTLD5VOGVDF7MOSSKQ3KPCT4HDGTNTTC6I6B4TWXOTPCJ7AC","FV6BJ5K64QG63YI2PTII44ZEBAYNJBQZ5FSBHW65EPHGBKFGUW4AC","H7R7Y3FQHYR44R65YLHUAL6SSSFEMLDJTKBXMG6M7N6GDMHEDYNQC","IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC","L77O4T7MWBZXKAKH5ZEMWNNACSOZMI42D7VTG4DUFTR4RH5BAXAQC","MOXHYSQ35EU5ENKNVE2N75HR2GQRF6QVL4K64CLOV2USASDE5R2QC","NDDQQP2PSYH5YNU5EHFRUFACLJURWAHFZQNOIQNJCWHRSB7A3N6QC","OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC","O2GM5J4FSOXLTJURP2K6JMCBRAJ2JPJ723A43CR6AT2VQQQYRHFQC","PBRUH4BJGPVY2F4C6SS7F5ZTQJAEBKZVEXCT7EOQRA25DT4MMZEAC","QWE26TMV6A5VUQLWG5ZMKHMH4NFZIQMVVXQJMPP42JUMM66C3VOQC","TDOR5XQUFRE2LRXML25IJ7A6CIZPFSRES7FQCXDBMIOV4JE2O6OAC","UCY2DO3DQ2WE55CVVJYMHINBWCZYPCSZ5Q2EHMZNNZIU5LPCJNSAC","VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC","XGP44R5HBQAHBXEJKN4AB77OZ32B32FPUHSUILZDVNO4QLUOTW6QC","X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC","ZI4GJ72VMCBV6EQAO4PIKCGXV6ASUYOTGPRVSIGCKDBCDNRQNUFAC","ZJ4QKTJROEJK2RSY4JS7EDJMUAVXBYVXZPFIXUC5BZGVPLP5XMJAC","3GEU7TC7VMBZOSUXQ7II5IGRDGGQCJOLBKFZYUIOGWTKM56ETINQC","5A5UVGNMHEYI62XUENBEPSRJ7M3MBULYITRDOEYYA5ZDUMFBB6ZQC","5OBTKGDLRGZ4K4373CVGBF53LRECXQ7OW45PW43MJLBU622OKMTQC"]},"hunks":[{"Edit":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":10,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":73}],"down_context":[{"change":3,"pos":73}],"flag":"","start":0,"end":106,"inode":{"change":3,"pos":17}}},"contents":[{"Add":{"text":"pub struct MaybeXmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:32"}},{"Add":{"text":" account: std::rc::Rc,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:75"}},{"Add":{"text":" inner: Option,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:102"}},{"Add":{"text":"}","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:104"}},{"Add":{"text":"","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:105"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":17,"ins":{"up_context":[{"change":3,"pos":74}],"down_context":[{"change":3,"pos":356}],"flag":"","start":107,"end":358,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":74},"to":{"change":3,"start":0,"end":77},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" inner: Client,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:125"}},{"Add":{"text":"}","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:127"}},{"Add":{"text":"","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:128"}},{"Add":{"text":"impl From for MaybeXmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:180"}},{"Add":{"text":" fn from(from: XmppConnection) -> MaybeXmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:239"}},{"Add":{"text":" MaybeXmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:269"}},{"Add":{"text":" account: from.account,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:304"}},{"Add":{"text":" inner: Some(from.inner),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:341"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:351"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:357"}}],"del_contents":[{"Del":{"text":" inner: Option<(stream::SplitSink, stream::SplitStream)>,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:76"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":29,"ins":{"up_context":[{"change":3,"pos":359}],"down_context":[{"change":3,"pos":479}],"flag":"","start":359,"end":478,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":359},"to":{"change":3,"start":78,"end":182},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":"impl MaybeXmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:385"}},{"Add":{"text":" fn new(account: config::Account) -> MaybeXmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:447"}},{"Add":{"text":" MaybeXmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:477"}}],"del_contents":[{"Del":{"text":"impl XmppConnection {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:99"}},{"Del":{"text":" fn new(account: config::Account) -> XmppConnection {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:156"}},{"Del":{"text":" XmppConnection {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:181"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":38,"ins":{"up_context":[{"change":3,"pos":554}],"down_context":[{"change":3,"pos":653}],"flag":"","start":479,"end":781,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":554},"to":{"change":3,"start":183,"end":282},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" /// don't connect if stop_future resolved","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:524"}},{"Add":{"text":" fn connect(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:543"}},{"Add":{"text":" self,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:557"}},{"Add":{"text":" stop_future: F,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:581"}},{"Add":{"text":" ) -> impl Future","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:649"}},{"Add":{"text":" where","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:659"}},{"Add":{"text":" F: future::Future + Clone + 'static,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:704"}},{"Add":{"text":" ::Error: Into + Send,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:774"}},{"Add":{"text":" {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:780"}}],"del_contents":[{"Del":{"text":" /// Error shoud be !","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:207"}},{"Del":{"text":" fn connect(self) -> impl Future {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:281"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":48,"ins":{"up_context":[{"change":3,"pos":690}],"down_context":[{"change":3,"pos":744}],"flag":"","start":782,"end":841,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":690},"to":{"change":3,"start":283,"end":337},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" let MaybeXmppConnection { account, inner } = self;","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:840"}}],"del_contents":[{"Del":{"text":" let XmppConnection { account, inner } = self;","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:336"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":51,"ins":{"up_context":[{"change":3,"pos":782}],"down_context":[{"change":3,"pos":944}],"flag":"","start":842,"end":962,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":782},"to":{"change":3,"start":338,"end":500},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Box::new(future::ok(XmppConnection { account, inner }))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:909"}},{"Add":{"text":" as Box>","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:961"}}],"del_contents":[{"Del":{"text":" Box::new(future::ok(XmppConnection {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:386"}},{"Del":{"text":" account,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:411"}},{"Del":{"text":" inner: Some(inner),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:447"}},{"Del":{"text":" })) as Box>","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:499"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":54,"ins":{"up_context":[{"change":3,"pos":961}],"down_context":[{"change":3,"pos":1476}],"flag":"","start":963,"end":1618,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":961},"to":{"change":3,"start":501,"end":1016},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Box::new(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:984"}},{"Add":{"text":" stop_future","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1012"}},{"Add":{"text":" .clone()","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1041"}},{"Add":{"text":" .select2(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1071"}},{"Add":{"text":" future::loop_fn(account, move |account| {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1137"}},{"Add":{"text":" info!(\"xmpp initialization...\");","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1198"}},{"Add":{"text":" let res_client = Client::new(&account.jid, &account.password);","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1289"}},{"Add":{"text":" match res_client {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1336"}},{"Add":{"text":" Err(_e) => Box::new(future::ok(future::Loop::Continue(account)))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1433"}},{"Add":{"text":" as Box>,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1506"}},{"Add":{"text":" Ok(client) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1554"}},{"Add":{"text":" info!(\"xmpp initialized\");","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1617"}}],"del_contents":[{"Del":{"text":" Box::new(future::loop_fn(account, |account| {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:558"}},{"Del":{"text":" info!(\"xmpp initialization...\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:607"}},{"Del":{"text":" let mut res_client = Client::new(&account.jid, &account.password);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:690"}},{"Del":{"text":" while let Err(e) = res_client {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:738"}},{"Del":{"text":" error!(\"Cann't init xmpp client: {}\", e);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:800"}},{"Del":{"text":" res_client = Client::new(&account.jid, &account.password);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:879"}},{"Del":{"text":" }","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:897"}},{"Del":{"text":" let client = res_client.expect(\"Cann't init xmpp client\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:972"}},{"Del":{"text":" info!(\"xmpp initialized\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1015"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":67,"ins":{"up_context":[{"change":3,"pos":1477}],"down_context":[{"change":3,"pos":426}],"flag":"","start":1619,"end":2926,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":1477},"to":{"change":3,"start":1017,"end":1167},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" let stop_future2 = stop_future.clone();","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1694"}},{"Add":{"text":"","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1695"}},{"Add":{"text":" // future to wait for online","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1760"}},{"Add":{"text":" Box::new(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1806"}},{"Add":{"text":" XmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1863"}},{"Add":{"text":" inner: client,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1922"}},{"Add":{"text":" account,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:1975"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2017"}},{"Add":{"text":" .processing(XmppConnection::online, stop_future.clone())","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2114"}},{"Add":{"text":" .map(|(conn, _)| conn)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2177"}},{"Add":{"text":" .map_err(|(acc, _)| acc)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2242"}},{"Add":{"text":" .and_then(|conn| conn.self_presence(stop_future2))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2333"}},{"Add":{"text":" .then(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2380"}},{"Add":{"text":" |r| match r {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2438"}},{"Add":{"text":" Ok(conn) => future::ok(future::Loop::Break(conn)),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2537"}},{"Add":{"text":" Err(acc) => future::ok(future::Loop::Continue(acc)),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2638"}},{"Add":{"text":" },","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2685"}},{"Add":{"text":" ),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2728"}},{"Add":{"text":" )","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2766"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2800"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2830"}},{"Add":{"text":" })","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2857"}},{"Add":{"text":" .map_err(|_: ()| ()),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2903"}},{"Add":{"text":" )","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:2925"}}],"del_contents":[{"Del":{"text":" // future to wait for online","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1061"}},{"Del":{"text":" Self::online(client.split(), account)","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1115"}},{"Del":{"text":" .and_then(Self::self_presence)","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1166"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":92,"ins":{"up_context":[{"change":3,"pos":466}],"down_context":[{"change":3,"pos":1858}],"flag":"","start":2927,"end":3372,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":466},"to":{"change":3,"start":1168,"end":1359},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Ok(Either::A((_x, _b))) => future::err(format_err!(\"Stop XMMP connection\")),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3027"}},{"Add":{"text":" Ok(Either::B((x, _a))) => future::ok(x),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3092"}},{"Add":{"text":" Err(Either::A((e, _b))) => future::err(e.into()),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3166"}},{"Add":{"text":" Err(Either::B((_, _a))) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3219"}},{"Add":{"text":" future::err(format_err!(\"Cann't initiate XMPP connection\"))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3307"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3333"}},{"Add":{"text":" }),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3357"}},{"Add":{"text":" )","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3371"}}],"del_contents":[{"Del":{"text":" Ok(conn) => future::ok(future::Loop::Break(conn)),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1242"}},{"Del":{"text":" Err(acc) => future::ok(future::Loop::Continue(acc)),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1319"}},{"Del":{"text":" })","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1342"}},{"Del":{"text":" }))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1358"}}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":102,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2890}],"down_context":[{"change":3,"pos":2997}],"flag":"","start":3373,"end":3375,"inode":{"change":3,"pos":17}}},"contents":[{"Add":{"text":"}","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3374"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":104,"ins":{"up_context":[{"change":3,"pos":2998}],"down_context":[{"change":3,"pos":3955}],"flag":"","start":3376,"end":4611,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":2998},"to":{"change":3,"start":1360,"end":2085},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":"impl XmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3397"}},{"Add":{"text":" /// base XMPP processing","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3426"}},{"Add":{"text":" fn xmpp_processing(&mut self, event: &Event) {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3477"}},{"Add":{"text":" info!(\"Incoming xmpp event: {:?}\", event);","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3528"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3534"}},{"Add":{"text":"","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3535"}},{"Add":{"text":" /// process event from xmpp stream","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3574"}},{"Add":{"text":" /// returns from future when condition met","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3621"}},{"Add":{"text":" /// or stop future was resolved","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3657"}},{"Add":{"text":" fn processing(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3688"}},{"Add":{"text":" self,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3702"}},{"Add":{"text":" stop_condition: S,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3729"}},{"Add":{"text":" stop_future: F,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3753"}},{"Add":{"text":" ) -> impl Future<","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3775"}},{"Add":{"text":" Item = (Self, Result, failure::Error>),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3836"}},{"Add":{"text":" Error = (","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3854"}},{"Add":{"text":" std::rc::Rc,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3896"}},{"Add":{"text":" Result, failure::Error>,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3946"}},{"Add":{"text":" ),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3957"}},{"Add":{"text":" >","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3963"}},{"Add":{"text":" where","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:3973"}},{"Add":{"text":" F: Future,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4013"}},{"Add":{"text":" E: Into,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4046"}},{"Add":{"text":" S: FnMut(&mut Self, &Event) -> Result,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4115"}},{"Add":{"text":" {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4121"}},{"Add":{"text":" future::loop_fn(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4146"}},{"Add":{"text":" (self, stop_future, stop_condition),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4195"}},{"Add":{"text":" |(xmpp, stop_future, mut stop_condition)| {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4251"}},{"Add":{"text":" let XmppConnection { inner, account } = xmpp;","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4313"}},{"Add":{"text":" inner.into_future().select2(stop_future).then(|r| match r {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4389"}},{"Add":{"text":" Ok(Either::A(((event, client), b))) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4450"}},{"Add":{"text":" if let Some(event) = event {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4503"}},{"Add":{"text":" let mut xmpp = XmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4563"}},{"Add":{"text":" inner: client,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4610"}}],"del_contents":[{"Del":{"text":" /// get connection and wait for online status and set presence","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1426"}},{"Del":{"text":" /// returns error if something went wrong","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1472"}},{"Del":{"text":" fn online(","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1487"}},{"Del":{"text":" (sink, stream): (stream::SplitSink, stream::SplitStream),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1569"}},{"Del":{"text":" account: std::rc::Rc,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1616"}},{"Del":{"text":" ) -> impl Future> {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1690"}},{"Del":{"text":" Box::new(future::loop_fn(","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1724"}},{"Del":{"text":" (sink, stream, account),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1761"}},{"Del":{"text":" |(sink, stream, account)| {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1801"}},{"Del":{"text":" stream.into_future().then(|r| match r {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1857"}},{"Del":{"text":" Ok((event, stream)) => match event {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1914"}},{"Del":{"text":" Some(Event::Online) => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:1963"}},{"Del":{"text":" info!(\"Online\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2008"}},{"Del":{"text":" future::ok(future::Loop::Break(XmppConnection {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2084"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":139,"ins":{"up_context":[{"change":3,"pos":3996}],"down_context":[{"change":3,"pos":4505}],"flag":"","start":4612,"end":5335,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":3996},"to":{"change":3,"start":2086,"end":2179},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" };","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4642"}},{"Add":{"text":" xmpp.xmpp_processing(&event);","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4700"}},{"Add":{"text":" match stop_condition(&mut xmpp, &event) {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4770"}},{"Add":{"text":" Ok(true) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4816"}},{"Add":{"text":" future::ok(future::Loop::Break((xmpp, Ok(Either::A(b)))))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4910"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4944"}},{"Add":{"text":" Ok(false) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:4991"}},{"Add":{"text":" future::ok(future::Loop::Continue((xmpp, b, stop_condition)))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5089"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5123"}},{"Add":{"text":" Err(e) => future::err((xmpp.account, Err(e))),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5202"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5232"}},{"Add":{"text":" } else {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5265"}},{"Add":{"text":" future::err((account, Ok(Either::A(b))))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5334"}}],"del_contents":[{"Del":{"text":" inner: Some((sink, stream)),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2146"}},{"Del":{"text":" }))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2178"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":153,"ins":{"up_context":[{"change":3,"pos":4531}],"down_context":[{"change":3,"pos":4974}],"flag":"","start":5336,"end":5779,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4531},"to":{"change":3,"start":2180,"end":2379},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5357"}},{"Add":{"text":" Ok(Either::B((t, a))) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5404"}},{"Add":{"text":" if let Some(inner) = a.into_inner() {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5466"}},{"Add":{"text":" future::ok(future::Loop::Break((","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5527"}},{"Add":{"text":" XmppConnection { inner, account },","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5594"}},{"Add":{"text":" Ok(Either::B(t)),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5644"}},{"Add":{"text":" )))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5676"}},{"Add":{"text":" } else {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5709"}},{"Add":{"text":" future::err((account, Ok(Either::B(t))))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5778"}}],"del_contents":[{"Del":{"text":" Some(Event::Stanza(s)) => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2231"}},{"Del":{"text":" info!(\"xmpp stanza: {:?}\", s);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2290"}},{"Del":{"text":" future::ok(future::Loop::Continue((sink, stream, account)))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2378"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":163,"ins":{"up_context":[{"change":3,"pos":5000}],"down_context":[{"change":3,"pos":5513}],"flag":"","start":5780,"end":6307,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":5000},"to":{"change":3,"start":2380,"end":2511},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5801"}},{"Add":{"text":" Err(Either::A((_e, b))) => future::err((account, Ok(Either::A(b)))),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5890"}},{"Add":{"text":" Err(Either::B((e, a))) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:5938"}},{"Add":{"text":" if let Some(inner) = a.into_inner() {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6000"}},{"Add":{"text":" future::ok(future::Loop::Break((","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6061"}},{"Add":{"text":" XmppConnection { inner, account },","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6128"}},{"Add":{"text":" Err(e.into()),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6175"}},{"Add":{"text":" )))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6207"}},{"Add":{"text":" } else {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6240"}},{"Add":{"text":" future::err((account, Err(e.into())))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6306"}}],"del_contents":[{"Del":{"text":" _ => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2410"}},{"Del":{"text":" warn!(\"Disconnected\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2461"}},{"Del":{"text":" future::err(account)","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2510"}}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":174,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":5539},"to":{"change":3,"start":2512,"end":2678},"introduced_by":3}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":{"text":" },","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2534"}},{"Del":{"text":" Err((e, _)) => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2571"}},{"Del":{"text":" error!(\"xmpp receive error: {}\", e);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2632"}},{"Del":{"text":" future::err(account)","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2677"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":177,"ins":{"up_context":[{"change":3,"pos":5595}],"down_context":[{"change":3,"pos":3349}],"flag":"","start":6308,"end":6318,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":5595},"to":{"change":3,"start":2679,"end":2690},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" )","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6317"}}],"del_contents":[{"Del":{"text":" ))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2689"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":180,"ins":{"up_context":[{"change":3,"pos":3356}],"down_context":[{"change":3,"pos":6101}],"flag":"","start":6319,"end":7144,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":887},"to":{"change":3,"start":650,"end":745},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3356},"to":{"change":3,"start":650,"end":745},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" /// get connection and wait for online status and set presence","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6385"}},{"Add":{"text":" /// returns error if something went wrong","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6431"}},{"Add":{"text":" fn online(&mut self, event: &Event) -> Result {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6505"}},{"Add":{"text":" match event {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6527"}},{"Add":{"text":" Event::Online => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6558"}},{"Add":{"text":" info!(\"Online!\");","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6592"}},{"Add":{"text":" Ok(true)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6617"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6631"}},{"Add":{"text":" Event::Stanza(s) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6665"}},{"Add":{"text":" warn!(\"Stanza before online: {:?}\", s);","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6721"}},{"Add":{"text":" Ok(false)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6747"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6761"}},{"Add":{"text":" _ => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6780"}},{"Add":{"text":" error!(\"Disconnected while online\");","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6833"}},{"Add":{"text":" Err(format_err!(\"Disconnected while online\"))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6895"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6909"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6919"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6925"}},{"Add":{"text":"","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6926"}},{"Add":{"text":" fn self_presence(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6954"}},{"Add":{"text":" self,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6968"}},{"Add":{"text":" stop_future: F,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:6992"}},{"Add":{"text":" ) -> impl Future>","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7064"}},{"Add":{"text":" where","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7074"}},{"Add":{"text":" F: Future,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7104"}},{"Add":{"text":" E: Into,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7137"}},{"Add":{"text":" {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7143"}}],"del_contents":[{"Del":{"text":" fn self_presence(self) -> impl Future> {","pos":"FV6BJ5K64QG63YI2PTII44ZEBAYNJBQZ5FSBHW65EPHGBKFGUW4AC:744"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":208,"ins":{"up_context":[{"change":3,"pos":6155}],"down_context":[{"change":3,"pos":784}],"flag":"","start":7145,"end":7207,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":6155},"to":{"change":3,"start":2691,"end":2775},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" let client = inner;","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7172"}},{"Add":{"text":" use tokio::prelude::Sink;","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7206"}}],"del_contents":[{"Del":{"text":" if let Some((sink, stream)) = inner {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2736"}},{"Del":{"text":" use tokio::prelude::Sink;","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2774"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":211,"ins":{"up_context":[{"change":3,"pos":785}],"down_context":[{"change":3,"pos":5234}],"flag":"","start":7208,"end":8375,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":785},"to":{"change":3,"start":2776,"end":4695},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":7755},"to":{"change":3,"start":2608,"end":2657},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2471},"to":{"change":3,"start":2608,"end":2657},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3187},"to":{"change":3,"start":2608,"end":2657},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4695},"to":{"change":3,"start":2608,"end":2657},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3348},"to":{"change":3,"start":2608,"end":2657},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3847},"to":{"change":3,"start":2608,"end":2657},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1498},"to":{"change":3,"start":2608,"end":2657},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2608},"to":{"change":3,"start":2608,"end":2657},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2657},"to":{"change":3,"start":4696,"end":4782},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":7854},"to":{"change":3,"start":2743,"end":2785},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2570},"to":{"change":3,"start":2743,"end":2785},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3286},"to":{"change":3,"start":2743,"end":2785},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4782},"to":{"change":3,"start":2743,"end":2785},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3435},"to":{"change":3,"start":2743,"end":2785},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3934},"to":{"change":3,"start":2743,"end":2785},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1597},"to":{"change":3,"start":2743,"end":2785},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2743},"to":{"change":3,"start":2743,"end":2785},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":7982},"to":{"change":3,"start":2785,"end":2823},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2698},"to":{"change":3,"start":2785,"end":2823},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3414},"to":{"change":3,"start":2785,"end":2823},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2785},"to":{"change":3,"start":2785,"end":2823},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2823},"to":{"change":3,"start":4783,"end":5234},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" let presence = stanzas::make_presence(&account);","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7264"}},{"Add":{"text":" info!(\"Sending presence...\");","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7302"}},{"Add":{"text":" let account2 = account.clone();","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7342"}},{"Add":{"text":" client","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7357"}},{"Add":{"text":" .send(presence)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7385"}},{"Add":{"text":" .map_err(|e| {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7412"}},{"Add":{"text":" error!(\"Error on send self-presence: {}\", e);","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7474"}},{"Add":{"text":" (account2, Err(failure::SyncFailure::new(e).into()))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7543"}},{"Add":{"text":" })","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7558"}},{"Add":{"text":" .and_then(move |client| {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7596"}},{"Add":{"text":" XmppConnection {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7629"}},{"Add":{"text":" inner: client,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7664"}},{"Add":{"text":" account,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7693"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7711"}},{"Add":{"text":" .processing(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7740"}},{"Add":{"text":" move |conn, event| {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7781"}},{"Add":{"text":" if let Event::Stanza(s) = event {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7839"}},{"Add":{"text":" if s.name() == \"presence\"","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7893"}},{"Add":{"text":" && s.attr(\"from\").map_or(false, |f| f == conn.account.jid)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:7984"}},{"Add":{"text":" && s.attr(\"to\").map_or(false, |f| f == conn.account.jid)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8073"}},{"Add":{"text":" {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8103"}},{"Add":{"text":" Ok(true)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8144"}},{"Add":{"text":" } else {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8181"}},{"Add":{"text":" Ok(false)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8223"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8253"}},{"Add":{"text":" } else {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8286"}},{"Add":{"text":" Err(format_err!(\"Wrong event while waiting self-presence\"))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8374"}}],"del_contents":[{"Del":{"text":" let presence = stanzas::make_presence(&account);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2836"}},{"Del":{"text":" info!(\"Sending presence...\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2878"}},{"Del":{"text":" Box::new(","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2900"}},{"Del":{"text":" sink.send(presence)","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2936"}},{"Del":{"text":" .map_err(|e| {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:2971"}},{"Del":{"text":" error!(\"Error on send self-presence: {}\", e);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3041"}},{"Del":{"text":" \"Cann't send self-presence\".to_owned()","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3104"}},{"Del":{"text":" })","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3127"}},{"Del":{"text":" .join(","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3154"}},{"Del":{"text":" future::loop_fn((account.clone(), stream), |(account, stream)| {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3243"}},{"Del":{"text":" stream","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3278"}},{"Del":{"text":" .into_future()","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3325"}},{"Del":{"text":" .map_err(|(e, _)| {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3377"}},{"Del":{"text":" error!(\"Error on reading self-presence: {}\", e);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3462"}},{"Del":{"text":" \"Cann't read self-presence\".to_owned()","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3537"}},{"Del":{"text":" })","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3572"}},{"Del":{"text":" .and_then(|(event, stream)| match event {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3646"}},{"Del":{"text":" Some(event) => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3699"}},{"Del":{"text":" if let tokio_xmpp::Event::Stanza(e) = event {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3785"}},{"Del":{"text":" info!(\"Get stanza: {:?}\", e);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3859"}},{"Del":{"text":" if e.name() == \"presence\"","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3929"}},{"Del":{"text":" && e.attr(\"from\")","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:3995"}},{"Del":{"text":" .map_or(false, |f| f == account.jid)","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4084"}},{"Del":{"text":" && e.attr(\"to\").map_or(false, |f| f == account.jid)","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4184"}},{"Del":{"text":" {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4230"}},{"Del":{"text":" info!(\"Self presence\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4302"}},{"Del":{"text":" future::ok(future::Loop::Break(stream))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4390"}},{"Del":{"text":" } else {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4443"}},{"Del":{"text":" future::ok(future::Loop::Continue((","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4527"}},{"Del":{"text":" account, stream,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4596"}},{"Del":{"text":" )))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4648"}},{"Del":{"text":" }","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4694"}},{"Del":{"text":" } else {","pos":"FV6BJ5K64QG63YI2PTII44ZEBAYNJBQZ5FSBHW65EPHGBKFGUW4AC:2656"}},{"Del":{"text":" future::err(\"Got wrong event\".to_owned())","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4781"}},{"Del":{"text":" }","pos":"FV6BJ5K64QG63YI2PTII44ZEBAYNJBQZ5FSBHW65EPHGBKFGUW4AC:2784"}},{"Del":{"text":" }","pos":"FV6BJ5K64QG63YI2PTII44ZEBAYNJBQZ5FSBHW65EPHGBKFGUW4AC:2822"}},{"Del":{"text":" None => future::err(\"Got closed stream\".to_owned()),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4871"}},{"Del":{"text":" })","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4906"}},{"Del":{"text":" })","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:4933"}},{"Del":{"text":" .map_err(|e| format!(\"waiting self-presence: {}\", e)),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5012"}},{"Del":{"text":" )","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5034"}},{"Del":{"text":" .then(|r| match r {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5074"}},{"Del":{"text":" Err(e) => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5110"}},{"Del":{"text":" error!(\"Self-presence waiting error: {}\", e);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5184"}},{"Del":{"text":" future::err(account)","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5233"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":239,"ins":{"up_context":[{"change":3,"pos":5260}],"down_context":[{"change":3,"pos":3783}],"flag":"","start":8376,"end":8718,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":5260},"to":{"change":3,"start":5260,"end":5642},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" },","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8398"}},{"Add":{"text":" stop_future,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8431"}},{"Add":{"text":" )","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8449"}},{"Add":{"text":" })","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8464"}},{"Add":{"text":" .then(|r| match r {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8496"}},{"Add":{"text":" Err((account, e)) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8535"}},{"Add":{"text":" error!(\"Cann't wait self-presence\");","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8592"}},{"Add":{"text":" future::err(account)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8633"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8651"}},{"Add":{"text":" Ok((conn, _)) => future::ok(conn),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8702"}},{"Add":{"text":" })","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8717"}}],"del_contents":[{"Del":{"text":" Ok(inner) => future::ok(XmppConnection {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5324"}},{"Del":{"text":" account,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5361"}},{"Del":{"text":" inner: Some(inner),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5409"}},{"Del":{"text":" }),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5437"}},{"Del":{"text":" }),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5461"}},{"Del":{"text":" )","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5475"}},{"Del":{"text":" } else {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5492"}},{"Del":{"text":" warn!(\"Don't gen connection on self-presence\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5552"}},{"Del":{"text":" Box::new(future::err(account)) as Box>","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5631"}},{"Del":{"text":" }","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5641"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":254,"ins":{"up_context":[{"change":3,"pos":60}],"down_context":[{"change":3,"pos":3816}],"flag":"","start":8719,"end":8743,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":60},"to":{"change":2,"start":0,"end":52},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":"pub struct XmppCommand;","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8742"}}],"del_contents":[{"Del":{"text":"pub struct XmppCommand {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:24"}},{"Del":{"text":" pub xmpp_to: String,","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:49"}},{"Del":{"text":"}","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:51"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":259,"ins":{"up_context":[{"change":3,"pos":3891}],"down_context":[{"change":3,"pos":3917}],"flag":"","start":8744,"end":8775,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":3891},"to":{"change":3,"start":5643,"end":5669},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" conn: MaybeXmppConnection,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8774"}}],"del_contents":[{"Del":{"text":" conn: XmppConnection,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5668"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":263,"ins":{"up_context":[{"change":3,"pos":133}],"down_context":[{"change":3,"pos":4038}],"flag":"","start":8776,"end":8859,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":133},"to":{"change":3,"start":5670,"end":5748},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" fn new(cmd_recv: S, signal: F, conn: MaybeXmppConnection) -> XmppState {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8858"}}],"del_contents":[{"Del":{"text":" fn new(cmd_recv: S, signal: F, conn: XmppConnection) -> XmppState {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5747"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":278,"ins":{"up_context":[{"change":3,"pos":4311}],"down_context":[{"change":3,"pos":465}],"flag":"","start":8860,"end":8987,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4311},"to":{"change":3,"start":5749,"end":5793},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" F: future::Future + Clone + 'static,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8900"}},{"Add":{"text":" ::Error: std::fmt::Display + Into + Send,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:8986"}}],"del_contents":[{"Del":{"text":" F: future::Future + 'static,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5792"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":282,"ins":{"up_context":[{"change":3,"pos":4357}],"down_context":[{"change":3,"pos":4526}],"flag":"","start":8988,"end":9038,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4357},"to":{"change":3,"start":5794,"end":5915},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" let conn = MaybeXmppConnection::new(account);","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9037"}}],"del_contents":[{"Del":{"text":" let signal = signal.map_err(|_| format_err!(\"Wrong shutdown signal\"));","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5868"}},{"Del":{"text":"","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5869"}},{"Del":{"text":" let conn = XmppConnection::new(account);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5914"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":290,"ins":{"up_context":[{"change":3,"pos":4692}],"down_context":[{"change":3,"pos":4761}],"flag":"","start":9039,"end":9107,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4692},"to":{"change":3,"start":5916,"end":5985},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" conn.connect(signal.clone())","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9075"}},{"Add":{"text":" .and_then(|conn| {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9106"}}],"del_contents":[{"Del":{"text":" signal","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5930"}},{"Del":{"text":" .select2(conn.connect().and_then(|conn| {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:5984"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":299,"ins":{"up_context":[{"change":3,"pos":675}],"down_context":[{"change":3,"pos":731}],"flag":"","start":9108,"end":9189,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":675},"to":{"change":3,"start":5986,"end":6042},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" .map(|(cmd, cmd_recv)| (cmd, cmd_recv, conn))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9173"}},{"Add":{"text":" })","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9188"}}],"del_contents":[{"Del":{"text":" .map(|f| (f, conn))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6025"}},{"Del":{"text":" }))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6041"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":303,"ins":{"up_context":[{"change":3,"pos":5146}],"down_context":[{"change":3,"pos":7045}],"flag":"","start":9190,"end":9763,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":5146},"to":{"change":3,"start":6043,"end":6333},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":9376},"to":{"change":3,"start":6169,"end":6191},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6333},"to":{"change":3,"start":6169,"end":6191},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6169},"to":{"change":3,"start":6169,"end":6191},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6191},"to":{"change":3,"start":6334,"end":7045},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Ok((cmd, cmd_recv, conn)) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9240"}},{"Add":{"text":" if let Some(_cmd) = cmd {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9290"}},{"Add":{"text":" info!(\"Got cmd\");","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9336"}},{"Add":{"text":" // got cmd, continue","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9385"}},{"Add":{"text":" future::ok(future::Loop::Continue(XmppState::new(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9463"}},{"Add":{"text":" cmd_recv,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9505"}},{"Add":{"text":" signal,","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9545"}},{"Add":{"text":" conn.into(),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9590"}},{"Add":{"text":" )))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9622"}},{"Add":{"text":" } else {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9655"}},{"Add":{"text":" future::ok(future::Loop::Break((None, conn.into())))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9736"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9762"}}],"del_contents":[{"Del":{"text":" Ok(Either::A((_x, b))) => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6090"}},{"Del":{"text":" info!(\"Got signal\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6135"}},{"Del":{"text":" // got signal, breaks","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6181"}},{"Del":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1))))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6268"}},{"Del":{"text":" as Box>","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6332"}},{"Del":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6190"}},{"Del":{"text":" Ok(Either::B((x, a))) => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6380"}},{"Del":{"text":" info!(\"Got cmd\");","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6422"}},{"Del":{"text":" // got cmd, continue","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6467"}},{"Del":{"text":" Box::new(future::ok(future::Loop::Continue(XmppState::new(","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6550"}},{"Del":{"text":" (x.0).1,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6587"}},{"Del":{"text":" a,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6618"}},{"Del":{"text":" x.1,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6651"}},{"Del":{"text":" )))) as Box>","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6716"}},{"Del":{"text":" }","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6738"}},{"Del":{"text":" Err(Either::A((e, b))) => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6786"}},{"Del":{"text":" // got signal error, breaks","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6838"}},{"Del":{"text":" error!(\"Signal error: {}\", e);","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6893"}},{"Del":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1))))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:6980"}},{"Del":{"text":" as Box>","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7044"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":316,"ins":{"up_context":[{"change":3,"pos":7067}],"down_context":[{"change":3,"pos":6240}],"flag":"","start":9764,"end":9796,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":7067},"to":{"change":3,"start":7067,"end":7116},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Err(e) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9795"}}],"del_contents":[{"Del":{"text":" Err(Either::B((e, _a))) => {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7115"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":319,"ins":{"up_context":[{"change":3,"pos":6342}],"down_context":[{"change":3,"pos":6572}],"flag":"","start":9797,"end":9859,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":6342},"to":{"change":3,"start":7117,"end":7253},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" future::err(format_err!(\"Cmd error\"))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9858"}}],"del_contents":[{"Del":{"text":" Box::new(future::err(format_err!(\"Cmd error\")))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7188"}},{"Del":{"text":" as Box>","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7252"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":324,"ins":{"up_context":[{"change":3,"pos":900}],"down_context":[{"change":3,"pos":969}],"flag":"","start":9860,"end":9934,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":900},"to":{"change":3,"start":7254,"end":7323},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" .and_then(|(opt_cmd_recv, _conn): (Option, MaybeXmppConnection)| {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9933"}}],"del_contents":[{"Del":{"text":" .and_then(|(opt_cmd_recv, _conn): (Option, XmppConnection)| {","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7322"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":334,"ins":{"up_context":[{"change":3,"pos":1354}],"down_context":[{"change":3,"pos":1422}],"flag":"","start":9935,"end":9972,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":1354},"to":{"change":3,"start":7324,"end":7392},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Box::new(future::ok(()))","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:9971"}}],"del_contents":[{"Del":{"text":" Box::new(future::err(format_err!(\"cmd receiver gone\")))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7391"}}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":22,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3921}],"down_context":[{"change":3,"pos":3953}],"flag":"","start":9973,"end":10005,"inode":{"change":3,"pos":17}}},"contents":[{"Add":{"text":"use hyper::service::service_fn;","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10004"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":28,"ins":{"up_context":[{"change":3,"pos":4066}],"down_context":[{"change":3,"pos":4092}],"flag":"","start":10006,"end":10032,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4066},"to":{"change":2,"start":53,"end":97},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":"use tokio::prelude::Sink;","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10031"}}],"del_contents":[{"Del":{"text":"use tokio::prelude::{Future, Sink, Stream};","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:96"}}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":38,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4260},"to":{"change":2,"start":98,"end":908},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":219},"to":{"change":3,"start":398,"end":399},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":2,"pos":908},"to":{"change":3,"start":398,"end":399},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":481},"to":{"change":3,"start":398,"end":399},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":113},"to":{"change":3,"start":398,"end":399},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":398},"to":{"change":3,"start":398,"end":399},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":399},"to":{"change":2,"start":909,"end":4701},"introduced_by":2}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":{"text":"","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:98"}},{"Del":{"text":"struct ServiceCmd {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:118"}},{"Del":{"text":" cmd_send: tokio_channel::mpsc::Sender,","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:174"}},{"Del":{"text":"}","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:176"}},{"Del":{"text":"","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:177"}},{"Del":{"text":"impl hyper::service::Service for ServiceCmd {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:223"}},{"Del":{"text":" type ReqBody = Body;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:248"}},{"Del":{"text":" type ResBody = Body;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:273"}},{"Del":{"text":" type Error = failure::Error;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:306"}},{"Del":{"text":" type Future =","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:324"}},{"Del":{"text":" Box, Error = Self::Error> + Send + 'static>;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:419"}},{"Del":{"text":"","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:420"}},{"Del":{"text":" fn call(&mut self, req: Request) -> Self::Future {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:490"}},{"Del":{"text":" let xmpp_to_opt = req.headers().get(\"X-XMPP-To\");","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:548"}},{"Del":{"text":" let xmpp_to_res: Result> = xmpp_to_opt.map_or_else(","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:638"}},{"Del":{"text":" || Err(\"none\".into()),","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:673"}},{"Del":{"text":" |xmpp_to| {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:697"}},{"Del":{"text":" xmpp_to.to_str().map(|x| x.to_owned()).map_err(|e| {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:766"}},{"Del":{"text":" format!(\"\\\"{}\\\" {}\", String::from_utf8_lossy(xmpp_to.as_bytes()), e).into()","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:862"}},{"Del":{"text":" })","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:881"}},{"Del":{"text":" },","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:896"}},{"Del":{"text":" );","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:907"}},{"Del":{"text":"","pos":"EOHEZXX3TBKGJTOMXEPAPHLAJSATRXNY4AIL63BE4VG3HFNWARVQC:398"}},{"Del":{"text":" match xmpp_to_res {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:936"}},{"Del":{"text":" Err(err) => {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:962"}},{"Del":{"text":" warn!(\"Unknown destination: {}\", err);","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1017"}},{"Del":{"text":" Box::new(tokio::prelude::future::result(","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1074"}},{"Del":{"text":" Response::builder()","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1114"}},{"Del":{"text":" .status(hyper::StatusCode::BAD_REQUEST)","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1178"}},{"Del":{"text":" .body(Body::from(format!(\"Unknown destination: {}\", err)))","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1261"}},{"Del":{"text":" .map_err(|e| e.into()),","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1309"}},{"Del":{"text":" )) as Box + Send + 'static>","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1381"}},{"Del":{"text":" }","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1395"}},{"Del":{"text":" Ok(xmpp_to) => {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1424"}},{"Del":{"text":" info!(\"Got request. Reading body...\");","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1479"}},{"Del":{"text":" let cmd_send = self.cmd_send.clone();","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1533"}},{"Del":{"text":" Box::new(","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1559"}},{"Del":{"text":" req.into_body()","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1595"}},{"Del":{"text":" .map_err(|e| e.into())","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1642"}},{"Del":{"text":" .fold(String::new(), |mut acc, ch| {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1703"}},{"Del":{"text":" std::str::from_utf8(&*ch).map(|s| {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1767"}},{"Del":{"text":" acc.push_str(s);","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1816"}},{"Del":{"text":" acc","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1852"}},{"Del":{"text":" })","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1883"}},{"Del":{"text":" })","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1910"}},{"Del":{"text":" .and_then(move |msg: String| {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:1965"}},{"Del":{"text":" if !msg.is_empty() {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2014"}},{"Del":{"text":" Box::new(","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2056"}},{"Del":{"text":" cmd_send","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2101"}},{"Del":{"text":" .clone()","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2150"}},{"Del":{"text":" .send(XmppCommand { xmpp_to })","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2221"}},{"Del":{"text":" .then(|r| match r {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2281"}},{"Del":{"text":" Ok(_) => tokio::prelude::future::ok(Response::new(","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2376"}},{"Del":{"text":" Body::from(\"Accepted\"),","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2448"}},{"Del":{"text":" )),","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2496"}},{"Del":{"text":" Err(e) => {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2552"}},{"Del":{"text":" error!(\"Command sent error: {}\", e);","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2637"}},{"Del":{"text":" tokio::prelude::future::result(","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2717"}},{"Del":{"text":" Response::builder()","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2789"}},{"Del":{"text":" .status(hyper::StatusCode::BAD_REQUEST)","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2885"}},{"Del":{"text":" .body(Body::from(format!(","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:2967"}},{"Del":{"text":" \"Command sent error: {}\",","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3053"}},{"Del":{"text":" e","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3115"}},{"Del":{"text":" ))),","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3176"}},{"Del":{"text":" )","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3226"}},{"Del":{"text":" }","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3272"}},{"Del":{"text":" })","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3315"}},{"Del":{"text":" .map_err(|e| e.into()),","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3379"}},{"Del":{"text":" )","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3413"}},{"Del":{"text":" } else {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3450"}},{"Del":{"text":" warn!(\"Empty message\");","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3506"}},{"Del":{"text":" Box::new(tokio::prelude::future::result(","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3579"}},{"Del":{"text":" Response::builder()","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3635"}},{"Del":{"text":" .status(hyper::StatusCode::BAD_REQUEST)","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3715"}},{"Del":{"text":" .body(Body::from(\"Empty message\"))","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3790"}},{"Del":{"text":" .map_err(|e| e.into()),","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3854"}},{"Del":{"text":" ))","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3889"}},{"Del":{"text":" as Box + Send + 'static>","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:3978"}},{"Del":{"text":" }","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4008"}},{"Del":{"text":" }),","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4036"}},{"Del":{"text":" ) as Box + Send + 'static>","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4107"}},{"Del":{"text":" }","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4121"}},{"Del":{"text":" }","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4131"}},{"Del":{"text":" }","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4137"}},{"Del":{"text":"}","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4139"}},{"Del":{"text":"","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4140"}},{"Del":{"text":"struct MakeServiceCmd {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4164"}},{"Del":{"text":" cmd_send: tokio_channel::mpsc::Sender,","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4220"}},{"Del":{"text":"}","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4222"}},{"Del":{"text":"","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4223"}},{"Del":{"text":"impl hyper::service::MakeService for MakeServiceCmd {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4287"}},{"Del":{"text":" type ReqBody = Body;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4312"}},{"Del":{"text":" type ResBody = Body;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4337"}},{"Del":{"text":" type Error = failure::Error;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4370"}},{"Del":{"text":" type Service = ServiceCmd;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4401"}},{"Del":{"text":" type Future = tokio::prelude::future::FutureResult;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4486"}},{"Del":{"text":" type MakeError = hyper::http::Error;","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4527"}},{"Del":{"text":"","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4528"}},{"Del":{"text":" fn make_service(&mut self, _ctx: Ctx) -> Self::Future {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4588"}},{"Del":{"text":" tokio::prelude::future::ok(ServiceCmd {","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4636"}},{"Del":{"text":" cmd_send: self.cmd_send.clone(),","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4681"}},{"Del":{"text":" })","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4692"}},{"Del":{"text":" }","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4698"}},{"Del":{"text":"}","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4700"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":63,"ins":{"up_context":[{"change":3,"pos":4954}],"down_context":[{"change":3,"pos":5020}],"flag":"","start":10033,"end":10140,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4954},"to":{"change":3,"start":7393,"end":7459},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" .map_err(|e| {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10055"}},{"Add":{"text":" error!(\"Cann't get CTRL+C signal: {}\", e.0);","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10112"}},{"Add":{"text":" e.0","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10128"}},{"Add":{"text":" })","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10139"}}],"del_contents":[{"Del":{"text":" .map_err(|e| error!(\"Cann't get CTRL+C signal: {}\", e.0))","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7458"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":72,"ins":{"up_context":[{"change":3,"pos":5155}],"down_context":[{"change":3,"pos":5935}],"flag":"","start":10141,"end":10921,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":5155},"to":{"change":2,"start":4703,"end":4747},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" .serve(move || {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10165"}},{"Add":{"text":" let cmd_send = cmd_send.clone();","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10210"}},{"Add":{"text":" service_fn(move |_req: Request| {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10262"}},{"Add":{"text":" info!(\"Got request\");","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10300"}},{"Add":{"text":" cmd_send.clone().send(XmppCommand {}).then(|r| match r {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10373"}},{"Add":{"text":" Ok(_) => tokio::prelude::future::ok(Response::new(Body::from(\"Accepted\"))),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10469"}},{"Add":{"text":" Err(e) => {","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10501"}},{"Add":{"text":" error!(\"Command sent error: {}\", e);","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10562"}},{"Add":{"text":" tokio::prelude::future::result(","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10618"}},{"Add":{"text":" Response::builder()","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10666"}},{"Add":{"text":" .status(hyper::StatusCode::BAD_REQUEST)","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10738"}},{"Add":{"text":" .body(Body::from(format!(\"Command sent error: {}\", e))),","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10827"}},{"Add":{"text":" )","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10853"}},{"Add":{"text":" }","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10875"}},{"Add":{"text":" })","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10894"}},{"Add":{"text":" })","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10909"}},{"Add":{"text":" })","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:10920"}}],"del_contents":[{"Del":{"text":" .serve(MakeServiceCmd { cmd_send })","pos":"QYY3KRGLZFFOMYZUMEX5DUFU2DSP3H3NVFLMVTS2PEFQZ6U63AMAC:4746"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":100,"ins":{"up_context":[{"change":3,"pos":6389}],"down_context":[{"change":3,"pos":6536}],"flag":"","start":10922,"end":11010,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":6389},"to":{"change":3,"start":7460,"end":7607},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" let result = ctrt.block_on(xmpp_process(ctrl_c.clone(), recv, config.account));","pos":"HU3NZX5ZNTZB43SBAYMY2PUUMIF2ROJ4EFAJ6HTZXZL5T7ZJ3OQAC:11009"}}],"del_contents":[{"Del":{"text":" let result = ctrt.block_on(xmpp_process(","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7508"}},{"Del":{"text":" ctrl_c.clone().map(|_| ()),","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7548"}},{"Del":{"text":" recv,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7566"}},{"Del":{"text":" config.account,","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7594"}},{"Del":{"text":" ));","pos":"IK3YDPTYYB4IQR3JFFXFLPGWTBG4HE4OCMKJ447RK72OYESHOMRQC:7606"}}]}}],"owner":"O01eg","repo":"sendxmppd-rs","token":"0nig6HCRM7G5bl8Hefu6mlOUXGc6upLwO+ocJJM7uPI=","login":null}

…

Dependencies

Change contents

Review