refactor: extract subpub from redis

test/helper/redis-mock.helper.ts

@@ -1,7 +1,7 @@
 import IORedis, { Redis } from 'ioredis'
 import RedisMemoryServer from 'redis-memory-server'
 
-import { CacheService } from '~/processors/cache/cache.service'
+import { CacheService } from '~/processors/redis/cache.service'
 
 export class MockCacheService {
   private client: Redis

test/src/app.controller.e2e-spec.ts

@@ -4,7 +4,7 @@ import { Test } from '@nestjs/testing'
 import { AppController } from '~/app.controller'
 import { fastifyApp } from '~/common/adapters/fastify.adapter'
 import { OptionModel } from '~/modules/configs/configs.model'
-import { CacheService } from '~/processors/cache/cache.service'
+import { CacheService } from '~/processors/redis/cache.service'
 import { getModelToken } from '~/transformers/model.transformer'
 
 describe('AppController (e2e)', () => {

test/src/modules/auth/auth.service.spec.ts

@@ -2,8 +2,8 @@ import { Test } from '@nestjs/testing'
 
 import { AuthService } from '~/modules/auth/auth.service'
 import { UserModel } from '~/modules/user/user.model'
-import { CacheService } from '~/processors/cache/cache.service'
 import { JWTService } from '~/processors/helper/helper.jwt.service'
+import { CacheService } from '~/processors/redis/cache.service'
 import { getModelToken } from '~/transformers/model.transformer'
 
 describe('Test AuthService', () => {

test/src/modules/configs/configs.service.spec.ts

@@ -9,8 +9,9 @@ import { RedisKeys } from '~/constants/cache.constant'
 import { OptionModel } from '~/modules/configs/configs.model'
 import { ConfigsService } from '~/modules/configs/configs.service'
 import { UserService } from '~/modules/user/user.service'
-import { CacheService } from '~/processors/cache/cache.service'
 import { EventManagerService } from '~/processors/helper/helper.event.service'
+import { CacheService } from '~/processors/redis/cache.service'
+import { SubPubBridgeService } from '~/processors/redis/subpub.service'
 import { getModelToken } from '~/transformers/model.transformer'
 import { getRedisKey } from '~/utils/redis.util'
 
@@ -45,6 +46,10 @@ describe('Test ConfigsService', () => {
           useValue: redisService$,
         },
         { provide: EventManagerService, useValue: { emit: mockEmitFn } },
+        {
+          provide: SubPubBridgeService,
+          useValue: {},
+        },
       ],
     }).compile()
 

test/src/modules/serverless/serverless.service.spec.ts

@@ -7,10 +7,10 @@ import { getModelForClass } from '@typegoose/typegoose'
 import { createMockedContextResponse } from '~/modules/serverless/mock-response.util'
 import { ServerlessService } from '~/modules/serverless/serverless.service'
 import { SnippetModel, SnippetType } from '~/modules/snippet/snippet.model'
-import { CacheService } from '~/processors/cache/cache.service'
 import { DatabaseService } from '~/processors/database/database.service'
 import { AssetService } from '~/processors/helper/helper.asset.service'
 import { HttpService } from '~/processors/helper/helper.http.service'
+import { CacheService } from '~/processors/redis/cache.service'
 import { getModelToken } from '~/transformers/model.transformer'
 
 describe('test serverless function service', () => {

test/src/modules/snippet/snippet.controller.e2e-spec.ts

@@ -10,8 +10,8 @@ import { ServerlessService } from '~/modules/serverless/serverless.service'
 import { SnippetController } from '~/modules/snippet/snippet.controller'
 import { SnippetModel, SnippetType } from '~/modules/snippet/snippet.model'
 import { SnippetService } from '~/modules/snippet/snippet.service'
-import { CacheService } from '~/processors/cache/cache.service'
 import { DatabaseService } from '~/processors/database/database.service'
+import { CacheService } from '~/processors/redis/cache.service'
 import { getModelToken } from '~/transformers/model.transformer'
 
 describe('test /snippets', () => {

test/src/modules/snippet/snippet.service.spec.ts

@@ -1,14 +1,16 @@
+import { dbHelper } from 'test/helper/db-mock.helper'
+import { redisHelper } from 'test/helper/redis-mock.helper'
+
 import { BadRequestException, NotFoundException } from '@nestjs/common'
 import { Test } from '@nestjs/testing'
 import { getModelForClass } from '@typegoose/typegoose'
-import { dbHelper } from 'test/helper/db-mock.helper'
-import { redisHelper } from 'test/helper/redis-mock.helper'
-import { getModelToken } from '~/transformers/model.transformer'
+
 import { ServerlessService } from '~/modules/serverless/serverless.service'
 import { SnippetModel, SnippetType } from '~/modules/snippet/snippet.model'
 import { SnippetService } from '~/modules/snippet/snippet.service'
-import { CacheService } from '~/processors/cache/cache.service'
 import { DatabaseService } from '~/processors/database/database.service'
+import { CacheService } from '~/processors/redis/cache.service'
+import { getModelToken } from '~/transformers/model.transformer'
 
 describe('test Snippet Service', () => {
   let service: SnippetService

test/src/modules/user/user.controller.spec.ts

@@ -1,8 +1,9 @@
 import { Test } from '@nestjs/testing'
+
 import { AuthService } from '~/modules/auth/auth.service'
 import { UserController } from '~/modules/user/user.controller'
 import { UserService } from '~/modules/user/user.service'
-import { CacheService } from '~/processors/cache/cache.service'
+import { CacheService } from '~/processors/redis/cache.service'
 
 describe('test UserModule controller', () => {
   let userController: UserController

test/src/modules/user/user.service.spec.ts

@@ -4,8 +4,8 @@ import { Test } from '@nestjs/testing'
 import { AuthService } from '~/modules/auth/auth.service'
 import { UserModel } from '~/modules/user/user.model'
 import { UserService } from '~/modules/user/user.service'
-import { CacheService } from '~/processors/cache/cache.service'
 import { JWTService } from '~/processors/helper/helper.jwt.service'
+import { CacheService } from '~/processors/redis/cache.service'
 import { getModelToken } from '~/transformers/model.transformer'
 
 describe('test UserModule service', () => {

test/src/processors/helper/helper.jwt.service.spec.ts

@@ -2,8 +2,8 @@ import { redisHelper } from 'test/helper/redis-mock.helper'
 
 import { Test } from '@nestjs/testing'
 
-import { CacheService } from '~/processors/cache/cache.service'
 import { JWTService } from '~/processors/helper/helper.jwt.service'
+import { CacheService } from '~/processors/redis/cache.service'
 
 describe('test jwt service', () => {
   let service: JWTService