art
/
Kord
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: art:9afaaf9a2e7e421a887e8bea8de3610bbdb9e064
Branches Tags
art:main
art:myong_dev
art:feature/invite-role
art:minseo_dev
art:delete-redis
art:feautre/minigame
art:DB연결-정상화-완료
..
compare: art:d9f3e160aae266e4dc6a91cf868a8b32c2a1435a
Branches Tags
art:main
art:myong_dev
art:feature/invite-role
art:minseo_dev
art:delete-redis
art:feautre/minigame
art:DB연결-정상화-완료

No commits in common. "9afaaf9a2e7e421a887e8bea8de3610bbdb9e064" and "d9f3e160aae266e4dc6a91cf868a8b32c2a1435a" have entirely different histories.
9afaaf9a2e ... d9f3e160aa

1 changed files with 2 additions and 35 deletions
Show Stats Expand all files Collapse all files

37
src/services/FishingService.ts
View File

@ -148,7 +148,7 @@ export class FishingService {
} }
const userKey = this.getUserKey(interaction.guildId, interaction.user.id); const userKey = this.getUserKey(interaction.guildId, interaction.user.id);
const existing = await this.getActiveSession(userKey); const existing = this.sessionsByUser.get(userKey);
if (existing) { if (existing) {
return { thread: existing.thread, existed: true }; return { thread: existing.thread, existed: true };
} }
@ -170,7 +170,7 @@ export class FishingService {
return false; return false;
} }
const session = await this.getActiveSession(this.getUserKey(interaction.guildId, interaction.user.id)); const session = this.sessionsByUser.get(this.getUserKey(interaction.guildId, interaction.user.id));
if (!session) { if (!session) {
const thread = await this.findOwnedFishingThread(interaction); const thread = await this.findOwnedFishingThread(interaction);
if (!thread) { if (!thread) {
@ -394,39 +394,6 @@ export class FishingService {
} }
} }
private static async getActiveSession(userKey: string) {
const session = this.sessionsByUser.get(userKey);
if (!session) {
return null;
}
if (await this.isSessionStale(session)) {
this.clearStaleSession(session);
return null;
}
return session;
}
private static async isSessionStale(session: FishingSession) {
try {
await session.thread.fetch();
await session.controlMessage.fetch();
return false;
} catch (error) {
logger.info(
`[Fishing] Clearing stale session for ${session.userId} in thread ${session.threadId}: ${error instanceof Error ? error.message : String(error)}`,
);
return true;
}
}
private static clearStaleSession(session: FishingSession) {
this.clearTick(session);
this.sessionsByUser.delete(this.getUserKey(session.guildId, session.userId));
this.sessionsByThread.delete(session.threadId);
}
private static async deleteThread(thread: ThreadChannel) { private static async deleteThread(thread: ThreadChannel) {
try { try {
await thread.delete(); await thread.delete();