Moved csv functions and fix doctest

Signed-off-by: carlosb1 <[email protected]>

Author: carlosb1

src/indexes.rs

@@ -753,14 +753,14 @@ impl Index {
             .await
     }
 
-    /// Add a raw csv payload to meilisearch.
+    /// Add a raw csv payload and update them if they already.
     ///
     /// It configures the correct content type for csv data.
     ///
-    /// If you send an already existing document (same id) the **whole existing document** will be overwritten by the new document.
-    /// Fields previously in the document not present in the new document are removed.
+    /// If you send an already existing document (same id) the old document will be only partially updated according to the fields of the new document.
+    /// Thus, any fields not present in the new document are kept and remained unchanged.
     ///
-    /// For a partial update of the document see [`Index::update_documents_csv`].
+    /// To completely overwrite a document, check out the [`Index::add_documents_csv`] documents method.
     ///
     /// # Example
     ///
@@ -774,9 +774,9 @@ impl Index {
     /// # let MEILISEARCH_API_KEY = option_env!("MEILISEARCH_API_KEY").unwrap_or("masterKey");
     /// # futures::executor::block_on(async move {
     /// # let client = Client::new(MEILISEARCH_URL, Some(MEILISEARCH_API_KEY));
-    /// let movie_index = client.index("add_documents_ndjson");
+    /// let movie_index = client.index("update_documents_csv");
     ///
-    /// let task = movie_index.add_documents_csv(
+    /// let task = movie_index.update_documents_csv(
     ///     "id,body\n1,\"doggo\"\n2,\"catto\"".as_bytes(),
     ///     Some("id"),
     ///   ).await.unwrap();
@@ -789,23 +789,23 @@ impl Index {
     /// # });
     /// ```
     #[cfg(not(target_arch = "wasm32"))]
-    pub async fn add_documents_csv<T: futures_io::AsyncRead + Send + Sync + 'static>(
+    pub async fn update_documents_csv<T: futures_io::AsyncRead + Send + Sync + 'static>(
         &self,
         payload: T,
         primary_key: Option<&str>,
     ) -> Result<TaskInfo, Error> {
-        self.add_or_replace_unchecked_payload(payload, "text/csv", primary_key)
+        self.add_or_update_unchecked_payload(payload, "text/csv", primary_key)
             .await
     }
 
-    /// Add a raw csv payload and update them if they already.
+    /// Add a raw csv payload to meilisearch.
     ///
     /// It configures the correct content type for csv data.
     ///
-    /// If you send an already existing document (same id) the old document will be only partially updated according to the fields of the new document.
-    /// Thus, any fields not present in the new document are kept and remained unchanged.
+    /// If you send an already existing document (same id) the **whole existing document** will be overwritten by the new document.
+    /// Fields previously in the document not present in the new document are removed.
     ///
-    /// To completely overwrite a document, check out the [`Index::add_documents_csv`] documents method.
+    /// For a partial update of the document see [`Index::update_documents_csv`].
     ///
     /// # Example
     ///
@@ -819,9 +819,9 @@ impl Index {
     /// # let MEILISEARCH_API_KEY = option_env!("MEILISEARCH_API_KEY").unwrap_or("masterKey");
     /// # futures::executor::block_on(async move {
     /// # let client = Client::new(MEILISEARCH_URL, Some(MEILISEARCH_API_KEY));
-    /// let movie_index = client.index("update_documents_ndjson");
+    /// let movie_index = client.index("add_documents_csv");
     ///
-    /// let task = movie_index.update_documents_csv(
+    /// let task = movie_index.add_documents_csv(
     ///     "id,body\n1,\"doggo\"\n2,\"catto\"".as_bytes(),
     ///     Some("id"),
     ///   ).await.unwrap();
@@ -834,12 +834,12 @@ impl Index {
     /// # });
     /// ```
     #[cfg(not(target_arch = "wasm32"))]
-    pub async fn update_documents_csv<T: futures_io::AsyncRead + Send + Sync + 'static>(
+    pub async fn add_documents_csv<T: futures_io::AsyncRead + Send + Sync + 'static>(
         &self,
         payload: T,
         primary_key: Option<&str>,
     ) -> Result<TaskInfo, Error> {
-        self.add_or_update_unchecked_payload(payload, "text/csv", primary_key)
+        self.add_or_replace_unchecked_payload(payload, "text/csv", primary_key)
             .await
     }
 
@@ -2062,20 +2062,21 @@ mod tests {
     }
 
     #[meilisearch_test]
-    async fn test_update_documents_csv(client: Client, index: Index) -> Result<(), Error> {
-        let old_csv = "id,body\n1,\"doggo\"\n2,\"catto\"".as_bytes();
-        let updated_csv = "id,body\n1,\"new_doggo\"\n2,\"new_catto\"".as_bytes();
+    async fn test_update_documents_ndjson(client: Client, index: Index) -> Result<(), Error> {
+        let old_ndjson = r#"{ "id": 1, "body": "doggo" }{ "id": 2, "body": "catto" }"#.as_bytes();
+        let updated_ndjson =
+            r#"{ "id": 1, "second_body": "second_doggo" }{ "id": 2, "second_body": "second_catto" }"#.as_bytes();
         // Add first njdson document
         let task = index
-            .add_documents_csv(old_csv, Some("id"))
+            .add_documents_ndjson(old_ndjson, Some("id"))
             .await?
             .wait_for_completion(&client, None, None)
             .await?;
         let _ = index.get_task(task).await?;
 
         // Update via njdson document
         let task = index
-            .update_documents_csv(updated_csv, Some("id"))
+            .update_documents_ndjson(updated_ndjson, Some("id"))
             .await?
             .wait_for_completion(&client, None, None)
             .await?;
@@ -2087,8 +2088,8 @@ mod tests {
         assert!(elements.results.len() == 2);
 
         let expected_result = vec![
-            json!( {"body": "new_doggo", "id": "1"}),
-            json!( {"body": "new_catto", "id": "2"}),
+            json!( {"body": "doggo", "id": 1, "second_body": "second_doggo"}),
+            json!( {"body": "catto", "id": 2, "second_body": "second_catto"}),
         ];
 
         assert_eq!(elements.results, expected_result);
@@ -2115,21 +2116,20 @@ mod tests {
     }
 
     #[meilisearch_test]
-    async fn test_update_documents_ndjson(client: Client, index: Index) -> Result<(), Error> {
-        let old_ndjson = r#"{ "id": 1, "body": "doggo" }{ "id": 2, "body": "catto" }"#.as_bytes();
-        let updated_ndjson =
-            r#"{ "id": 1, "second_body": "second_doggo" }{ "id": 2, "second_body": "second_catto" }"#.as_bytes();
+    async fn test_update_documents_csv(client: Client, index: Index) -> Result<(), Error> {
+        let old_csv = "id,body\n1,\"doggo\"\n2,\"catto\"".as_bytes();
+        let updated_csv = "id,body\n1,\"new_doggo\"\n2,\"new_catto\"".as_bytes();
         // Add first njdson document
         let task = index
-            .add_documents_ndjson(old_ndjson, Some("id"))
+            .add_documents_csv(old_csv, Some("id"))
             .await?
             .wait_for_completion(&client, None, None)
             .await?;
         let _ = index.get_task(task).await?;
 
         // Update via njdson document
         let task = index
-            .update_documents_ndjson(updated_ndjson, Some("id"))
+            .update_documents_csv(updated_csv, Some("id"))
             .await?
             .wait_for_completion(&client, None, None)
             .await?;
@@ -2141,15 +2141,14 @@ mod tests {
         assert!(elements.results.len() == 2);
 
         let expected_result = vec![
-            json!( {"body": "doggo", "id": 1, "second_body": "second_doggo"}),
-            json!( {"body": "catto", "id": 2, "second_body": "second_catto"}),
+            json!( {"body": "new_doggo", "id": "1"}),
+            json!( {"body": "new_catto", "id": "2"}),
         ];
 
         assert_eq!(elements.results, expected_result);
 
         Ok(())
     }
-
     #[meilisearch_test]
     async fn test_get_one_task(client: Client, index: Index) -> Result<(), Error> {
         let task = index