Function init_key_value_index_for_collection

src/api_service.rs:267–281

creates an key value index for a collection

(
    ctx: Arc<AppContext>,
    collection: &Collection,
)

/// creates an key value index for a collection
pub async fn init_key_value_index_for_collection(
    ctx: Arc<AppContext>,
    collection: &Collection,
) -> Result<Arc<KeyValueIndex>, WaCustomError> {
    let collection_path: Arc<Path> = collection.get_path();
    let index_path = collection_path.join("key_value_index");
    fs::create_dir_all(&index_path).map_err(|e| WaCustomError::FsError(e.to_string()))?;

    let index = Arc::new(KeyValueIndex::new(index_path.clone())?);

    ctx.ain_env
        .collections_map
        .insert_key_value_index(collection, index.clone())?;
    Ok(index)
}

/// creates an USV for a collection
pub async fn init_usv_index_for_collection(