feat: fix caching, and adjust indexes mongo

docker-compose.yml

@@ -13,7 +13,7 @@ services:
       resources:
         limits:
           cpus: '0.37'
-          memory: '0.7GB'
+          memory: '0.4GB'
 
   api02:
     build: ./
@@ -27,7 +27,7 @@ services:
       resources:
         limits:
           cpus: '0.37'
-          memory: '0.7GB'
+          memory: '0.4GB'
 
   nginx:
     image: nginx:latest
@@ -48,7 +48,7 @@ services:
     image: mongo:latest
     hostname: db
     environment:
-      - MONGO_INITDB_DATABASE=elysia
+      - MONGO_INITDB_DATABASE=nestjs
       - MONGO_INITDB_ROOT_USERNAME=root
       - MONGO_INITDB_ROOT_PASSWORD=root
     command: mongod --quiet --logpath /dev/null
@@ -70,7 +70,7 @@ services:
       resources:
         limits:
           cpus: '0.05'
-          memory: '0.15GB'
+          memory: '0.75GB'
 
 networks:
   default:

package.json

@@ -28,9 +28,11 @@
     "@nestjs/platform-express": "^10.0.0",
     "bull": "^4.11.3",
     "cache-manager": "^5.2.3",
+    "cache-manager-redis-yet": "^4.1.2",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.0",
     "mongoose": "^7.4.4",
+    "redis": "^4.6.7",
     "reflect-metadata": "^0.1.13",
     "rxjs": "^7.8.1"
   },

src/app.module.ts

@@ -2,6 +2,8 @@ import { Module } from '@nestjs/common';
 import { PessoaModule } from './pessoa/pessoa.module';
 import { BullModule } from '@nestjs/bull';
 import { CacheModule } from '@nestjs/cache-manager';
+import { redisStore } from 'cache-manager-redis-yet';
+import { RedisClientOptions } from 'redis';
 
 @Module({
   imports: [
@@ -12,7 +14,12 @@ import { CacheModule } from '@nestjs/cache-manager';
         port: 6379,
       },
     }),
-    CacheModule.register({
+    CacheModule.register<RedisClientOptions>({
+      store: redisStore,
+      socket: {
+        host: 'redis',
+        port: 6379,
+      },
       isGlobal: true,
     }),
   ],

src/pessoa/pessoa.schema.ts

@@ -15,3 +15,10 @@ PessoaSchema.set('toJSON', {
     delete ret._id;
   },
 });
+
+PessoaSchema.index({ nome: 'text', apelido: 'text', stack: 'text' });
+PessoaSchema.index({
+  nome: 'ascending',
+  apelido: 'ascending',
+  stack: 'ascending',
+});

src/pessoa/pessoa.service.ts

@@ -26,35 +26,43 @@ export class PessoaService {
       throw new UnprocessableEntityException('Apelido já existe');
     }
 
-    await this.cacheManager.set(body.apelido, '1');
+    await this.cacheManager.set(body.apelido, '1', 0);
+    await this.cacheManager.set(body.id, JSON.stringify(body), 0);
     await this.pessoaQueue.add('createPerson', body);
     return;
   }
 
-  getPersons(t: string) {
-    return this.pessoaModel
+  async getPersons(t: string) {
+    const cached = await this.cacheManager.get(t);
+    if (cached) {
+      await this.cacheManager.del(t);
+      return JSON.parse(cached as string);
+    }
+    const persons = await this.pessoaModel
       .find({
         $or: [
           { nome: { $regex: t, $options: 'i' } },
           { apelido: { $regex: t, $options: 'i' } },
-          { stack: { $regex: t, $options: 'i' } },
+          { stack: t },
         ],
       })
       .limit(50)
       .exec();
+    await this.cacheManager.set(t, JSON.stringify(persons), 0);
+    return persons;
   }
 
   async getPerson(id: string) {
-    // const cached = await this.cacheManager.get<string>(id);
-    // if (!cached) {
-    //   throw new NotFoundException();
-    // }
-    // return JSON.parse(cached);
-    //
-    const person = await this.pessoaModel.findById(id).exec();
+    const cached = await this.cacheManager.get(id);
+    if (cached) {
+      await this.cacheManager.del(id);
+      return JSON.parse(cached as string);
+    }
+    const person = await this.pessoaModel.findOne({ _id: id }).exec();
     if (!person) {
       throw new NotFoundException();
     }
+    await this.cacheManager.set(id, JSON.stringify(person));
     return person;
   }