fix: Format

Author: asafgardin

package.json

@@ -15,7 +15,7 @@
   "scripts": {
     "build": "tsc",
     "test": "jest",
-    "lint": "eslint . .ts,.tsx",
+    "lint": "npx eslint 'src/**/*.{ts,tsx}' --no-ignore",
     "format": "prettier --write \"src/**/*.ts\"",
     "prepare": "npm run build",
     "example": "npx tsx src/script.ts"

src/Core.ts

@@ -155,4 +155,3 @@ export abstract class APIClient {
     );
   }
 }
-

src/ResponseHandler.ts

@@ -2,8 +2,7 @@ import { APIResponseProps } from './models';
 import { AI21Error } from './errors';
 import { Stream } from './Streaming';
 
-
-export async function handleAPIResponse({response, options }: APIResponseProps): Promise<any> {
+export async function handleAPIResponse({ response, options }: APIResponseProps): Promise<any> {
   if (options.stream) {
     if (!response.body) {
       throw new AI21Error('Response body is null');
@@ -12,13 +11,10 @@ export async function handleAPIResponse({response, options }: APIResponseProps):
   }
 
   const contentType = response.headers.get('content-type');
-  const data = contentType?.includes('application/json') 
-    ? await response.json()
-    : await response.text();
+  const data = contentType?.includes('application/json') ? await response.json() : await response.text();
 
   return {
     data,
     response,
   };
 }
-

src/Streaming/SSEDecoder.ts

@@ -3,57 +3,55 @@ import { Readable } from 'stream';
 import { SSE_DATA_PREFIX } from './Consts';
 import { StreamingDecodeError } from '../errors';
 
+export interface SSEDecoder {
+  decode(line: string): string | null;
+  iterLines(response: NodeResponse): AsyncIterableIterator<string>;
+}
 
+export class DefaultSSEDecoder implements SSEDecoder {
+  decode(line: string): string | null {
+    if (!line) return null;
 
-export interface SSEDecoder {
-    decode(line: string): string | null;
-    iterLines(response: NodeResponse): AsyncIterableIterator<string>;
+    if (line.startsWith(SSE_DATA_PREFIX)) {
+      return line.slice(SSE_DATA_PREFIX.length);
+    }
+
+    throw new StreamingDecodeError(`Invalid SSE line: ${line}`);
   }
-  
-export class DefaultSSEDecoder implements SSEDecoder {
-    decode(line: string): string | null {
-      if (!line) return null;
-  
-      if (line.startsWith(SSE_DATA_PREFIX)) {
-        return line.slice(SSE_DATA_PREFIX.length);
-      }
-  
-      throw new StreamingDecodeError(`Invalid SSE line: ${line}`);
+
+  async *iterLines(response: NodeResponse): AsyncIterableIterator<string> {
+    if (!response.body) {
+      throw new Error('Response body is null');
     }
-  
-    async *iterLines(response: NodeResponse): AsyncIterableIterator<string> {
-      if (!response.body) {
-        throw new Error('Response body is null');
-      }
-  
-      const webReadableStream = Readable.toWeb(response.body as any) as ReadableStream;
-      const reader = webReadableStream.getReader();
-  
-      let buffer = '';
-  
-      try {
-        while (true) {
-          const { done, value } = await reader.read();
-  
-          if (done) {
-            if (buffer.length > 0) {
-              const decoded = this.decode(buffer.trim());
-              if (decoded) yield decoded;
-            }
-            break;
-          }
-  
-          buffer += new TextDecoder().decode(value);
-          const lines = buffer.split('\n');
-          buffer = lines.pop() || '';
-  
-          for (const line of lines) {
-            const decoded = this.decode(line.trim());
+
+    const webReadableStream = Readable.toWeb(response.body as any) as ReadableStream;
+    const reader = webReadableStream.getReader();
+
+    let buffer = '';
+
+    try {
+      while (true) {
+        const { done, value } = await reader.read();
+
+        if (done) {
+          if (buffer.length > 0) {
+            const decoded = this.decode(buffer.trim());
             if (decoded) yield decoded;
           }
+          break;
+        }
+
+        buffer += new TextDecoder().decode(value);
+        const lines = buffer.split('\n');
+        buffer = lines.pop() || '';
+
+        for (const line of lines) {
+          const decoded = this.decode(line.trim());
+          if (decoded) yield decoded;
         }
-      } finally {
-        reader.releaseLock();
       }
+    } finally {
+      reader.releaseLock();
     }
-  }
+  }
+}

src/Streaming/Stream.ts

@@ -5,7 +5,6 @@ import { SSEDecoder } from './SSEDecoder';
 import { SSE_DONE_MSG } from './Consts';
 import { StreamingDecodeError } from '../errors';
 
-
 function getStreamMessage<T>(chunk: string): T {
   try {
     return JSON.parse(chunk);
@@ -39,4 +38,4 @@ export class Stream<T> implements AsyncIterableIterator<T> {
   [Symbol.asyncIterator](): AsyncIterableIterator<T> {
     return this;
   }
-}
+}

src/Streaming/index.ts

@@ -1 +1 @@
-export { Stream } from './Stream';
+export { Stream } from './Stream';

src/errors.ts

@@ -7,8 +7,7 @@ export class MissingAPIKeyError extends AI21Error {
 }
 
 export class StreamingDecodeError extends Error {
-    constructor(chunk: string) {
-      super(`Failed to decode chunk: ${chunk}`);
+  constructor(chunk: string) {
+    super(`Failed to decode chunk: ${chunk}`);
   }
 }
-