feat: battle log endpoint

Author: csuvajit

src/players/dto/battle-log.dto.ts

@@ -0,0 +1,15 @@
+export class BattleLogDto {
+  playerTag: string;
+  opponentTag: string;
+  battleType: string;
+  isAttack: boolean;
+  stars: number;
+  destruction: number;
+  trophies: number;
+  trophyChange: number;
+  createdAt: string;
+}
+
+export class BattleLogItemsDto {
+  items: BattleLogDto[];
+}

src/players/dto/index.ts

@@ -1,3 +1,4 @@
+export * from './battle-log.dto';
 export * from './clan-history.dto';
 export * from './clan-war-attack-log.dto';
 export * from './legend-attacks.dto';

src/players/players.controller.ts

@@ -8,6 +8,7 @@ import {
   AggregateClanWarLeagueHistoryItemsDto,
   AttackHistoryInputDto,
   AttackHistoryItemsDto,
+  BattleLogItemsDto,
   ClanHistoryItemsDto,
 } from './dto';
 import { PlayersService } from './players.service';
@@ -24,6 +25,12 @@ export class PlayersController {
     private globalService: GlobalService,
   ) {}
 
+  @Get('/:playerTag/battle-log')
+  @Cache(600)
+  getBattleLog(@Param('playerTag') playerTag: string): Promise<BattleLogItemsDto> {
+    return this.playersService.getPlayerBattleLog(playerTag);
+  }
+
   @Get('/:playerTag/history')
   @Cache(600)
   getClanHistory(@Param('playerTag') playerTag: string): Promise<ClanHistoryItemsDto> {

src/players/players.service.ts

@@ -1,17 +1,49 @@
 import { ClashClientService } from '@app/clash-client';
+import { ClickHouseClient } from '@clickhouse/client';
 import { Inject, Injectable } from '@nestjs/common';
 import Redis from 'ioredis';
 import { Db } from 'mongodb';
-import { GO_REDIS_TOKEN, MONGODB_TOKEN } from '../db';
+import { CLICKHOUSE_TOKEN, GO_REDIS_TOKEN, MONGODB_TOKEN } from '../db';
+import { BattleLogDto } from './dto';
 
 @Injectable()
 export class PlayersService {
   constructor(
     @Inject(GO_REDIS_TOKEN) private redis: Redis,
     @Inject(MONGODB_TOKEN) private db: Db,
     private clashClientService: ClashClientService,
+    @Inject(CLICKHOUSE_TOKEN) private clickhouse: ClickHouseClient,
   ) {}
 
+  async getPlayerBattleLog(playerTag: string) {
+    const result = await this.clickhouse.query({
+      query: `
+        SELECT
+          player_tag as playerTag,
+          opponent_tag as opponentTag,
+          battle_type as battleType,
+          toBool(is_attack) as isAttack,
+          stars,
+          destruction,
+          trophies,
+          trophy_change as trophyChange,
+          battle_date as battleDate,
+          ingested_at as ingestedAt
+        FROM battle_logs FINAL
+        WHERE player_tag = {playerTag: String}
+        ORDER BY version LIMIT {limit: Int32}
+      `,
+      query_params: {
+        playerTag,
+        limit: 300,
+      },
+    });
+
+    const rows = await result.json<BattleLogDto>();
+
+    return { items: (rows.data || []).reverse() };
+  }
+
   async addPlayer(tag: string) {
     const player = await this.clashClientService.getPlayerOrThrow(tag);
     await this.redis.sadd('legend_player_tags', player.tag);