Create endpoint to get messages

src/functions/telegram_get_messages/function.yml

@@ -0,0 +1,11 @@
+name: ${self:custom.secrets.service.name}-${self:custom.secrets.provider.stage}-telegram-get-messages
+handler: index.telegramGetAll
+memorySize: 128
+timeout: 30
+reservedConcurrency: 5
+events:
+  - http:
+      path: /${self:custom.secrets.service.name}-${self:custom.secrets.provider.stage}/telegram/get-messages
+      method: POST
+      cors: true
+      authorizer: telegramAuthorizer

src/functions/telegram_get_messages/index.ts

@@ -0,0 +1,22 @@
+import { APIGatewayEvent, Callback, Context } from "aws-lambda";
+import { OK } from "http-status";
+import { ChatMessageDao } from "../../lib/dao";
+
+const execute = async (): Promise<any> => {
+  await ChatMessageDao.initInstance();
+  const messages = await ChatMessageDao.getAll();
+
+  return { statusCode: OK, body: JSON.stringify(messages) };
+};
+
+export const telegramGetAll = async (
+  event: APIGatewayEvent,
+  context: Context,
+  callback: Callback
+): Promise<void> => {
+  context.callbackWaitsForEmptyEventLoop = false;
+
+  const response = await execute();
+
+  return callback(null, response);
+};

src/lib/dao/chatMessageDao.ts

@@ -38,4 +38,13 @@ export class ChatMessageDao {
   ): Promise<ChatMessage | null> {
     return ChatMessageDao.chatMessageModel.create(chatMessage);
   }
+
+  public static async getAll(): Promise<Array<ChatMessage>> {
+    const chatMessages = await ChatMessageDao.chatMessageModel.find({}).exec();
+    if (!chatMessages || !chatMessages?.length) {
+      return [];
+    }
+
+    return chatMessages;
+  }
 }