kopitiam-ai 0.2.3

Pluggable model adapters (local Qwen, Claude, GPT, Gemini) for KOPITIAM's Semantic Runtime.
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

//! Pluggable model adapters for KOPITIAM's Semantic Runtime.
//!
//! This crate defines the [`ModelAdapter`] trait — the sole boundary through
//! which a model (local Qwen, Claude, GPT, Gemini, ...) is invoked anywhere
//! in the platform. Per the Semantic Runtime's dependency rule, only
//! `kopitiam-workflow` depends on this crate; everything else in the
//! platform (`kopitiam-knowledge`, `kopitiam-index`, `kopitiam-search`,
//! `kopitiam-workspace`, `kopitiam-translation`) stays model-agnostic.
//!
//! What lives here is the shape of a request/response
//! ([`CompletionRequest`], [`CompletionResponse`], [`Message`]), one
//! deterministic stub adapter ([`EchoAdapter`], always available) so
//! `kopitiam-workflow` has something real to compile and test against with
//! no weights and no network, and — behind the default-on `local` Cargo
//! feature — [`LocalAdapter`], a real, offline, on-CPU adapter backed by
//! `kopitiam-runtime`'s Qwen inference stack. See [`local`]'s module docs
//! for the full local-vs-cloud architecture and why depending on
//! `kopitiam-runtime` from here does not violate the Semantic Runtime's
//! dependency rule.
//!
//! Two other pieces round out the boundary for a live chat UI:
//!
//! * **Streaming** — alongside the blocking [`ModelAdapter::complete`], every
//!   adapter can [`ModelAdapter::stream`] its reply token-by-token over a
//!   channel of [`StreamChunk`]s, so a UI renders tokens as they land instead
//!   of freezing on a slow generation. [`EchoAdapter`] and [`LocalAdapter`]
//!   do this on a real background thread (the AID-0028 actor discipline, std
//!   threads + `mpsc`, no async runtime).
//! * **Cloud scaffold** — [`CloudAdapter`] + [`CloudStub`] for
//!   Claude/GPT/Gemini ([`CloudVendor`]), gated on an API key from the
//!   environment. Key-detection and the "no key → [`CloudUnavailable`]" path
//!   are real; the network layer itself is a deliberate follow-up.

mod adapter;
mod bilingual;
mod cloud;
mod echo;
mod glossary;
mod message;
mod preprocess;
mod stream;
mod translate;

#[cfg(feature = "local")]
mod local;

pub use adapter::ModelAdapter;
pub use bilingual::{
    BilingualOptions, BilingualSegment, Layout, ReviewCoverage, DEFAULT_REVIEW_THRESHOLD,
    REVIEW_MARKER, from_two_pass, render_bilingual, review_coverage, review_targets,
};
pub use cloud::{CloudAdapter, CloudStub, CloudUnavailable, CloudVendor};
pub use echo::EchoAdapter;
pub use glossary::{Applied, Entry, Glossary, SourceKind, Substitution};
#[cfg(feature = "local")]
pub use local::LocalAdapter;
pub use message::{CompletionRequest, CompletionResponse, Message, Role};
pub use preprocess::{
    Bucket, DiagnosticBuckets, DropReport, Preprocessed, ECHO_PASSTHROUGH_NOTE, classify_diagnostics,
    draft_commit_message, summarize, triage,
};
pub use stream::StreamChunk;
pub use translate::{
    ConfidenceSignals, Decision, SegmentPlan, TwoPassConfig, TwoPassPlan, TwoPassSummary,
    DEFAULT_ACCEPT_THRESHOLD, ECHO_PASSTHROUGH_NOTE as TWO_PASS_ECHO_PASSTHROUGH_NOTE,
    dice_similarity, draft_and_route, glossary_score, length_score,
};