279 first task add get all notes by parentnote endpoint

src/domain/service/note.ts

@@ -236,6 +236,19 @@ export default class NoteService {
       items: await this.noteRepository.getNoteListByUserId(userId, offset, this.noteListPortionSize),
     };
   }
+
+  /**
+   * Returns note list by parent note id
+   * @param parentId - id of the parent note
+   * @param page - number of current page
+   * @returns list of the notes ordered by time of last visit
+   */
+  public async getNoteListByParentNote(parentNoteId: NoteInternalId, page: number): Promise<NoteList> {
+    const offset = (page - 1) * this.noteListPortionSize;
+    return {
+      items: await this.noteRepository.getNoteListByParentNote(parentNoteId, offset, this.noteListPortionSize),
+    };
+  }
 
   /**
    * Create note relation

src/presentation/http/http-api.ts

@@ -207,6 +207,7 @@ export default class HttpApi implements Api {
     await this.server?.register(NoteListRouter, {
       prefix: '/notes',
       noteService: domainServices.noteService,
+      noteSettingsService: domainServices.noteSettingsService
     });
 
     await this.server?.register(JoinRouter, {

src/presentation/http/middlewares/note/useNoteResolver.ts

@@ -4,7 +4,7 @@ import { notEmpty } from '@infrastructure/utils/empty.js';
 import { StatusCodes } from 'http-status-codes';
 import hasProperty from '@infrastructure/utils/hasProperty.js';
 import { getLogger } from '@infrastructure/logging/index.js';
-import type { Note, NotePublicId } from '@domain/entities/note.js';
+import type { Note, NotePublicId, NoteInternalId } from '@domain/entities/note.js';
 
 /**
  * Add middleware for resolve Note by public id and add it to request
@@ -36,8 +36,12 @@ export default function useNoteResolver(noteService: NoteService): {
 
       return await noteService.getNoteByPublicId(publicId);
     }
+    else if (hasProperty(requestData, 'parentNoteId') && notEmpty(requestData.parentNoteId)) {
+      const noteId = requestData.parentNoteId as NoteInternalId;
+      return await noteService.getNoteById(noteId)
+    }
   }
-
+  
   return {
     noteResolver: async function noteIdResolver(request, reply) {
       let note: Note | undefined;

src/presentation/http/router/noteList.test.ts

@@ -144,3 +144,132 @@ describe('GET /notes?page', () => {
     }
   });
 });
+
+
+describe('GET /notes/:parentNoteId?page', () => {
+  test.each([
+    /**
+     * Returns noteList with specified length
+     * User is authorized
+     */
+    {
+      isAuthorized: true,
+      expectedStatusCode: 200,
+      expectedMessage: null,
+      expectedLength: 30,
+      pageNumber: 1,
+    },
+    /**
+     * Returns noteList with specified length (for last page)
+     * User is authorized
+     */
+    {
+      isAuthorized: true,
+      expectedStatusCode: 200,
+      expectedMessage: null,
+      expectedLength: 19,
+      pageNumber: 2,
+    },
+    /**
+     * Returns noteList with no items if there are no notes for certain parentNote
+     * User is authorized
+     */
+    {
+      isAuthorized: true,
+      expectedStatusCode: 200,
+      expectedMessage: null,
+      expectedLength: 0,
+      pageNumber: 3,
+    },
+    /**
+     * Returns 'querystring/page must be >= 1' message when page < 0
+     */
+    {
+      isAuthorized: true,
+      expectedStatusCode: 400,
+      expectedMessage: 'querystring/page must be >= 1',
+      expectedLength: 0,
+      pageNumber: -1,
+    },
+    /**
+     * Returns 'querystring/page must be <= 30' message when page is too large (maximum page numbrer is 30 by default)
+     */
+    {
+      isAuthorized: true,
+      expectedStatusCode: 400,
+      expectedMessage: 'querystring/page must be <= 30',
+      expectedLength: 0,
+      pageNumber: 31,
+    },
+    /**
+     * Returns 'unauthorized' message when user is not authorized
+     */
+    {
+      isAuthorized: false,
+      expectedStatusCode: 401,
+      expectedMessage: 'You must be authenticated to access this resource',
+      expectedLength: 0,
+      pageNumber: 1,
+    },
+  ])('Get note list', async ({ isAuthorized, expectedStatusCode, expectedMessage, expectedLength, pageNumber }) => {
+    const portionSize = 49;
+    let accessToken;
+
+    /** Insert creator and randomGuy */
+    const creator = await global.db.insertUser();
+
+    const randomGuy = await global.db.insertUser();
+
+    if (isAuthorized) {
+      accessToken = global.auth(randomGuy.id);
+    }
+
+    const parentNote = await global.db.insertNote({
+      creatorId: creator.id,
+    });
+
+    await global.db.insertNoteSetting({
+      noteId: parentNote.id,
+      cover: 'DZnvqi63.png',
+      isPublic: true,
+    });
+
+    for (let i = 0; i < portionSize; i++) {
+      const note = await global.db.insertNote({
+        creatorId: creator.id,
+      });
+
+      await global.db.insertNoteSetting({
+        noteId: note.id,
+        cover: 'DZnvqi63.png',
+        isPublic: true,
+      });
+
+      await global.db.insertNoteRelation({
+        parentId: parentNote.id,
+        noteId: note.id,
+      });
+    }
+
+    const response = await global.api?.fakeRequest({
+      method: 'GET',
+      headers: {
+        authorization: `Bearer ${accessToken}`,
+      },
+      url: `/notes/${parentNote.id}?page=${pageNumber}`,
+    });
+
+    const body = response?.json();
+
+    if (expectedMessage !== null) {
+      expect(response?.statusCode).toBe(expectedStatusCode);
+
+      expect(body.message).toBe(expectedMessage);
+    } else {
+      expect(response?.statusCode).toBe(expectedStatusCode);
+
+      expect(body.items).toHaveLength(expectedLength);
+    }
+  });
+});
+

src/presentation/http/router/noteList.ts

@@ -1,7 +1,12 @@
 import type { FastifyPluginCallback } from 'fastify';
 import type NoteService from '@domain/service/note.js';
+import useNoteResolver from '../middlewares/note/useNoteResolver.js';
+import useNoteSettingsResolver from '../middlewares/noteSettings/useNoteSettingsResolver.js';
+import useMemberRoleResolver from '../middlewares/noteSettings/useMemberRoleResolver.js';
+import type NoteSettingsService from '@domain/service/noteSettings.js';
 import { definePublicNote, type NotePublic } from '@domain/entities/notePublic.js';
 import type { NoteListPublic } from '@domain/entities/noteList.js';
+import { NoteInternalId } from '@domain/entities/note.js';
 
 /**
  * Interface for the noteList router.
@@ -12,6 +17,12 @@ interface NoteListRouterOptions {
    */
   noteService: NoteService;
 
+  /**
+  * Note Settings service instance
+  */
+  noteSettingsService: NoteSettingsService;
+
+
 }
 
 /**
@@ -22,6 +33,25 @@ interface NoteListRouterOptions {
  */
 const NoteListRouter: FastifyPluginCallback<NoteListRouterOptions> = (fastify, opts, done) => {
   const noteService = opts.noteService;
+  const noteSettingsService = opts.noteSettingsService;
+
+  /**
+   * Prepare note id resolver middleware
+   * It should be used in routes that accepts note public id
+   */
+  const { noteResolver } = useNoteResolver(noteService);
+
+  /**
+   * Prepare note settings resolver middleware
+   * It should be used to use note settings in middlewares
+   */
+  const { noteSettingsResolver } = useNoteSettingsResolver(noteSettingsService);
+
+  /**
+   * Prepare user role resolver middleware
+   * It should be used to use user role in middlewares
+   */
+  const { memberRoleResolver } = useMemberRoleResolver(noteSettingsService);
 
   /**
    * Get note list ordered by time of last visit
@@ -77,6 +107,71 @@ const NoteListRouter: FastifyPluginCallback<NoteListRouterOptions> = (fastify, o
     return reply.send(noteListPublic);
   });
 
+  /**
+   * Get note list by parent note
+   */
+  fastify.get<{
+    Params: {
+      parentNoteId: NoteInternalId;
+    }
+    Querystring: {
+      page: number;
+    };
+  }>('/:parentNoteId', {
+    config: {
+      policy: [
+        'authRequired',
+        'notePublicOrUserInTeam',
+      ],
+    },
+    schema: {
+      params: {
+        notePublicId: {
+          $ref: 'NoteSchema#/properties/id',
+        },
+      }, querystring: {
+        page: {
+          type: 'number',
+          minimum: 1,
+          maximum: 30,
+        },
+      }, response: {
+        '2xx': {
+          description: 'Query notelist',
+          properties: {
+            items: {
+              id: { type: 'string' },
+              content: { type: 'string' },
+              createdAt: { type: 'string' },
+              creatorId: { type: 'string' },
+              updatedAt: { type: 'string' },
+            },
+          },
+        },
+      },
+    }, preHandler: [
+      noteResolver,
+      noteSettingsResolver,
+      memberRoleResolver,
+    ],
+  }, async (request, reply) => {
+    const { parentNoteId } = await request.params;
+    const { page } = await request.query;
+
+    const noteList = await noteService.getNoteListByParentNote(parentNoteId, page);
+    /**
+     * Wrapping Notelist for public use
+     */
+    const noteListItemsPublic: NotePublic[] = noteList.items.map(definePublicNote);
+
+    const noteListPublic: NoteListPublic = {
+      items: noteListItemsPublic,
+    };
+
+    return reply.send(noteListPublic);
+  })
+
+
   done();
 };
 

src/repository/index.ts

@@ -139,6 +139,7 @@ export async function init(orm: Orm, s3Config: S3StorageConfig): Promise<Reposit
   /**
    * Create associations between note and relations table
    */
+  noteStorage.createAssociationWithNoteRelationsModel(noteRelationshipStorage.model)
   noteRelationshipStorage.createAssociationWithNoteModel(noteStorage.model);
 
   /**

src/repository/note.repository.ts

@@ -90,4 +90,14 @@ export default class NoteRepository {
   public async getNotesByIds(noteIds: NoteInternalId[]): Promise<Note[]> {
     return await this.storage.getNotesByIds(noteIds);
   }
+
+  /**
+   * Gets note list by parent note id
+   * @param parentId - parent note id
+   * @param offset - number of skipped notes
+   * @param limit - number of notes to get
+   */
+  public async getNoteListByParentNote(parentNoteId: number, offset: number, limit: number): Promise<Note[]> {
+    return await this.storage.getNoteListByParentNote(parentNoteId, offset, limit);
+  }
 }