Method sync_contacts

src/chat.rs:2028–2069

Sends a `SyncAction` synchronising chat contacts to other devices.

(&self, context: &Context)

    /// Sends a `SyncAction` synchronising chat contacts to other devices.
    pub(crate) async fn sync_contacts(&self, context: &Context) -> Result<()> {
        if self.is_encrypted(context).await? {
            let self_fp = self_fingerprint(context).await?;
            let fingerprint_addrs = context
                .sql
                .query_map_vec(
                    "SELECT c.id, c.fingerprint, c.addr
                     FROM contacts c INNER JOIN chats_contacts cc
                     ON c.id=cc.contact_id
                     WHERE cc.chat_id=? AND cc.add_timestamp >= cc.remove_timestamp",
                    (self.id,),
                    |row| {
                        if row.get::<_, ContactId>(0)? == ContactId::SELF {
                            return Ok((self_fp.to_string(), String::new()));
                        }
                        let fingerprint = row.get(1)?;
                        let addr = row.get(2)?;
                        Ok((fingerprint, addr))
                    },
                )
                .await?;
            self.sync(context, SyncAction::SetPgpContacts(fingerprint_addrs))
                .await?;
        } else {
            let addrs = context
                .sql
                .query_map_vec(
                    "SELECT c.addr \
                    FROM contacts c INNER JOIN chats_contacts cc \
                    ON c.id=cc.contact_id \
                    WHERE cc.chat_id=? AND cc.add_timestamp >= cc.remove_timestamp",
                    (self.id,),
                    |row| {
                        let addr: String = row.get(0)?;
                        Ok(addr)
                    },
                )
                .await?;
            self.sync(context, SyncAction::SetContacts(addrs)).await?;
        }
        Ok(())
    }

    /// Returns chat id for the purpose of synchronisation across devices.
    async fn get_sync_id(&self, context: &Context) -> Result<Option<SyncId>> {