openkind-api 0.2.0

Phase 1: HTTP (axum) and gRPC (tonic) protocol layer for openkind.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

use axum::http::StatusCode;
use serde_json::Value;

use super::helpers::{body_bytes, get};

#[tokio::test]
async fn models_list_returns_jev_top_level_models_array() {
    let (status, resp) = get("/v1/models", &[]).await;
    assert_eq!(status, StatusCode::OK);
    let v: Value = serde_json::from_slice(&body_bytes(resp).await).unwrap();
    // Top-level `models` array (per spec).
    assert!(v["models"].is_array(), "expected `models` array, got {v}");
    // No OpenAI-style `data`/`object` keys.
    assert!(v.get("data").is_none());
    assert!(v.get("object").is_none());
}

#[tokio::test]
async fn models_list_entries_have_required_fields() {
    // Spec: name/description/release_date all required.
    let (_, resp) = get("/v1/models", &[]).await;
    let v: Value = serde_json::from_slice(&body_bytes(resp).await).unwrap();
    for entry in v["models"].as_array().unwrap() {
        assert!(entry["name"].is_string(), "missing name");
        assert!(entry["description"].is_string(), "missing description");
        assert!(entry["release_date"].is_string(), "missing release_date");
    }
}

#[tokio::test]
async fn models_list_name_matches_alias_sent_to_systemone() {
    // Spec: "name: The model ID or alias, as accepted by the model field."
    let (_, models_resp) = get("/v1/models", &[]).await;
    let models: Value = serde_json::from_slice(&body_bytes(models_resp).await).unwrap();
    let names: Vec<&str> = models["models"]
        .as_array()
        .unwrap()
        .iter()
        .map(|m| m["name"].as_str().unwrap())
        .collect();
    // The SDK quickstart uses `model="jev-latest"` by default.
    assert!(names.contains(&"mock"));
    assert!(names.contains(&"jev-latest"));
}

#[tokio::test]
async fn models_list_is_sorted() {
    let (_, resp) = get("/v1/models", &[]).await;
    let v: Value = serde_json::from_slice(&body_bytes(resp).await).unwrap();
    let names: Vec<String> = v["models"]
        .as_array()
        .unwrap()
        .iter()
        .map(|m| m["name"].as_str().unwrap().to_string())
        .collect();
    let mut sorted = names.clone();
    sorted.sort();
    assert_eq!(names, sorted);
}

#[tokio::test]
async fn models_list_response_keys_match_python_sdk() {
    // SDK type: ListModelsResponse { models: tuple[ModelMetadata, ...] }
    // ModelMetadata { name, description, release_date }.
    let (_, resp) = get("/v1/models", &[]).await;
    let v: Value = serde_json::from_slice(&body_bytes(resp).await).unwrap();
    let arr = v["models"].as_array().expect("`models` is an array");
    assert!(!arr.is_empty());
    for m in arr {
        // Every key the SDK reads must be present and a string.
        for key in ["name", "description", "release_date"] {
            assert!(m[key].is_string(), "{key} must be a string, got {m:?}");
        }
    }
}