snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-30 09:04:59 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

implement clear documents

Browse Source
This commit is contained in:
mpostma 2021-03-04 16:04:12 +01:00
parent ae5581d37c
commit a955e04ab6
No known key found for this signature in database
GPG Key ID: CBC8A7C1D7A28C3A
3 changed files with 18 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/data/updates.rs
View File

@ -34,12 +34,10 @@ impl Data {
pub async fn clear_documents( pub async fn clear_documents(
&self, &self,
_index: impl AsRef<str> + Sync + Send + 'static, index: impl AsRef<str> + Sync + Send + 'static,
) -> anyhow::Result<UpdateStatus> { ) -> anyhow::Result<UpdateStatus> {
todo!() let update = self.index_controller.clear_documents(index.as_ref().to_string()).await?;
//let index_controller = self.index_controller.clone(); Ok(update)
//let update = tokio::task::spawn_blocking(move || index_controller.clear_documents(index)).await??;
//Ok(update.into())
} }
pub async fn delete_documents( pub async fn delete_documents(

8
src/index_controller/mod.rs
View File

@ -106,8 +106,12 @@ impl IndexController {
Ok(status) Ok(status)
} }
fn clear_documents(&self, index: String) -> anyhow::Result<UpdateStatus> { pub async fn clear_documents(&self, index: String) -> anyhow::Result<UpdateStatus> {
todo!() let uuid = self.uuid_resolver.resolve(index).await.unwrap().unwrap();
let meta = UpdateMeta::ClearDocuments;
let (_, receiver) = mpsc::channel(1);
let status = self.update_handle.update(meta, receiver, uuid).await?;
Ok(status)
} }
pub async fn delete_documents(&self, index: String, document_ids: Vec<String>) -> anyhow::Result<UpdateStatus> { pub async fn delete_documents(&self, index: String, document_ids: Vec<String>) -> anyhow::Result<UpdateStatus> {

19
src/routes/document.rs
View File

@ -250,14 +250,13 @@ async fn clear_all_documents(
data: web::Data<Data>, data: web::Data<Data>,
path: web::Path<IndexParam>, path: web::Path<IndexParam>,
) -> Result<HttpResponse, ResponseError> { ) -> Result<HttpResponse, ResponseError> {
todo!() match data.clear_documents(path.index_uid.clone()).await {
//match data.clear_documents(path.index_uid.clone()).await { Ok(update) => {
//Ok(update) => { let json = serde_json::to_string(&update).unwrap();
//let json = serde_json::to_string(&update).unwrap(); Ok(HttpResponse::Ok().body(json))
//Ok(HttpResponse::Ok().body(json)) }
//} Err(e) => {
//Err(e) => { Ok(HttpResponse::BadRequest().body(serde_json::json!({ "error": e.to_string() })))
//Ok(HttpResponse::BadRequest().body(serde_json::json!({ "error": e.to_string() }))) }
//} }
//}
} }