Method execute_sync_items

src/sync.rs:310–349

Executes sync items sent by other device. CAVE: When changing the code to handle other sync items, take care that does not result in calls to `add_sync_item()` as otherwise we would add in a dead-loop between two devices sending message back and forth. If an error is returned, the caller shall not try over because some sync items could be already executed. Sync items are considered independent a

(&self, items: &SyncItems, timestamp_sent: i64)

    /// already executed. Sync items are considered independent and executed in the given order but
    /// regardless of whether executing of the previous items succeeded.
    pub(crate) async fn execute_sync_items(&self, items: &SyncItems, timestamp_sent: i64) {
        info!(self, "executing {} sync item(s)", items.items.len());
        for item in &items.items {
            // Limit the timestamp to ensure it is not in the future.
            //
            // `sent_timestamp` should be already corrected
            // if the `Date` header is in the future.
            let timestamp = std::cmp::min(item.timestamp, timestamp_sent);

            match &item.data {
                SyncDataOrUnknown::SyncData(data) => match data {
                    AddQrToken(token) => self.add_qr_token(token, timestamp).await,
                    DeleteQrToken(token) => self.delete_qr_token(token, timestamp).await,
                    AlterChat { id, action } => self.sync_alter_chat(id, action).await,
                    SyncData::Config { key, val } => self.sync_config(key, val).await,
                    SyncData::SaveMessage { src, dest } => self.save_message(src, dest).await,
                    SyncData::DeleteMessages { msgs } => self.sync_message_deletion(msgs).await,
                    SyncData::Transports {
                        transports,
                        removed_transports,
                    } => sync_transports(self, transports, removed_transports).await,
                },
                SyncDataOrUnknown::Unknown(data) => {
                    warn!(self, "Ignored unknown sync item: {data}.");
                    Ok(())
                }
            }
            .log_err(self)
            .ok();
        }

        // Since there was a sync message, we know that there is a second device.
        // Set BccSelf to true if it isn't already.
        if !items.items.is_empty() && !self.get_config_bool(Config::BccSelf).await.unwrap_or(true) {
            self.set_config_ex(Sync::Nosync, Config::BccSelf, Some("1"))
                .await
                .log_err(self)
                .ok();
        }
    }

    async fn add_qr_token(&self, token: &QrTokenData, timestamp: i64) -> Result<()> {
        let grpid = token.grpid.as_deref();