{"header":{"message":"Move XMPP to separate dir","description":null,"timestamp":"2018-10-30T11:25:20Z","authors":[{"email":"o01eg@yandex.ru","name":"O01eg"}]},"hash":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC","authors":[],"deps":{"hashes":[["VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC","Move XMPP to separate dir"],["AA",null],["FVVPKFTLD5VOGVDF7MOSSKQ3KPCT4HDGTNTTC6I6B4TWXOTPCJ7AC","Initial commit"]],"deps":["FVVPKFTLD5VOGVDF7MOSSKQ3KPCT4HDGTNTTC6I6B4TWXOTPCJ7AC"],"known":[]},"hunks":[{"FileAdd":{"meta":{"basename":"xmpp","metadata":1005},"context":[{"change":2,"pos":6}],"contents":[]}},{"FileAdd":{"meta":{"basename":"mod.rs","metadata":420},"context":[{"change":0,"pos":7}],"contents":[{"Add":{"text":"use tokio::prelude::future::{self, Either};","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:61"}},{"Add":{"text":"use tokio::prelude::stream;","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:89"}},{"Add":{"text":"use tokio::prelude::{Future, Stream};","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:127"}},{"Add":{"text":"use tokio_channel::mpsc::Receiver;","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:162"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:163"}},{"Add":{"text":"use tokio_xmpp::{Client, Event};","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:196"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:197"}},{"Add":{"text":"use config;","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:209"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:210"}},{"Add":{"text":"pub struct XmppConnection {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:238"}},{"Add":{"text":" account: config::Account,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:268"}},{"Add":{"text":" inner: Option<(stream::SplitSink, stream::SplitStream)>,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:345"}},{"Add":{"text":"}","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:347"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:348"}},{"Add":{"text":"impl XmppConnection {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:370"}},{"Add":{"text":" fn new(account: config::Account) -> XmppConnection {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:427"}},{"Add":{"text":" XmppConnection {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:452"}},{"Add":{"text":" account,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:473"}},{"Add":{"text":" inner: None,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:498"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:508"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:514"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:515"}},{"Add":{"text":" /// connects if nothing connected","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:553"}},{"Add":{"text":" /// Error shoud be !","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:578"}},{"Add":{"text":" fn connect(self) -> impl Future {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:652"}},{"Add":{"text":" info!(\"xmpp connection...\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:689"}},{"Add":{"text":" let XmppConnection { account, inner } = self;","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:743"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:744"}},{"Add":{"text":" if let Some(inner) = inner {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:781"}},{"Add":{"text":" Box::new(future::ok(XmppConnection {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:830"}},{"Add":{"text":" account,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:855"}},{"Add":{"text":" inner: Some(inner),","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:891"}},{"Add":{"text":" })) as Box>","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:943"}},{"Add":{"text":" } else {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:960"}},{"Add":{"text":" Box::new(future::loop_fn(account, |account| {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1018"}},{"Add":{"text":" info!(\"xmpp initialization...\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1067"}},{"Add":{"text":" let mut res_client = Client::new(&account.jid, &account.password);","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1150"}},{"Add":{"text":" while let Err(e) = res_client {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1198"}},{"Add":{"text":" error!(\"Cann't init xmpp client: {}\", e);","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1260"}},{"Add":{"text":" res_client = Client::new(&account.jid, &account.password);","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1339"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1357"}},{"Add":{"text":" let client = res_client.expect(\"Cann't init xmpp client\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1432"}},{"Add":{"text":" info!(\"xmpp initialized\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1475"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1476"}},{"Add":{"text":" // future to wait for online","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1521"}},{"Add":{"text":" Self::online(client.split(), account)","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1575"}},{"Add":{"text":" .and_then(Self::self_presence)","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1626"}},{"Add":{"text":" .then(|r| match r {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1666"}},{"Add":{"text":" Ok(conn) => future::ok(future::Loop::Break(conn)),","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1741"}},{"Add":{"text":" Err(acc) => future::ok(future::Loop::Continue(acc)),","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1818"}},{"Add":{"text":" })","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1841"}},{"Add":{"text":" }))","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1857"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1867"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1873"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1874"}},{"Add":{"text":" /// get connection and wait for online status and set presence","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1941"}},{"Add":{"text":" /// returns error if something went wrong","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:1987"}},{"Add":{"text":" fn online(","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2002"}},{"Add":{"text":" (sink, stream): (stream::SplitSink, stream::SplitStream),","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2084"}},{"Add":{"text":" account: config::Account,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2118"}},{"Add":{"text":" ) -> impl Future {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2179"}},{"Add":{"text":" Box::new(future::loop_fn(","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2213"}},{"Add":{"text":" (sink, stream, account),","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2250"}},{"Add":{"text":" |(sink, stream, account)| {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2290"}},{"Add":{"text":" stream.into_future().then(|r| match r {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2346"}},{"Add":{"text":" Ok((event, stream)) => match event {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2403"}},{"Add":{"text":" Some(Event::Online) => {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2452"}},{"Add":{"text":" info!(\"Online\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2497"}},{"Add":{"text":" future::ok(future::Loop::Break(XmppConnection {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2573"}},{"Add":{"text":" account,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2614"}},{"Add":{"text":" inner: Some((sink, stream)),","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2675"}},{"Add":{"text":" }))","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2707"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2733"}},{"Add":{"text":" Some(Event::Stanza(s)) => {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2785"}},{"Add":{"text":" info!(\"xmpp stanza: {:?}\", s);","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2844"}},{"Add":{"text":" future::ok(future::Loop::Continue((sink, stream, account)))","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2932"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2958"}},{"Add":{"text":" _ => {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:2989"}},{"Add":{"text":" warn!(\"Disconnected\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3040"}},{"Add":{"text":" future::err(account)","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3089"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3115"}},{"Add":{"text":" },","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3138"}},{"Add":{"text":" Err((e, _)) => {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3175"}},{"Add":{"text":" error!(\"xmpp receive error: {}\", e);","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3236"}},{"Add":{"text":" future::err(account)","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3281"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3303"}},{"Add":{"text":" })","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3322"}},{"Add":{"text":" },","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3337"}},{"Add":{"text":" ))","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3348"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3354"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3355"}},{"Add":{"text":" fn self_presence(self) -> impl Future {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3437"}},{"Add":{"text":" let XmppConnection { account, inner } = self;","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3491"}},{"Add":{"text":" if let Some((sink, stream)) = inner {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3537"}},{"Add":{"text":" future::ok(XmppConnection {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3577"}},{"Add":{"text":" account,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3602"}},{"Add":{"text":" inner: Some((sink, stream)),","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3647"}},{"Add":{"text":" })","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3662"}},{"Add":{"text":" } else {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3679"}},{"Add":{"text":" warn!(\"Don't gen connection on self-presence\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3739"}},{"Add":{"text":" future::err(account)","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3772"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3782"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3788"}},{"Add":{"text":"}","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3790"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3791"}},{"Add":{"text":"pub struct XmppCommand;","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3815"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3816"}},{"Add":{"text":"struct XmppState {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3838"}},{"Add":{"text":" cmd_recv: Receiver,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3875"}},{"Add":{"text":" signal: F,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3890"}},{"Add":{"text":" conn: XmppConnection,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3916"}},{"Add":{"text":"}","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3918"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3919"}},{"Add":{"text":"impl XmppState {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:3942"}},{"Add":{"text":" fn new(cmd_recv: Receiver, signal: F, conn: XmppConnection) -> XmppState {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4037"}},{"Add":{"text":" XmppState {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4057"}},{"Add":{"text":" cmd_recv,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4079"}},{"Add":{"text":" signal,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4099"}},{"Add":{"text":" conn,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4117"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4127"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4133"}},{"Add":{"text":"}","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4135"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4136"}},{"Add":{"text":"pub fn xmpp_process(","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4160"}},{"Add":{"text":" signal: F,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4175"}},{"Add":{"text":" cmd_recv: Receiver,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4212"}},{"Add":{"text":" account: config::Account,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4242"}},{"Add":{"text":") -> impl future::Future","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4304"}},{"Add":{"text":"where","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4310"}},{"Add":{"text":" F: future::Future + 'static,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4354"}},{"Add":{"text":"{","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4356"}},{"Add":{"text":" let signal = signal","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4380"}},{"Add":{"text":" .map_err(|_| tokio::io::Error::new(tokio::io::ErrorKind::Other, \"Wrong shutdown signal\"));","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4479"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4480"}},{"Add":{"text":" let conn = XmppConnection::new(account);","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4525"}},{"Add":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4526"}},{"Add":{"text":" future::loop_fn(XmppState::new(cmd_recv, signal, conn), |s| {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4592"}},{"Add":{"text":" let XmppState {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4616"}},{"Add":{"text":" cmd_recv,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4638"}},{"Add":{"text":" signal,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4658"}},{"Add":{"text":" conn,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4676"}},{"Add":{"text":" } = s;","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4691"}},{"Add":{"text":" signal","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4706"}},{"Add":{"text":" .select2(conn.connect().and_then(|conn| {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4760"}},{"Add":{"text":" info!(\"xmpp connected!\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4802"}},{"Add":{"text":" cmd_recv","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4827"}},{"Add":{"text":" .into_future()","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4862"}},{"Add":{"text":" .map_err(|_| {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4897"}},{"Add":{"text":" error!(\"Got error on recv cmd\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4954"}},{"Add":{"text":" tokio::io::Error::new(tokio::io::ErrorKind::Other, \"Receive cmd error\")","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5050"}},{"Add":{"text":" }).map(|f| (f, conn))","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5092"}},{"Add":{"text":" })).then(|r| {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5119"}},{"Add":{"text":" match r {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5145"}},{"Add":{"text":" Ok(Either::A((_x, b))) => {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5193"}},{"Add":{"text":" info!(\"Got signal\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5238"}},{"Add":{"text":" // got signal, breaks","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5284"}},{"Add":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1))))","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5371"}},{"Add":{"text":" as Box>","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5435"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5457"}},{"Add":{"text":" Ok(Either::B((x, a))) => {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5504"}},{"Add":{"text":" info!(\"Got cmd\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5546"}},{"Add":{"text":" // got cmd, continue","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5591"}},{"Add":{"text":" Box::new(future::ok(future::Loop::Continue(XmppState::new(","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5674"}},{"Add":{"text":" (x.0).1,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5711"}},{"Add":{"text":" a,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5742"}},{"Add":{"text":" x.1,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5775"}},{"Add":{"text":" )))) as Box>","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5840"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5862"}},{"Add":{"text":" Err(Either::A((e, b))) => {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5910"}},{"Add":{"text":" // got signal error, breaks","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:5962"}},{"Add":{"text":" error!(\"Signal error: {}\", e);","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6017"}},{"Add":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1))))","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6104"}},{"Add":{"text":" as Box>","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6168"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6190"}},{"Add":{"text":" Err(Either::B((e, _a))) => {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6239"}},{"Add":{"text":" // got cmd error, its bad","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6289"}},{"Add":{"text":" error!(\"Cmd error: {}\", e);","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6341"}},{"Add":{"text":" Box::new(future::err(tokio::io::Error::new(","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6409"}},{"Add":{"text":" tokio::io::ErrorKind::Other,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6466"}},{"Add":{"text":" \"Cmd error\",","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6507"}},{"Add":{"text":" ))) as Box>","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6571"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6593"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6611"}},{"Add":{"text":" })","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6626"}},{"Add":{"text":" }).and_then(","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6643"}},{"Add":{"text":" |(opt_cmd_recv, _conn): (Option>, XmppConnection)| {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6726"}},{"Add":{"text":" if let Some(mut cmd_recv) = opt_cmd_recv {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6781"}},{"Add":{"text":" // process left commands","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6822"}},{"Add":{"text":" info!(\"Stop accepting commands\");","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6872"}},{"Add":{"text":" cmd_recv.close();","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6906"}},{"Add":{"text":" Box::new(cmd_recv.for_each(|_cmd| future::ok(())).map_err(|_| {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:6986"}},{"Add":{"text":" tokio::io::Error::new(tokio::io::ErrorKind::Other, \"cmd receiver last error\")","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7084"}},{"Add":{"text":" })) as Box>","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7156"}},{"Add":{"text":" } else {","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7177"}},{"Add":{"text":" Box::new(future::err(tokio::io::Error::new(","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7237"}},{"Add":{"text":" tokio::io::ErrorKind::Other,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7286"}},{"Add":{"text":" \"cmd receiver gone\",","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7327"}},{"Add":{"text":" )))","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7347"}},{"Add":{"text":" }","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7361"}},{"Add":{"text":" },","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7372"}},{"Add":{"text":" )","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7378"}},{"Add":{"text":"}","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:7380"}}]}}],"owner":"O01eg","repo":"sendxmppd-rs","token":"YggzRBzEx2cogGxjxKY+h5HpP5olIgDu4ASPUf1bKX4=","login":null}

…

Dependencies

Change contents

Review