feat(cc-sdk): fixed-blob-issue

packages/@webex/plugin-cc/src/services/core/WebSocket/WebSocketManager.ts

@@ -1,5 +1,4 @@
 /* eslint-disable */
-// Temporarily adding the above until a fix for the blob can be found
 import { Signal } from '../Signal';
 import { WebexSDK, SubscribeRequest, HTTP_METHODS, WelcomeResponse } from '../../../types';
 import { SUBSCRIBE_API, WCC_API_GATEWAY } from '../../constants';

packages/@webex/plugin-cc/test/unit/spec/services/core/WebSocket/connection-service.ts

@@ -0,0 +1,50 @@
+import { ConnectionService } from '../../../../../../src/services/core/WebSocket/connection-service';
+import { WebSocketManager } from '../../../../../../src/services/core/WebSocket/WebSocketManager';
+import { Signal } from '../../../../../../src/services/core/Signal';
+
+jest.mock('../../../../../../src/services/core/WebSocket/WebSocketManager');
+
+describe('ConnectionService', () => {
+  let connectionService: ConnectionService;
+  let mockWebSocketManager: jest.Mocked<WebSocketManager>;
+
+  beforeEach(() => {
+    mockWebSocketManager = new WebSocketManager({ webex: {} as any }) as jest.Mocked<WebSocketManager>;
+
+    // Mock the onMessage and onSocketClose properties
+    mockWebSocketManager.onMessage = {
+      listen: jest.fn(),
+    } as any;
+
+    mockWebSocketManager.onSocketClose = {
+      listen: jest.fn(),
+    } as any;
+
+    connectionService = new ConnectionService(mockWebSocketManager);
+    jest.useFakeTimers();
+  });
+
+  afterEach(() => {
+    jest.clearAllMocks();
+    jest.useRealTimers();
+  });
+
+  it('should initialize ConnectionService', () => {
+    expect(connectionService).toBeDefined();
+  });
+
+  it('should set connection properties', () => {
+    const newProps = { lostConnectionRecoveryTimeout: 30000 };
+    connectionService.setConnectionProp(newProps);
+    expect(connectionService['connectionProp']).toEqual(newProps);
+  });
+
+  it('should handle ping message and update connection data', () => {
+    const pingMessage = JSON.stringify({ keepalive: 'true' });
+    connectionService['onPing'](pingMessage);
+    expect(connectionService['isKeepAlive']).toBe(true);
+    expect(connectionService['isConnectionLost']).toBe(false);
+    expect(connectionService['isRestoreFailed']).toBe(false);
+    expect(connectionService['isSocketReconnected']).toBe(false);
+  });
+});