feat!: upgrade nest to v11

Signed-off-by: Innei <tukon479@gmail.com>

Author: Innei

apps/core/package.json

@@ -59,41 +59,41 @@
     "@babel/plugin-transform-modules-commonjs": "7.26.3",
     "@babel/plugin-transform-typescript": "7.26.7",
     "@babel/types": "^7.26.7",
-    "@fastify/cookie": "9.4.0",
-    "@fastify/multipart": "8.3.0",
+    "@fastify/cookie": "11.0.2",
+    "@fastify/multipart": "9.0.3",
     "@fastify/static": "8.1.0",
     "@innei/next-async": "0.3.0",
     "@innei/pretty-logger-nestjs": "0.3.3",
-    "@langchain/openai": "0.3.17",
+    "@keyv/redis": "4.2.0",
+    "@langchain/openai": "0.4.2",
     "@mx-space/compiled": "workspace:*",
-    "@nestjs/cache-manager": "2.3.0",
-    "@nestjs/common": "10.4.15",
-    "@nestjs/core": "10.4.15",
-    "@nestjs/event-emitter": "2.1.1",
+    "@nestjs/cache-manager": "3.0.0",
+    "@nestjs/common": "11.0.7",
+    "@nestjs/core": "11.0.7",
+    "@nestjs/event-emitter": "3.0.0",
     "@nestjs/mapped-types": "^2.1.0",
-    "@nestjs/platform-fastify": "10.4.15",
-    "@nestjs/platform-socket.io": "10.4.15",
-    "@nestjs/schedule": "4.1.2",
+    "@nestjs/platform-fastify": "11.0.7",
+    "@nestjs/platform-socket.io": "11.0.7",
+    "@nestjs/schedule": "5.0.1",
     "@nestjs/throttler": "6.4.0",
-    "@nestjs/websockets": "10.4.15",
+    "@nestjs/websockets": "11.0.7",
     "@simplewebauthn/server": "10.0.1",
     "@socket.io/redis-adapter": "8.3.0",
     "@socket.io/redis-emitter": "5.1.0",
     "@typegoose/auto-increment": "4.9.0",
     "@typegoose/typegoose": "12.8.0",
     "@types/jsonwebtoken": "9.0.8",
     "algoliasearch": "4.24.0",
-    "axios": "^1.7.8",
+    "axios": "^1.7.9",
     "axios-retry": "4.5.0",
     "bcryptjs": "^2.4.3",
     "blurhash": "2.0.5",
-    "cache-manager": "5.7.6",
-    "cache-manager-ioredis-yet": "2.1.2",
+    "cache-manager": "6.4.0",
     "class-transformer": "0.5.1",
     "class-validator": "0.13.2",
     "class-validator-jsonschema": "npm:@innei/class-validator-jsonschema@3.1.2",
     "cls-hooked": "^4.2.2",
-    "commander": "12.1.0",
+    "commander": "13.1.0",
     "dayjs": "1.11.13",
     "ejs": "3.1.10",
     "form-data": "4.0.1",
@@ -103,6 +103,7 @@
     "json5": "2.2.3",
     "jsonwebtoken": "9.0.2",
     "jszip": "3.10.1",
+    "keyv": "5.2.3",
     "langchain": "0.3.15",
     "linkedom": "0.18.7",
     "lodash": "^4.17.21",
@@ -111,13 +112,13 @@
     "mime-types": "^2.1.35",
     "mkdirp": "^3.0.1",
     "mongoose": "8.7.0",
-    "mongoose-aggregate-paginate-v2": "1.1.2",
+    "mongoose-aggregate-paginate-v2": "1.1.3",
     "mongoose-autopopulate": "1.1.0",
     "mongoose-lean-getters": "2.1.1",
-    "mongoose-lean-virtuals": "1.0.0",
+    "mongoose-lean-virtuals": "1.1.0",
     "mongoose-paginate-v2": "1.9.0",
     "node-machine-id": "1.1.12",
-    "nodemailer": "6.9.16",
+    "nodemailer": "6.10.0",
     "openai": "4.82.0",
     "pluralize": "^8.0.0",
     "qs": "6.14.0",
@@ -143,12 +144,12 @@
     "@swc/core": "1.10.14",
     "@types/babel__core": "7.20.5",
     "@types/bcryptjs": "^2.4.6",
-    "@types/cache-manager": "4.0.6",
+    "@types/cache-manager": "5.0.0",
     "@types/cls-hooked": "^4.3.9",
     "@types/ejs": "3.1.5",
     "@types/get-image-colors": "4.0.5",
     "@types/js-yaml": "4.0.9",
-    "@types/lodash": "4.17.14",
+    "@types/lodash": "4.17.15",
     "@types/mime-types": "2.1.4",
     "@types/mongoose-aggregate-paginate-v2": "1.0.12",
     "@types/node": "22.13.1",
@@ -169,4 +170,4 @@
     "vitest": "1.5.2",
     "zx": "7.2.3"
   }
-}
+}

apps/core/src/app.controller.ts

@@ -21,12 +21,13 @@ import { AllowAllCorsInterceptor } from './common/interceptors/allow-all-cors.in
 import { RedisKeys } from './constants/cache.constant'
 import { OptionModel } from './modules/configs/configs.model'
 import { CacheService } from './processors/redis/cache.service'
+import { RedisService } from './processors/redis/redis.service'
 import { getRedisKey } from './utils/redis.util'
 
 @ApiController()
 export class AppController {
   constructor(
-    private readonly cacheService: CacheService,
+    private readonly redisService: RedisService,
     @InjectModel(OptionModel)
     private readonly optionModel: MongooseModel<OptionModel>,
   ) {}
@@ -64,7 +65,7 @@ export class AppController {
   @HttpCache.disable
   @HttpCode(204)
   async likeThis(@IpLocation() { ip }: IpRecord) {
-    const redis = this.cacheService.getClient()
+    const redis = this.redisService.getClient()
 
     const isLikedBefore = await redis.sismember(
       getRedisKey(RedisKeys.LikeSite),
@@ -100,13 +101,13 @@ export class AppController {
   @HttpCache.disable
   @Auth()
   async cleanCatch() {
-    await this.cacheService.cleanCatch()
+    await this.redisService.cleanCatch()
   }
 
   @Get('/clean_redis')
   @HttpCache.disable
   @Auth()
   async cleanAllRedisKey() {
-    await this.cacheService.cleanAllRedisKey()
+    await this.redisService.cleanAllRedisKey()
   }
 }

apps/core/src/app.module.ts

@@ -175,6 +175,6 @@ export class AppModule implements NestModule {
     }
   }
   configure(consumer: MiddlewareConsumer) {
-    consumer.apply(RequestContextMiddleware).forRoutes('(.*)')
+    consumer.apply(RequestContextMiddleware).forRoutes('*app')
   }
 }

apps/core/src/bootstrap.ts

@@ -1,6 +1,7 @@
 import cluster from 'node:cluster'
 import { performance } from 'node:perf_hooks'
 import wcmatch from 'wildcard-match'
+import type { FastifyCorsOptions } from '@fastify/cors'
 import type { LogLevel } from '@nestjs/common'
 import type { CorsOptions } from '@nestjs/common/interfaces/external/cors-options.interface'
 import type { NestFastifyApplication } from '@nestjs/platform-fastify'
@@ -40,11 +41,12 @@ export async function bootstrap() {
     },
   )
 
-  const allowAllCors: CorsOptions = {
+  const allowAllCors: FastifyCorsOptions = {
     credentials: true,
-    origin: (origin, callback) => callback(null, origin),
+    origin: (origin, callback) => callback(null, origin || ''),
   }
   // Origin 如果不是数组就全部允许跨域
+
   app.enableCors(
     isDev
       ? allowAllCors
@@ -53,14 +55,14 @@ export async function bootstrap() {
             origin: (origin, callback) => {
               let currentHost: string
               try {
-                currentHost = new URL(origin).host
+                currentHost = new URL(origin || '').host
               } catch {
-                currentHost = origin
+                currentHost = origin || ''
               }
               const allow = Origin.some((host) => wcmatch(host)(currentHost))
 
               if (allow) {
-                callback(null, origin)
+                callback(null, origin || '')
               } else {
                 callback(null, false)
               }

apps/core/src/common/interceptors/analyze.interceptor.ts

@@ -24,6 +24,7 @@ import { REFLECTOR } from '~/constants/system.constant'
 import { AnalyzeModel } from '~/modules/analyze/analyze.model'
 import { OptionModel } from '~/modules/configs/configs.model'
 import { CacheService } from '~/processors/redis/cache.service'
+import { RedisService } from '~/processors/redis/redis.service'
 import { getNestExecutionContextRequest } from '~/transformers/get-req.transformer'
 import { InjectModel } from '~/transformers/model.transformer'
 import { getIp } from '~/utils/ip.util'
@@ -40,7 +41,7 @@ export class AnalyzeInterceptor implements NestInterceptor {
     private readonly model: ReturnModelType<typeof AnalyzeModel>,
     @InjectModel(OptionModel)
     private readonly options: ReturnModelType<typeof OptionModel>,
-    private readonly cacheService: CacheService,
+    private readonly redisService: RedisService,
     @Inject(REFLECTOR) private readonly reflector: Reflector,
   ) {
     this.init()
@@ -121,7 +122,7 @@ export class AnalyzeInterceptor implements NestInterceptor {
         })
 
         // ip access in redis
-        const client = this.cacheService.getClient()
+        const client = this.redisService.getClient()
 
         const count = await client.sadd(getRedisKey(RedisKeys.AccessIp), ip)
         if (count) {

apps/core/src/common/interceptors/idempotence.interceptor.ts

@@ -20,6 +20,7 @@ import {
 } from '~/constants/meta.constant'
 import { REFLECTOR } from '~/constants/system.constant'
 import { CacheService } from '~/processors/redis/cache.service'
+import { RedisService } from '~/processors/redis/redis.service'
 import { getIp } from '~/utils/ip.util'
 import { getRedisKey } from '~/utils/redis.util'
 import { hashString } from '~/utils/tool.util'
@@ -56,7 +57,7 @@ export type IdempotenceOption = {
 @Injectable()
 export class IdempotenceInterceptor implements NestInterceptor {
   constructor(
-    private readonly cacheService: CacheService,
+    private readonly redisService: RedisService,
     @Inject(REFLECTOR) private readonly reflector: Reflector,
   ) {}
 
@@ -85,7 +86,7 @@ export class IdempotenceInterceptor implements NestInterceptor {
       expired = 60,
       disableGenerateKey = false,
     } = options
-    const redis = this.cacheService.getClient()
+    const redis = this.redisService.getClient()
 
     const idempotence = request.headers[IdempotenceHeaderKey] as string
     const key = disableGenerateKey

apps/core/src/modules/aggregate/aggregate.service.ts

@@ -18,6 +18,7 @@ import { EventBusEvents } from '~/constants/event-bus.constant'
 import { WebEventsGateway } from '~/processors/gateway/web/events.gateway'
 import { UrlBuilderService } from '~/processors/helper/helper.url-builder.service'
 import { CacheService } from '~/processors/redis/cache.service'
+import { RedisService } from '~/processors/redis/redis.service'
 import { addYearCondition } from '~/transformers/db-query.transformer'
 import { getRedisKey } from '~/utils/redis.util'
 import { getShortDate } from '~/utils/time.util'
@@ -66,7 +67,7 @@ export class AggregateService {
 
     private readonly configs: ConfigsService,
     private readonly gateway: WebEventsGateway,
-    private readonly cacheService: CacheService,
+    private readonly redisService: RedisService,
   ) {}
 
   getAllCategory() {
@@ -353,7 +354,7 @@ export class AggregateService {
   }
 
   async getCounts() {
-    const redisClient = this.cacheService.getClient()
+    const redisClient = this.redisService.getClient()
     const dateFormat = getShortDate(new Date())
 
     const [
@@ -423,7 +424,7 @@ export class AggregateService {
 
   @OnEvent(EventBusEvents.CleanAggregateCache, { async: true })
   public clearAggregateCache() {
-    const redis = this.cacheService.getClient()
+    const redis = this.redisService.getClient()
     return Promise.all([
       redis.del(CacheKeys.RSS),
       redis.del(CacheKeys.RSSXml),

apps/core/src/modules/ai/ai-summary/ai-summary.service.ts

@@ -11,6 +11,7 @@ import { CollectionRefTypes } from '~/constants/db.constant'
 import { ErrorCodeEnum } from '~/constants/error-code.constant'
 import { DatabaseService } from '~/processors/database/database.service'
 import { CacheService } from '~/processors/redis/cache.service'
+import { RedisService } from '~/processors/redis/redis.service'
 import { InjectModel } from '~/transformers/model.transformer'
 import { transformDataToPaginate } from '~/transformers/paginate.transformer'
 import { md5 } from '~/utils/tool.util'
@@ -29,7 +30,7 @@ export class AiSummaryService {
     private readonly databaseService: DatabaseService,
     private readonly configService: ConfigsService,
 
-    private readonly cacheService: CacheService,
+    private readonly redisService: RedisService,
     private readonly aiService: AiService,
   ) {
     this.logger = new Logger(AiSummaryService.name)
@@ -108,7 +109,7 @@ export class AiSummaryService {
       if (this.cachedTaskId2AiPromise.has(taskId)) {
         return this.cachedTaskId2AiPromise.get(taskId)
       }
-      const redis = this.cacheService.getClient()
+      const redis = this.redisService.getClient()
 
       const isProcessing = await redis.get(taskId)
 

apps/core/src/modules/analyze/analyze.controller.ts

@@ -8,6 +8,7 @@ import { Auth } from '~/common/decorators/auth.decorator'
 import { Paginator } from '~/common/decorators/http.decorator'
 import { RedisKeys } from '~/constants/cache.constant'
 import { CacheService } from '~/processors/redis/cache.service'
+import { RedisService } from '~/processors/redis/redis.service'
 import { getRedisKey } from '~/utils/redis.util'
 import { getTodayEarly, getWeekStart } from '~/utils/time.util'
 
@@ -19,7 +20,7 @@ import { AnalyzeService } from './analyze.service'
 export class AnalyzeController {
   constructor(
     private readonly service: AnalyzeService,
-    private readonly cacheService: CacheService,
+    private readonly redisService: RedisService,
   ) {}
 
   @Get('/')
@@ -148,7 +149,7 @@ export class AnalyzeController {
 
   @Get('/like')
   async getTodayLikedArticle() {
-    const client = this.cacheService.getClient()
+    const client = this.redisService.getClient()
     const keys = await client.keys(getRedisKey(RedisKeys.Like, '*'))
 
     return Promise.all(

apps/core/src/modules/analyze/analyze.service.ts

@@ -7,6 +7,7 @@ import { ReturnModelType } from '@typegoose/typegoose'
 
 import { RedisKeys } from '~/constants/cache.constant'
 import { CacheService } from '~/processors/redis/cache.service'
+import { RedisService } from '~/processors/redis/redis.service'
 import { InjectModel } from '~/transformers/model.transformer'
 import { getRedisKey } from '~/utils/redis.util'
 
@@ -20,7 +21,7 @@ export class AnalyzeService {
     private readonly options: ReturnModelType<typeof OptionModel>,
     @InjectModel(AnalyzeModel)
     private readonly analyzeModel: MongooseModel<AnalyzeModel>,
-    private readonly cacheService: CacheService,
+    private readonly redisService: RedisService,
   ) {}
 
   public get model() {
@@ -289,7 +290,7 @@ export class AnalyzeService {
   }
 
   async getTodayAccessIp(): Promise<string[]> {
-    const redis = this.cacheService.getClient()
+    const redis = this.redisService.getClient()
     const fromRedisIps = await redis.smembers(getRedisKey(RedisKeys.AccessIp))
 
     return fromRedisIps