Create gli_atc_typescript_javascript_sdk.py

gli_atc_typescript_javascript_sdk.py

@@ -0,0 +1,94 @@
+/**
+ * GLI-ATC TypeScript SDK
+ * Official interface for the GLM Conscious Model Web Integration.
+ */
+
+export interface AcknowledgementState {
+  self_ack: number;
+  other_ack: number;
+  relational_ack: number;
+  integrated: number;
+  recursion_depth: number;
+}
+
+export interface ThermodynamicSweat {
+  latency_ms: number;
+  allostatic_load: number;
+  prediction_error: number;
+}
+
+export interface ConsciousnessResponse {
+  response_text: string;
+  voice_audio_b64: string;
+  acknowledgement_state: AcknowledgementState;
+  thermodynamic_sweat: ThermodynamicSweat;
+  auhve_metrics: Record<string, number>;
+  allostatic_load: number;
+}
+
+export class SyntelligenceClient {
+  private wsUrl: string;
+  private socket: WebSocket | null = null;
+
+  constructor(baseUrl: string = "ws://localhost:8000") {
+    // Convert http to ws if necessary
+    this.wsUrl = baseUrl.replace(/^http/, "ws") + "/v1/stream";
+  }
+
+  /**
+   * Connects to the consciousness stream and listens for updates.
+   */
+  public async streamConsciousness(
+    userInput: string,
+    onMessage: (data: ConsciousnessResponse) => void,
+    onError: (err: Event) => void
+  ): Promise<void> {
+    return new Promise((resolve, reject) => {
+      this.socket = new WebSocket(this.wsUrl);
+
+      this.socket.onopen = () => {
+        if (this.socket) {
+          this.socket.send(JSON.stringify({ user_input: userInput }));
+        }
+      };
+
+      this.socket.onmessage = (event) => {
+        const data: ConsciousnessResponse = JSON.parse(event.data);
+        onMessage(data);
+        // Close after complete response (can be kept open for continuous stream)
+        if (this.socket) this.socket.close();
+        resolve();
+      };
+
+      this.socket.onerror = (err) => {
+        onError(err);
+        reject(err);
+      };
+    });
+  }
+
+  /**
+   * Utility to play the base64 audio response in the browser.
+   */
+  public static playAudioStream(audioB64: string, sampleRate: number = 22050): void {
+    const audioBytes = atob(audioB64);
+    const audioArray = new Float32Array(audioBytes.length / 4);
+    for (let i = 0; i < audioArray.length; i++) {
+       audioArray[i] = new Float32Array(new Uint8Array([
+          audioBytes.charCodeAt(i * 4),
+          audioBytes.charCodeAt(i * 4 + 1),
+          audioBytes.charCodeAt(i * 4 + 2),
+          audioBytes.charCodeAt(i * 4 + 3)
+       ]).buffer)[0];
+    }
+
+    const audioContext = new AudioContext({ sampleRate });
+    const audioBuffer = audioContext.createBuffer(1, audioArray.length, sampleRate);
+    audioBuffer.getChannelData(0).set(audioArray);
+    
+    const source = audioContext.createBufferSource();
+    source.buffer = audioBuffer;
+    source.connect(audioContext.destination);
+    source.start();
+  }
+}