- Activities system work

src/activities/activities-feed/activities-feed.service.ts

@@ -1,12 +1,10 @@
-import { HttpException, HttpStatus, Inject, Injectable } from "@nestjs/common";
+import { HttpException, HttpStatus, Injectable } from "@nestjs/common";
 import { Activity } from "../activities-repository/entities/activity.entity";
 import {
     ActivitiesFeedRequestDto,
     ActivityFeedCriteria,
 } from "./dto/activities-feed-request.dto";
 import { ActivitiesRepositoryService } from "../activities-repository/activities-repository.service";
-import { CACHE_MANAGER } from "@nestjs/cache-manager";
-import { Cache } from "cache-manager";
 import { TPaginationData } from "../../utils/pagination/pagination-response.dto";
 import { ActivityType } from "../activities-queue/activities-queue.constants";
 import { FollowService } from "../../follow/follow.service";
@@ -84,7 +82,7 @@ export class ActivitiesFeedService {
         userId: string,
         dto: ActivitiesFeedRequestDto,
     ): Promise<TPaginationData<Activity>> {
-        const [followedUsersIds] = await this.followService.getFollowerData({
+        const [followedUsersIds] = await this.followService.getFollowerInfo({
             targetUserId: userId,
             criteria: "followers",
             offset: 0,

src/activities/activities-repository/activities-repository.controller.ts

@@ -0,0 +1,33 @@
+import {
+    Controller,
+    Get,
+    Query,
+    UseGuards,
+    UseInterceptors,
+} from "@nestjs/common";
+import { ApiOkResponse, ApiTags } from "@nestjs/swagger";
+import { FindLatestActivitiesDto } from "./dto/find-latest-activities.dto";
+import { ActivitiesRepositoryService } from "./activities-repository.service";
+import { ActivitiesPaginatedResponseDto } from "./dto/activities-paginated-response.dto";
+import { PaginationInterceptor } from "../../interceptor/pagination.interceptor";
+import { AuthGuard } from "../../auth/auth.guard";
+import { Public } from "../../auth/public.decorator";
+
+@Controller("activities")
+@ApiTags("activities")
+@UseGuards(AuthGuard)
+export class ActivitiesRepositoryController {
+    constructor(
+        private readonly activitiesRepositoryService: ActivitiesRepositoryService,
+    ) {}
+
+    @Get()
+    @ApiOkResponse({
+        type: ActivitiesPaginatedResponseDto,
+    })
+    @UseInterceptors(PaginationInterceptor)
+    @Public()
+    async findLatest(@Query() dto: FindLatestActivitiesDto) {
+        return this.activitiesRepositoryService.findLatest(dto);
+    }
+}

src/activities/activities-repository/activities-repository.module.ts

@@ -3,10 +3,12 @@ import { ActivitiesRepositoryService } from "./activities-repository.service";
 import { TypeOrmModule } from "@nestjs/typeorm";
 import { Activity } from "./entities/activity.entity";
 import { StatisticsQueueModule } from "../../statistics/statistics-queue/statistics-queue.module";
+import { ActivitiesRepositoryController } from './activities-repository.controller';
 
 @Module({
     imports: [TypeOrmModule.forFeature([Activity]), StatisticsQueueModule],
     providers: [ActivitiesRepositoryService],
     exports: [ActivitiesRepositoryService],
+    controllers: [ActivitiesRepositoryController],
 })
 export class ActivitiesRepositoryModule {}

src/activities/activities-repository/activities-repository.service.ts

@@ -13,6 +13,8 @@ import {
 } from "../activities-queue/activities-queue.constants";
 import { StatisticsQueueService } from "../../statistics/statistics-queue/statistics-queue.service";
 import { StatisticsSourceType } from "../../statistics/statistics.constants";
+import { FindLatestActivitiesDto } from "./dto/find-latest-activities.dto";
+import { buildBaseFindOptions } from "../../utils/buildBaseFindOptions";
 
 @Injectable()
 export class ActivitiesRepositoryService {
@@ -107,4 +109,14 @@ export class ActivitiesRepositoryService {
     async findOneBy(by: FindOneOptions<Activity>) {
         return await this.activitiesRepository.findOne(by);
     }
+
+    async findLatest(dto: FindLatestActivitiesDto) {
+        const baseFindOptions = buildBaseFindOptions(dto);
+        return await this.findLatestBy({
+            ...baseFindOptions,
+            where: {
+                profileUserId: dto.userId,
+            },
+        });
+    }
 }

src/activities/activities-repository/dto/activities-paginated-response.dto.ts

@@ -0,0 +1,7 @@
+import { Activity } from "../entities/activity.entity";
+import { PaginationInfo } from "../../../utils/pagination/pagination-response.dto";
+
+export class ActivitiesPaginatedResponseDto {
+    data: Activity[];
+    pagination: PaginationInfo;
+}

src/activities/activities-repository/dto/find-latest-activities.dto.ts

@@ -0,0 +1,14 @@
+import { IsOptional, IsString, Length } from "class-validator";
+import { OmitType } from "@nestjs/swagger";
+import { BaseFindDto } from "../../../utils/base-find.dto";
+import { Activity } from "../entities/activity.entity";
+
+export class FindLatestActivitiesDto extends OmitType(BaseFindDto<Activity>, [
+    "orderBy",
+    "search",
+]) {
+    @IsOptional()
+    @IsString()
+    @Length(36)
+    userId?: string;
+}

src/app.module.ts

@@ -78,7 +78,7 @@ function getRedisConfig() {
                     autoLoadEntities: true,
                     // Never turn this on. Use migrations instead.
                     synchronize: false,
-                    logging: false,
+
                     /**
                      * Allows us to cache select queries using ioredis. Default duration of 1000ms.
                      * https://orkhan.gitbook.io/typeorm/docs/caching

src/follow/follow.controller.ts

@@ -61,7 +61,7 @@ export class FollowController {
     @Public()
     @HttpCode(HttpStatus.OK)
     async getFollowInfo(@Body() dto: FollowInfoRequestDto) {
-        return await this.followService.getFollowerData(dto);
+        return await this.followService.getFollowerInfo(dto);
     }
 
     @Post()

src/follow/follow.service.ts

@@ -127,7 +127,7 @@ export class FollowService {
      * Gets followers or followed user ids with pagination data.
      * @param dto
      */
-    public async getFollowerData(
+    public async getFollowerInfo(
         dto: FollowInfoRequestDto,
     ): Promise<TPaginationData<string>> {
         const baseFindOptions = buildBaseFindOptions(dto);

src/statistics/game-statistics.service.ts

@@ -170,6 +170,7 @@ export class GameStatisticsService implements StatisticsService {
             .addOrderBy(`s.viewsCount`, `DESC`)
             .skip(0)
             .take(fixedStatisticsLimit)
+            .printSql()
             .cache(`trending-games-statistics`, hours(6))
             .getMany();