diff --git a/apps/data-service/src/providers/proxy.provider.ts b/apps/data-service/src/providers/proxy.provider.ts index ad55764..d42f94f 100644 --- a/apps/data-service/src/providers/proxy.provider.ts +++ b/apps/data-service/src/providers/proxy.provider.ts @@ -5,17 +5,17 @@ export const proxyProvider: ProviderConfig = { service: 'proxy', operations: { 'fetch-and-check': async (payload: { sources?: string[] }) => { - const { proxyService } = await import('../services/proxy.service'); + const { proxyService } = await import('./proxy.tasks'); return await proxyService.fetchProxiesFromSources(); }, 'check-specific': async (payload: { proxies: any[] }) => { - const { proxyService } = await import('../services/proxy.service'); + const { proxyService } = await import('./proxy.tasks'); return await proxyService.checkProxies(payload.proxies); }, 'get-working-proxy': async (payload: { protocol?: string; country?: string; timeout?: number }) => { - const { proxyService } = await import('../services/proxy.service'); + const { proxyService } = await import('./proxy.tasks'); return await proxyService.getWorkingProxy(); } }, diff --git a/apps/data-service/src/services/proxy.service.ts b/apps/data-service/src/providers/proxy.tasks.ts similarity index 96% rename from apps/data-service/src/services/proxy.service.ts rename to apps/data-service/src/providers/proxy.tasks.ts index bebc411..fc2ef77 100644 --- a/apps/data-service/src/services/proxy.service.ts +++ b/apps/data-service/src/providers/proxy.tasks.ts @@ -65,24 +65,14 @@ export class ProxyService { this.httpClient = new HttpClient({ timeout: 10000, }, this.logger); - - // Start scheduled tasks - this.initializeScheduling(); + this.logger.info('ProxyService initialized'); } - private async initializeScheduling() { - try { - // Queue manager will handle scheduling - this.logger.info('Proxy scheduling will be handled by queue manager'); - } catch (error) { - this.logger.error('Failed to initialize scheduling', { error }); - } - } // Add queue integration methods async queueProxyFetch(): Promise { - const { queueManager } = await import('./queue.service'); + const { queueManager } = await import('../services/queue.service'); const job = await queueManager.addJob({ type: 'proxy-fetch', service: 'proxy', @@ -98,7 +88,7 @@ export class ProxyService { } async queueProxyCheck(proxies: ProxyInfo[]): Promise { - const { queueManager } = await import('./queue.service'); + const { queueManager } = await import('../services/queue.service'); const job = await queueManager.addJob({ type: 'proxy-check', service: 'proxy', diff --git a/apps/data-service/src/proxy-demo.ts b/apps/data-service/src/proxy-demo.ts index d9019a2..d258caa 100644 --- a/apps/data-service/src/proxy-demo.ts +++ b/apps/data-service/src/proxy-demo.ts @@ -1,4 +1,4 @@ -import { proxyService } from './services/proxy.service.js'; +import { proxyService } from './providers/proxy.tasks.js'; import { getLogger } from '@stock-bot/logger'; // Initialize logger for the demo