mirror of
https://github.com/NovaOSS/nova-python.git
synced 2024-11-29 10:13:59 +01:00
Compare commits
No commits in common. "7b3be882381b4ff61752738bef3216b31ecee6ab" and "59b7c6073aa95361f68aac79dedd7ae2565327ae" have entirely different histories.
7b3be88238
...
59b7c6073a
2
.gitignore
vendored
2
.gitignore
vendored
|
@ -96,5 +96,3 @@ valgrind-python.supp
|
|||
*.pyd
|
||||
lcov.info
|
||||
netlify_build/
|
||||
|
||||
build.sh
|
|
@ -1,6 +1,6 @@
|
|||
[package]
|
||||
name = "nova-python"
|
||||
version = "0.1.5"
|
||||
version = "0.1.2"
|
||||
edition = "2021"
|
||||
|
||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||
|
@ -9,7 +9,6 @@ name = "nova_python"
|
|||
crate-type = ["cdylib"]
|
||||
|
||||
[dependencies]
|
||||
pyo3 = {version = "0.19.2", features = ["extension-module", "generate-import-lib"]}
|
||||
pyo3 = "0.19.0"
|
||||
reqwest = "0.11.18"
|
||||
tokio = { version = "1.29.1", features = ["rt-multi-thread", "time"] }
|
||||
serde_json = "1.0.104"
|
31
README.md
31
README.md
|
@ -36,7 +36,7 @@ Now, to make a request, use the `make_request` function. For example:
|
|||
from nova_python import Endpoints, Models, NovaClient
|
||||
client = NovaClient("YOUR_API_KEY")
|
||||
|
||||
reponse = client.make_request(
|
||||
client.make_request(
|
||||
endpoint=Endpoints.CHAT_COMPLETION,
|
||||
model=Models.GPT3,
|
||||
data=[
|
||||
|
@ -44,8 +44,6 @@ reponse = client.make_request(
|
|||
{"role": "user", "content": "Hello!"}
|
||||
]
|
||||
)
|
||||
|
||||
...
|
||||
```
|
||||
|
||||
or
|
||||
|
@ -54,36 +52,15 @@ or
|
|||
from nova_python import Endpoints, Models, NovaClient
|
||||
client = NovaClient("YOUR_API_KEY")
|
||||
|
||||
reponse = client.make_request(
|
||||
client.make_request(
|
||||
endpoint=Endpoints.MODERATION,
|
||||
model=Models.MODERATION_STABLE,
|
||||
data=[{"input": "I'm going to kill them."}]
|
||||
)
|
||||
|
||||
...
|
||||
```
|
||||
|
||||
|
||||
If everything goes to plan, you'll receive a string containing JSON-Data, which you can then use in your project.
|
||||
|
||||
Note, that when using chat completion, as special ChatResponse-Instance get's returned.
|
||||
You can access the reponse's json.data, by casting it to a string using the `str` method, like this:
|
||||
```python
|
||||
...
|
||||
|
||||
str(reponse)
|
||||
|
||||
...
|
||||
```
|
||||
|
||||
but more importantly, you can use it's `get_message_content` function, to directly get access to the chat reponse. Used like this:
|
||||
```
|
||||
...
|
||||
|
||||
content = reponse.get_message_content()
|
||||
|
||||
...
|
||||
```
|
||||
|
||||
|
||||
*Happy prompting!*
|
||||
<br><br>
|
||||
## FAQ ##
|
||||
|
|
61
src/lib.rs
61
src/lib.rs
|
@ -54,7 +54,7 @@ impl NovaClient {
|
|||
}
|
||||
|
||||
// Used to make a request to the Nova API
|
||||
fn make_request(&self, endpoint: Endpoints, model: Models, data: Vec<Py<PyDict>>, seconds_until_timeout: Option<usize>) -> PyResult<PyObject> {
|
||||
fn make_request(&self, endpoint: Endpoints, model: Models, data: Vec<Py<PyDict>>, seconds_until_timeout: Option<String>) -> PyResult<String> {
|
||||
if !model_is_compatible(&endpoint, &model) {
|
||||
return Err(NovaClient::get_endpoint_not_compatible_error());
|
||||
}
|
||||
|
@ -64,13 +64,13 @@ impl NovaClient {
|
|||
|
||||
let rt = tokio::runtime::Runtime::new().unwrap();
|
||||
let seconds_until_timeout = match seconds_until_timeout {
|
||||
Some(seconds_until_timeout) => seconds_until_timeout,
|
||||
Some(seconds_until_timeout) => seconds_until_timeout.parse::<u64>().unwrap(),
|
||||
None => 30
|
||||
};
|
||||
|
||||
let unmatched_response: Result<String, reqwest::Error> = rt.block_on(async {
|
||||
let response: Result<String, reqwest::Error> = rt.block_on(async {
|
||||
let client = reqwest::Client::builder()
|
||||
.timeout(time::Duration::from_secs(seconds_until_timeout as u64))
|
||||
.timeout(time::Duration::from_secs(seconds_until_timeout))
|
||||
.user_agent("Mozilla/5.0")
|
||||
.build()
|
||||
.unwrap();
|
||||
|
@ -86,25 +86,9 @@ impl NovaClient {
|
|||
Ok(text)
|
||||
});
|
||||
|
||||
let reponse = match unmatched_response {
|
||||
Ok(unmatched_response) => Ok(unmatched_response),
|
||||
Err(unmatched_response) => Err(pyo3::exceptions::PyRuntimeError::new_err(unmatched_response.to_string()))
|
||||
}.unwrap();
|
||||
|
||||
if endpoint == Endpoints::ChatCompletion {
|
||||
let final_reponse = Python::with_gil(|py| {
|
||||
let reponse = ChatResponse::new(reponse);
|
||||
reponse.into_py(py)
|
||||
});
|
||||
|
||||
return Ok(final_reponse);
|
||||
|
||||
} else {
|
||||
let final_reponse = Python::with_gil(|py| {
|
||||
reponse.into_py(py)
|
||||
});
|
||||
|
||||
return Ok(final_reponse);
|
||||
match response {
|
||||
Ok(response) => Ok(response),
|
||||
Err(response) => Err(pyo3::exceptions::PyRuntimeError::new_err(response.to_string()))
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -197,36 +181,9 @@ impl NovaClient {
|
|||
fn get_invalid_model_error() -> PyErr {
|
||||
pyo3::exceptions::PyValueError::new_err("Invalid model")
|
||||
}
|
||||
}
|
||||
|
||||
#[pyclass(module = "nova_python", frozen)]
|
||||
struct ChatResponse {
|
||||
json: String,
|
||||
}
|
||||
|
||||
#[pymethods]
|
||||
impl ChatResponse {
|
||||
#[new]
|
||||
fn new(json: String) -> Self {
|
||||
ChatResponse {
|
||||
json
|
||||
}
|
||||
}
|
||||
|
||||
fn get_message_content(&self) -> PyResult<String> {
|
||||
let json = &self.json;
|
||||
let json: serde_json::Value = serde_json::from_str(json).unwrap();
|
||||
|
||||
let content = json["choices"][0]["message"]["content"].as_str().unwrap();
|
||||
Ok(content.trim().to_string())
|
||||
}
|
||||
|
||||
fn __str__(&self) -> PyResult<String> {
|
||||
Ok(self.json.clone())
|
||||
}
|
||||
|
||||
fn __repr__(&self) -> PyResult<String> {
|
||||
Ok(format!("ChatResponse(json={})", self.json))
|
||||
fn get_request_failed_error() -> PyErr {
|
||||
pyo3::exceptions::PyRuntimeError::new_err("Request failed for unknown reasons.")
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in a new issue