refactor: refactored the routes

Author: vikyw89

server/src/expressRoutes/getAllTelegramUsers/index.ts

@@ -0,0 +1,24 @@
+import { NextFunction, Request, Response } from "express";
+import { prisma } from "../../utils/prisma";
+
+/**
+ * Retrieves all Telegram users from the database and sends a JSON response.
+ *
+ * @param {Request} req - The request object.
+ * @param {Response} res - The response object.
+ * @param {NextFunction} next - The next middleware function.
+ * @return {Promise<void>} - This function does not return anything.
+ */
+export const getAllTelegramUsers = async (req:Request,res:Response, next:NextFunction) => {
+    try {
+        
+        const allTelegramUsers = await prisma.telegram.findMany()
+        res.json(allTelegramUsers)
+    
+    }
+    catch (err) {
+
+        console.log(err)
+        
+    }
+}

server/src/expressRoutes/getAllUsers/index.ts

@@ -0,0 +1,22 @@
+import { NextFunction, Request, Response } from "express";
+import { prisma } from "../../utils/prisma";
+
+/**
+ * Retrieves all users from the database and sends a JSON response.
+ *
+ * @param {Request} req - The request object.
+ * @param {Response} res - The response object.
+ * @param {NextFunction} next - The next middleware function.
+ * @return {Promise<void>} - A promise that resolves to nothing.
+ */
+export const getAllUsers = async(req:Request,res:Response,next:NextFunction) => {
+    try {
+        const allUsers = await prisma.user.findMany()
+        res.json(allUsers)
+    }
+    catch (err) {
+
+        console.log(err)
+    
+    }
+}

server/src/expressRoutes/index.ts

@@ -0,0 +1,16 @@
+import { Router } from "express"
+import { getAllTelegramUsers } from "./getAllTelegramUsers"
+import { getAllUsers } from "./getAllUsers"
+import { TELEGRAM_BOT_TOKEN } from "../utils/telegram/config"
+import { webhookCallback } from "grammy"
+import { telegramBot } from "../telegramRoutes"
+
+const router = Router()
+
+router.get("/telegram", getAllTelegramUsers)
+
+router.get("/user", getAllUsers)
+
+router.use(`/bot/${TELEGRAM_BOT_TOKEN}`, webhookCallback(telegramBot, "express"));
+
+export { router }

server/src/index.ts

@@ -1,25 +1,24 @@
 console.time('express')
 import "dotenv/config";
-import { telegramBot } from "./utils/telegram";
 import { initRoutes } from "./telegramRoutes";
-import { Request, Response } from "express";
+import { NextFunction, Request, Response } from "express";
 import express from "express";
-import { webhookCallback } from "grammy";
-import { TELEGRAM_BOT_TOKEN } from "./utils/telegram/config";
+import { router } from "./expressRoutes";
 
 const port = process.env.PORT ?? 3000;
 const app = express();
 
 app.use(express.json());
 
-initRoutes()
-// telegramBot.start()
-app.use(`/api/bot/${TELEGRAM_BOT_TOKEN}`, webhookCallback(telegramBot, "express"));
-app.use("/api", (req:Request, res:Response) => {
-    res.json('Welcome to Fingu!')
-});
+app.use('/api',router)
 
 app.use((req:Request, res:Response) => res.status(200).send());
+
+app.use((err:Error, req:Request, res:Response, next:NextFunction) => {
+    console.error(err.stack)
+    res.status(500).json('Something broke!')
+  })
+  
 app.listen(port, () => console.log(`listening on port ${port}`));
 
 console.timeEnd('express')

server/src/telegramRoutes/index.ts

@@ -10,7 +10,7 @@ import { telegramQueueEndHandler, telegramQueueStartHandler } from "./telegramQu
 telegramBot.use(limit({
     limit: 100,
     timeFrame: 1000 * 60 * 60 * 24,
-    onLimitExceeded: async(ctx: Context, next: NextFunction) => {
+    onLimitExceeded: async (ctx: Context, next: NextFunction) => {
         ctx.reply("Fingu gotta go, see you tomorrow !")
     }
 }))
@@ -35,4 +35,4 @@ telegramBot.use((ctx: Context, next: NextFunction) => {
     ctx.reply("What's that ?", { reply_to_message_id: ctx.message.message_id })
 })
 
-export const initRoutes = () => { }
+export { telegramBot }