cleanup warnings and fix DTS build phase for typescript

Author: Abica

elixir/lib/datagrout_conduit/transport/ws.ex

@@ -232,7 +232,7 @@ defmodule DatagroutConduit.Transport.Ws do
 
     cond do
       Map.has_key?(state.pending_subscribe, str_id) ->
-        {topic, caller_pid, from} = Map.fetch!(state.pending_subscribe, str_id)
+        {_topic, caller_pid, from} = Map.fetch!(state.pending_subscribe, str_id)
         pending_subscribe = Map.delete(state.pending_subscribe, str_id)
 
         if err = msg["error"] do

elixir/test/ws_transport_test.exs

@@ -10,28 +10,10 @@ defmodule DatagroutConduit.Transport.WsTest do
 
   use ExUnit.Case, async: true
 
-  import Mox
-
   alias DatagroutConduit.Transport.Ws
 
   # ── Helpers ─────────────────────────────────────────────────────────────────
 
-  # Start a WS GenServer with a stub conn_pid (not a real WebSockex process).
-  # We inject frames directly via `send/2`.
-  defp start_ws_with_stub do
-    # We bypass the init by manually setting state via :sys.replace_state.
-    {:ok, pid} =
-      GenServer.start_link(Ws, %Ws{
-        conn_pid: self(),
-        pending: %{},
-        pending_subscribe: %{},
-        subscriptions: %{},
-        next_id: 0
-      })
-
-    pid
-  end
-
   defp inject_frame(pid, payload) do
     send(pid, {:ws_frame, Jason.encode!(payload)})
   end
@@ -252,14 +234,6 @@ defmodule DatagroutConduit.Transport.WsTest do
 
   describe "to_ws_url / build_headers (via init logic)" do
     test "URL rewriting: https → wss" do
-      state = %Ws{
-        conn_pid: self(),
-        pending: %{},
-        pending_subscribe: %{},
-        subscriptions: %{},
-        next_id: 0
-      }
-
       ws_url =
         "https://gateway.datagrout.ai/servers/test/ws"
         |> String.replace_prefix("https://", "wss://")

python/tests/test_identity.py

@@ -336,7 +336,7 @@ def test_with_expiry_returns_new_object(self) -> None:
 
     def test_needs_rotation_handles_naive_datetime(self) -> None:
         """Naive datetimes are treated as UTC."""
-        past_naive = datetime.utcnow() - timedelta(seconds=1)
+        past_naive = datetime.now(timezone.utc).replace(tzinfo=None) - timedelta(seconds=1)
         identity = ConduitIdentity.from_pem(CERT_PEM, KEY_PEM).with_expiry(past_naive)
         assert identity.needs_rotation(0) is True
 

ruby/test/datagrout_conduit_test.rb

@@ -128,9 +128,11 @@ def test_extract_meta_with_meta_key_fallback
   end
 
   def test_extract_meta_returns_nil_for_no_meta
-    assert_nil DatagroutConduit.extract_meta({})
-    assert_nil DatagroutConduit.extract_meta({ "value" => 42 })
-    assert_nil DatagroutConduit.extract_meta(nil)
+    assert_output(nil, /No DataGrout metadata/) do
+      assert_nil DatagroutConduit.extract_meta({})
+      assert_nil DatagroutConduit.extract_meta({ "value" => 42 })
+      assert_nil DatagroutConduit.extract_meta(nil)
+    end
   end
 
   def test_extract_meta_with_symbol_keys

typescript/src/transports/ws.ts

@@ -147,7 +147,6 @@ interface PendingSubscribe {
 export class WsTransport extends Transport {
   private readonly _url: string;
   private readonly _auth?: AuthConfig;
-  private readonly _identity?: ConduitIdentity;
 
   private _ws: WebSocket | null = null;
   private _nextId = 0;
@@ -156,7 +155,7 @@ export class WsTransport extends Transport {
   private readonly _pendingSubscribe = new Map<string, PendingSubscribe>();
   private readonly _subscriptions = new Map<string, Subscription>();
 
-  constructor(url: string, auth?: AuthConfig, _timeout?: number, identity?: ConduitIdentity) {
+  constructor(url: string, auth?: AuthConfig, _timeout?: number, _identity?: ConduitIdentity) {
     super();
 
     const scheme = new URL(url).protocol.replace(':', '');
@@ -166,7 +165,6 @@ export class WsTransport extends Transport {
 
     this._url = url;
     this._auth = auth;
-    this._identity = identity;
   }
 
   // ── Lifecycle ─────────────────────────────────────────────────────────────
@@ -186,7 +184,7 @@ export class WsTransport extends Transport {
     await new Promise<void>((resolve, reject) => {
       ws.onopen = () => resolve();
       ws.onerror = (ev: Event) =>
-        reject(new Error(`WS connect failed: ${(ev as ErrorEvent).message ?? 'unknown'}`));
+        reject(new Error(`WS connect failed: ${(ev as any).message ?? 'unknown'}`));
     });
 
     ws.onmessage = (ev: MessageEvent) => this._handleMessage(ev.data);

typescript/src/types.ts

@@ -221,6 +221,7 @@ export interface GuideState {
 
 export interface AuthConfig {
   bearer?: string;
+  apiKey?: string;
   basic?: {
     username: string;
     password: string;
@@ -287,7 +288,7 @@ export interface ClientOptions {
    * @default false
    */
   disableMtls?: boolean;
-  transport?: 'mcp' | 'jsonrpc';
+  transport?: 'mcp' | 'jsonrpc' | 'websocket';
   timeout?: number;
   /**
    * Maximum number of automatic retries on "server not initialized" errors.