Method append_analytics_events

src/global_db.rs:2228–2258

(
        &self,
        events: &[AnalyticsEventInsert],
    )

    }

    pub async fn append_analytics_events(
        &self,
        events: &[AnalyticsEventInsert],
    ) -> Result<Vec<i64>, String> {
        if events.is_empty() {
            return Ok(Vec::new());
        }

        self.conn
            .execute("BEGIN IMMEDIATE", ())
            .await
            .map_err(|e| format!("failed to begin analytics event batch: {e}"))?;

        let mut ids = Vec::with_capacity(events.len());
        for event in events {
            match self.append_analytics_event(event).await {
                Ok(id) => ids.push(id),
                Err(err) => {
                    let _ = self.conn.execute("ROLLBACK", ()).await;
                    return Err(err);
                }
            }
        }

        if let Err(err) = self.conn.execute("COMMIT", ()).await {
            let _ = self.conn.execute("ROLLBACK", ()).await;
            return Err(format!("failed to commit analytics event batch: {err}"));
        }

        Ok(ids)
    }

    pub async fn session_message_count(&self) -> Result<i64, String> {
        let mut rows = self