diff --git a/src/services/EventSubscribeService.ts b/src/services/EventSubscribeService.ts index fa04f65..a6ab61e 100644 --- a/src/services/EventSubscribeService.ts +++ b/src/services/EventSubscribeService.ts @@ -1,5 +1,5 @@ import { prisma } from "../prisma/db"; -import { xcxApi } from "../utils/server"; +import type { EventDetail } from "../types"; import { KaiqiuService } from "./KaiqiuService"; export class EventSubscribeService { @@ -48,7 +48,15 @@ export class EventSubscribeService { select: { event_id: true }, distinct: 'event_id', }).then(v => v.map(e => e.event_id)); - const events = await Promise.all(eids.map(eid => KaiqiuService.getEventInfo(eid))); + const events = []; + for (const eid of eids) { + const info = await KaiqiuService.getEventInfo(eid) + console.debug( + 'Getting event info for %s - %s, should check: %s', + info.title, info.eventId, !info.isFinished && !info.isProcessing, + ); + events.push(info); + } const expiredEvents = events.filter(e => e.isFinished || e.isProcessing); const beforeEvents = events.filter(e => !e.isFinished && !e.isProcessing); await prisma.eventSubs.deleteMany({ @@ -56,10 +64,12 @@ export class EventSubscribeService { event_id: { in: expiredEvents.map(e => e.eventId) } } }); - const [requests] = await Promise.all([ - beforeEvents.map(e => KaiqiuService.getMatchDetail(e.eventId, true)), - ]); - const details = await Promise.all(requests); + const details: EventDetail[] = []; + for (const e of beforeEvents) { + const result = await KaiqiuService.getMatchDetail(e.eventId, true) + console.debug('Get match detail: %s - %s, url: %s', e.title, e.eventId, e.url) + details.push(result); + } return details; } } \ No newline at end of file