Fix/unit tests v3

package.json

@@ -138,7 +138,12 @@
       "\\.enum\\.ts$",
       "\\.config\\.ts$",
       "\\.d\\.ts$",
-      "constants\\.ts$"
+      "constants\\.ts$",
+      "firebase/",
+      "storage/",
+      "ai-integration/",
+      "redis/",
+      "config/validate-config.ts"
     ],
     "coverageDirectory": "../coverage",
     "testEnvironment": "node",

src/email/email.service.spec.ts

@@ -3,10 +3,10 @@ import { EmailService } from './email.service';
 import { Services, RedisQueues } from 'src/utils/constants';
 import mailerConfig from 'src/common/config/mailer.config';
 import { getQueueToken } from '@nestjs/bullmq';
-import * as fs from 'fs';
+import * as fs from 'node:fs';
 
-// Mock fs.readFileSync
-jest.mock('fs', () => ({
+// Mock fs.readFileSync - must use 'node:fs' to match the import in the service
+jest.mock('node:fs', () => ({
   readFileSync: jest.fn(),
 }));
 

src/gateway/socket.gateway.spec.ts

@@ -34,6 +34,7 @@ describe('SocketGateway', () => {
     isUserInConversation: jest.fn(),
     markMessagesAsSeen: jest.fn(),
     getConversationUsers: jest.fn(),
+    getConversationUsersCached: jest.fn(),
     create: jest.fn(),
     update: jest.fn(),
   };
@@ -714,7 +715,7 @@ describe('SocketGateway', () => {
       const mockSocket = createMockSocket(1);
       mockSocket.to = jest.fn().mockReturnThis();
 
-      mockMessagesService.getConversationUsers.mockResolvedValue({
+      mockMessagesService.getConversationUsersCached.mockResolvedValue({
         user1Id: 1,
         user2Id: 2,
       });
@@ -741,7 +742,7 @@ describe('SocketGateway', () => {
       const mockSocket = createMockSocket(3);
       mockSocket.to = jest.fn().mockReturnThis();
 
-      mockMessagesService.getConversationUsers.mockResolvedValue({
+      mockMessagesService.getConversationUsersCached.mockResolvedValue({
         user1Id: 1,
         user2Id: 2,
       });
@@ -755,7 +756,7 @@ describe('SocketGateway', () => {
       const mockSocket = createMockSocket(1);
       mockSocket.to = jest.fn().mockReturnThis();
 
-      mockMessagesService.getConversationUsers.mockResolvedValue({
+      mockMessagesService.getConversationUsersCached.mockResolvedValue({
         user1Id: 1,
         user2Id: 2,
       });
@@ -773,7 +774,7 @@ describe('SocketGateway', () => {
       const mockSocket = createMockSocket(2);
       mockSocket.to = jest.fn().mockReturnThis();
 
-      mockMessagesService.getConversationUsers.mockResolvedValue({
+      mockMessagesService.getConversationUsersCached.mockResolvedValue({
         user1Id: 1,
         user2Id: 2,
       });
@@ -793,7 +794,7 @@ describe('SocketGateway', () => {
       const mockSocket = createMockSocket(1);
       mockSocket.to = jest.fn().mockReturnThis();
 
-      mockMessagesService.getConversationUsers.mockResolvedValue({
+      mockMessagesService.getConversationUsersCached.mockResolvedValue({
         user1Id: 1,
         user2Id: 2,
       });
@@ -820,7 +821,7 @@ describe('SocketGateway', () => {
       const mockSocket = createMockSocket(3);
       mockSocket.to = jest.fn().mockReturnThis();
 
-      mockMessagesService.getConversationUsers.mockResolvedValue({
+      mockMessagesService.getConversationUsersCached.mockResolvedValue({
         user1Id: 1,
         user2Id: 2,
       });
@@ -834,7 +835,7 @@ describe('SocketGateway', () => {
       const mockSocket = createMockSocket(1);
       mockSocket.to = jest.fn().mockReturnThis();
 
-      mockMessagesService.getConversationUsers.mockResolvedValue({
+      mockMessagesService.getConversationUsersCached.mockResolvedValue({
         user1Id: 1,
         user2Id: 2,
       });
@@ -852,7 +853,7 @@ describe('SocketGateway', () => {
       const mockSocket = createMockSocket(2);
       mockSocket.to = jest.fn().mockReturnThis();
 
-      mockMessagesService.getConversationUsers.mockResolvedValue({
+      mockMessagesService.getConversationUsersCached.mockResolvedValue({
         user1Id: 1,
         user2Id: 2,
       });

src/messages/messages.service.spec.ts

@@ -32,6 +32,14 @@ describe('MessagesService', () => {
     $transaction: jest.fn(),
   };
 
+  const mockRedisService = {
+    get: jest.fn(),
+    set: jest.fn(),
+    del: jest.fn(),
+    getJSON: jest.fn(),
+    setJSON: jest.fn(),
+  };
+
   beforeEach(async () => {
     const module: TestingModule = await Test.createTestingModule({
       providers: [
@@ -43,6 +51,10 @@ describe('MessagesService', () => {
           provide: Services.PRISMA,
           useValue: mockPrismaService,
         },
+        {
+          provide: Services.REDIS,
+          useValue: mockRedisService,
+        },
       ],
     }).compile();
 

src/notifications/events/notification.listener.spec.ts

@@ -35,6 +35,9 @@ describe('NotificationListener', () => {
             post: {
               findUnique: jest.fn(),
             },
+            mute: {
+              findUnique: jest.fn(),
+            },
           },
         },
       ],

src/post/hashtag.controller.spec.ts

@@ -10,6 +10,10 @@ describe('HashtagController', () => {
     recalculateTrends: jest.fn(),
   };
 
+  const mockPersonalizedTrendsService = {
+    getPersonalizedTrending: jest.fn(),
+  };
+
   beforeEach(async () => {
     const module: TestingModule = await Test.createTestingModule({
       controllers: [HashtagController],
@@ -18,6 +22,10 @@ describe('HashtagController', () => {
           provide: Services.HASHTAG_TRENDS,
           useValue: mockHashtagTrendService,
         },
+        {
+          provide: Services.PERSONALIZED_TRENDS,
+          useValue: mockPersonalizedTrendsService,
+        },
       ],
     }).compile();
 

src/post/post-timeline.service.spec.ts

@@ -1067,14 +1067,14 @@ describe('PostService - Timeline Endpoints', () => {
       );
     });
 
-    it('should only fetch posts from last 30 days', async () => {
+    it('should only fetch posts from last 14 days', async () => {
       mockPrismaService.$queryRawUnsafe.mockResolvedValue([mockPostWithInterestName]);
       mockMlService.getQualityScores.mockResolvedValue(new Map([[100, 0.85]]));
 
       await service.getExploreAllInterestsFeed(1);
 
       const query = mockPrismaService.$queryRawUnsafe.mock.calls[0][0];
-      expect(query).toContain("NOW() - INTERVAL '30 days'");
+      expect(query).toContain("NOW() - INTERVAL '14 days'");
     });
 
     it('should include user interaction flags', async () => {