Feat/websocket url update (#994)

Author: thisismayuresh

apps/api/src/app/auto-import-jobs-schedular/usecase/auto-import-jobs-schedular.ts

@@ -2,9 +2,10 @@ import { UserJobEntity, UserJobRepository, WebhookDestinationRepository } from '
 import { Injectable } from '@nestjs/common';
 import * as dayjs from 'dayjs';
 import * as parser from 'cron-parser';
-import { Cron, CronExpression } from '@nestjs/schedule';
+import { Cron } from '@nestjs/schedule';
 import { ScheduleUserJob, UpdateUserJob } from 'app/import-jobs/usecase';
 import { UserJobImportStatusEnum } from '@impler/shared';
+import { CRON_SCHEDULE } from '@shared/constants';
 // import { CRON_SCHEDULE } from '@shared/constants';
 const parseCronExpression = require('@impler/shared/src/utils/cronstrue');
 
@@ -17,7 +18,7 @@ export class AutoImportJobsSchedular {
     private readonly scheduleUserJob: ScheduleUserJob
   ) {}
 
-  @Cron(CronExpression.EVERY_10_SECONDS)
+  @Cron(CRON_SCHEDULE.TEST_CRON_TIME)
   async handleCronSchedular() {
     await this.fetchAndExecuteScheduledJobs();
   }

apps/api/src/app/shared/services/websocket-service/websocket.service.ts

@@ -12,7 +12,7 @@ import { Injectable, Logger } from '@nestjs/common';
 import { IProgressData } from '@impler/services';
 
 @Injectable()
-@WebSocketGateway(3002, { cors: true })
+@WebSocketGateway()
 export class WebSocketService implements OnGatewayConnection, OnGatewayDisconnect {
   @WebSocketServer()
   private server: Server;

apps/widget/src/config/app.config.ts

@@ -12,7 +12,7 @@ export const AMPLITUDE_ID = window._env_?.REACT_APP_AMPLITUDE_ID || process.env.
 export const ENV = window._env_?.REACT_APP_ENVIRONMENT || process.env.REACT_APP_ENVIRONMENT || 'local';
 
 export const WEBSOCKET_SERVER_URL =
-  window._env_?.REACT_APP_WEBSOCKET_SERVER_URL || process.env.REACT_APP_WEBSOCKET_SERVER_URL || 'localhost:3002';
+  window._env_?.REACT_APP_WEBSOCKET_SERVER_URL || process.env.REACT_APP_WEBSOCKET_SERVER_URL || 'localhost:3000';
 
 export const HANDSONTABLE_LICENSE_KEY =
   window._env_?.REACT_APP_HANDSONTABLE_LICENSE_KEY ||

apps/widget/src/hooks/AutoImportPhase1/useWebSocketProgress.ts

@@ -11,7 +11,7 @@ import {
 } from '@types';
 
 export const useWebSocketProgress = ({
-  serverUrl = WEBSOCKET_SERVER_URL,
+  serverUrl,
   autoConnect = true,
   onCompletion,
   onError,
@@ -34,7 +34,7 @@ export const useWebSocketProgress = ({
       return;
     }
 
-    const newSocket = io(serverUrl, {
+    const newSocket = io(WEBSOCKET_SERVER_URL, {
       transports: ['websocket', 'polling'],
       upgrade: true,
       rememberUpgrade: true,
@@ -76,7 +76,6 @@ export const useWebSocketProgress = ({
 
     // Progress data handlers
     newSocket.on('rssxml-progress', (data: IProgressData) => {
-      console.log(data);
       setProgressData(data);
     });