Comprehensive audit: fix 18 implementation issues, expand test coverage to 1581 tests

CRITICAL fixes:
- Fix error_rate calculation using rolling window (state_manager.py)
- Fix HTTP streaming to read line-by-line instead of buffering (base_provider.py)
- Add context manager protocol to _StreamIterator (mesh_client.py)
- Fix shutdown() to properly close async provider connectors (mesh.py)
- Sync src/python/pyproject.toml version to 0.1.1

HIGH fixes:
- Add missing AudioSpeech/AudioTranscription exports (interfaces/__init__.py)
- Replace deprecated gpt-3.5-turbo with gpt-4o-mini (openai_provider.py)
- Add type annotation to dynamic require() in mesh.ts
- Add `implements ProviderConnector` to BrowserBaseProvider
- Fix _modelsByid typo to _modelsById (browser-provider.ts)

MEDIUM fixes:
- Fix Optional[dict] type annotations (observability.py)

Docs fixes:
- Fix pip install modelmesh → modelmesh-lite (DeveloperGuide.md)
- Fix Python version 3.10 → 3.11 (DeveloperGuide.md)
- Fix install path src/python[yaml] → .[yaml] (ProxyGuide.md)
- Mark unimplemented connectors and strategies as (Planned) (ConnectorCatalogue.md)

Sample fixes:
- Fix snake_case → camelCase in all TypeScript connector samples

Test coverage:
- Add 82 new Python tests for 5 previously untested modules (937 total)
- Expand TypeScript tests from 97 to 644 across 13 test suites

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: apartsin

docs/ConnectorCatalogue.md

@@ -301,13 +301,13 @@ Interface: [ConnectorInterfaces.md — Rotation Policy](ConnectorInterfaces.html
 | Policy | Description |
 | --- | --- |
 | **`rotation.modelmesh.stick-until-failure.v1`** | Use the current model until it fails, then rotate. Default policy. |
-| **`rotation.modelmesh.priority-selection.v1`** | Follow an ordered model/provider preference list; fall back on exhaust. |
-| **`rotation.modelmesh.round-robin.v1`** | Cycle through active models in sequence. |
-| **`rotation.modelmesh.cost-first.v1`** | Select the cheapest active model for each request. |
-| **`rotation.modelmesh.latency-first.v1`** | Select the model with the lowest observed latency. |
-| **`rotation.modelmesh.session-stickiness.v1`** | Route all requests in a session to the same model. |
-| **`rotation.modelmesh.rate-limit-aware.v1`** | Switch models preemptively before hitting rate limits. |
-| **`rotation.modelmesh.load-balanced.v1`** | Distribute requests proportionally to each model's rate-limit headroom. |
+| **`rotation.modelmesh.priority-selection.v1`** | *(Planned)* Follow an ordered model/provider preference list; fall back on exhaust. |
+| **`rotation.modelmesh.round-robin.v1`** | *(Planned)* Cycle through active models in sequence. |
+| **`rotation.modelmesh.cost-first.v1`** | *(Planned)* Select the cheapest active model for each request. |
+| **`rotation.modelmesh.latency-first.v1`** | *(Planned)* Select the model with the lowest observed latency. |
+| **`rotation.modelmesh.session-stickiness.v1`** | *(Planned)* Route all requests in a session to the same model. |
+| **`rotation.modelmesh.rate-limit-aware.v1`** | *(Planned)* Switch models preemptively before hitting rate limits. |
+| **`rotation.modelmesh.load-balanced.v1`** | *(Planned)* Distribute requests proportionally to each model's rate-limit headroom. |
 
 ---
 
@@ -319,10 +319,10 @@ Interface: [ConnectorInterfaces.md — Secret Store](ConnectorInterfaces.html#se
 | --- | --- | --- | --- |
 | **`secret-store.modelmesh.env.v1`** | Reads secrets from environment variables. Default store. | Built-in | - |
 | **`secret-store.modelmesh.dotenv.v1`** | Loads secrets from `.env` files. Ideal for local development. | Built-in | - |
-| **`secret-store.aws.secrets-manager.v1`** | Managed secret storage with automatic rotation and IAM integration | 30-day trial; then $0.40/secret/month + $0.05/10K calls | [aws.amazon.com/secrets-manager](https://aws.amazon.com/secrets-manager) |
-| **`secret-store.google.secret-manager.v1`** | Google Cloud managed secrets with IAM and audit logging | 6 active versions free; 10K access ops/month free | [cloud.google.com/secret-manager](https://cloud.google.com/secret-manager) |
-| **`secret-store.microsoft.key-vault.v1`** | Microsoft cloud secret, key, and certificate management | 10K operations/month free (Standard tier) | [azure.microsoft.com/en-us/products/key-vault](https://azure.microsoft.com/en-us/products/key-vault) |
-| **`secret-store.1password.connect.v1`** | Secrets Automation API for CI/CD and server-side use | No free API tier; requires Business or Enterprise plan | [developer.1password.com](https://developer.1password.com) |
+| **`secret-store.aws.secrets-manager.v1`** | *(Planned)* Managed secret storage with automatic rotation and IAM integration | 30-day trial; then $0.40/secret/month + $0.05/10K calls | [aws.amazon.com/secrets-manager](https://aws.amazon.com/secrets-manager) |
+| **`secret-store.google.secret-manager.v1`** | *(Planned)* Google Cloud managed secrets with IAM and audit logging | 6 active versions free; 10K access ops/month free | [cloud.google.com/secret-manager](https://cloud.google.com/secret-manager) |
+| **`secret-store.microsoft.key-vault.v1`** | *(Planned)* Microsoft cloud secret, key, and certificate management | 10K operations/month free (Standard tier) | [azure.microsoft.com/en-us/products/key-vault](https://azure.microsoft.com/en-us/products/key-vault) |
+| **`secret-store.1password.connect.v1`** | *(Planned)* Secrets Automation API for CI/CD and server-side use | No free API tier; requires Business or Enterprise plan | [developer.1password.com](https://developer.1password.com) |
 | **`secret-store.modelmesh.json-secrets.v1`** | Reads secrets from a local JSON file. Keys are top-level object keys; values are strings. Supports dot-notation for nested keys. | Built-in | - |
 | **`secret-store.modelmesh.memory-secrets.v1`** | Holds secrets in an in-memory dictionary. Ideal for testing, scripting, and user-provided keys. Supports runtime add/remove via SecretManagement interface. | Built-in | - |
 | **`secret-store.modelmesh.encrypted-file.v1`** | AES-256-GCM encrypted JSON file. Secrets are decrypted at initialization using a passphrase (PBKDF2) or raw key. Supports save/load round-trips. | Built-in | - |
@@ -435,9 +435,9 @@ Interface: [ConnectorInterfaces.md — Storage](ConnectorInterfaces.html#storage
 | Connector | Backend | Concurrency | Free Tier | Best For | Docs |
 | --- | --- | --- | --- | --- | --- |
 | **`storage.modelmesh.local-file.v1`** | local disk | single-process only | Built-in | development, single-instance deploys | - |
-| **`storage.aws.s3.v1`** | AWS S3 | conditional writes | 5 GB, 20K GET, 2K PUT/month (12 months) | multi-instance, serverless | [aws.amazon.com/s3](https://aws.amazon.com/s3) |
-| **`storage.google.drive.v1`** | Google Drive | revision-based | 15 GB free (shared across Google services) | shared team state, client-side apps | [developers.google.com/drive](https://developers.google.com/drive) |
-| **`storage.redis.redis.v1`** | Redis | atomic operations | Redis Cloud 30 MB free; self-hosted open-source | low-latency multi-instance sync | [redis.io](https://redis.io) |
+| **`storage.aws.s3.v1`** | *(Planned)* AWS S3 | conditional writes | 5 GB, 20K GET, 2K PUT/month (12 months) | multi-instance, serverless | [aws.amazon.com/s3](https://aws.amazon.com/s3) |
+| **`storage.google.drive.v1`** | *(Planned)* Google Drive | revision-based | 15 GB free (shared across Google services) | shared team state, client-side apps | [developers.google.com/drive](https://developers.google.com/drive) |
+| **`storage.redis.redis.v1`** | *(Planned)* Redis | atomic operations | Redis Cloud 30 MB free; self-hosted open-source | low-latency multi-instance sync | [redis.io](https://redis.io) |
 | **`storage.modelmesh.sqlite.v1`** | SQLite | single-process only | Built-in | structured local storage, queryable state | - |
 | **`storage.modelmesh.memory.v1`** | in-memory | single-process only | Built-in | testing, ephemeral workloads, no persistence | - |
 | **`storage.modelmesh.localstorage.v1`** | browser localStorage | single-tab | Built-in (TS only) | browser apps, small state (~5-10 MB) | - |

docs/cdk/DeveloperGuide.md

@@ -1590,7 +1590,7 @@ A chatbot that answers questions about anything. You type a question, the chatbo
 
 ### What you need
 
-- **Python 3.10 or later** -- check by running `python --version` in your terminal
+- **Python 3.11 or later** -- check by running `python --version` in your terminal
 - **A free API key** from one of these providers:
   - [OpenAI](https://platform.openai.com/api-keys) -- sign up and create a key starting with `sk-`
   - [Groq](https://console.groq.com/keys) -- sign up for free and create a key starting with `gsk_`
@@ -1600,10 +1600,10 @@ A chatbot that answers questions about anything. You type a question, the chatbo
 Open your terminal (Command Prompt on Windows, Terminal on Mac/Linux) and run:
 
 ```bash
-pip install modelmesh
+pip install modelmesh-lite
 ```
 
-If that does not work, try `pip3 install modelmesh` or `python -m pip install modelmesh`.
+If that does not work, try `pip3 install modelmesh-lite` or `python -m pip install modelmesh-lite`.
 
 ### Step 2: Set your API key
 

docs/guides/ProxyGuide.md

@@ -42,7 +42,7 @@ pip install modelmesh-lite[yaml]
 ```bash
 git clone https://github.com/ApartsinProjects/ModelMesh.git
 cd ModelMesh
-pip install -e "src/python[yaml]"
+pip install -e ".[yaml]"
 ```
 
 ### 2. Set API Keys

samples/connectors/typescript/customDiscovery.ts

@@ -40,37 +40,37 @@ enum DeprecationAction {
 
 /** Outcome of a registry synchronization run. */
 interface SyncResult {
-    new_models: string[];
-    deprecated_models: string[];
-    updated_models: string[];
+    newModels: string[];
+    deprecatedModels: string[];
+    updatedModels: string[];
     errors: string[];
 }
 
 /** Current status of the registry synchronization process. */
 interface SyncStatus {
-    last_sync?: Date;
-    next_sync?: Date;
-    models_synced: number;
+    lastSync?: Date;
+    nextSync?: Date;
+    modelsSynced: number;
     status: string;
 }
 
 /** Health assessment for a single provider over a monitoring window. */
 interface HealthReport {
-    provider_id: string;
+    providerId: string;
     available: boolean;
-    latency_ms?: number;
-    status_code?: number;
+    latencyMs?: number;
+    statusCode?: number;
     error?: string;
-    availability_score: number;
+    availabilityScore: number;
     timestamp: Date;
 }
 
 /** Result of a single health probe against a provider. */
 interface ProbeResult {
-    provider_id: string;
+    providerId: string;
     success: boolean;
-    latency_ms?: number;
-    status_code?: number;
+    latencyMs?: number;
+    statusCode?: number;
     error?: string;
 }
 
@@ -115,14 +115,14 @@ interface YamlModelEntry {
     name: string;
     provider: string;
     capabilities: string[];
-    context_window: number;
-    max_output_tokens: number;
+    contextWindow: number;
+    maxOutputTokens: number;
     status: "active" | "deprecated" | "preview";
-    health_endpoint?: string;
+    healthEndpoint?: string;
     pricing?: {
-        input_per_1k_tokens: number;
-        output_per_1k_tokens: number;
-        per_request?: number;
+        inputPer1kTokens: number;
+        outputPer1kTokens: number;
+        perRequest?: number;
     };
     metadata?: Record<string, unknown>;
 }
@@ -131,10 +131,10 @@ interface YamlModelEntry {
 interface YamlProviderEntry {
     id: string;
     name: string;
-    base_url: string;
-    health_endpoint: string;
-    health_method?: string;
-    health_expected_status?: number;
+    baseUrl: string;
+    healthEndpoint: string;
+    healthMethod?: string;
+    healthExpectedStatus?: number;
     models: string[];
 }
 
@@ -191,7 +191,7 @@ class YamlDiscoveryConnector implements DiscoveryConnector {
 
     /** Sync status tracking. */
     private syncStatus: SyncStatus = {
-        models_synced: 0,
+        modelsSynced: 0,
         status: "idle",
     };
 

samples/connectors/typescript/customObservability.ts

@@ -42,41 +42,41 @@ enum LogLevel {
 
 /** A routing state-change event. */
 interface RoutingEvent {
-    event_type: EventType;
+    eventType: EventType;
     timestamp: Date;
-    model_id?: string;
-    provider_id?: string;
-    pool_id?: string;
+    modelId?: string;
+    providerId?: string;
+    poolId?: string;
     metadata: Record<string, unknown>;
 }
 
 /** A single request/response log record. */
 interface RequestLogEntry {
     timestamp: Date;
-    model_id: string;
-    provider_id: string;
+    modelId: string;
+    providerId: string;
     capability: string;
-    delivery_mode: string;
-    latency_ms: number;
-    status_code: number;
-    tokens_in: number;
-    tokens_out: number;
+    deliveryMode: string;
+    latencyMs: number;
+    statusCode: number;
+    tokensIn: number;
+    tokensOut: number;
     cost?: number;
     error?: string;
 }
 
 /** Aggregate metrics for a single model, provider, or pool over a time window. */
 interface AggregateStats {
-    requests_total: number;
-    requests_success: number;
-    requests_failed: number;
-    tokens_in: number;
-    tokens_out: number;
-    cost_total: number;
-    latency_avg: number;
-    latency_p95: number;
-    downtime_total: number;
-    rotation_events: number;
+    requestsTotal: number;
+    requestsSuccess: number;
+    requestsFailed: number;
+    tokensIn: number;
+    tokensOut: number;
+    costTotal: number;
+    latencyAvg: number;
+    latencyP95: number;
+    downtimeTotal: number;
+    rotationEvents: number;
 }
 
 // ---------------------------------------------------------------------------
@@ -193,19 +193,19 @@ class SlackJsonObservabilityConnector implements ObservabilityConnector {
         // Check event filter.
         if (
             this.config.slackEventFilter &&
-            !this.config.slackEventFilter.includes(event.event_type)
+            !this.config.slackEventFilter.includes(event.eventType)
         ) {
             return;
         }
 
         // Also write the event to the JSON log for completeness.
         this.appendToLogFile({
             type: "event",
-            event_type: event.event_type,
+            eventType: event.eventType,
             timestamp: event.timestamp.toISOString(),
-            model_id: event.model_id,
-            provider_id: event.provider_id,
-            pool_id: event.pool_id,
+            modelId: event.modelId,
+            providerId: event.providerId,
+            poolId: event.poolId,
             metadata: event.metadata,
         });
 
@@ -232,14 +232,14 @@ class SlackJsonObservabilityConnector implements ObservabilityConnector {
         const logRecord: Record<string, unknown> = {
             type: "request",
             timestamp: entry.timestamp.toISOString(),
-            model_id: entry.model_id,
-            provider_id: entry.provider_id,
+            modelId: entry.modelId,
+            providerId: entry.providerId,
             capability: entry.capability,
-            delivery_mode: entry.delivery_mode,
-            latency_ms: entry.latency_ms,
-            status_code: entry.status_code,
-            tokens_in: entry.tokens_in,
-            tokens_out: entry.tokens_out,
+            deliveryMode: entry.deliveryMode,
+            latencyMs: entry.latencyMs,
+            statusCode: entry.statusCode,
+            tokensIn: entry.tokensIn,
+            tokensOut: entry.tokensOut,
         };
 
         // Include cost if present.
@@ -257,7 +257,7 @@ class SlackJsonObservabilityConnector implements ObservabilityConnector {
         // Alert on slow requests if threshold is configured.
         if (
             this.config.slowRequestThresholdMs &&
-            entry.latency_ms > this.config.slowRequestThresholdMs
+            entry.latencyMs > this.config.slowRequestThresholdMs
         ) {
             this.sendSlowRequestAlert(entry);
         }
@@ -305,9 +305,9 @@ class SlackJsonObservabilityConnector implements ObservabilityConnector {
 
     /** Format a routing event into a rich Slack Block Kit message. */
     private formatEventForSlack(event: RoutingEvent): SlackMessage {
-        const emoji = this.getEventEmoji(event.event_type);
-        const severity = this.getEventSeverity(event.event_type);
-        const title = this.formatEventTitle(event.event_type);
+        const emoji = this.getEventEmoji(event.eventType);
+        const severity = this.getEventSeverity(event.eventType);
+        const title = this.formatEventTitle(event.eventType);
 
         const blocks: SlackBlock[] = [
             {
@@ -323,7 +323,7 @@ class SlackJsonObservabilityConnector implements ObservabilityConnector {
                 fields: [
                     {
                         type: "mrkdwn",
-                        text: `*Event:*\n${event.event_type}`,
+                        text: `*Event:*\n${event.eventType}`,
                     },
                     {
                         type: "mrkdwn",
@@ -335,22 +335,22 @@ class SlackJsonObservabilityConnector implements ObservabilityConnector {
 
         // Add model/provider/pool info if present.
         const infoFields: Array<{ type: string; text: string }> = [];
-        if (event.model_id) {
+        if (event.modelId) {
             infoFields.push({
                 type: "mrkdwn",
-                text: `*Model:*\n\`${event.model_id}\``,
+                text: `*Model:*\n\`${event.modelId}\``,
             });
         }
-        if (event.provider_id) {
+        if (event.providerId) {
             infoFields.push({
                 type: "mrkdwn",
-                text: `*Provider:*\n\`${event.provider_id}\``,
+                text: `*Provider:*\n\`${event.providerId}\``,
             });
         }
-        if (event.pool_id) {
+        if (event.poolId) {
             infoFields.push({
                 type: "mrkdwn",
-                text: `*Pool:*\n\`${event.pool_id}\``,
+                text: `*Pool:*\n\`${event.poolId}\``,
             });
         }
         if (infoFields.length > 0) {
@@ -408,19 +408,19 @@ class SlackJsonObservabilityConnector implements ObservabilityConnector {
         // Add a section for each scope.
         for (const [scopeId, scopeStats] of Object.entries(stats)) {
             const successRate =
-                scopeStats.requests_total > 0
-                    ? ((scopeStats.requests_success / scopeStats.requests_total) * 100).toFixed(1)
+                scopeStats.requestsTotal > 0
+                    ? ((scopeStats.requestsSuccess / scopeStats.requestsTotal) * 100).toFixed(1)
                     : "N/A";
 
             blocks.push({
                 type: "section",
                 fields: [
                     { type: "mrkdwn", text: `*Scope:*\n\`${scopeId}\`` },
-                    { type: "mrkdwn", text: `*Requests:*\n${scopeStats.requests_total}` },
+                    { type: "mrkdwn", text: `*Requests:*\n${scopeStats.requestsTotal}` },
                     { type: "mrkdwn", text: `*Success Rate:*\n${successRate}%` },
-                    { type: "mrkdwn", text: `*Avg Latency:*\n${scopeStats.latency_avg.toFixed(0)}ms` },
-                    { type: "mrkdwn", text: `*P95 Latency:*\n${scopeStats.latency_p95.toFixed(0)}ms` },
-                    { type: "mrkdwn", text: `*Cost:*\n$${scopeStats.cost_total.toFixed(4)}` },
+                    { type: "mrkdwn", text: `*Avg Latency:*\n${scopeStats.latencyAvg.toFixed(0)}ms` },
+                    { type: "mrkdwn", text: `*P95 Latency:*\n${scopeStats.latencyP95.toFixed(0)}ms` },
+                    { type: "mrkdwn", text: `*Cost:*\n$${scopeStats.costTotal.toFixed(4)}` },
                 ],
             });
         }
@@ -446,15 +446,15 @@ class SlackJsonObservabilityConnector implements ObservabilityConnector {
                     type: "section",
                     text: {
                         type: "mrkdwn",
-                        text: `*Slow Request Alert*\nModel \`${entry.model_id}\` via \`${entry.provider_id}\` took *${entry.latency_ms.toFixed(0)}ms* (threshold: ${this.config.slowRequestThresholdMs}ms)`,
+                        text: `*Slow Request Alert*\nModel \`${entry.modelId}\` via \`${entry.providerId}\` took *${entry.latencyMs.toFixed(0)}ms* (threshold: ${this.config.slowRequestThresholdMs}ms)`,
                     },
                 },
                 {
                     type: "section",
                     fields: [
                         { type: "mrkdwn", text: `*Capability:*\n${entry.capability}` },
-                        { type: "mrkdwn", text: `*Status:*\n${entry.status_code}` },
-                        { type: "mrkdwn", text: `*Tokens:*\n${entry.tokens_in} in / ${entry.tokens_out} out` },
+                        { type: "mrkdwn", text: `*Status:*\n${entry.statusCode}` },
+                        { type: "mrkdwn", text: `*Tokens:*\n${entry.tokensIn} in / ${entry.tokensOut} out` },
                     ],
                 },
             ],