ci(release): v0.9.0

BREAKING CHANGE: `Model.OpenMistral8x7b` has been renamed to `Model.OpenMixtral8x7b`.

.env.example

@@ -1,3 +1,3 @@
 # This key is only used for development purposes.
 # You'll only need one if you want to contribute to this library.
-MISTRAL_API_KEY=
+export MISTRAL_API_KEY=

.github/ISSUE_TEMPLATE/bug_report.md

@@ -1,17 +1,16 @@
 ---
 name: Bug report
 about: Create a report to help us improve
-title: ''
+title: ""
-labels: ''
+labels: "bug"
-assignees: ''
+assignees: ""
-
 ---
 
 **Describe the bug**
 
-A clear and concise description of what the bug is.
+...
 
-**To Reproduce**
+**Reproduction**
 
 Steps to reproduce the behavior:
 
@@ -20,7 +19,7 @@ Steps to reproduce the behavior:
 
 **Expected behavior**
 
-A clear and concise description of what you expected to happen.
+...
 
 **Screenshots**
 
@@ -32,4 +31,4 @@ If applicable, what version did you use?
 
 **Environment**
 
-Add useful information about your configuration and environment here.
+If applicable, add relevant information about your config and environment here.

.github/ISSUE_TEMPLATE/feature_request.md

@@ -1,24 +1,19 @@
 ---
 name: Feature request
-about: Suggest an idea for this project
+about: Suggest a new idea for the project.
-title: ''
+title: ""
-labels: ''
+labels: "enhancement"
-assignees: ''
+assignees: ""
-
 ---
 
-**Is your feature request related to a problem? Please describe.**
+**Is your feature request related to some problems?**
 
-A clear and concise description of what the problem is. Ex. I'm always frustrated when [...]
+- _Ex. I'm always frustrated when..._
 
-**Describe the solution you'd like**
+**What are the solutions you'd like?**
 
-A clear and concise description of what you want to happen.
+- _Ex. A new option to..._
 
-**Describe alternatives you've considered**
+**Anything else?**
 
-A clear and concise description of any alternative solutions or features you've considered.
+- ...
-
-**Additional context**
-
-Add any other context or screenshots about the feature request here.

.github/workflows/test.yml

@@ -6,10 +6,6 @@ jobs:
   test:
     name: Test
     runs-on: ubuntu-latest
-    container:
-      image: xd009642/tarpaulin
-      # https://github.com/xd009642/tarpaulin#github-actions
-      options: --security-opt seccomp=unconfined
     steps:
       - name: Checkout
         uses: actions/checkout@v4
@@ -17,12 +13,45 @@ jobs:
         uses: actions-rs/toolchain@v1
         with:
           toolchain: 1.76.0
+      - name: Install cargo-llvm-cov
+        uses: taiki-e/install-action@cargo-llvm-cov
       - name: Run tests (with coverage)
-        run: make test-cover
+        run: cargo llvm-cov --lcov --output-path ./lcov.info
         env:
           MISTRAL_API_KEY: ${{ secrets.MISTRAL_API_KEY }}
       - name: Upload tests coverage
-        uses: codecov/codecov-action@v3
+        uses: codecov/codecov-action@v4
         with:
           fail_ci_if_error: true
+          files: ./lcov.info
           token: ${{ secrets.CODECOV_TOKEN }}
+
+  test_documentation:
+    name: Test Documentation
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+      - name: Setup Rust
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: 1.76.0
+      - name: Run documentation tests
+        run: make test-doc
+        env:
+          MISTRAL_API_KEY: ${{ secrets.MISTRAL_API_KEY }}
+
+  test_examples:
+    name: Test Examples
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+      - name: Setup Rust
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: 1.76.0
+      - name: Run examples
+        run: make test-examples
+        env:
+          MISTRAL_API_KEY: ${{ secrets.MISTRAL_API_KEY }}

CHANGELOG.md

@@ -0,0 +1,99 @@
+## [0.9.0](https://github.com/ivangabriele/mistralai-client-rs/compare/v0.8.0...v) (2024-04-13)
+
+
+### ⚠ BREAKING CHANGES
+
+* `Model.OpenMistral8x7b` has been renamed to `Model.OpenMixtral8x7b`.
+
+### Bug Fixes
+
+* **deps:** update rust crate reqwest to 0.12.0 ([#6](https://github.com/ivangabriele/mistralai-client-rs/issues/6)) ([fccd59c](https://github.com/ivangabriele/mistralai-client-rs/commit/fccd59c0cc783edddec1b404363faabb009eecd6))
+* fix typo in OpenMixtral8x7b model name ([#8](https://github.com/ivangabriele/mistralai-client-rs/issues/8)) ([6a99eca](https://github.com/ivangabriele/mistralai-client-rs/commit/6a99eca49c0cc8e3764a56f6dfd7762ec44a4c3b))
+
+## [0.8.0](https://github.com/ivangabriele/mistralai-client-rs/compare/v0.7.0...v) (2024-03-09)
+
+
+### ⚠ BREAKING CHANGES
+
+* Too many to count in this version. Check the README examples.
+
+### Features
+
+* add function calling support to client.chat() & client.chat_async() ([74bf8a9](https://github.com/ivangabriele/mistralai-client-rs/commit/74bf8a96ee31f9d54ee3d7404619e803a182918b))
+
+## [0.7.0](https://github.com/ivangabriele/mistralai-client-rs/compare/v0.6.0...v) (2024-03-05)
+
+
+### ⚠ BREAKING CHANGES
+
+* - Rename `ClientError.ApiKeyError` to `MissingApiKey`.
+- Rename `ClientError.ReadResponseTextError` to `ClientError.UnreadableResponseText`.
+
+### Bug Fixes
+
+* fix failure when api key as param and not env ([ef5d475](https://github.com/ivangabriele/mistralai-client-rs/commit/ef5d475e2d0e3fe040c44d6adabf7249e9962835))
+
+## [0.6.0](https://github.com/ivangabriele/mistralai-client-rs/compare/v0.5.0...v) (2024-03-04)
+
+
+### ⚠ BREAKING CHANGES
+
+* You can't set the `stream` option for `client.chat*()`.
+
+Either use `client.chat_stream()` if you want to use streams
+or use `client.chat()` / `client.chat_async()` otherwise.
+
+### Features
+
+* add client.chat_stream() method ([4a4219d](https://github.com/ivangabriele/mistralai-client-rs/commit/4a4219d3eaa8f0ae953ee6182b36bf464d1c4a21))
+
+## [0.5.0](https://github.com/ivangabriele/mistralai-client-rs/compare/v0.4.0...v) (2024-03-04)
+
+
+### Features
+
+* add client.embeddings_async() method ([3c22891](https://github.com/ivangabriele/mistralai-client-rs/commit/3c228914f78b0edd4a592091265b88d0bc55568b))
+* add client.list_models_async() method ([b69f7c6](https://github.com/ivangabriele/mistralai-client-rs/commit/b69f7c617c15dd63abb61d004636512916d766bb))
+
+## [0.4.0](https://github.com/ivangabriele/mistralai-client-rs/compare/v0.3.0...v) (2024-03-04)
+
+
+### ⚠ BREAKING CHANGES
+
+* `Client::new()` now returns a `Result`.
+* `APIError` is renamed to `ApiError`.
+
+### Features
+
+* add client.chat_async() method ([1dd59f6](https://github.com/ivangabriele/mistralai-client-rs/commit/1dd59f67048c10458ab0382af8fdfe4ed21c82fa))
+* add missing api key error ([1deab88](https://github.com/ivangabriele/mistralai-client-rs/commit/1deab88251fc706e0415a5e416ab9aee4b52f6f3))
+* wrap Client::new() return in a Result ([3387618](https://github.com/ivangabriele/mistralai-client-rs/commit/33876183e41340f426aa1dd1b6d8b5c05c8e15b9))
+
+## [0.3.0](https://github.com/ivangabriele/mistralai-client-rs/compare/v0.2.0...v) (2024-03-04)
+
+
+### ⚠ BREAKING CHANGES
+
+* Models are now enforced by `Model` & `EmbedModel` enums.
+
+### Features
+
+* add client.embeddings() method ([f44d951](https://github.com/ivangabriele/mistralai-client-rs/commit/f44d95124767c3a3f14c78c4be3d9c203fac49ad))
+
+## [0.2.0](https://github.com/ivangabriele/mistralai-client-rs/compare/v0.1.0...v) (2024-03-03)
+
+
+### ⚠ BREAKING CHANGES
+
+* Chat completions must now be called directly from client.chat() without building a request in between.
+
+### Features
+
+* add client.list_models() method ([814b991](https://github.com/ivangabriele/mistralai-client-rs/commit/814b9918b3aca78bfd606b5b9bb470b70ea2a5c6))
+* simplify chat completion call ([7de2b19](https://github.com/ivangabriele/mistralai-client-rs/commit/7de2b19b981f1d65fe5c566fcaf521e4f2a9ced1))
+
+## [0.1.0](https://github.com/ivangabriele/mistralai-client-rs/compare/7d3b438d16e9936591b6454525968c5c2cdfd6ad...v0.1.0) (2024-03-03)
+
+### Features
+
+- add chat completion without streaming ([7d3b438](https://github.com/ivangabriele/mistralai-client-rs/commit/7d3b438d16e9936591b6454525968c5c2cdfd6ad))

CONTRIBUTING.md

@@ -4,7 +4,10 @@
   - [Requirements](#requirements)
   - [First setup](#first-setup)
   - [Optional requirements](#optional-requirements)
+- [Local Development](#local-development)
   - [Test](#test)
+- [Documentation](#documentation)
+  - [Readme](#readme)
 - [Code of Conduct](#code-of-conduct)
 - [Commit Message Format](#commit-message-format)
 
@@ -27,11 +30,21 @@ Then run:
 git clone https://github.com/ivangabriele/mistralai-client-rs.git # or your fork
 cd ./mistralai-client-rs
 cargo build
+cp .env.example .env
 ```
 
+Then edit the `.env` file to set your `MISTRAL_API_KEY`.
+
+> [!NOTE]
+> All tests use either the `open-mistral-7b` or `mistral-embed` models and only consume a few dozen tokens.
+> So you would have to run them thousands of times to even reach a single dollar of usage.
+
 ### Optional requirements
 
-- [cargo-watch](https://github.com/watchexec/cargo-watch#install) for `make test-*-watch`.
+- [cargo-llvm-cov](https://github.com/taiki-e/cargo-llvm-cov?tab=readme-ov-file#installation) for `make test-cover`
+- [cargo-watch](https://github.com/watchexec/cargo-watch#install) for `make test-watch`.
+
+## Local Development
 
 ### Test
 
@@ -45,11 +58,20 @@ or
 make test-watch
 ```
 
+## Documentation
+
+### Readme
+
+> [!IMPORTANT]
+> Do not edit the `README.md` file directly. It is generated from the `README.template.md` file.
+
+1. Edit the `README.template.md` file.
+2. Run `make readme` to generate/update the `README.md` file.
+
 ## Code of Conduct
 
 Help us keep this project open and inclusive. Please read and follow our [Code of Conduct](./CODE_OF_CONDUCT.md).
 
 ## Commit Message Format
 
-This repository follow the [Conventional Commits](https://www.conventionalcommits.org/en/v1.0.0/) specification and
+This repository follow the [Conventional Commits](https://www.conventionalcommits.org/en/v1.0.0/) specification.
-specificaly the [Angular Commit Message Guidelines](https://github.com/angular/angular/blob/main/CONTRIBUTING.md#commit).

Cargo.toml

@@ -2,7 +2,7 @@
 name = "mistralai-client"
 description = "Mistral AI API client library for Rust (unofficial)."
 license = "Apache-2.0"
-version = "0.1.0"
+version = "0.9.0"
 
 edition = "2021"
 rust-version = "1.76.0"
@@ -15,12 +15,18 @@ readme = "README.md"
 repository = "https://github.com/ivangabriele/mistralai-client-rs"
 
 [dependencies]
-minreq = { version = "2.11.0", features = ["https-rustls", "json-using-serde"] }
+async-stream = "0.3.5"
+async-trait = "0.1.77"
+env_logger = "0.11.3"
+futures = "0.3.30"
+log = "0.4.21"
+reqwest = { version = "0.12.0", features = ["json", "blocking", "stream"] }
 serde = { version = "1.0.197", features = ["derive"] }
 serde_json = "1.0.114"
+strum = "0.26.1"
 thiserror = "1.0.57"
 tokio = { version = "1.36.0", features = ["full"] }
+tokio-stream = "0.1.14"
 
 [dev-dependencies]
-dotenv = "0.15.0"
 jrest = "0.2.3"

Makefile

@@ -1,6 +1,72 @@
+SHELL := /bin/bash
+
+.PHONY: doc readme test
+
+define source_env_if_not_ci
+	@if [ -z "$${CI}" ]; then \
+		if [ -f ./.env ]; then \
+			source ./.env; \
+		else \
+			echo "No .env file found"; \
+			exit 1; \
+		fi \
+	fi
+endef
+
+define RELEASE_TEMPLATE
+	npx conventional-changelog-cli -p conventionalcommits -i ./CHANGELOG.md -s
+	git add .
+	git commit -m "docs(changelog): update"
+	git push origin HEAD
+	cargo release $(1) --execute
+	git push origin HEAD --tags
+endef
+
+doc:
+	cargo doc
+	open ./target/doc/mistralai_client/index.html
+
+readme:
+	@echo "Generating README.md from template..."
+	@> README.md # Clear README.md content before starting
+	@while IFS= read -r line || [[ -n "$$line" ]]; do \
+		if [[ $$line == *"<CODE>"* && $$line == *"</CODE>"* ]]; then \
+			example_path=$$(echo $$line | sed -n 's/.*<CODE>\(.*\)<\/CODE>.*/\1/p'); \
+			if [ -f $$example_path ]; then \
+				echo '```rs' >> README.md; \
+				cat $$example_path >> README.md; \
+				echo '```' >> README.md; \
+			else \
+				echo "Error: Example $$example_path not found." >&2; \
+			fi; \
+		else \
+			echo "$$line" >> README.md; \
+		fi; \
+	done < README.template.md
+	@echo "README.md has been generated."
+
+release-patch:
+	$(call RELEASE_TEMPLATE,patch)
+release-minor:
+	$(call RELEASE_TEMPLATE,minor)
+release-major:
+	$(call RELEASE_TEMPLATE,major)
+
 test:
+	@$(source_env_if_not_ci)
 	cargo test --no-fail-fast
 test-cover:
-	cargo tarpaulin --frozen --no-fail-fast --out Xml --skip-clean
+	@$(source_env_if_not_ci)
+	cargo llvm-cov
+test-doc:
+	@$(source_env_if_not_ci)
+	cargo test --doc --no-fail-fast
+test-examples:
+	@$(source_env_if_not_ci)
+	@for example in $$(ls examples/*.rs | sed 's/examples\/\(.*\)\.rs/\1/'); do \
+		echo "Running $$example"; \
+		cargo run --example $$example; \
+	done
 test-watch:
+	@source ./.env
 	cargo watch -x "test -- --nocapture"

README.md

@@ -15,20 +15,30 @@ Rust client for the Mistral AI API.
     - [As an environment variable](#as-an-environment-variable)
     - [As a client argument](#as-a-client-argument)
 - [Usage](#usage)
-  - [Chat without streaming](#chat-without-streaming)
+  - [Chat](#chat)
-  - [Chat with streaming](#chat-with-streaming)
+  - [Chat (async)](#chat-async)
+  - [Chat with streaming (async)](#chat-with-streaming-async)
+  - [Chat with Function Calling](#chat-with-function-calling)
+  - [Chat with Function Calling (async)](#chat-with-function-calling-async)
   - [Embeddings](#embeddings)
+  - [Embeddings (async)](#embeddings-async)
   - [List models](#list-models)
+  - [List models (async)](#list-models-async)
+- [Contributing](#contributing)
 
 ---
 
 ## Supported APIs
 
 - [x] Chat without streaming
-- [ ] Chat with streaming
+- [x] Chat without streaming (async)
-- [ ] Embedding
+- [x] Chat with streaming
-- [ ] List models
+- [x] Embedding
-- [ ] Function Calling
+- [x] Embedding (async)
+- [x] List models
+- [x] List models (async)
+- [x] Function Calling
+- [x] Function Calling (async)
 
 ## Installation
 
@@ -46,6 +56,18 @@ You can get your Mistral API Key there: <https://docs.mistral.ai/#api-access>.
 
 Just set the `MISTRAL_API_KEY` environment variable.
 
+```rs
+use mistralai_client::v1::client::Client;
+
+fn main() {
+    let client = Client::new(None, None, None, None);
+}
+```
+
+```sh
+MISTRAL_API_KEY=your_api_key cargo run
+```
+
 #### As a client argument
 
 ```rs
@@ -54,54 +76,366 @@ use mistralai_client::v1::client::Client;
 fn main() {
     let api_key = "your_api_key";
 
-    let client = Client::new(Some(api_key), None, None, None);
+    let client = Client::new(Some(api_key), None, None, None).unwrap();
 }
 ```
 
 ## Usage
 
-### Chat without streaming
+### Chat
 
 ```rs
-use mistralai::v1::{
+use mistralai_client::v1::{
-    chat_completion::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
-        ChatCompletionMessage, ChatCompletionMessageRole, ChatCompletionRequest,
-        ChatCompletionRequestOptions,
-    },
     client::Client,
-    constants::OPEN_MISTRAL_7B,
+    constants::Model,
 };
 
 fn main() {
     // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
-    let client = Client::new(None, None, None, None);
+    let client = Client::new(None, None, None, None).unwrap();
 
-    let model = OPEN_MISTRAL_7B.to_string();
+    let model = Model::OpenMistral7b;
-    let messages = vec![ChatCompletionMessage {
+    let messages = vec![ChatMessage {
-        role: ChatCompletionMessageRole::user,
+        role: ChatMessageRole::User,
         content: "Just guess the next word: \"Eiffel ...\"?".to_string(),
+        tool_calls: None,
     }];
-    let options = ChatCompletionRequestOptions {
+    let options = ChatParams {
         temperature: Some(0.0),
         random_seed: Some(42),
         ..Default::default()
     };
 
-    let chat_completion_request = ChatCompletionRequest::new(model, messages, Some(options));
+    let result = client.chat(model, messages, Some(options)).unwrap();
-    let result = client.chat(chat_completion_request).unwrap();
     println!("Assistant: {}", result.choices[0].message.content);
-    // => "Assistant: Tower. [...]"
+    // => "Assistant: Tower. The Eiffel Tower is a famous landmark in Paris, France."
 }
 ```
 
-### Chat with streaming
+### Chat (async)
 
-_In progress._
+```rs
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
+    client::Client,
+    constants::Model,
+};
+
+#[tokio::main]
+async fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let model = Model::OpenMistral7b;
+    let messages = vec![ChatMessage {
+        role: ChatMessageRole::User,
+        content: "Just guess the next word: \"Eiffel ...\"?".to_string(),
+        tool_calls: None,
+    }];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        ..Default::default()
+    };
+
+    let result = client
+        .chat_async(model, messages, Some(options))
+        .await
+        .unwrap();
+    println!(
+        "{:?}: {}",
+        result.choices[0].message.role, result.choices[0].message.content
+    );
+    // => "Assistant: Tower. The Eiffel Tower is a famous landmark in Paris, France."
+}
+```
+
+### Chat with streaming (async)
+
+```rs
+use futures::stream::StreamExt;
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
+    client::Client,
+    constants::Model,
+};
+use std::io::{self, Write};
+
+#[tokio::main]
+async fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let model = Model::OpenMistral7b;
+    let messages = vec![ChatMessage {
+        role: ChatMessageRole::User,
+        content: "Tell me a short happy story.".to_string(),
+        tool_calls: None,
+    }];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        ..Default::default()
+    };
+
+    let stream_result = client
+        .chat_stream(model, messages, Some(options))
+        .await
+        .unwrap();
+    stream_result
+        .for_each(|chunk_result| async {
+            match chunk_result {
+                Ok(chunks) => chunks.iter().for_each(|chunk| {
+                    print!("{}", chunk.choices[0].delta.content);
+                    io::stdout().flush().unwrap();
+                    // => "Once upon a time, [...]"
+                }),
+                Err(error) => {
+                    eprintln!("Error processing chunk: {:?}", error)
+                }
+            }
+        })
+        .await;
+    print!("\n") // To persist the last chunk output.
+}
+```
+
+### Chat with Function Calling
+
+```rs
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
+    client::Client,
+    constants::Model,
+    tool::{Function, Tool, ToolChoice, ToolFunctionParameter, ToolFunctionParameterType},
+};
+use serde::Deserialize;
+use std::any::Any;
+
+#[derive(Debug, Deserialize)]
+struct GetCityTemperatureArguments {
+    city: String,
+}
+
+struct GetCityTemperatureFunction;
+#[async_trait::async_trait]
+impl Function for GetCityTemperatureFunction {
+    async fn execute(&self, arguments: String) -> Box<dyn Any + Send> {
+        // Deserialize arguments, perform the logic, and return the result
+        let GetCityTemperatureArguments { city } = serde_json::from_str(&arguments).unwrap();
+
+        let temperature = match city.as_str() {
+            "Paris" => "20°C",
+            _ => "Unknown city",
+        };
+
+        Box::new(temperature.to_string())
+    }
+}
+
+fn main() {
+    let tools = vec![Tool::new(
+        "get_city_temperature".to_string(),
+        "Get the current temperature in a city.".to_string(),
+        vec![ToolFunctionParameter::new(
+            "city".to_string(),
+            "The name of the city.".to_string(),
+            ToolFunctionParameterType::String,
+        )],
+    )];
+
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let mut client = Client::new(None, None, None, None).unwrap();
+    client.register_function(
+        "get_city_temperature".to_string(),
+        Box::new(GetCityTemperatureFunction),
+    );
+
+    let model = Model::MistralSmallLatest;
+    let messages = vec![ChatMessage {
+        role: ChatMessageRole::User,
+        content: "What's the temperature in Paris?".to_string(),
+        tool_calls: None,
+    }];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        tool_choice: Some(ToolChoice::Auto),
+        tools: Some(tools),
+        ..Default::default()
+    };
+
+    client.chat(model, messages, Some(options)).unwrap();
+    let temperature = client
+        .get_last_function_call_result()
+        .unwrap()
+        .downcast::<String>()
+        .unwrap();
+    println!("The temperature in Paris is: {}.", temperature);
+    // => "The temperature in Paris is: 20°C."
+}
+```
+
+### Chat with Function Calling (async)
+
+```rs
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
+    client::Client,
+    constants::Model,
+    tool::{Function, Tool, ToolChoice, ToolFunctionParameter, ToolFunctionParameterType},
+};
+use serde::Deserialize;
+use std::any::Any;
+
+#[derive(Debug, Deserialize)]
+struct GetCityTemperatureArguments {
+    city: String,
+}
+
+struct GetCityTemperatureFunction;
+#[async_trait::async_trait]
+impl Function for GetCityTemperatureFunction {
+    async fn execute(&self, arguments: String) -> Box<dyn Any + Send> {
+        // Deserialize arguments, perform the logic, and return the result
+        let GetCityTemperatureArguments { city } = serde_json::from_str(&arguments).unwrap();
+
+        let temperature = match city.as_str() {
+            "Paris" => "20°C",
+            _ => "Unknown city",
+        };
+
+        Box::new(temperature.to_string())
+    }
+}
+
+#[tokio::main]
+async fn main() {
+    let tools = vec![Tool::new(
+        "get_city_temperature".to_string(),
+        "Get the current temperature in a city.".to_string(),
+        vec![ToolFunctionParameter::new(
+            "city".to_string(),
+            "The name of the city.".to_string(),
+            ToolFunctionParameterType::String,
+        )],
+    )];
+
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let mut client = Client::new(None, None, None, None).unwrap();
+    client.register_function(
+        "get_city_temperature".to_string(),
+        Box::new(GetCityTemperatureFunction),
+    );
+
+    let model = Model::MistralSmallLatest;
+    let messages = vec![ChatMessage {
+        role: ChatMessageRole::User,
+        content: "What's the temperature in Paris?".to_string(),
+        tool_calls: None,
+    }];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        tool_choice: Some(ToolChoice::Auto),
+        tools: Some(tools),
+        ..Default::default()
+    };
+
+    client
+        .chat_async(model, messages, Some(options))
+        .await
+        .unwrap();
+    let temperature = client
+        .get_last_function_call_result()
+        .unwrap()
+        .downcast::<String>()
+        .unwrap();
+    println!("The temperature in Paris is: {}.", temperature);
+    // => "The temperature in Paris is: 20°C."
+}
+```
 
 ### Embeddings
 
-_In progress._
+```rs
+use mistralai_client::v1::{client::Client, constants::EmbedModel};
+
+fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client: Client = Client::new(None, None, None, None).unwrap();
+
+    let model = EmbedModel::MistralEmbed;
+    let input = vec!["Embed this sentence.", "As well as this one."]
+        .iter()
+        .map(|s| s.to_string())
+        .collect();
+    let options = None;
+
+    let response = client.embeddings(model, input, options).unwrap();
+    println!("First Embedding: {:?}", response.data[0]);
+    // => "First Embedding: {...}"
+}
+```
+
+### Embeddings (async)
+
+```rs
+use mistralai_client::v1::{client::Client, constants::EmbedModel};
+
+#[tokio::main]
+async fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client: Client = Client::new(None, None, None, None).unwrap();
+
+    let model = EmbedModel::MistralEmbed;
+    let input = vec!["Embed this sentence.", "As well as this one."]
+        .iter()
+        .map(|s| s.to_string())
+        .collect();
+    let options = None;
+
+    let response = client
+        .embeddings_async(model, input, options)
+        .await
+        .unwrap();
+    println!("First Embedding: {:?}", response.data[0]);
+    // => "First Embedding: {...}"
+}
+```
 
 ### List models
 
-_In progress._
+```rs
+use mistralai_client::v1::client::Client;
+
+fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let result = client.list_models().unwrap();
+    println!("First Model ID: {:?}", result.data[0].id);
+    // => "First Model ID: open-mistral-7b"
+}
+```
+
+### List models (async)
+
+```rs
+use mistralai_client::v1::client::Client;
+
+#[tokio::main]
+async fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let result = client.list_models_async().await.unwrap();
+    println!("First Model ID: {:?}", result.data[0].id);
+    // => "First Model ID: open-mistral-7b"
+}
+```
+
+## Contributing
+
+Please read [CONTRIBUTING.md](./CONTRIBUTING.md) for details on how to contribute to this library.

README.template.md

@@ -0,0 +1,123 @@
+# Mistral AI Rust Client
+
+[![Crates.io Package](https://img.shields.io/crates/v/mistralai-client?style=for-the-badge)](https://crates.io/crates/mistralai-client)
+[![Docs.rs Documentation](https://img.shields.io/docsrs/mistralai-client/latest?style=for-the-badge)](https://docs.rs/mistralai-client/latest/mistralai-client)
+[![Test Workflow Status](https://img.shields.io/github/actions/workflow/status/ivangabriele/mistralai-client-rs/test.yml?label=CI&style=for-the-badge)](https://github.com/ivangabriele/mistralai-client-rs/actions?query=branch%3Amain+workflow%3ATest++)
+[![Code Coverage](https://img.shields.io/codecov/c/github/ivangabriele/mistralai-client-rs/main?label=Cov&style=for-the-badge)](https://app.codecov.io/github/ivangabriele/mistralai-client-rs)
+
+Rust client for the Mistral AI API.
+
+---
+
+- [Supported APIs](#supported-apis)
+- [Installation](#installation)
+  - [Mistral API Key](#mistral-api-key)
+    - [As an environment variable](#as-an-environment-variable)
+    - [As a client argument](#as-a-client-argument)
+- [Usage](#usage)
+  - [Chat](#chat)
+  - [Chat (async)](#chat-async)
+  - [Chat with streaming (async)](#chat-with-streaming-async)
+  - [Chat with Function Calling](#chat-with-function-calling)
+  - [Chat with Function Calling (async)](#chat-with-function-calling-async)
+  - [Embeddings](#embeddings)
+  - [Embeddings (async)](#embeddings-async)
+  - [List models](#list-models)
+  - [List models (async)](#list-models-async)
+- [Contributing](#contributing)
+
+---
+
+## Supported APIs
+
+- [x] Chat without streaming
+- [x] Chat without streaming (async)
+- [x] Chat with streaming
+- [x] Embedding
+- [x] Embedding (async)
+- [x] List models
+- [x] List models (async)
+- [x] Function Calling
+- [x] Function Calling (async)
+
+## Installation
+
+You can install the library in your project using:
+
+```sh
+cargo add mistralai-client
+```
+
+### Mistral API Key
+
+You can get your Mistral API Key there: <https://docs.mistral.ai/#api-access>.
+
+#### As an environment variable
+
+Just set the `MISTRAL_API_KEY` environment variable.
+
+```rs
+use mistralai_client::v1::client::Client;
+
+fn main() {
+    let client = Client::new(None, None, None, None);
+}
+```
+
+```sh
+MISTRAL_API_KEY=your_api_key cargo run
+```
+
+#### As a client argument
+
+```rs
+use mistralai_client::v1::client::Client;
+
+fn main() {
+    let api_key = "your_api_key";
+
+    let client = Client::new(Some(api_key), None, None, None).unwrap();
+}
+```
+
+## Usage
+
+### Chat
+
+<CODE>examples/chat.rs</CODE>
+
+### Chat (async)
+
+<CODE>examples/chat_async.rs</CODE>
+
+### Chat with streaming (async)
+
+<CODE>examples/chat_with_streaming.rs</CODE>
+
+### Chat with Function Calling
+
+<CODE>examples/chat_with_function_calling.rs</CODE>
+
+### Chat with Function Calling (async)
+
+<CODE>examples/chat_with_function_calling_async.rs</CODE>
+
+### Embeddings
+
+<CODE>examples/embeddings.rs</CODE>
+
+### Embeddings (async)
+
+<CODE>examples/embeddings_async.rs</CODE>
+
+### List models
+
+<CODE>examples/list_models.rs</CODE>
+
+### List models (async)
+
+<CODE>examples/list_models_async.rs</CODE>
+
+## Contributing
+
+Please read [CONTRIBUTING.md](./CONTRIBUTING.md) for details on how to contribute to this library.

examples/chat.rs

@@ -0,0 +1,26 @@
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
+    client::Client,
+    constants::Model,
+};
+
+fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let model = Model::OpenMistral7b;
+    let messages = vec![ChatMessage {
+        role: ChatMessageRole::User,
+        content: "Just guess the next word: \"Eiffel ...\"?".to_string(),
+        tool_calls: None,
+    }];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        ..Default::default()
+    };
+
+    let result = client.chat(model, messages, Some(options)).unwrap();
+    println!("Assistant: {}", result.choices[0].message.content);
+    // => "Assistant: Tower. The Eiffel Tower is a famous landmark in Paris, France."
+}

examples/chat_async.rs

@@ -0,0 +1,33 @@
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
+    client::Client,
+    constants::Model,
+};
+
+#[tokio::main]
+async fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let model = Model::OpenMistral7b;
+    let messages = vec![ChatMessage {
+        role: ChatMessageRole::User,
+        content: "Just guess the next word: \"Eiffel ...\"?".to_string(),
+        tool_calls: None,
+    }];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        ..Default::default()
+    };
+
+    let result = client
+        .chat_async(model, messages, Some(options))
+        .await
+        .unwrap();
+    println!(
+        "{:?}: {}",
+        result.choices[0].message.role, result.choices[0].message.content
+    );
+    // => "Assistant: Tower. The Eiffel Tower is a famous landmark in Paris, France."
+}

examples/chat_with_function_calling.rs

@@ -0,0 +1,71 @@
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
+    client::Client,
+    constants::Model,
+    tool::{Function, Tool, ToolChoice, ToolFunctionParameter, ToolFunctionParameterType},
+};
+use serde::Deserialize;
+use std::any::Any;
+
+#[derive(Debug, Deserialize)]
+struct GetCityTemperatureArguments {
+    city: String,
+}
+
+struct GetCityTemperatureFunction;
+#[async_trait::async_trait]
+impl Function for GetCityTemperatureFunction {
+    async fn execute(&self, arguments: String) -> Box<dyn Any + Send> {
+        // Deserialize arguments, perform the logic, and return the result
+        let GetCityTemperatureArguments { city } = serde_json::from_str(&arguments).unwrap();
+
+        let temperature = match city.as_str() {
+            "Paris" => "20°C",
+            _ => "Unknown city",
+        };
+
+        Box::new(temperature.to_string())
+    }
+}
+
+fn main() {
+    let tools = vec![Tool::new(
+        "get_city_temperature".to_string(),
+        "Get the current temperature in a city.".to_string(),
+        vec![ToolFunctionParameter::new(
+            "city".to_string(),
+            "The name of the city.".to_string(),
+            ToolFunctionParameterType::String,
+        )],
+    )];
+
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let mut client = Client::new(None, None, None, None).unwrap();
+    client.register_function(
+        "get_city_temperature".to_string(),
+        Box::new(GetCityTemperatureFunction),
+    );
+
+    let model = Model::MistralSmallLatest;
+    let messages = vec![ChatMessage {
+        role: ChatMessageRole::User,
+        content: "What's the temperature in Paris?".to_string(),
+        tool_calls: None,
+    }];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        tool_choice: Some(ToolChoice::Auto),
+        tools: Some(tools),
+        ..Default::default()
+    };
+
+    client.chat(model, messages, Some(options)).unwrap();
+    let temperature = client
+        .get_last_function_call_result()
+        .unwrap()
+        .downcast::<String>()
+        .unwrap();
+    println!("The temperature in Paris is: {}.", temperature);
+    // => "The temperature in Paris is: 20°C."
+}

examples/chat_with_function_calling_async.rs

@@ -0,0 +1,75 @@
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
+    client::Client,
+    constants::Model,
+    tool::{Function, Tool, ToolChoice, ToolFunctionParameter, ToolFunctionParameterType},
+};
+use serde::Deserialize;
+use std::any::Any;
+
+#[derive(Debug, Deserialize)]
+struct GetCityTemperatureArguments {
+    city: String,
+}
+
+struct GetCityTemperatureFunction;
+#[async_trait::async_trait]
+impl Function for GetCityTemperatureFunction {
+    async fn execute(&self, arguments: String) -> Box<dyn Any + Send> {
+        // Deserialize arguments, perform the logic, and return the result
+        let GetCityTemperatureArguments { city } = serde_json::from_str(&arguments).unwrap();
+
+        let temperature = match city.as_str() {
+            "Paris" => "20°C",
+            _ => "Unknown city",
+        };
+
+        Box::new(temperature.to_string())
+    }
+}
+
+#[tokio::main]
+async fn main() {
+    let tools = vec![Tool::new(
+        "get_city_temperature".to_string(),
+        "Get the current temperature in a city.".to_string(),
+        vec![ToolFunctionParameter::new(
+            "city".to_string(),
+            "The name of the city.".to_string(),
+            ToolFunctionParameterType::String,
+        )],
+    )];
+
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let mut client = Client::new(None, None, None, None).unwrap();
+    client.register_function(
+        "get_city_temperature".to_string(),
+        Box::new(GetCityTemperatureFunction),
+    );
+
+    let model = Model::MistralSmallLatest;
+    let messages = vec![ChatMessage {
+        role: ChatMessageRole::User,
+        content: "What's the temperature in Paris?".to_string(),
+        tool_calls: None,
+    }];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        tool_choice: Some(ToolChoice::Auto),
+        tools: Some(tools),
+        ..Default::default()
+    };
+
+    client
+        .chat_async(model, messages, Some(options))
+        .await
+        .unwrap();
+    let temperature = client
+        .get_last_function_call_result()
+        .unwrap()
+        .downcast::<String>()
+        .unwrap();
+    println!("The temperature in Paris is: {}.", temperature);
+    // => "The temperature in Paris is: 20°C."
+}

examples/chat_with_streaming.rs

@@ -0,0 +1,45 @@
+use futures::stream::StreamExt;
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams},
+    client::Client,
+    constants::Model,
+};
+use std::io::{self, Write};
+
+#[tokio::main]
+async fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let model = Model::OpenMistral7b;
+    let messages = vec![ChatMessage {
+        role: ChatMessageRole::User,
+        content: "Tell me a short happy story.".to_string(),
+        tool_calls: None,
+    }];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        ..Default::default()
+    };
+
+    let stream_result = client
+        .chat_stream(model, messages, Some(options))
+        .await
+        .unwrap();
+    stream_result
+        .for_each(|chunk_result| async {
+            match chunk_result {
+                Ok(chunks) => chunks.iter().for_each(|chunk| {
+                    print!("{}", chunk.choices[0].delta.content);
+                    io::stdout().flush().unwrap();
+                    // => "Once upon a time, [...]"
+                }),
+                Err(error) => {
+                    eprintln!("Error processing chunk: {:?}", error)
+                }
+            }
+        })
+        .await;
+    print!("\n") // To persist the last chunk output.
+}

examples/embeddings.rs

@@ -0,0 +1,17 @@
+use mistralai_client::v1::{client::Client, constants::EmbedModel};
+
+fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client: Client = Client::new(None, None, None, None).unwrap();
+
+    let model = EmbedModel::MistralEmbed;
+    let input = vec!["Embed this sentence.", "As well as this one."]
+        .iter()
+        .map(|s| s.to_string())
+        .collect();
+    let options = None;
+
+    let response = client.embeddings(model, input, options).unwrap();
+    println!("First Embedding: {:?}", response.data[0]);
+    // => "First Embedding: {...}"
+}

examples/embeddings_async.rs

@@ -0,0 +1,21 @@
+use mistralai_client::v1::{client::Client, constants::EmbedModel};
+
+#[tokio::main]
+async fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client: Client = Client::new(None, None, None, None).unwrap();
+
+    let model = EmbedModel::MistralEmbed;
+    let input = vec!["Embed this sentence.", "As well as this one."]
+        .iter()
+        .map(|s| s.to_string())
+        .collect();
+    let options = None;
+
+    let response = client
+        .embeddings_async(model, input, options)
+        .await
+        .unwrap();
+    println!("First Embedding: {:?}", response.data[0]);
+    // => "First Embedding: {...}"
+}

examples/list_models.rs

@@ -0,0 +1,10 @@
+use mistralai_client::v1::client::Client;
+
+fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let result = client.list_models().unwrap();
+    println!("First Model ID: {:?}", result.data[0].id);
+    // => "First Model ID: open-mistral-7b"
+}

examples/list_models_async.rs

@@ -0,0 +1,11 @@
+use mistralai_client::v1::client::Client;
+
+#[tokio::main]
+async fn main() {
+    // This example suppose you have set the `MISTRAL_API_KEY` environment variable.
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let result = client.list_models_async().await.unwrap();
+    println!("First Model ID: {:?}", result.data[0].id);
+    // => "First Model ID: open-mistral-7b"
+}

release.toml

@@ -0,0 +1,4 @@
+# https://github.com/crate-ci/cargo-release/blob/master/docs/reference.md
+allow-branch = ["main"]
+pre-release-commit-message = "ci(release): v{{version}}"
+pre-release-replacements = [{ file = "CHANGELOG.md", search = "## \\[\\]", replace = "## [{{version}}]" }]

src/lib.rs

@@ -1 +1,4 @@
+//! This crate provides a easy bindings and types for MistralAI's API.
+
+/// The v1 module contains the types and methods for the v1 API endpoints.
 pub mod v1;

src/v1/chat.rs

@@ -0,0 +1,154 @@
+use serde::{Deserialize, Serialize};
+
+use crate::v1::{common, constants, tool};
+
+// -----------------------------------------------------------------------------
+// Definitions
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ChatMessage {
+    pub role: ChatMessageRole,
+    pub content: String,
+    pub tool_calls: Option<Vec<tool::ToolCall>>,
+}
+impl ChatMessage {
+    pub fn new_assistant_message(content: &str, tool_calls: Option<Vec<tool::ToolCall>>) -> Self {
+        Self {
+            role: ChatMessageRole::Assistant,
+            content: content.to_string(),
+            tool_calls,
+        }
+    }
+
+    pub fn new_user_message(content: &str) -> Self {
+        Self {
+            role: ChatMessageRole::User,
+            content: content.to_string(),
+            tool_calls: None,
+        }
+    }
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+pub enum ChatMessageRole {
+    #[serde(rename = "assistant")]
+    Assistant,
+    #[serde(rename = "user")]
+    User,
+}
+
+// -----------------------------------------------------------------------------
+// Request
+
+#[derive(Debug)]
+pub struct ChatParams {
+    pub max_tokens: Option<u32>,
+    pub random_seed: Option<u32>,
+    pub safe_prompt: Option<bool>,
+    pub temperature: Option<f32>,
+    pub tool_choice: Option<tool::ToolChoice>,
+    pub tools: Option<Vec<tool::Tool>>,
+    pub top_p: Option<f32>,
+}
+impl Default for ChatParams {
+    fn default() -> Self {
+        Self {
+            max_tokens: None,
+            random_seed: None,
+            safe_prompt: None,
+            temperature: None,
+            tool_choice: None,
+            tools: None,
+            top_p: None,
+        }
+    }
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+pub struct ChatRequest {
+    pub messages: Vec<ChatMessage>,
+    pub model: constants::Model,
+
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub max_tokens: Option<u32>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub random_seed: Option<u32>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub safe_prompt: Option<bool>,
+    pub stream: bool,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub temperature: Option<f32>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub tool_choice: Option<tool::ToolChoice>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub tools: Option<Vec<tool::Tool>>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub top_p: Option<f32>,
+    // TODO Check this prop (seen in official Python client but not in API doc).
+    // pub tool_choice: Option<String>,
+    // TODO Check this prop (seen in official Python client but not in API doc).
+    // pub response_format: Option<String>,
+}
+impl ChatRequest {
+    pub fn new(
+        model: constants::Model,
+        messages: Vec<ChatMessage>,
+        stream: bool,
+        options: Option<ChatParams>,
+    ) -> Self {
+        let ChatParams {
+            max_tokens,
+            random_seed,
+            safe_prompt,
+            temperature,
+            tool_choice,
+            tools,
+            top_p,
+        } = options.unwrap_or_default();
+
+        Self {
+            messages,
+            model,
+
+            max_tokens,
+            random_seed,
+            safe_prompt,
+            stream,
+            temperature,
+            tool_choice,
+            tools,
+            top_p,
+        }
+    }
+}
+
+// -----------------------------------------------------------------------------
+// Response
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ChatResponse {
+    pub id: String,
+    pub object: String,
+    /// Unix timestamp (in seconds).
+    pub created: u32,
+    pub model: constants::Model,
+    pub choices: Vec<ChatResponseChoice>,
+    pub usage: common::ResponseUsage,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ChatResponseChoice {
+    pub index: u32,
+    pub message: ChatMessage,
+    pub finish_reason: ChatResponseChoiceFinishReason,
+    // TODO Check this prop (seen in API responses but undocumented).
+    // pub logprobs: ???
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+pub enum ChatResponseChoiceFinishReason {
+    #[serde(rename = "stop")]
+    Stop,
+    #[serde(rename = "tool_calls")]
+    ToolCalls,
+}

src/v1/chat_completion.rs

@@ -1,113 +0,0 @@
-use serde::{Deserialize, Serialize};
-
-use crate::v1::common;
-
-#[derive(Debug)]
-pub struct ChatCompletionRequestOptions {
-    pub tools: Option<String>,
-    pub temperature: Option<f32>,
-    pub max_tokens: Option<u32>,
-    pub top_p: Option<f32>,
-    pub random_seed: Option<u32>,
-    pub stream: Option<bool>,
-    pub safe_prompt: Option<bool>,
-}
-impl Default for ChatCompletionRequestOptions {
-    fn default() -> Self {
-        Self {
-            tools: None,
-            temperature: None,
-            max_tokens: None,
-            top_p: None,
-            random_seed: None,
-            stream: None,
-            safe_prompt: None,
-        }
-    }
-}
-
-#[derive(Debug, Serialize, Deserialize)]
-pub struct ChatCompletionRequest {
-    pub messages: Vec<ChatCompletionMessage>,
-    pub model: String,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub tools: Option<String>,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub temperature: Option<f32>,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub max_tokens: Option<u32>,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub top_p: Option<f32>,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub random_seed: Option<u32>,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub stream: Option<bool>,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub safe_prompt: Option<bool>,
-    // TODO Check that prop (seen in official Python client but not in API doc).
-    // pub tool_choice: Option<String>,
-    // TODO Check that prop (seen in official Python client but not in API doc).
-    // pub response_format: Option<String>,
-}
-impl ChatCompletionRequest {
-    pub fn new(
-        model: String,
-        messages: Vec<ChatCompletionMessage>,
-        options: Option<ChatCompletionRequestOptions>,
-    ) -> Self {
-        let ChatCompletionRequestOptions {
-            tools,
-            temperature,
-            max_tokens,
-            top_p,
-            random_seed,
-            stream,
-            safe_prompt,
-        } = options.unwrap_or_default();
-
-        Self {
-            messages,
-            model,
-            tools,
-            temperature,
-            max_tokens,
-            top_p,
-            random_seed,
-            stream,
-            safe_prompt,
-        }
-    }
-}
-
-#[derive(Clone, Debug, Deserialize, Serialize)]
-pub struct ChatCompletionResponse {
-    pub id: String,
-    pub object: String,
-    /// Unix timestamp (in seconds).
-    pub created: u32,
-    pub model: String,
-    pub choices: Vec<ChatCompletionChoice>,
-    pub usage: common::ResponseUsage,
-}
-
-#[derive(Clone, Debug, Deserialize, Serialize)]
-pub struct ChatCompletionChoice {
-    pub index: u32,
-    pub message: ChatCompletionMessage,
-    pub finish_reason: String,
-    // TODO Check that prop (seen in API responses but undocumented).
-    // pub logprobs: ???
-}
-
-#[derive(Clone, Debug, Deserialize, Serialize)]
-pub struct ChatCompletionMessage {
-    pub role: ChatCompletionMessageRole,
-    pub content: String,
-}
-
-#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
-#[allow(non_camel_case_types)]
-pub enum ChatCompletionMessageRole {
-    assistant,
-    user,
-}

src/v1/chat_stream.rs

@@ -0,0 +1,57 @@
+use serde::{Deserialize, Serialize};
+use serde_json::from_str;
+
+use crate::v1::{chat, common, constants, error};
+
+// -----------------------------------------------------------------------------
+// Response
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ChatStreamChunk {
+    pub id: String,
+    pub object: String,
+    /// Unix timestamp (in seconds).
+    pub created: u32,
+    pub model: constants::Model,
+    pub choices: Vec<ChatStreamChunkChoice>,
+    pub usage: Option<common::ResponseUsage>,
+    // TODO Check this prop (seen in API responses but undocumented).
+    // pub logprobs: ???,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ChatStreamChunkChoice {
+    pub index: u32,
+    pub delta: ChatStreamChunkChoiceDelta,
+    pub finish_reason: Option<String>,
+    // TODO Check this prop (seen in API responses but undocumented).
+    // pub logprobs: ???,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ChatStreamChunkChoiceDelta {
+    pub role: Option<chat::ChatMessageRole>,
+    pub content: String,
+}
+
+/// Extracts serialized chunks from a stream message.
+pub fn get_chunk_from_stream_message_line(
+    line: &str,
+) -> Result<Option<Vec<ChatStreamChunk>>, error::ApiError> {
+    if line.trim() == "data: [DONE]" {
+        return Ok(None);
+    }
+
+    let chunk_as_json = line.trim_start_matches("data: ").trim();
+    if chunk_as_json.is_empty() {
+        return Ok(Some(vec![]));
+    }
+
+    // Attempt to deserialize the JSON string into ChatStreamChunk
+    match from_str::<ChatStreamChunk>(chunk_as_json) {
+        Ok(chunk) => Ok(Some(vec![chunk])),
+        Err(e) => Err(error::ApiError {
+            message: e.to_string(),
+        }),
+    }
+}

src/v1/client.rs

@@ -1,175 +1,650 @@
-use crate::v1::error::APIError;
+use futures::stream::StreamExt;
-use minreq::Response;
+use futures::Stream;
-
+use log::debug;
-use crate::v1::{
+use reqwest::Error as ReqwestError;
-    chat_completion::{ChatCompletionRequest, ChatCompletionResponse},
+use std::{
-    constants::API_URL_BASE,
+    any::Any,
+    collections::HashMap,
+    sync::{Arc, Mutex},
 };
 
+use crate::v1::{chat, chat_stream, constants, embedding, error, model_list, tool, utils};
+
 pub struct Client {
     pub api_key: String,
     pub endpoint: String,
     pub max_retries: u32,
     pub timeout: u32,
+
+    functions: Arc<Mutex<HashMap<String, Box<dyn tool::Function>>>>,
+    last_function_call_result: Arc<Mutex<Option<Box<dyn Any + Send>>>>,
 }
 
 impl Client {
+    /// Constructs a new `Client`.
+    ///
+    /// # Arguments
+    ///
+    /// * `api_key`     - An optional API key.
+    ///                   If not provided, the method will try to use the `MISTRAL_API_KEY` environment variable.
+    /// * `endpoint`    - An optional custom API endpoint. Defaults to the official API endpoint if not provided.
+    /// * `max_retries` - Optional maximum number of retries for failed requests. Defaults to `5`.
+    /// * `timeout`     - Optional timeout in seconds for requests. Defaults to `120`.
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// use mistralai_client::v1::client::Client;
+    ///
+    /// let client = Client::new(Some("your_api_key_here".to_string()), None, Some(3), Some(60));
+    /// assert!(client.is_ok());
+    /// ```
+    ///
+    /// # Errors
+    ///
+    /// This method fails whenever neither the `api_key` is provided
+    /// nor the `MISTRAL_API_KEY` environment variable is set.
     pub fn new(
         api_key: Option<String>,
         endpoint: Option<String>,
         max_retries: Option<u32>,
         timeout: Option<u32>,
-    ) -> Self {
+    ) -> Result<Self, error::ClientError> {
-        let api_key = api_key.unwrap_or(std::env::var("MISTRAL_API_KEY").unwrap());
+        let api_key = match api_key {
-        let endpoint = endpoint.unwrap_or(API_URL_BASE.to_string());
+            Some(api_key_from_param) => api_key_from_param,
+            None => {
+                std::env::var("MISTRAL_API_KEY").map_err(|_| error::ClientError::MissingApiKey)?
+            }
+        };
+        let endpoint = endpoint.unwrap_or(constants::API_URL_BASE.to_string());
         let max_retries = max_retries.unwrap_or(5);
         let timeout = timeout.unwrap_or(120);
 
-        Self {
+        let functions: Arc<_> = Arc::new(Mutex::new(HashMap::new()));
+        let last_function_call_result = Arc::new(Mutex::new(None));
+
+        Ok(Self {
             api_key,
             endpoint,
             max_retries,
             timeout,
+
+            functions,
+            last_function_call_result,
+        })
+    }
+
+    /// Synchronously sends a chat completion request and returns the response.
+    ///
+    /// # Arguments
+    ///
+    /// * `model` - The [Model] to use for the chat completion.
+    /// * `messages` - A vector of [ChatMessage] to send as part of the chat.
+    /// * `options` - Optional [ChatParams] to customize the request.
+    ///
+    /// # Returns
+    ///
+    /// Returns a [Result] containing the `ChatResponse` if the request is successful,
+    /// or an [ApiError] if there is an error.
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// use mistralai_client::v1::{
+    ///     chat::{ChatMessage, ChatMessageRole},
+    ///     client::Client,
+    ///     constants::Model,
+    /// };
+    ///
+    /// let client = Client::new(None, None, None, None).unwrap();
+    /// let messages = vec![ChatMessage {
+    ///     role: ChatMessageRole::User,
+    ///     content: "Hello, world!".to_string(),
+    ///     tool_calls: None,
+    /// }];
+    /// let response = client.chat(Model::OpenMistral7b, messages, None).unwrap();
+    /// println!("{:?}: {}", response.choices[0].message.role, response.choices[0].message.content);
+    /// ```
+    pub fn chat(
+        &self,
+        model: constants::Model,
+        messages: Vec<chat::ChatMessage>,
+        options: Option<chat::ChatParams>,
+    ) -> Result<chat::ChatResponse, error::ApiError> {
+        let request = chat::ChatRequest::new(model, messages, false, options);
+
+        let response = self.post_sync("/chat/completions", &request)?;
+        let result = response.json::<chat::ChatResponse>();
+        match result {
+            Ok(data) => {
+                utils::debug_pretty_json_from_struct("Response Data", &data);
+
+                self.call_function_if_any(data.clone());
+
+                Ok(data)
+            }
+            Err(error) => Err(self.to_api_error(error)),
         }
     }
 
-    pub fn build_request(&self, request: minreq::Request) -> minreq::Request {
+    /// Asynchronously sends a chat completion request and returns the response.
-        let authorization = format!("Bearer {}", self.api_key);
+    ///
+    /// # Arguments
+    ///
+    /// * `model` - The [Model] to use for the chat completion.
+    /// * `messages` - A vector of [ChatMessage] to send as part of the chat.
+    /// * `options` - Optional [ChatParams] to customize the request.
+    ///
+    /// # Returns
+    ///
+    /// Returns a [Result] containing a `Stream` of `ChatStreamChunk` if the request is successful,
+    /// or an [ApiError] if there is an error.
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// use mistralai_client::v1::{
+    ///     chat::{ChatMessage, ChatMessageRole},
+    ///     client::Client,
+    ///     constants::Model,
+    /// };
+    ///
+    /// #[tokio::main]
+    /// async fn main() {
+    ///     let client = Client::new(None, None, None, None).unwrap();
+    ///     let messages = vec![ChatMessage {
+    ///         role: ChatMessageRole::User,
+    ///         content: "Hello, world!".to_string(),
+    ///         tool_calls: None,
+    ///     }];
+    ///     let response = client.chat_async(Model::OpenMistral7b, messages, None).await.unwrap();
+    ///     println!("{:?}: {}", response.choices[0].message.role, response.choices[0].message.content);
+    /// }
+    /// ```
+    pub async fn chat_async(
+        &self,
+        model: constants::Model,
+        messages: Vec<chat::ChatMessage>,
+        options: Option<chat::ChatParams>,
+    ) -> Result<chat::ChatResponse, error::ApiError> {
+        let request = chat::ChatRequest::new(model, messages, false, options);
+
+        let response = self.post_async("/chat/completions", &request).await?;
+        let result = response.json::<chat::ChatResponse>().await;
+        match result {
+            Ok(data) => {
+                utils::debug_pretty_json_from_struct("Response Data", &data);
+
+                self.call_function_if_any_async(data.clone()).await;
+
+                Ok(data)
+            }
+            Err(error) => Err(self.to_api_error(error)),
+        }
+    }
+
+    /// Asynchronously sends a chat completion request and returns a stream of message chunks.
+    ///
+    /// # Arguments
+    ///
+    /// * `model` - The [Model] to use for the chat completion.
+    /// * `messages` - A vector of [ChatMessage] to send as part of the chat.
+    /// * `options` - Optional [ChatParams] to customize the request.
+    ///
+    /// # Returns
+    ///
+    /// Returns a [Result] containing a `Stream` of `ChatStreamChunk` if the request is successful,
+    /// or an [ApiError] if there is an error.
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// use futures::stream::StreamExt;
+    /// use mistralai_client::v1::{
+    ///     chat::{ChatMessage, ChatMessageRole},
+    ///     client::Client,
+    ///     constants::Model,
+    /// };
+    /// use std::io::{self, Write};
+    ///
+    /// #[tokio::main]
+    /// async fn main() {
+    ///     let client = Client::new(None, None, None, None).unwrap();
+    ///     let messages = vec![ChatMessage {
+    ///         role: ChatMessageRole::User,
+    ///         content: "Hello, world!".to_string(),
+    ///         tool_calls: None,
+    ///     }];
+    ///
+    ///     let stream_result = client
+    ///         .chat_stream(Model::OpenMistral7b,messages, None)
+    ///         .await
+    ///         .unwrap();
+    ///     stream_result
+    ///         .for_each(|chunk_result| async {
+    ///             match chunk_result {
+    ///                 Ok(chunks) => chunks.iter().for_each(|chunk| {
+    ///                     print!("{}", chunk.choices[0].delta.content);
+    ///                     io::stdout().flush().unwrap();
+    ///                     // => "Once upon a time, [...]"
+    ///                 }),
+    ///                 Err(error) => {
+    ///                     eprintln!("Error processing chunk: {:?}", error)
+    ///                 }
+    ///             }
+    ///         })
+    ///         .await;
+    ///     print!("\n") // To persist the last chunk output.
+    /// }
+    pub async fn chat_stream(
+        &self,
+        model: constants::Model,
+        messages: Vec<chat::ChatMessage>,
+        options: Option<chat::ChatParams>,
+    ) -> Result<
+        impl Stream<Item = Result<Vec<chat_stream::ChatStreamChunk>, error::ApiError>>,
+        error::ApiError,
+    > {
+        let request = chat::ChatRequest::new(model, messages, true, options);
+        let response = self
+            .post_stream("/chat/completions", &request)
+            .await
+            .map_err(|e| error::ApiError {
+                message: e.to_string(),
+            })?;
+        if !response.status().is_success() {
+            let status = response.status();
+            let text = response.text().await.unwrap_or_default();
+            return Err(error::ApiError {
+                message: format!("{}: {}", status, text),
+            });
+        }
+
+        let deserialized_stream = response.bytes_stream().then(|bytes_result| async move {
+            match bytes_result {
+                Ok(bytes) => match String::from_utf8(bytes.to_vec()) {
+                    Ok(message) => {
+                        let chunks = message
+                            .lines()
+                            .filter_map(
+                                |line| match chat_stream::get_chunk_from_stream_message_line(line) {
+                                    Ok(Some(chunks)) => Some(chunks),
+                                    Ok(None) => None,
+                                    Err(_error) => None,
+                                },
+                            )
+                            .flatten()
+                            .collect();
+
+                        Ok(chunks)
+                    }
+                    Err(e) => Err(error::ApiError {
+                        message: e.to_string(),
+                    }),
+                },
+                Err(e) => Err(error::ApiError {
+                    message: e.to_string(),
+                }),
+            }
+        });
+
+        Ok(deserialized_stream)
+    }
+
+    pub fn embeddings(
+        &self,
+        model: constants::EmbedModel,
+        input: Vec<String>,
+        options: Option<embedding::EmbeddingRequestOptions>,
+    ) -> Result<embedding::EmbeddingResponse, error::ApiError> {
+        let request = embedding::EmbeddingRequest::new(model, input, options);
+
+        let response = self.post_sync("/embeddings", &request)?;
+        let result = response.json::<embedding::EmbeddingResponse>();
+        match result {
+            Ok(data) => {
+                utils::debug_pretty_json_from_struct("Response Data", &data);
+
+                Ok(data)
+            }
+            Err(error) => Err(self.to_api_error(error)),
+        }
+    }
+
+    pub async fn embeddings_async(
+        &self,
+        model: constants::EmbedModel,
+        input: Vec<String>,
+        options: Option<embedding::EmbeddingRequestOptions>,
+    ) -> Result<embedding::EmbeddingResponse, error::ApiError> {
+        let request = embedding::EmbeddingRequest::new(model, input, options);
+
+        let response = self.post_async("/embeddings", &request).await?;
+        let result = response.json::<embedding::EmbeddingResponse>().await;
+        match result {
+            Ok(data) => {
+                utils::debug_pretty_json_from_struct("Response Data", &data);
+
+                Ok(data)
+            }
+            Err(error) => Err(self.to_api_error(error)),
+        }
+    }
+
+    pub fn get_last_function_call_result(&self) -> Option<Box<dyn Any + Send>> {
+        let mut result_lock = self.last_function_call_result.lock().unwrap();
+
+        result_lock.take()
+    }
+
+    pub fn list_models(&self) -> Result<model_list::ModelListResponse, error::ApiError> {
+        let response = self.get_sync("/models")?;
+        let result = response.json::<model_list::ModelListResponse>();
+        match result {
+            Ok(data) => {
+                utils::debug_pretty_json_from_struct("Response Data", &data);
+
+                Ok(data)
+            }
+            Err(error) => Err(self.to_api_error(error)),
+        }
+    }
+
+    pub async fn list_models_async(
+        &self,
+    ) -> Result<model_list::ModelListResponse, error::ApiError> {
+        let response = self.get_async("/models").await?;
+        let result = response.json::<model_list::ModelListResponse>().await;
+        match result {
+            Ok(data) => {
+                utils::debug_pretty_json_from_struct("Response Data", &data);
+
+                Ok(data)
+            }
+            Err(error) => Err(self.to_api_error(error)),
+        }
+    }
+
+    pub fn register_function(&mut self, name: String, function: Box<dyn tool::Function>) {
+        let mut functions = self.functions.lock().unwrap();
+
+        functions.insert(name, function);
+    }
+
+    fn build_request_sync(
+        &self,
+        request: reqwest::blocking::RequestBuilder,
+    ) -> reqwest::blocking::RequestBuilder {
         let user_agent = format!(
-            "ivangabriele/mistral-client-rs/{}",
+            "ivangabriele/mistralai-client-rs/{}",
             env!("CARGO_PKG_VERSION")
         );
 
-        let request = request
+        let request_builder = request
-            .with_header("Authorization", authorization)
+            .bearer_auth(&self.api_key)
-            .with_header("Accept", "application/json")
+            .header("Accept", "application/json")
-            .with_header("Content-Type", "application/json")
+            .header("Content-Type", "application/json")
-            .with_header("User-Agent", user_agent);
+            .header("User-Agent", user_agent);
 
-        request
+        request_builder
     }
 
-    pub fn get(&self, path: &str) -> Result<Response, APIError> {
+    fn build_request_async(&self, request: reqwest::RequestBuilder) -> reqwest::RequestBuilder {
+        let user_agent = format!(
+            "ivangabriele/mistralai-client-rs/{}",
+            env!("CARGO_PKG_VERSION")
+        );
+
+        let request_builder = request
+            .bearer_auth(&self.api_key)
+            .header("Accept", "application/json")
+            .header("Content-Type", "application/json")
+            .header("User-Agent", user_agent);
+
+        request_builder
+    }
+
+    fn build_request_stream(&self, request: reqwest::RequestBuilder) -> reqwest::RequestBuilder {
+        let user_agent = format!(
+            "ivangabriele/mistralai-client-rs/{}",
+            env!("CARGO_PKG_VERSION")
+        );
+
+        let request_builder = request
+            .bearer_auth(&self.api_key)
+            .header("Accept", "text/event-stream")
+            .header("Content-Type", "application/json")
+            .header("User-Agent", user_agent);
+
+        request_builder
+    }
+
+    fn call_function_if_any(&self, response: chat::ChatResponse) -> () {
+        let next_result = match response.choices.get(0) {
+            Some(first_choice) => match first_choice.message.tool_calls.to_owned() {
+                Some(tool_calls) => match tool_calls.get(0) {
+                    Some(first_tool_call) => {
+                        let functions = self.functions.lock().unwrap();
+                        match functions.get(&first_tool_call.function.name) {
+                            Some(function) => {
+                                let runtime = tokio::runtime::Runtime::new().unwrap();
+                                let result = runtime.block_on(async {
+                                    function
+                                        .execute(first_tool_call.function.arguments.to_owned())
+                                        .await
+                                });
+
+                                Some(result)
+                            }
+                            None => None,
+                        }
+                    }
+                    None => None,
+                },
+                None => None,
+            },
+            None => None,
+        };
+
+        let mut last_result_lock = self.last_function_call_result.lock().unwrap();
+        *last_result_lock = next_result;
+    }
+
+    async fn call_function_if_any_async(&self, response: chat::ChatResponse) -> () {
+        let next_result = match response.choices.get(0) {
+            Some(first_choice) => match first_choice.message.tool_calls.to_owned() {
+                Some(tool_calls) => match tool_calls.get(0) {
+                    Some(first_tool_call) => {
+                        let functions = self.functions.lock().unwrap();
+                        match functions.get(&first_tool_call.function.name) {
+                            Some(function) => {
+                                let result = function
+                                    .execute(first_tool_call.function.arguments.to_owned())
+                                    .await;
+
+                                Some(result)
+                            }
+                            None => None,
+                        }
+                    }
+                    None => None,
+                },
+                None => None,
+            },
+            None => None,
+        };
+
+        let mut last_result_lock = self.last_function_call_result.lock().unwrap();
+        *last_result_lock = next_result;
+    }
+
+    fn get_sync(&self, path: &str) -> Result<reqwest::blocking::Response, error::ApiError> {
+        let reqwest_client = reqwest::blocking::Client::new();
         let url = format!("{}{}", self.endpoint, path);
-        let request = self.build_request(minreq::post(url));
+        debug!("Request URL: {}", url);
+
+        let request = self.build_request_sync(reqwest_client.get(url));
 
         let result = request.send();
         match result {
-            Ok(res) => {
+            Ok(response) => {
-                if (200..=299).contains(&res.status_code) {
+                if response.status().is_success() {
-                    Ok(res)
+                    Ok(response)
                 } else {
-                    Err(APIError {
+                    let response_status = response.status();
-                        message: format!("{}: {}", res.status_code, res.as_str().unwrap()),
+                    let response_body = response.text().unwrap_or_default();
+                    debug!("Response Status: {}", &response_status);
+                    utils::debug_pretty_json_from_string("Response Data", &response_body);
+
+                    Err(error::ApiError {
+                        message: format!("{}: {}", response_status, response_body),
                     })
                 }
             }
-            Err(e) => Err(self.new_error(e)),
+            Err(error) => Err(error::ApiError {
+                message: error.to_string(),
+            }),
         }
     }
 
-    pub fn post<T: serde::ser::Serialize + std::fmt::Debug>(
+    async fn get_async(&self, path: &str) -> Result<reqwest::Response, error::ApiError> {
+        let reqwest_client = reqwest::Client::new();
+        let url = format!("{}{}", self.endpoint, path);
+        debug!("Request URL: {}", url);
+
+        let request_builder = reqwest_client.get(url);
+        let request = self.build_request_async(request_builder);
+
+        let result = request.send().await;
+        match result {
+            Ok(response) => {
+                if response.status().is_success() {
+                    Ok(response)
+                } else {
+                    let response_status = response.status();
+                    let response_body = response.text().await.unwrap_or_default();
+                    debug!("Response Status: {}", &response_status);
+                    utils::debug_pretty_json_from_string("Response Data", &response_body);
+
+                    Err(error::ApiError {
+                        message: format!("{}: {}", response_status, response_body),
+                    })
+                }
+            }
+            Err(error) => Err(error::ApiError {
+                message: error.to_string(),
+            }),
+        }
+    }
+
+    fn post_sync<T: std::fmt::Debug + serde::ser::Serialize>(
         &self,
         path: &str,
         params: &T,
-    ) -> Result<Response, APIError> {
+    ) -> Result<reqwest::blocking::Response, error::ApiError> {
-        // print!("{:?}", params);
+        let reqwest_client = reqwest::blocking::Client::new();
-
         let url = format!("{}{}", self.endpoint, path);
-        let request = self.build_request(minreq::post(url));
+        debug!("Request URL: {}", url);
+        utils::debug_pretty_json_from_struct("Request Body", params);
 
-        let result = request.with_json(params).unwrap().send();
+        let request_builder = reqwest_client.post(url).json(params);
-        match result {
+        let request = self.build_request_sync(request_builder);
-            Ok(res) => {
-                print!("{:?}", res.as_str().unwrap());
-
-                if (200..=299).contains(&res.status_code) {
-                    Ok(res)
-                } else {
-                    Err(APIError {
-                        message: format!("{}: {}", res.status_code, res.as_str().unwrap()),
-                    })
-                }
-            }
-            Err(e) => Err(self.new_error(e)),
-        }
-    }
-
-    pub fn delete(&self, path: &str) -> Result<Response, APIError> {
-        let url = format!("{}{}", self.endpoint, path);
-        let request = self.build_request(minreq::post(url));
 
         let result = request.send();
         match result {
-            Ok(res) => {
+            Ok(response) => {
-                if (200..=299).contains(&res.status_code) {
+                if response.status().is_success() {
-                    Ok(res)
+                    Ok(response)
                 } else {
-                    Err(APIError {
+                    let response_status = response.status();
-                        message: format!("{}: {}", res.status_code, res.as_str().unwrap()),
+                    let response_body = response.text().unwrap_or_default();
+                    debug!("Response Status: {}", &response_status);
+                    utils::debug_pretty_json_from_string("Response Data", &response_body);
+
+                    Err(error::ApiError {
+                        message: format!("{}: {}", response_body, response_status),
                     })
                 }
             }
-            Err(e) => Err(self.new_error(e)),
+            Err(error) => Err(error::ApiError {
+                message: error.to_string(),
+            }),
         }
     }
 
-    // pub fn completion(&self, req: CompletionRequest) -> Result<CompletionResponse, APIError> {
+    async fn post_async<T: serde::ser::Serialize + std::fmt::Debug>(
-    //     let res = self.post("/completions", &req)?;
+        &self,
-    //     let r = res.json::<CompletionResponse>();
+        path: &str,
-    //     match r {
+        params: &T,
-    //         Ok(r) => Ok(r),
+    ) -> Result<reqwest::Response, error::ApiError> {
-    //         Err(e) => Err(self.new_error(e)),
+        let reqwest_client = reqwest::Client::new();
-    //     }
+        let url = format!("{}{}", self.endpoint, path);
-    // }
+        debug!("Request URL: {}", url);
+        utils::debug_pretty_json_from_struct("Request Body", params);
 
-    // pub fn embedding(&self, req: EmbeddingRequest) -> Result<EmbeddingResponse, APIError> {
+        let request_builder = reqwest_client.post(url).json(params);
-    //     let res = self.post("/embeddings", &req)?;
+        let request = self.build_request_async(request_builder);
-    //     let r = res.json::<EmbeddingResponse>();
-    //     match r {
-    //         Ok(r) => Ok(r),
-    //         Err(e) => Err(self.new_error(e)),
-    //     }
-    // }
 
-    pub fn chat(&self, request: ChatCompletionRequest) -> Result<ChatCompletionResponse, APIError> {
+        let result = request.send().await;
-        let response = self.post("/chat/completions", &request)?;
-        let result = response.json::<ChatCompletionResponse>();
         match result {
-            Ok(r) => Ok(r),
+            Ok(response) => {
-            Err(e) => Err(self.new_error(e)),
+                if response.status().is_success() {
+                    Ok(response)
+                } else {
+                    let response_status = response.status();
+                    let response_body = response.text().await.unwrap_or_default();
+                    debug!("Response Status: {}", &response_status);
+                    utils::debug_pretty_json_from_string("Response Data", &response_body);
+
+                    Err(error::ApiError {
+                        message: format!("{}: {}", response_status, response_body),
+                    })
+                }
+            }
+            Err(error) => Err(error::ApiError {
+                message: error.to_string(),
+            }),
         }
     }
 
-    fn new_error(&self, err: minreq::Error) -> APIError {
+    async fn post_stream<T: serde::ser::Serialize + std::fmt::Debug>(
-        APIError {
+        &self,
+        path: &str,
+        params: &T,
+    ) -> Result<reqwest::Response, error::ApiError> {
+        let reqwest_client = reqwest::Client::new();
+        let url = format!("{}{}", self.endpoint, path);
+        debug!("Request URL: {}", url);
+        utils::debug_pretty_json_from_struct("Request Body", params);
+
+        let request_builder = reqwest_client.post(url).json(params);
+        let request = self.build_request_stream(request_builder);
+
+        let result = request.send().await;
+        match result {
+            Ok(response) => {
+                if response.status().is_success() {
+                    Ok(response)
+                } else {
+                    let response_status = response.status();
+                    let response_body = response.text().await.unwrap_or_default();
+                    debug!("Response Status: {}", &response_status);
+                    utils::debug_pretty_json_from_string("Response Data", &response_body);
+
+                    Err(error::ApiError {
+                        message: format!("{}: {}", response_status, response_body),
+                    })
+                }
+            }
+            Err(error) => Err(error::ApiError {
+                message: error.to_string(),
+            }),
+        }
+    }
+
+    fn to_api_error(&self, err: ReqwestError) -> error::ApiError {
+        error::ApiError {
             message: err.to_string(),
         }
     }
-
-    // fn query_params(
-    //     limit: Option<i64>,
-    //     order: Option<String>,
-    //     after: Option<String>,
-    //     before: Option<String>,
-    //     mut url: String,
-    // ) -> String {
-    //     let mut params = vec![];
-    //     if let Some(limit) = limit {
-    //         params.push(format!("limit={}", limit));
-    //     }
-    //     if let Some(order) = order {
-    //         params.push(format!("order={}", order));
-    //     }
-    //     if let Some(after) = after {
-    //         params.push(format!("after={}", after));
-    //     }
-    //     if let Some(before) = before {
-    //         params.push(format!("before={}", before));
-    //     }
-    //     if !params.is_empty() {
-    //         url = format!("{}?{}", url, params.join("&"));
-    //     }
-    //     url
-    // }
 }

src/v1/constants.rs

@@ -1,7 +1,23 @@
+use serde::{Deserialize, Serialize};
+
 pub const API_URL_BASE: &str = "https://api.mistral.ai/v1";
 
-pub const OPEN_MISTRAL_7B: &str = "open-mistral-7b";
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
-pub const OPEN_MISTRAL_8X7B: &str = "open-mixtral-8x7b";
+pub enum Model {
-pub const MISTRAL_SMALL_LATEST: &str = "mistral-small-latest";
+    #[serde(rename = "open-mistral-7b")]
-pub const MISTRAL_MEDIUM_LATEST: &str = "mistral-medium-latest";
+    OpenMistral7b,
-pub const MISTRAL_LARGE_LATEST: &str = "mistral-large-latest";
+    #[serde(rename = "open-mixtral-8x7b")]
+    OpenMixtral8x7b,
+    #[serde(rename = "mistral-small-latest")]
+    MistralSmallLatest,
+    #[serde(rename = "mistral-medium-latest")]
+    MistralMediumLatest,
+    #[serde(rename = "mistral-large-latest")]
+    MistralLargeLatest,
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+pub enum EmbedModel {
+    #[serde(rename = "mistral-embed")]
+    MistralEmbed,
+}

src/v1/embedding.rs

@@ -0,0 +1,66 @@
+use serde::{Deserialize, Serialize};
+
+use crate::v1::{common, constants};
+
+// -----------------------------------------------------------------------------
+// Request
+
+#[derive(Debug)]
+pub struct EmbeddingRequestOptions {
+    pub encoding_format: Option<EmbeddingRequestEncodingFormat>,
+}
+impl Default for EmbeddingRequestOptions {
+    fn default() -> Self {
+        Self {
+            encoding_format: None,
+        }
+    }
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+pub struct EmbeddingRequest {
+    pub model: constants::EmbedModel,
+    pub input: Vec<String>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub encoding_format: Option<EmbeddingRequestEncodingFormat>,
+}
+impl EmbeddingRequest {
+    pub fn new(
+        model: constants::EmbedModel,
+        input: Vec<String>,
+        options: Option<EmbeddingRequestOptions>,
+    ) -> Self {
+        let EmbeddingRequestOptions { encoding_format } = options.unwrap_or_default();
+
+        Self {
+            model,
+            input,
+            encoding_format,
+        }
+    }
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+#[allow(non_camel_case_types)]
+pub enum EmbeddingRequestEncodingFormat {
+    float,
+}
+
+// -----------------------------------------------------------------------------
+// Response
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct EmbeddingResponse {
+    pub id: String,
+    pub object: String,
+    pub model: constants::EmbedModel,
+    pub data: Vec<EmbeddingResponseDataItem>,
+    pub usage: common::ResponseUsage,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct EmbeddingResponseDataItem {
+    pub index: u32,
+    pub embedding: Vec<f32>,
+    pub object: String,
+}

src/v1/error.rs

@@ -2,14 +2,22 @@ use std::error::Error;
 use std::fmt;
 
 #[derive(Debug)]
-pub struct APIError {
+pub struct ApiError {
     pub message: String,
 }
-
+impl fmt::Display for ApiError {
-impl fmt::Display for APIError {
     fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
-        write!(f, "APIError: {}", self.message)
+        write!(f, "ApiError: {}", self.message)
     }
 }
+impl Error for ApiError {}
 
-impl Error for APIError {}
+#[derive(Debug, PartialEq, thiserror::Error)]
+pub enum ClientError {
+    #[error(
+        "You must either set the `MISTRAL_API_KEY` environment variable or specify it in `Client::new(api_key, ...)."
+    )]
+    MissingApiKey,
+    #[error("Failed to read the response text.")]
+    UnreadableResponseText,
+}

src/v1/mod.rs

@@ -1,5 +1,10 @@
-pub mod chat_completion;
+pub mod chat;
+pub mod chat_stream;
 pub mod client;
 pub mod common;
 pub mod constants;
+pub mod embedding;
 pub mod error;
+pub mod model_list;
+pub mod tool;
+pub mod utils;

src/v1/model_list.rs

@@ -0,0 +1,42 @@
+use serde::{Deserialize, Serialize};
+
+// -----------------------------------------------------------------------------
+// Response
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ModelListResponse {
+    pub object: String,
+    pub data: Vec<ModelListData>,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ModelListData {
+    pub id: String,
+    pub object: String,
+    /// Unix timestamp (in seconds).
+    pub created: u32,
+    pub owned_by: String,
+    pub permission: Vec<ModelListDataPermission>,
+    // TODO Check this prop (seen in API responses but undocumented).
+    // pub root: ???,
+    // TODO Check this prop (seen in API responses but undocumented).
+    // pub parent: ???,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ModelListDataPermission {
+    pub id: String,
+    pub object: String,
+    /// Unix timestamp (in seconds).
+    pub created: u32,
+    pub allow_create_engine: bool,
+    pub allow_sampling: bool,
+    pub allow_logprobs: bool,
+    pub allow_search_indices: bool,
+    pub allow_view: bool,
+    pub allow_fine_tuning: bool,
+    pub organization: String,
+    pub is_blocking: bool,
+    // TODO Check this prop (seen in API responses but undocumented).
+    // pub group: ???,
+}

src/v1/tool.rs

@@ -0,0 +1,134 @@
+use async_trait::async_trait;
+use serde::{Deserialize, Serialize};
+use std::{any::Any, collections::HashMap};
+
+// -----------------------------------------------------------------------------
+// Definitions
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+pub struct ToolCall {
+    pub function: ToolCallFunction,
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+pub struct ToolCallFunction {
+    pub name: String,
+    pub arguments: String,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct Tool {
+    pub r#type: ToolType,
+    pub function: ToolFunction,
+}
+impl Tool {
+    pub fn new(
+        function_name: String,
+        function_description: String,
+        function_parameters: Vec<ToolFunctionParameter>,
+    ) -> Self {
+        let properties: HashMap<String, ToolFunctionParameterProperty> = function_parameters
+            .into_iter()
+            .map(|param| {
+                (
+                    param.name,
+                    ToolFunctionParameterProperty {
+                        r#type: param.r#type,
+                        description: param.description,
+                    },
+                )
+            })
+            .collect();
+        let property_names = properties.keys().cloned().collect();
+
+        let parameters = ToolFunctionParameters {
+            r#type: ToolFunctionParametersType::Object,
+            properties,
+            required: property_names,
+        };
+
+        Self {
+            r#type: ToolType::Function,
+            function: ToolFunction {
+                name: function_name,
+                description: function_description,
+                parameters,
+            },
+        }
+    }
+}
+
+// -----------------------------------------------------------------------------
+// Request
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ToolFunction {
+    name: String,
+    description: String,
+    parameters: ToolFunctionParameters,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ToolFunctionParameter {
+    name: String,
+    description: String,
+    r#type: ToolFunctionParameterType,
+}
+impl ToolFunctionParameter {
+    pub fn new(name: String, description: String, r#type: ToolFunctionParameterType) -> Self {
+        Self {
+            name,
+            r#type,
+            description,
+        }
+    }
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ToolFunctionParameters {
+    r#type: ToolFunctionParametersType,
+    properties: HashMap<String, ToolFunctionParameterProperty>,
+    required: Vec<String>,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ToolFunctionParameterProperty {
+    r#type: ToolFunctionParameterType,
+    description: String,
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+pub enum ToolFunctionParametersType {
+    #[serde(rename = "object")]
+    Object,
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+pub enum ToolFunctionParameterType {
+    #[serde(rename = "string")]
+    String,
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+pub enum ToolType {
+    #[serde(rename = "function")]
+    Function,
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Deserialize, Serialize)]
+pub enum ToolChoice {
+    #[serde(rename = "any")]
+    Any,
+    #[serde(rename = "auto")]
+    Auto,
+    #[serde(rename = "none")]
+    None,
+}
+
+// -----------------------------------------------------------------------------
+// Custom
+
+#[async_trait]
+pub trait Function {
+    async fn execute(&self, arguments: String) -> Box<dyn Any + Send>;
+}

src/v1/utils.rs

@@ -0,0 +1,32 @@
+use std::fmt::Debug;
+
+use log::debug;
+use serde::Serialize;
+
+pub fn prettify_json_string(json: &String) -> String {
+    match serde_json::from_str::<serde_json::Value>(&json) {
+        Ok(json_value) => {
+            serde_json::to_string_pretty(&json_value).unwrap_or_else(|_| json.to_owned())
+        }
+        Err(_) => json.to_owned(),
+    }
+}
+
+pub fn prettify_json_struct<T: Debug + Serialize>(value: T) -> String {
+    match serde_json::to_string_pretty(&value) {
+        Ok(pretty_json) => pretty_json,
+        Err(_) => format!("{:?}", value),
+    }
+}
+
+pub fn debug_pretty_json_from_string(label: &str, json: &String) -> () {
+    let pretty_json = prettify_json_string(json);
+
+    debug!("{label}: {}", pretty_json);
+}
+
+pub fn debug_pretty_json_from_struct<T: Debug + Serialize>(label: &str, value: &T) -> () {
+    let pretty_json = prettify_json_struct(value);
+
+    debug!("{label}: {}", pretty_json);
+}

tests/setup.rs

@@ -0,0 +1,3 @@
+pub fn setup() {
+    let _ = env_logger::builder().is_test(true).try_init();
+}

tests/v1_chat_completion_test.rs

@@ -1,53 +0,0 @@
-use jrest::expect;
-use mistralai_client::v1::{
-    chat_completion::{
-        ChatCompletionMessage, ChatCompletionMessageRole, ChatCompletionRequest,
-        ChatCompletionRequestOptions,
-    },
-    client::Client,
-    constants::OPEN_MISTRAL_7B,
-};
-
-#[test]
-fn test_chat_completion() {
-    extern crate dotenv;
-
-    use dotenv::dotenv;
-    dotenv().ok();
-
-    let client = Client::new(None, None, None, None);
-
-    let model = OPEN_MISTRAL_7B.to_string();
-    let messages = vec![ChatCompletionMessage {
-        role: ChatCompletionMessageRole::user,
-        content: "Just guess the next word: \"Eiffel ...\"?".to_string(),
-    }];
-    let options = ChatCompletionRequestOptions {
-        temperature: Some(0.0),
-        random_seed: Some(42),
-        ..Default::default()
-    };
-
-    let chat_completion_request = ChatCompletionRequest::new(model, messages, Some(options));
-    let result = client.chat(chat_completion_request);
-
-    match result {
-        Ok(res) => {
-            expect!(res.model).to_be("open-mistral-7b".to_string());
-            expect!(res.object).to_be("chat.completion".to_string());
-            expect!(res.choices.len()).to_be(1);
-            expect!(res.choices[0].index).to_be(0);
-            expect!(res.choices[0].message.role.clone())
-                .to_be(ChatCompletionMessageRole::assistant);
-            expect!(res.choices[0].message.content.clone()).to_be(
-                "Tower. The Eiffel Tower is a famous landmark in Paris, France.".to_string(),
-            );
-            expect!(res.usage.prompt_tokens).to_be_greater_than(0);
-            expect!(res.usage.completion_tokens).to_be_greater_than(0);
-            expect!(res.usage.total_tokens).to_be_greater_than(21);
-        }
-        Err(err) => {
-            panic!("Error: {}", err);
-        }
-    }
-}

tests/v1_client_chat_async_test.rs

@@ -0,0 +1,101 @@
+use jrest::expect;
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams, ChatResponseChoiceFinishReason},
+    client::Client,
+    constants::Model,
+    tool::{Tool, ToolChoice, ToolFunctionParameter, ToolFunctionParameterType},
+};
+
+mod setup;
+
+#[tokio::test]
+async fn test_client_chat_async() {
+    setup::setup();
+
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let model = Model::OpenMistral7b;
+    let messages = vec![ChatMessage::new_user_message(
+        "Just guess the next word: \"Eiffel ...\"?",
+    )];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        ..Default::default()
+    };
+
+    let response = client
+        .chat_async(model, messages, Some(options))
+        .await
+        .unwrap();
+
+    expect!(response.model).to_be(Model::OpenMistral7b);
+    expect!(response.object).to_be("chat.completion".to_string());
+
+    expect!(response.choices.len()).to_be(1);
+    expect!(response.choices[0].index).to_be(0);
+    expect!(response.choices[0].finish_reason.clone()).to_be(ChatResponseChoiceFinishReason::Stop);
+
+    expect!(response.choices[0].message.role.clone()).to_be(ChatMessageRole::Assistant);
+    expect!(response.choices[0].message.content.clone())
+        .to_be("Tower. The Eiffel Tower is a famous landmark in Paris, France.".to_string());
+
+    expect!(response.usage.prompt_tokens).to_be_greater_than(0);
+    expect!(response.usage.completion_tokens).to_be_greater_than(0);
+    expect!(response.usage.total_tokens).to_be_greater_than(0);
+}
+
+#[tokio::test]
+async fn test_client_chat_async_with_function_calling() {
+    setup::setup();
+
+    let tools = vec![Tool::new(
+        "get_city_temperature".to_string(),
+        "Get the current temperature in a city.".to_string(),
+        vec![ToolFunctionParameter::new(
+            "city".to_string(),
+            "The name of the city.".to_string(),
+            ToolFunctionParameterType::String,
+        )],
+    )];
+
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let model = Model::MistralSmallLatest;
+    let messages = vec![ChatMessage::new_user_message(
+        "What's the current temperature in Paris?",
+    )];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        tool_choice: Some(ToolChoice::Any),
+        tools: Some(tools),
+        ..Default::default()
+    };
+
+    let response = client
+        .chat_async(model, messages, Some(options))
+        .await
+        .unwrap();
+
+    expect!(response.model).to_be(Model::MistralSmallLatest);
+    expect!(response.object).to_be("chat.completion".to_string());
+
+    expect!(response.choices.len()).to_be(1);
+    expect!(response.choices[0].index).to_be(0);
+    expect!(response.choices[0].finish_reason.clone())
+        .to_be(ChatResponseChoiceFinishReason::ToolCalls);
+
+    expect!(response.choices[0].message.role.clone()).to_be(ChatMessageRole::Assistant);
+    expect!(response.choices[0].message.content.clone()).to_be("".to_string());
+    // expect!(response.choices[0].message.tool_calls.clone()).to_be(Some(vec![ToolCall {
+    //     function: ToolCallFunction {
+    //         name: "get_city_temperature".to_string(),
+    //         arguments: "{\"city\": \"Paris\"}".to_string(),
+    //     },
+    // }]));
+
+    expect!(response.usage.prompt_tokens).to_be_greater_than(0);
+    expect!(response.usage.completion_tokens).to_be_greater_than(0);
+    expect!(response.usage.total_tokens).to_be_greater_than(0);
+}

tests/v1_client_chat_stream_test.rs

@@ -0,0 +1,40 @@
+// use futures::stream::StreamExt;
+// use jrest::expect;
+// use mistralai_client::v1::{
+//     chat_completion::{ChatParams, ChatMessage, ChatMessageRole},
+//     client::Client,
+//     constants::Model,
+// };
+
+// #[tokio::test]
+// async fn test_client_chat_stream() {
+//     let client = Client::new(None, None, None, None).unwrap();
+
+//     let model = Model::OpenMistral7b;
+//     let messages = vec![ChatMessage::new_user_message(
+//         "Just guess the next word: \"Eiffel ...\"?",
+//     )];
+//     let options = ChatParams {
+//         temperature: Some(0.0),
+//         random_seed: Some(42),
+//         ..Default::default()
+//     };
+
+//     let stream_result = client.chat_stream(model, messages, Some(options)).await;
+//     let mut stream = stream_result.expect("Failed to create stream.");
+//     while let Some(maybe_chunk_result) = stream.next().await {
+//         match maybe_chunk_result {
+//             Some(Ok(chunk)) => {
+//                 if chunk.choices[0].delta.role == Some(ChatMessageRole::Assistant)
+//                     || chunk.choices[0].finish_reason == Some("stop".to_string())
+//                 {
+//                     expect!(chunk.choices[0].delta.content.len()).to_be(0);
+//                 } else {
+//                     expect!(chunk.choices[0].delta.content.len()).to_be_greater_than(0);
+//                 }
+//             }
+//             Some(Err(error)) => eprintln!("Error processing chunk: {:?}", error),
+//             None => (),
+//         }
+//     }
+// }

tests/v1_client_chat_test.rs

@@ -0,0 +1,83 @@
+use jrest::expect;
+use mistralai_client::v1::{
+    chat::{ChatMessage, ChatMessageRole, ChatParams, ChatResponseChoiceFinishReason},
+    client::Client,
+    constants::Model,
+    tool::{Tool, ToolChoice, ToolFunctionParameter, ToolFunctionParameterType},
+};
+
+mod setup;
+
+#[test]
+fn test_client_chat() {
+    setup::setup();
+
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let model = Model::OpenMistral7b;
+    let messages = vec![ChatMessage::new_user_message(
+        "Just guess the next word: \"Eiffel ...\"?",
+    )];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        ..Default::default()
+    };
+
+    let response = client.chat(model, messages, Some(options)).unwrap();
+
+    expect!(response.model).to_be(Model::OpenMistral7b);
+    expect!(response.object).to_be("chat.completion".to_string());
+    expect!(response.choices.len()).to_be(1);
+    expect!(response.choices[0].index).to_be(0);
+    expect!(response.choices[0].message.role.clone()).to_be(ChatMessageRole::Assistant);
+    expect!(response.choices[0].message.content.clone())
+        .to_be("Tower. The Eiffel Tower is a famous landmark in Paris, France.".to_string());
+    expect!(response.choices[0].finish_reason.clone()).to_be(ChatResponseChoiceFinishReason::Stop);
+    expect!(response.usage.prompt_tokens).to_be_greater_than(0);
+    expect!(response.usage.completion_tokens).to_be_greater_than(0);
+    expect!(response.usage.total_tokens).to_be_greater_than(0);
+}
+
+#[test]
+fn test_client_chat_with_function_calling() {
+    setup::setup();
+
+    let tools = vec![Tool::new(
+        "get_city_temperature".to_string(),
+        "Get the current temperature in a city.".to_string(),
+        vec![ToolFunctionParameter::new(
+            "city".to_string(),
+            "The name of the city.".to_string(),
+            ToolFunctionParameterType::String,
+        )],
+    )];
+
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let model = Model::MistralSmallLatest;
+    let messages = vec![ChatMessage::new_user_message(
+        "What's the current temperature in Paris?",
+    )];
+    let options = ChatParams {
+        temperature: Some(0.0),
+        random_seed: Some(42),
+        tool_choice: Some(ToolChoice::Auto),
+        tools: Some(tools),
+        ..Default::default()
+    };
+
+    let response = client.chat(model, messages, Some(options)).unwrap();
+
+    expect!(response.model).to_be(Model::MistralSmallLatest);
+    expect!(response.object).to_be("chat.completion".to_string());
+    expect!(response.choices.len()).to_be(1);
+    expect!(response.choices[0].index).to_be(0);
+    expect!(response.choices[0].message.role.clone()).to_be(ChatMessageRole::Assistant);
+    expect!(response.choices[0].message.content.clone()).to_be("".to_string());
+    expect!(response.choices[0].finish_reason.clone())
+        .to_be(ChatResponseChoiceFinishReason::ToolCalls);
+    expect!(response.usage.prompt_tokens).to_be_greater_than(0);
+    expect!(response.usage.completion_tokens).to_be_greater_than(0);
+    expect!(response.usage.total_tokens).to_be_greater_than(0);
+}

tests/v1_client_embeddings_async_test.rs

@@ -0,0 +1,29 @@
+use jrest::expect;
+use mistralai_client::v1::{client::Client, constants::EmbedModel};
+
+#[tokio::test]
+async fn test_client_embeddings_async() {
+    let client: Client = Client::new(None, None, None, None).unwrap();
+
+    let model = EmbedModel::MistralEmbed;
+    let input = vec!["Embed this sentence.", "As well as this one."]
+        .iter()
+        .map(|s| s.to_string())
+        .collect();
+    let options = None;
+
+    let response = client
+        .embeddings_async(model, input, options)
+        .await
+        .unwrap();
+
+    expect!(response.model).to_be(EmbedModel::MistralEmbed);
+    expect!(response.object).to_be("list".to_string());
+    expect!(response.data.len()).to_be(2);
+    expect!(response.data[0].index).to_be(0);
+    expect!(response.data[0].object.clone()).to_be("embedding".to_string());
+    expect!(response.data[0].embedding.len()).to_be_greater_than(0);
+    expect!(response.usage.prompt_tokens).to_be_greater_than(0);
+    expect!(response.usage.completion_tokens).to_be(0);
+    expect!(response.usage.total_tokens).to_be_greater_than(0);
+}

tests/v1_client_embeddings_test.rs

@@ -0,0 +1,26 @@
+use jrest::expect;
+use mistralai_client::v1::{client::Client, constants::EmbedModel};
+
+#[test]
+fn test_client_embeddings() {
+    let client: Client = Client::new(None, None, None, None).unwrap();
+
+    let model = EmbedModel::MistralEmbed;
+    let input = vec!["Embed this sentence.", "As well as this one."]
+        .iter()
+        .map(|s| s.to_string())
+        .collect();
+    let options = None;
+
+    let response = client.embeddings(model, input, options).unwrap();
+
+    expect!(response.model).to_be(EmbedModel::MistralEmbed);
+    expect!(response.object).to_be("list".to_string());
+    expect!(response.data.len()).to_be(2);
+    expect!(response.data[0].index).to_be(0);
+    expect!(response.data[0].object.clone()).to_be("embedding".to_string());
+    expect!(response.data[0].embedding.len()).to_be_greater_than(0);
+    expect!(response.usage.prompt_tokens).to_be_greater_than(0);
+    expect!(response.usage.completion_tokens).to_be(0);
+    expect!(response.usage.total_tokens).to_be_greater_than(0);
+}

tests/v1_client_list_models_async_test.rs

@@ -0,0 +1,12 @@
+use jrest::expect;
+use mistralai_client::v1::client::Client;
+
+#[tokio::test]
+async fn test_client_list_models_async() {
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let response = client.list_models_async().await.unwrap();
+
+    expect!(response.object).to_be("list".to_string());
+    expect!(response.data.len()).to_be_greater_than(0);
+}

tests/v1_client_list_models_test.rs

@@ -0,0 +1,12 @@
+use jrest::expect;
+use mistralai_client::v1::client::Client;
+
+#[test]
+fn test_client_list_models() {
+    let client = Client::new(None, None, None, None).unwrap();
+
+    let response = client.list_models().unwrap();
+
+    expect!(response.object).to_be("list".to_string());
+    expect!(response.data.len()).to_be_greater_than(0);
+}

tests/v1_client_new_test.rs

@@ -0,0 +1,106 @@
+use jrest::expect;
+use mistralai_client::v1::{client::Client, error::ClientError};
+
+#[test]
+fn test_client_new_with_none_params() {
+    let maybe_original_mistral_api_key = std::env::var("MISTRAL_API_KEY").ok();
+    std::env::remove_var("MISTRAL_API_KEY");
+    std::env::set_var("MISTRAL_API_KEY", "test_api_key_from_env");
+
+    let client = Client::new(None, None, None, None).unwrap();
+
+    expect!(client.api_key).to_be("test_api_key_from_env".to_string());
+    expect!(client.endpoint).to_be("https://api.mistral.ai/v1".to_string());
+    expect!(client.max_retries).to_be(5);
+    expect!(client.timeout).to_be(120);
+
+    match maybe_original_mistral_api_key {
+        Some(original_mistral_api_key) => {
+            std::env::set_var("MISTRAL_API_KEY", original_mistral_api_key)
+        }
+        None => std::env::remove_var("MISTRAL_API_KEY"),
+    }
+}
+
+#[test]
+fn test_client_new_with_all_params() {
+    let maybe_original_mistral_api_key = std::env::var("MISTRAL_API_KEY").ok();
+    std::env::remove_var("MISTRAL_API_KEY");
+
+    let api_key = Some("test_api_key_from_param".to_string());
+    let endpoint = Some("https://example.org".to_string());
+    let max_retries = Some(10);
+    let timeout = Some(20);
+
+    let client = Client::new(
+        api_key.clone(),
+        endpoint.clone(),
+        max_retries.clone(),
+        timeout.clone(),
+    )
+    .unwrap();
+
+    expect!(client.api_key).to_be(api_key.unwrap());
+    expect!(client.endpoint).to_be(endpoint.unwrap());
+    expect!(client.max_retries).to_be(max_retries.unwrap());
+    expect!(client.timeout).to_be(timeout.unwrap());
+
+    match maybe_original_mistral_api_key {
+        Some(original_mistral_api_key) => {
+            std::env::set_var("MISTRAL_API_KEY", original_mistral_api_key)
+        }
+        None => std::env::remove_var("MISTRAL_API_KEY"),
+    }
+}
+
+#[test]
+fn test_client_new_with_api_key_as_both_env_and_param() {
+    let maybe_original_mistral_api_key = std::env::var("MISTRAL_API_KEY").ok();
+    std::env::remove_var("MISTRAL_API_KEY");
+    std::env::set_var("MISTRAL_API_KEY", "test_api_key_from_env");
+
+    let api_key = Some("test_api_key_from_param".to_string());
+    let endpoint = Some("https://example.org".to_string());
+    let max_retries = Some(10);
+    let timeout = Some(20);
+
+    let client = Client::new(
+        api_key.clone(),
+        endpoint.clone(),
+        max_retries.clone(),
+        timeout.clone(),
+    )
+    .unwrap();
+
+    expect!(client.api_key).to_be(api_key.unwrap());
+    expect!(client.endpoint).to_be(endpoint.unwrap());
+    expect!(client.max_retries).to_be(max_retries.unwrap());
+    expect!(client.timeout).to_be(timeout.unwrap());
+
+    match maybe_original_mistral_api_key {
+        Some(original_mistral_api_key) => {
+            std::env::set_var("MISTRAL_API_KEY", original_mistral_api_key)
+        }
+        None => std::env::remove_var("MISTRAL_API_KEY"),
+    }
+}
+
+#[test]
+fn test_client_new_with_missing_api_key() {
+    let maybe_original_mistral_api_key = std::env::var("MISTRAL_API_KEY").ok();
+    std::env::remove_var("MISTRAL_API_KEY");
+
+    let call = || Client::new(None, None, None, None);
+
+    match call() {
+        Ok(_) => panic!("Expected `ClientError::MissingApiKey` but got Ok.`"),
+        Err(error) => assert_eq!(error, ClientError::MissingApiKey),
+    }
+
+    match maybe_original_mistral_api_key {
+        Some(original_mistral_api_key) => {
+            std::env::set_var("MISTRAL_API_KEY", original_mistral_api_key)
+        }
+        None => std::env::remove_var("MISTRAL_API_KEY"),
+    }
+}

tests/v1_client_test.rs

@@ -1,52 +0,0 @@
-use jrest::expect;
-use mistralai_client::v1::client::Client;
-
-#[test]
-fn test_client_new_with_none_params() {
-    let maybe_original_mistral_api_key = std::env::var("MISTRAL_API_KEY").ok();
-    std::env::set_var("MISTRAL_API_KEY", "test_api_key_from_env");
-
-    let client = Client::new(None, None, None, None);
-
-    expect!(client.api_key).to_be("test_api_key_from_env".to_string());
-    expect!(client.endpoint).to_be("https://api.mistral.ai/v1".to_string());
-    expect!(client.max_retries).to_be(5);
-    expect!(client.timeout).to_be(120);
-
-    match maybe_original_mistral_api_key {
-        Some(original_mistral_api_key) => {
-            std::env::set_var("MISTRAL_API_KEY", original_mistral_api_key)
-        }
-        None => std::env::remove_var("MISTRAL_API_KEY"),
-    }
-}
-
-#[test]
-fn test_client_new_with_all_params() {
-    let maybe_original_mistral_api_key = std::env::var("MISTRAL_API_KEY").ok();
-    std::env::set_var("MISTRAL_API_KEY", "test_api_key_from_env");
-
-    let api_key = Some("test_api_key_from_param".to_string());
-    let endpoint = Some("https://example.org".to_string());
-    let max_retries = Some(10);
-    let timeout = Some(20);
-
-    let client = Client::new(
-        api_key.clone(),
-        endpoint.clone(),
-        max_retries.clone(),
-        timeout.clone(),
-    );
-
-    expect!(client.api_key).to_be(api_key.unwrap());
-    expect!(client.endpoint).to_be(endpoint.unwrap());
-    expect!(client.max_retries).to_be(max_retries.unwrap());
-    expect!(client.timeout).to_be(timeout.unwrap());
-
-    match maybe_original_mistral_api_key {
-        Some(original_mistral_api_key) => {
-            std::env::set_var("MISTRAL_API_KEY", original_mistral_api_key)
-        }
-        None => std::env::remove_var("MISTRAL_API_KEY"),
-    }
-}