feat: rename project to athena-classifier-sdk and update package details

- Updated project name and description in package.json.
- Added new dependencies for authentication and image processing.
- Introduced AuthenticationManager for handling OAuth authentication.
- Created hashing utility to compute MD5 and SHA1 hashes while resizing images.
- Refactored main.ts to integrate new authentication and hashing functionalities.
- Updated TypeScript configuration for better module handling and declaration generation.

Author: abbottdev-kroll

.github/FUNDING.yml

@@ -26,4 +26,5 @@ build/
 .eslintcache
 
 # Misc
-.DS_Store
+.DS_Store
+.env

.gitignore

@@ -1,33 +1,94 @@
-import { describe, it, afterEach, beforeEach, vi, expect } from 'vitest';
-import { classifyImage, computeHashesFromStream, ClassifyImageOptions } from '../../src/main.js';
-
-
+import { describe, it,} from 'vitest';
+import { ClassifierSdk, ClassifyImageOptions, ClassifyResponse, ImageFormat } from '../../src/main';
 import fs from 'fs';
+import { randomUUID } from 'crypto';
+
+describe('classifierHelper', () => {
+  it('should listDeployments and return responses using stubbed api)', async ({expect}) => {
+      // This is a smoke test. You must have a running gRPC server at localhost:50051 for this to pass.
+      // You may want to mock the gRPC client for true unit testing.
+      const sdk = new ClassifierSdk({
+        deploymentId: process.env.VITE_ATHENA_DEPLOYMENT_ID,
+        affiliate: process.env.VITE_ATHENA_AFFILIATE,
+        authentication: {
+          issuerUrl: 'https://crispthinking.auth0.com/',
+          clientId: process.env.VITE_ATHENA_CLIENT_ID,
+          clientSecret: process.env.VITE_ATHENA_CLIENT_SECRET,
+          scope: 'manage:classify'
+        }
+      });
+       // This will fail if no server is running, but will exercise the code path.
+    let error: any = null;
+    try {
+      const responses = await sdk.listDeployments();
+      expect(Array.isArray(responses)).toBe(true);
+    } catch (err) {
+      error = err;
+    }
+    // Assert error is unset
+    expect(error).toBeNull();
+  }, { timeout: 10000 })
+});
 
 describe('classifyImage function', () => {
-  it('should classify Steamboat-willie.jpg and return responses (integration smoke test)', async () => {
+  it('should classify Steamboat-willie.jpg and return responses (integration smoke test)', async ({expect}) => {
     // This is a smoke test. You must have a running gRPC server at localhost:50051 for this to pass.
     // You may want to mock the gRPC client for true unit testing.
     const imagePath = __dirname + '/Steamboat-willie.jpg';
+    const sdk = new ClassifierSdk({
+        deploymentId: process.env.VITE_ATHENA_DEPLOYMENT_ID,
+        affiliate: process.env.VITE_ATHENA_AFFILIATE,
+        authentication: {
+          issuerUrl: 'https://crispthinking.auth0.com/',
+          clientId: process.env.VITE_ATHENA_CLIENT_ID,
+          clientSecret: process.env.VITE_ATHENA_CLIENT_SECRET,
+          scope: 'manage:classify'
+        }
+    });
+
+    const correlationId = randomUUID();
+
+    // Create a promise to wrap the event emitter event 'data'
+    const promise = new Promise<ClassifyResponse>((resolve, reject) => {
+      sdk.once('data', (data) => {
+        const byCorrelationId = data.outputs.filter(o => o.correlationId === correlationId);
+        if (byCorrelationId.length > 0) {
+          resolve(data);
+        }
+        sdk.close();
+      });
+      sdk.once('error', (err) => {
+        reject(err);
+      });
+    });
+
+    // This will fail if no server is running, but will exercise the code path.
+    let error: any = undefined;
+
+    await sdk.open();
+
     const imageStream = fs.createReadStream(imagePath);
     const options: ClassifyImageOptions = {
       imageStream,
-      deploymentId: 'test-deployment',
-      affiliate: 'test-affiliate',
-      correlationId: 'test-correlation',
-      // encoding, format, grpcAddress use defaults
+      format: ImageFormat.PNG,
+      correlationId
     };
-    // This will fail if no server is running, but will exercise the code path.
-    let error: any = null;
     try {
-      const responses = await classifyImage(options);
-      expect(Array.isArray(responses)).toBe(true);
+      await sdk.sendClassifyRequest(options);
     } catch (err) {
       error = err;
     }
+
+    // Wait for classifier to process some data....
+    const first = await promise;
+
+    expect(first).toBeDefined();
+
+    const byCorrelationId = first.outputs.filter(o => o.correlationId === correlationId);
+
+    expect(byCorrelationId.length).toBeGreaterThan(0);
+
     // Accept either a successful call or a connection error (for CI/dev convenience)
-    if (error) {
-      expect(error.message).toMatch(/connect|unavailable|ECONNREFUSED|14/);
-    }
-  });
+    expect(error).toBeUndefined();
+  }, { timeout: 120000 });
 });

__tests__/unit/main.test.ts

@@ -9,7 +9,7 @@ import tseslint from 'typescript-eslint';
 // You should change it to your needs following the documentation.
 export default tseslint.config(
   {
-    ignores: ['**/build/**', '**/tmp/**', '**/coverage/**'],
+    ignores: ['**/build/**', '**/__tests__/**', '**/tmp/**', '**/coverage/**', 'src/athena/**'],
   },
   eslint.configs.recommended,
   eslintConfigPrettier,