fixed typescript

apps/data-ingestion/src/handlers/webshare/webshare.handler.ts

@@ -1,82 +1,63 @@
-/**
- * WebShare Provider for proxy management with scheduled updates
- */
-import { getLogger } from '@stock-bot/logger';
+import type { IDataIngestionServices } from '@stock-bot/di';
 import {
-  createJobHandler,
-  handlerRegistry,
-  type HandlerConfigWithSchedule,
-} from '@stock-bot/queue';
+  BaseHandler,
+  Handler,
+  Operation,
+  QueueSchedule,
+  type ExecutionContext
+} from '@stock-bot/handlers';
 import { updateProxies } from '@stock-bot/utils';
-import type { ServiceContainer } from '@stock-bot/di';
 
-const logger = getLogger('webshare-provider');
+@Handler('webshare')
+export class WebShareHandler extends BaseHandler {
+  constructor(services: IDataIngestionServices) {
+    super(services);
+  }
 
-// Initialize and register the WebShare provider
-export function initializeWebShareProvider(_container: ServiceContainer) {
-  logger.debug('Registering WebShare provider with scheduled jobs...');
-
-  const webShareProviderConfig: HandlerConfigWithSchedule = {
-    name: 'webshare',
-
-    operations: {
-      'fetch-proxies': createJobHandler(async () => {
-        logger.info('Fetching proxies from WebShare API');
-        const { fetchWebShareProxies } = await import('./operations/fetch.operations');
+  @Operation('fetch-proxies')
+  @QueueSchedule('0 */6 * * *', { 
+    priority: 3, 
+    immediately: true, 
+    description: 'Fetch fresh proxies from WebShare API' 
+  })
+  async fetchProxies(_input: unknown, _context: ExecutionContext): Promise<unknown> {
+    this.logger.info('Fetching proxies from WebShare API');
+    
+    try {
+      const { fetchWebShareProxies } = await import('./operations/fetch.operations');
+      const proxies = await fetchWebShareProxies();
+      
+      if (proxies.length > 0) {
+        // Update the centralized proxy manager
+        await updateProxies(proxies);
         
-        try {
-          const proxies = await fetchWebShareProxies();
-          
-          if (proxies.length > 0) {
-            // Update the centralized proxy manager
-            await updateProxies(proxies);
-            
-            logger.info('Updated proxy manager with WebShare proxies', { 
-              count: proxies.length,
-              workingCount: proxies.filter(p => p.isWorking !== false).length,
-            });
-            
-            return { 
-              success: true,
-              proxiesUpdated: proxies.length,
-              workingProxies: proxies.filter(p => p.isWorking !== false).length,
-            };
-          } else {
-            logger.warn('No proxies fetched from WebShare API');
-            return {
-              success: false,
-              proxiesUpdated: 0,
-              error: 'No proxies returned from API',
-            };
-          }
-        } catch (error) {
-          logger.error('Failed to fetch and update proxies', { error });
-          return {
-            success: false,
-            proxiesUpdated: 0,
-            error: error instanceof Error ? error.message : 'Unknown error',
-          };
-        }
-      }),
-    },
-
-    scheduledJobs: [
-      {
-        type: 'webshare-fetch',
-        operation: 'fetch-proxies',
-        cronPattern: '0 */6 * * *', // Every 6 hours
-        priority: 3,
-        description: 'Fetch fresh proxies from WebShare API',
-        immediately: true, // Run on startup
-      },
-    ],
-  };
-
-  handlerRegistry.registerWithSchedule(webShareProviderConfig);
-  logger.debug('WebShare provider registered successfully');
+        this.logger.info('Updated proxy manager with WebShare proxies', { 
+          count: proxies.length,
+          workingCount: proxies.filter(p => p.isWorking !== false).length,
+        });
+        
+        // Cache proxy stats for monitoring
+        await this.cache.set('webshare-proxy-count', proxies.length, 3600);
+        await this.cache.set('webshare-working-count', proxies.filter(p => p.isWorking !== false).length, 3600);
+        await this.cache.set('last-webshare-fetch', new Date().toISOString(), 1800);
+        
+        return { 
+          success: true,
+          proxiesUpdated: proxies.length,
+          workingProxies: proxies.filter(p => p.isWorking !== false).length,
+        };
+      } else {
+        this.logger.warn('No proxies fetched from WebShare API');
+        return {
+          success: false,
+          proxiesUpdated: 0,
+          error: 'No proxies returned from API',
+        };
+      }
+    } catch (error) {
+      this.logger.error('Failed to fetch and update proxies', { error });
+      throw error;
+    }
+  }
 }
 
-export const webShareProvider = {
-  initialize: (container: ServiceContainer) => initializeWebShareProvider(container),
-};
-