1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137
use crate::{errors::*, indexes::*, request::*}; use serde_json::{json, Value}; /// The top-level struct of the SDK, representing a client containing [indexes](../indexes/struct.Index.html). #[derive(Debug)] pub struct Client<'a> { pub(crate) host: &'a str, pub(crate) apikey: &'a str, } impl<'a> Client<'a> { /// Create a client using the specified server. /// Don't put a '/' at the end of the host. /// If you are not in production mode, the second field is useless. /// In production mode, see [the documentation](https://docs.meilisearch.com/references/keys.html) to get the needed key. /// /// # Example /// /// ``` /// # use meilisearch_sdk::{client::*, indexes::*}; /// # /// // create the client /// let client = Client::new("http://localhost:7700", ""); /// ``` pub fn new(host: &'a str, apikey: &'a str) -> Client<'a> { Client { host, apikey } } /// List all [indexes](../indexes/struct.Index.html). /// /// # Example /// /// ``` /// # use meilisearch_sdk::{client::*, indexes::*}; /// // create the client /// let client = Client::new("http://localhost:7700", ""); /// /// let indexes: Vec<Index> = client.list_all_indexes().unwrap(); /// println!("{:?}", indexes); /// ``` pub fn list_all_indexes(&'a self) -> Result<Vec<Index<'a>>, Error> { let json_indexes = request::<(), Vec<JsonIndex>>( &format!("{}/indexes", self.host), self.apikey, Method::Get, 200, )?; let mut indexes = Vec::new(); for json_index in json_indexes { indexes.push(json_index.into_index(self)) } Ok(indexes) } /// Get an [index](../indexes/struct.Index.html). /// /// # Example /// /// ``` /// # use meilisearch_sdk::{client::*, indexes::*}; /// # let client = Client::new("http://localhost:7700", ""); /// # client.create_index("movies", None); /// // create the client /// let client = Client::new("http://localhost:7700", ""); /// /// // get the index named "movies" /// let movies = client.get_index("movies").unwrap(); /// ``` pub fn get_index(&'a self, uid: &'a str) -> Result<Index<'a>, Error> { Ok(request::<(), JsonIndex>( &format!("{}/indexes/{}", self.host, uid), self.apikey, Method::Get, 200, )? .into_index(self)) } /// Create an [index](../indexes/struct.Index.html). /// The second parameter will be used as the primary key of the new index. If it is not specified, MeiliSearch will **try** to infer the primary key. /// # Example /// /// ``` /// # use meilisearch_sdk::{client::*, indexes::*}; /// // create the client /// let client = Client::new("http://localhost:7700", ""); /// # if let Ok(mut movies) = client.get_index("movies") { /// # movies.delete(); /// # } /// /// // create a new index called movies and access it /// let movies = client.create_index("movies", None); /// ``` pub fn create_index( &'a self, uid: &'a str, primary_key: Option<&str>, ) -> Result<Index<'a>, Error> { Ok(request::<Value, JsonIndex>( &format!("{}/indexes", self.host), self.apikey, Method::Post(json!({ "uid": uid, "primaryKey": primary_key, })), 201, )? .into_index(self)) } /// Delete an index from its UID. /// To delete an index from the [index object](../indexes/struct.Index.html), use [the delete method](../indexes/struct.Index.html#method.delete). pub fn delete_index(&self, uid: &str) -> Result<(), Error> { Ok(request::<(), ()>( &format!("{}/indexes/{}", self.host, uid), self.apikey, Method::Delete, 204, )?) } /// This will try to get an index and create the index if it does not exist. pub fn get_or_create(&'a self, uid: &'a str) -> Result<Index<'a>, Error> { if let Ok(index) = self.get_index(uid) { Ok(index) } else { self.create_index(uid, None) } } /// Alias for [list_all_indexes](#method.list_all_indexes). pub fn get_indexes(&'a self) -> Result<Vec<Index<'a>>, Error> { self.list_all_indexes() } }