Method open_array

nodedb/src/engine/array/engine.rs:95–116

Open or attach to an array. Idempotent: if the array is already open with the same `schema_hash`, this is a no-op so SQL read handlers can call `open_array` lazily on every request without losing state. If the array is open with a *different* schema_hash, returns [`ArrayEngineError::SchemaMismatch`].

(
        &mut self,
        id: ArrayId,
        schema: Arc<ArraySchema>,
        schema_hash: u64,
    )

    /// If the array is open with a *different* schema_hash, returns
    /// [`ArrayEngineError::SchemaMismatch`].
    pub fn open_array(
        &mut self,
        id: ArrayId,
        schema: Arc<ArraySchema>,
        schema_hash: u64,
    ) -> ArrayEngineResult<()> {
        if let Some(existing) = self.arrays.get(&id) {
            if existing.schema_hash() == schema_hash {
                return Ok(());
            }
            return Err(ArrayEngineError::SchemaMismatch {
                name: id.name.clone(),
            });
        }
        let dir = array_dir(&self.cfg.root, &id);
        let mut store = ArrayStore::open(dir, schema, schema_hash)?;
        if let Some(kek) = &self.cfg.kek {
            store.set_kek(kek.clone());
        }
        self.arrays.insert(id, store);
        Ok(())
    }

    pub fn array_ids(&self) -> impl Iterator<Item = &ArrayId> {
        self.arrays.keys()