Interface ArrayExt

collab/src/util.rs:303–367

}

pub trait ArrayExt: Array {
  fn clear(&self, txn: &mut TransactionMut) {
    let len = self.len(txn);
    self.remove_range(txn, 0, len);
  }

  /// Removes the first element that satisfies the predicate.
  fn remove_one<F, V>(&self, txn: &mut TransactionMut, predicate: F)
  where
    F: Fn(V) -> bool,
    V: TryFrom<Out>,
  {
    let mut i = 0;
    while let Some(out) = self.get(txn, i) {
      if let Ok(value) = V::try_from(out) {
        if predicate(value) {
          self.remove(txn, i);
          break;
        }
      }
      i += 1;
    }
  }

  fn update_map<F>(&self, txn: &mut TransactionMut, id: &str, f: F)
  where
    F: FnOnce(&mut HashMap<String, Any>),
  {
    let map_ref: MapRef = self.upsert(txn, id);
    let mut map = map_ref.to_json(txn).into_map().unwrap();
    f(&mut map);
    Any::from(map).fill(txn, &map_ref).unwrap();
  }

  fn index_by_id<T: ReadTxn>(&self, txn: &T, id: &str) -> Option<u32> {
    let i = self.iter(txn).position(|value| {
      if let Ok(value) = value.cast::<MapRef>() {
        if let Some(current_id) = value.get_id(txn) {
          return &*current_id == id;
        }
      }
      false
    })?;
    Some(i as u32)
  }

  fn upsert<V>(&self, txn: &mut TransactionMut, id: &str) -> V
  where
    V: DefaultPrelim + TryFrom<Out>,
  {
    match self.index_by_id(txn, id) {
      None => self.push_back(txn, V::default_prelim()),
      Some(i) => {
        let out = self.get(txn, i).unwrap();
        match V::try_from(out) {
          Ok(shared_ref) => shared_ref,
          Err(_) => {
            self.remove(txn, i);