oxi-ai 0.63.0

Unified LLM API — multi-provider streaming interface for AI coding assistants
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

//! Google Gemini CLI transport — explicit typed unsupported-provider path.
//!
//! `Api::GoogleGeminiCli` is a first-class dialect in `oxi_catalog::api::Api`
//! and appears in the model catalog for the `google-gemini-cli` provider.
//! However, the Gemini CLI is a remote-AGENT protocol without a dedicated
//! transport (no `proto/`, no bundled SDK), and the upstream openclaw port
//! collapses it to `google-generative-ai` (`scripts/catalog/port-openclaw.py:48`).
//!
//! Before this module existed, the `build_builtin_transport` factory arm
//! for `Api::GoogleGeminiCli` fell through to `_ => None`, which silently
//! surfaced as `ProviderError::UnknownProvider("google-gemini-cli")` downstream.
//!
//! This transport keeps the factory dispatch non-`None` (so resolution does
//! not silently miss) while surfacing a typed `ProviderError::NotImplemented`
//! error at the moment the caller actually invokes `stream()`. No fake
//! success, no fabricated HTTP traffic.
//!
//! When a real Gemini CLI protocol is integrated (likely a local
//! subprocess / OAuth helper), replace the body of `Provider::stream` with
//! the real implementation — the rest of the dispatch path stays unchanged.

use std::future::Future;
use std::pin::Pin;

use crate::error::ProviderError;
use crate::{Context, Model, Provider, StreamOptions, StreamResult};

/// Thin transport for the `google-gemini-cli` dialect.
///
/// Carries no identity — the canonical catalog id is the registry key (see
/// `oxi_ai::providers::register_builtins::create_builtin_provider`).
#[derive(Clone, Default)]
pub struct GeminiCliProvider;

impl GeminiCliProvider {
    /// Construct a new `GeminiCliProvider`.
    pub fn new() -> Self {
        Self
    }
}

impl Provider for GeminiCliProvider {
    fn stream<'a>(
        &'a self,
        _model: &'a Model,
        _context: &'a Context,
        _options: Option<StreamOptions>,
    ) -> Pin<Box<dyn Future<Output = StreamResult> + Send + 'a>> {
        Box::pin(async move {
            Err(ProviderError::NotImplemented(
                "google-gemini-cli: no dedicated transport in oxi-ai; \
                 upstream collapses to google-generative-ai. \
                 Use the `google` provider instead."
                    .into(),
            ))
        })
    }
}