O01eg/sendxmppd-rs - Change ZDGCVSXJL7OKUEVXOQAOLS3A3QYY7NN5BFFZWTABKXI7G3R74JAAC

Send id and receipts with message

Created by O01eg on December 13, 2020

ZDGCVSXJL7OKUEVXOQAOLS3A3QYY7NN5BFFZWTABKXI7G3R74JAAC

Dependencies

In channels

main

Change contents

Replacement in src/xmpp/xmpp_connection.rs at line 229 [4.36]

B:BD[4.5859] → [4.5859:5884]

B:BD[4.5884] → [2.50:138]

    /// outgoing mailbox
    outgoing_mailbox: HashMap<xmpp_parsers::BareJid, Vec<(String, xmpp_parsers::Jid)>>,

[4.5859]

[4.5947]

    /// outgoing mailbox: bare jid to message, fulljid, id
    outgoing_mailbox: HashMap<xmpp_parsers::BareJid, Vec<(String, xmpp_parsers::Jid, String)>>,

Insertion in src/xmpp/xmpp_connection.rs at line 948 [4.36]

[5.70]

[2.139]

                self.state.data.counter += 1;
                let id_send_message = format!("id_send_message{}", self.state.data.counter);

Replacement in src/xmpp/xmpp_connection.rs at line 956 [4.36]

B:BD[5.239] → [2.272:319]

                    .push((message, xmpp_to));

[5.239]

[2.319]

                    .push((message, xmpp_to, id_send_message));

Replacement in src/xmpp/xmpp_connection.rs at line 1007 [4.36]

B:BD[5.1037] → [5.1037:1096]

B:BD[5.1096] → [2.523:700]

∅:D[2.700] → [5.1275:1302]

B:BD[5.1275] → [5.1275:1302]

                        self.state.data.send_queue.extend(
                            mailbox
                                .drain(..)
                                .map(|message| stanzas::make_chat_message(message.1, message.0)),
                        );

[5.1037]

[5.1302]

                        self.state
                            .data
                            .send_queue
                            .extend(mailbox.drain(..).map(|message| {
                                stanzas::make_chat_message(message.2, message.1, message.0)
                            }));

Replacement in src/xmpp/xmpp_connection.rs at line 1030 [4.36]

B:BD[3.27] → [3.27:263]

∅:D[3.263] → [6.198:225]

B:BD[6.198] → [6.198:225]

                        self.state.data.send_queue.extend(
                            mailbox
                                .drain(..)
                                .map(|message| stanzas::make_chat_message(message.1, message.0)),
                        );

[3.27]

[3.264]

                        self.state
                            .data
                            .send_queue
                            .extend(mailbox.drain(..).map(|message| {
                                stanzas::make_chat_message(message.2, message.1, message.0)
                            }));

Replacement in src/xmpp/stanzas.rs at line 73 [4.32569]

B:BD[4.34640] → [4.34640:34716]

pub fn make_chat_message(jid: xmpp_parsers::Jid, text: String) -> Element {

[4.34640]

[4.34716]

pub fn make_chat_message(id: String, jid: xmpp_parsers::Jid, text: String) -> Element {

Insertion in src/xmpp/stanzas.rs at line 75 [4.32569]
[4.34763]
[4.34763]
```
    message.id = Some(id);
```

Insertion in src/xmpp/stanzas.rs at line 78 [4.32569]

[4.34856]

    message
        .payloads
        .push(xmpp_parsers::receipts::Request {}.into());