Dev (#110)

* fixed signup and login links and made register page public

* replaced IAM view model with redux

* replaced todo view model with redux

* removed recoil from modules

* added infinite scrolling to todo page

* fixed infinite scroll and changed version

* wrote test and moved slices to store directory

* updated readme

Author: Raj-divine

README.md

@@ -113,4 +113,4 @@
       "@tests/(.*)": "tests/$1"
     }
   }
-}
+}

backend/package.json

@@ -12,6 +12,7 @@ import {
   Param,
   UseGuards,
   Request,
+  Query,
 } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config';
 import {
@@ -81,9 +82,10 @@ export class TodoController {
   @Get()
   @ApiOperation({ summary: 'Get all todos' })
   @ApiResponse({ status: 200, type: GetAllTodosResponseDto, description: 'Returns all todos' })
-  async getAll() {
-    const results = await this.queryBus.request(new GetTodosQuery());
-
+  async getAll(@Query('limit') limit: number, @Query('offset') offset: number) {
+    const results = await this.queryBus.request(
+      new GetTodosQuery(limit, offset),
+    );
     if (results.isOk) {
       const data = results.data;
       const todos: TodoReadModel[] = data.map((todo) => TodoReadModel.fromPrimitives(todo));

backend/src/api/todo.rest.controller.ts

@@ -47,7 +47,10 @@ export class TodoReadRepository implements TodoReadRepoPort {
   }
 
   @Application.Repo.Decorators.ReturnUnexpectedError()
-  async getAll(): Promise<
+  async getAll(params?: {
+    limit?: number;
+    offset?: number;
+  }): Promise<
     Either<TTodoReadModelSnapshot[], Application.Repo.Errors.Unexpected>
   > {
     const ctx = asyncLocalStorage.getStore()?.get('context');
@@ -62,9 +65,16 @@ export class TodoReadRepository implements TodoReadRepoPort {
     if (!userId) {
       throw new Error('Invalid userId');
     }
-    const todos = await this.collection
-      .find({ userId: { id: userId } })
-      .toArray();
+    let cursor = this.collection.find({ userId: { id: userId } });
+
+    if (params?.offset !== undefined) {
+      cursor = cursor.skip(+params.offset);
+    }
+    if (params?.limit !== undefined) {
+      cursor = cursor.limit(+params.limit);
+    }
+
+    const todos = await cursor.toArray();
     return ok(
       todos.map((todo) => {
         const res = {

backend/src/bounded-contexts/todo/todo/repository/todo-read.repository.ts

@@ -13,12 +13,11 @@ export type GetTodosQueryHandlerResponse = Either<
 >;
 
 export class GetTodosHandler
-  implements Application.IQueryHandler<GetTodosQuery, TTodoReadModelSnapshot[]>
-{
+  implements Application.IQueryHandler<GetTodosQuery, TTodoReadModelSnapshot[]> {
   constructor(
     @Inject(TodoReadRepoPortToken)
     private readonly todoRepo: TodoReadRepoPort,
-  ) {}
+  ) { }
 
   get query() {
     return GetTodosQuery;
@@ -37,7 +36,8 @@ export class GetTodosHandler
     },
   })
   async execute(query: GetTodosQuery): Promise<GetTodosQueryHandlerResponse> {
-    const results = await this.todoRepo.getAll();
+    const { limit, offset } = query;
+    const results = await this.todoRepo.getAll({ limit, offset });
     if (results.isFail()) return fail(results.value);
     if (results.value) return ok(results.value);
     return ok([]);

backend/src/lib/bounded-contexts/todo/todo/application/query-handlers/get-todos.handler.ts

@@ -1,9 +1,15 @@
-import { Application } from '@bitloops/bl-boilerplate-core';
+import { Application, Either } from '@bitloops/bl-boilerplate-core';
 import { TTodoReadModelSnapshot } from '../domain/todo.read-model.js';
 
-export type TodoReadRepoPort =
-  Application.Repo.ICRUDReadPort<TTodoReadModelSnapshot>;
-
+export interface TodoReadRepoPort
+  extends Application.Repo.ICRUDReadPort<TTodoReadModelSnapshot> {
+  getAll(params?: {
+    limit?: number;
+    offset?: number;
+  }): Promise<
+    Either<TTodoReadModelSnapshot[], Application.Repo.Errors.Unexpected>
+  >;
+}
 // export interface ITodoReadRepository {
 //   findAll(): Promise<TodoReadModel[]>;
 // }

backend/src/lib/bounded-contexts/todo/todo/ports/todo-read.repo-port.ts

@@ -1,7 +1,7 @@
 import { Application } from '@bitloops/bl-boilerplate-core';
 
 export class GetTodosQuery extends Application.Query {
-  constructor() {
+  constructor(public readonly limit?: number, public readonly offset?: number) {
     super('Todo');
   }
 }

backend/src/lib/bounded-contexts/todo/todo/queries/get-todos.query.ts

@@ -21,22 +21,22 @@ async function bootstrap() {
     }),
     { abortOnError: false },
   );
-  
+
   // Swagger configuration
   const swaggerConfig = new DocumentBuilder()
     .setTitle('API Documentation')
     .setDescription('API description')
     .setVersion('1.0')
     .addBearerAuth()
     .build();
-  
+
   const document = SwaggerModule.createDocument(api, swaggerConfig);
   SwaggerModule.setup('api', api, document);
-  
+
   writeFileSync('swagger.json', JSON.stringify(document, null, 2));
 
   api.enableCors({
-    origin: ['http://localhost:5175', 'http://localhost:4173'],
+    origin: ['http://localhost:5175', 'http://localhost:4173', 'http://localhost:5173'],
     methods: ['GET', 'POST', 'PUT', 'DELETE', 'OPTIONS', 'PATCH'],
     allowedHeaders: ['Content-Type', 'Accept', 'Authorization', 'Cache-Control', 'Last-Event-ID', 'x-request-id', 'x-user-agent', 'cache-hash'],
     exposedHeaders: ['Authorization', 'Content-Type'],

backend/src/main.ts

@@ -97,7 +97,24 @@
       },
       "get": {
         "operationId": "TodoController_getAll",
-        "parameters": [],
+        "parameters": [
+          {
+            "name": "limit",
+            "required": true,
+            "in": "query",
+            "schema": {
+              "type": "number"
+            }
+          },
+          {
+            "name": "offset",
+            "required": true,
+            "in": "query",
+            "schema": {
+              "type": "number"
+            }
+          }
+        ],
         "responses": {
           "200": {
             "description": "Returns all todos",