Method get_database_data

collab/src/database/database.rs:1521–1559

Collect full database data for duplication/import/export. If `include_embedded` is false, embedded views are excluded.

(
    &self,
    chunk_size: usize,
    auto_fetch: bool,
    include_embedded: bool,
  )

  /// Collect full database data for duplication/import/export.
  /// If `include_embedded` is false, embedded views are excluded.
  pub async fn get_database_data(
    &self,
    chunk_size: usize,
    auto_fetch: bool,
    include_embedded: bool,
  ) -> Result<DatabaseData, CollabError> {
    let txn = self.collab.transact();

    let database_id = self.body.get_database_id(&txn)?;
    let inline_view_id = self.body.get_inline_view_id(&txn);
    let views = self
      .body
      .views
      .get_all_views(&txn, include_embedded)
      .into_iter()
      .filter(|view| !view.is_inline)
      .collect();
    let fields = self.body.get_fields_in_view(&txn, &inline_view_id, None);
    let rows_stream = self.get_all_rows(chunk_size, None, auto_fetch).await?;
    let rows: Vec<Row> = rows_stream
      .filter_map(|result| async move { result.ok() })
      .collect()
      .await;

    let mut row_metas = HashMap::with_capacity(rows.len());
    for row in &rows {
      if let Some(row_meta) = self.get_row_meta(&row.id).await {
        row_metas.insert(row.id, row_meta);
      }
    }

    Ok(DatabaseData {
      database_id,
      fields,
      rows,
      views,
      row_metas,
    })
  }

  pub fn get_view(&self, view_id: &str) -> Option<DatabaseView> {
    let txn = self.collab.transact();