Function run

crates/cli/src/commands/init.rs:15–46

(db_path: &Path)

};

pub async fn run(db_path: &Path) -> Result<()> {
    let db = connect_db(db_path).await?;

    let articles_table = ensure_table(&db, "articles", article_schema()).await?;
    let images_table = ensure_table(&db, "images", image_schema()).await?;
    ensure_table(&db, "taxonomies", taxonomy_schema()).await?;
    let _interactive_store = InteractivePageStore::connect(&db_path.to_string_lossy()).await?;

    if let Err(err) = ensure_fts_index(&articles_table, "content").await {
        tracing::warn!("Failed to create FTS index on articles: {err}");
    }

    if let Err(err) = ensure_vector_index(&articles_table, "vector_en").await {
        tracing::warn!("Failed to create vector index on articles (vector_en): {err}");
    }
    if let Err(err) = ensure_vector_index(&articles_table, "vector_zh").await {
        tracing::warn!("Failed to create vector index on articles (vector_zh): {err}");
    }
    if let Err(err) = ensure_vector_index(&images_table, "vector").await {
        tracing::warn!("Failed to create vector index on images: {err}");
    }

    let _ = articles_table
        .query()
        .full_text_search(FullTextSearchQuery::new("init".to_string()))
        .limit(1)
        .execute()
        .await;

    tracing::info!("LanceDB initialized at {}", db_path.display());
    Ok(())
}