Fix /link delete API

apps/service-auth/src/app.module.ts

@@ -8,10 +8,12 @@ import { GuildsModule } from './guilds/guilds.module';
 import { LinksModule } from './links/links.module';
 import { PlayersModule } from './players/players.module';
 import { RostersModule } from './rosters/rosters.module';
+import { ScheduleModule } from '@nestjs/schedule';
 
 @Module({
  imports: [
  ConfigModule.forRoot({ isGlobal: true }),
+ ScheduleModule.forRoot(),
  MongoDbModule,
  RedisModule,
  AuthModule,

apps/service-auth/src/links/discord-link.service.ts

@@ -0,0 +1,41 @@
+import { Injectable } from '@nestjs/common';
+import { Interval } from '@nestjs/schedule';
+
+@Injectable()
+export class DiscordLinkService {
+ private bearerToken: string;
+
+ private onModuleInit() {
+ this.login();
+ }
+
+ @Interval(1000 * 60 * 60)
+ private async login() {
+ const res = await fetch('https://cocdiscord.link/login', {
+ method: 'POST',
+ headers: {
+ 'Content-Type': 'application/json',
+ },
+ body: JSON.stringify({
+ username: process.env.DISCORD_LINK_USERNAME,
+ password: process.env.DISCORD_LINK_PASSWORD,
+ }),
+ }).catch(() => null);
+ const data = (await res?.json().catch(() => null)) as { token?: string } | null;
+
+ if (data?.token) this.bearerToken = data.token;
+ return res?.status === 200 && this.bearerToken;
+ }
+
+ public async unlinkPlayerTag(playerTag: string) {
+ const res = await fetch(`https://cocdiscord.link/links/${encodeURIComponent(playerTag)}`, {
+ method: 'DELETE',
+ headers: {
+ Authorization: `Bearer ${this.bearerToken}`,
+ 'Content-Type': 'application/json',
+ },
+ }).catch(() => null);
+
+ return Promise.resolve(res?.status === 200);
+ }
+}

apps/service-auth/src/links/links.module.ts

@@ -1,12 +1,13 @@
 import { ClashClientModule } from '@app/clash-client';
 import { DiscordClientModule } from '@app/discord-client';
 import { Module } from '@nestjs/common';
+import { DiscordLinkService } from './discord-link.service';
 import { LinksController } from './links.controller';
 import { LinksService } from './links.service';
 
 @Module({
  imports: [ClashClientModule, DiscordClientModule],
  controllers: [LinksController],
- providers: [LinksService],
+ providers: [LinksService, DiscordLinkService],
 })
 export class LinksModule {}

apps/service-auth/src/links/links.service.ts

@@ -4,6 +4,7 @@ import { DiscordClientService } from '@app/discord-client';
 import { PlayerLinksEntity } from '@app/entities';
 import { ForbiddenException, Inject, Injectable, Logger, NotFoundException } from '@nestjs/common';
 import { Collection } from 'mongodb';
+import { DiscordLinkService } from './discord-link.service';
 import { CreateLinkInput, DeleteLinkInput } from './dto';
 
 @Injectable()
@@ -13,7 +14,7 @@ export class LinksService {
  constructor(
  private discordClientService: DiscordClientService,
  private clashClientService: ClashClientService,
-
+ private discordLinkService: DiscordLinkService,
  @Inject(Collections.PLAYER_LINKS)
  private playerLinksCollection: Collection<PlayerLinksEntity>,
  ) {}
@@ -80,6 +81,10 @@ export class LinksService {
  async deleteLink(userId: string, input: DeleteLinkInput) {
  await this.postUnlinkActions(userId, input.playerTag);
  await this.playerLinksCollection.deleteOne({ tag: input.playerTag });
+ await this.discordLinkService.unlinkPlayerTag(input.playerTag);
+
+ this.logger.log(`Link ${input.playerTag} deleted by ${userId}`);
+
  return { message: 'OK' };
  }
 

apps/service-auth/src/main.ts

@@ -1,14 +1,16 @@
+import { morganLogger } from '@app/helper';
 import { Logger, ValidationPipe, VersioningType } from '@nestjs/common';
 import { NestFactory } from '@nestjs/core';
+import { NestExpressApplication } from '@nestjs/platform-express';
 import { DocumentBuilder, SwaggerModule } from '@nestjs/swagger';
 import { AppModule } from './app.module';
-import { morganLogger } from '@app/helper';
 
 async function bootstrap() {
- const app = await NestFactory.create(AppModule, { cors: true });
+ const app = await NestFactory.create<NestExpressApplication>(AppModule);
  const logger = new Logger(AppModule.name);
 
  app.enableShutdownHooks();
+ app.enableCors();
  app.use(morganLogger(logger));
  app.useGlobalPipes(new ValidationPipe({ transform: true, whitelist: true }));
 

package.json

@@ -30,6 +30,7 @@
  "@nestjs/microservices": "^10.2.6",
  "@nestjs/passport": "^10.0.2",
  "@nestjs/platform-express": "^10.0.0",
+ "@nestjs/schedule": "^4.0.2",
  "@nestjs/swagger": "^7.3.0",
  "clashofclans.js": "^3.3.4",
  "class-transformer": "^0.5.1",
@@ -109,4 +110,4 @@
  "^@app/validators(|/.*)$": "<rootDir>/libs/validators/src/$1"
  }
  }
-}
+}