fix booking and db loading

Author: ich-klyukovka

.env

@@ -3,4 +3,5 @@ DB_PASSWORD=password
 DB_NAME=project_db
 DB_HOST=127.0.0.1
 DB_PORT=8529
-DATABASE_URL=http://db:8529
+DATABASE_URL=http://db:8529
+SEED_ON_STARTUP=true

README.md

@@ -21,7 +21,8 @@
 Для запуска:
 sudo docker compose build --no-cache && sudo docker compose up
 
-http://localhost/
+Фронтенд доступен по адресу: http://localhost:8080/
+API (бэкенд) слушает: http://localhost:3000/
 
 ivanov@uni.edu - логин пользователя
 admin - пароль пользователя

backend/src/app.js

@@ -38,7 +38,12 @@ app.use((err, req, res, next) => {
 });
 
 const PORT = process.env.PORT || 3000;
-await seedDatabase();
+if (process.env.SEED_ON_STARTUP === 'true') {
+    await seedDatabase();
+} else {
+    console.log('SEED_ON_STARTUP != true — пропуск автоматического посева БД.');
+}
+
 app.listen(PORT, '0.0.0.0', () => {
     console.log(`[server]: Server is running at http://localhost:${PORT}`);
 });

backend/src/dao/bookings.js

@@ -95,6 +95,25 @@ class BookingDao {
         return await cursor.all();
     }
 
+    /**
+     * Method: findActiveByUser
+     * Найти активные бронирования пользователя на конкретное время.
+     */
+    async findActiveByUser(userId, startTime, transaction = null) {
+        const fromId = userId.includes('/') ? userId : `Users/${userId}`;
+
+        const queryFn = () => db.query(aql`
+            FOR b IN Bookings
+                FILTER b._from == ${fromId}
+                FILTER b.status != 'cancelled'
+                FILTER b.start_at == ${startTime}
+                RETURN b
+        `);
+
+        const cursor = transaction ? await transaction.step(queryFn) : await queryFn();
+        return await cursor.all();
+    }
+
     /**
      * Method: findFreePC
      * Найти первый свободный ПК по тегам.

backend/src/services/bookingService.js

@@ -108,6 +108,14 @@ class BookingService {
         const toId = pcId.includes('/') ? pcId : `Computers/${pcId}`;
 
         return withTransaction({ write: ['Bookings'], read: ['Computers'] }, async (transaction) => {
+            // Проверяем, не забронировал ли пользователь уже ПК на этот урок
+            const userExisting = await BookingDao.findActiveByUser(userId, interval.start, transaction);
+            if (userExisting.length > 0) {
+                const e = new Error("У вас уже есть бронь на этот урок");
+                e.status = 409;
+                throw e;
+            }
+
             const existing = await BookingDao.findActiveByPC(toId, interval.start, transaction);
             if (existing.length > 0) {
                 const e = new Error("Это место уже забронировано");
@@ -187,6 +195,14 @@ class BookingService {
         const fromId = `Users/${userId}`;
 
         return withTransaction({ read: ['Computers'], write: ['Bookings'] }, async (transaction) => {
+            // Проверяем, не забронировал ли пользователь уже место на этот урок
+            const userExisting = await BookingDao.findActiveByUser(userId, interval.start, transaction);
+            if (userExisting.length > 0) {
+                const e = new Error("У вас уже есть бронь на этот урок");
+                e.status = 409;
+                throw e;
+            }
+
             const freePC = await BookingDao.findFreePC({ startTime: interval.start, tagList }, transaction);
             if (!freePC) {
                 const e = new Error("Нет свободных ПК по вашему запросу");