feature: add events module

api/migrations/20230805131402-create-events.js

@@ -0,0 +1,56 @@
+'use strict';
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    await queryInterface.createTable('events', {
+      id: {
+        type: Sequelize.BIGINT,
+        primaryKey: true,
+        autoIncrement: true,
+        allowNull: false,
+      },
+      title: {
+        type: Sequelize.STRING,
+        allowNull: false,
+      },
+      description: {
+        type: Sequelize.TEXT,
+        defaultValue: '',
+        allowNull: false,
+      },
+      examinations: {
+        type: Sequelize.ARRAY(Sequelize.BIGINT),
+        allowNull: false,
+      },
+      startDate: {
+        type: Sequelize.DATE,
+        allowNull: false,
+      },
+      endDate: {
+        type: Sequelize.DATE,
+        allowNull: false,
+      },
+      primaryPrice: {
+        type: Sequelize.BIGINT,
+        allowNull: false,
+      },
+      secondaryPrice: {
+        type: Sequelize.BIGINT,
+        allowNull: false,
+      },
+      createdAt: {
+        type: Sequelize.DATE,
+        allowNull: false,
+      },
+      updatedAt: {
+        type: Sequelize.DATE,
+        allowNull: false,
+      },
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    await queryInterface.dropTable('events');
+  },
+};

api/migrations/20230806073635-add-eventid-to-orders-and-exam-attemp.js

@@ -0,0 +1,32 @@
+'use strict';
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  up: async (queryInterface, Sequelize) => {
+    return Promise.all([
+      queryInterface.addColumn('orders', 'eventId', {
+        type: Sequelize.BIGINT,
+        allowNull: false,
+        references: {
+          model: 'events',
+          key: 'id',
+        },
+      }),
+      queryInterface.addColumn('examAttempts', 'eventId', {
+        type: Sequelize.BIGINT,
+        allowNull: false,
+        references: {
+          model: 'events',
+          key: 'id',
+        },
+      }),
+    ]);
+  },
+
+  down: async (queryInterface, Sequelize) => {
+    return Promise.all([
+      queryInterface.removeColumn('orders', 'eventId'),
+      queryInterface.removeColumn('examAttempts', 'eventId'),
+    ]);
+  },
+};

api/models/event.js

@@ -0,0 +1,51 @@
+const JsonApiModel = require('base/jsonApiModel');
+const SerializerOpts = require('serializer-opts/event');
+
+class Event extends JsonApiModel {
+  static get serializerOpts() {
+    return SerializerOpts(this);
+  }
+
+  static associate() {}
+}
+
+module.exports = (sequelize, DataTypes) => {
+  Event.init(
+    {
+      title: {
+        type: DataTypes.STRING,
+        allowNull: false,
+      },
+      description: {
+        type: DataTypes.TEXT,
+        defaultValue: '',
+        allowNull: false,
+      },
+      examinations: {
+        type: DataTypes.ARRAY(DataTypes.BIGINT),
+        allowNull: false,
+      },
+      startDate: {
+        type: DataTypes.DATE,
+        allowNull: false,
+      },
+      endDate: {
+        type: DataTypes.DATE,
+        allowNull: false,
+      },
+      primaryPrice: {
+        type: DataTypes.BIGINT,
+        allowNull: false,
+      },
+      secondaryPrice: {
+        type: DataTypes.BIGINT,
+        allowNull: false,
+      },
+    },
+    {
+      sequelize,
+      modelName: 'events',
+    },
+  );
+  return Event;
+};

api/models/exam-attempt.js

@@ -7,9 +7,10 @@ class ExamAttempt extends JsonApiModel {
     return SerializerOpts(this);
   }
 
-  static associate({ examAttempts, examinations, users }) {
+  static associate({ examAttempts, examinations, users, events }) {
     examAttempts.belongsTo(examinations);
     examAttempts.belongsTo(users);
+    examAttempts.belongsTo(events);
   }
 }
 

api/models/order.js

@@ -7,9 +7,10 @@ class Order extends JsonApiModel {
     return SerializerOpts(this);
   }
 
-  static associate({ orders, users }) {
+  static associate({ orders, users, events }) {
     orders.belongsTo(users);
     users.hasMany(orders);
+    orders.belongsTo(events);
   }
 }
 

api/routes/admin/events/controllers.js

@@ -0,0 +1,37 @@
+const BaseDetailController = require('base/controllers/detailController');
+const BaseCreateController = require('base/controllers/createController');
+const BaseUpdateController = require('base/controllers/updateController');
+const BaseDeleteController = require('base/controllers/deleteController');
+const DB = require('models');
+const EventSerializerOpts = require('serializer-opts/admin/event');
+
+class EventDetailController extends BaseDetailController {
+  model = DB.events;
+  modelName = DB.events.name;
+  serializerOpts = EventSerializerOpts(DB.events.name);
+}
+
+class EventDeleteController extends BaseDeleteController {
+  model = DB.events;
+  modelName = DB.events.name;
+  serializerOpts = EventSerializerOpts(DB.events.name);
+}
+
+class EventCreateController extends BaseCreateController {
+  model = DB.events;
+  modelName = DB.events.name;
+  serializerOpts = EventSerializerOpts(DB.events.name);
+}
+
+class EventUpdateController extends BaseUpdateController {
+  model = DB.events;
+  modelName = DB.events.name;
+  serializerOpts = EventSerializerOpts(DB.events.name);
+}
+
+module.exports = {
+  EventDetailController,
+  EventDeleteController,
+  EventCreateController,
+  EventUpdateController,
+};

api/routes/admin/events/index.js

@@ -0,0 +1,32 @@
+const AdminRoleRequired = require('hooks/admin-role-required');
+const Controllers = require('./controllers');
+
+module.exports = async (app, opts) => {
+  app.get(
+    '/:id',
+    {
+      preHandler: AdminRoleRequired,
+    },
+    Controllers.EventDetailController.asHandler('get'),
+  );
+
+  app.post(
+    '/',
+    { preHandler: AdminRoleRequired },
+    Controllers.EventCreateController.asHandler('post'),
+  );
+
+  app.patch(
+    '/:id',
+    { preHandler: AdminRoleRequired },
+    Controllers.EventUpdateController.asHandler('patch'),
+  );
+
+  app.delete(
+    '/:id',
+    { preHandler: AdminRoleRequired },
+    Controllers.EventDeleteController.asHandler('delete'),
+  );
+};
+
+module.exports.autoPrefix = '/admin/events';

api/routes/events/controllers.js

@@ -0,0 +1,16 @@
+const BaseListController = require('base/controllers/listController');
+const BaseDetailController = require('base/controllers/detailController');
+const DB = require('models');
+
+class EventListController extends BaseListController {
+  model = DB.events;
+}
+
+class EventDetailController extends BaseDetailController {
+  model = DB.events;
+}
+
+module.exports = {
+  EventListController,
+  EventDetailController,
+};

api/routes/events/index.js

@@ -0,0 +1,16 @@
+const Controllers = require('./controllers');
+const LoginRequired = require('hooks/login-required');
+
+module.exports = async (app, opts) => {
+  app.get('/', Controllers.EventListController.asHandler('get'));
+
+  app.get(
+    '/:id',
+    {
+      preHandler: [LoginRequired],
+    },
+    Controllers.EventDetailController.asHandler('get'),
+  );
+};
+
+module.exports.autoPrefix = '/events';

api/routes/orders/controllers.js

@@ -15,9 +15,13 @@ class OrdersDetailController extends BaseDetailController {
 
   async post() {
     const _ordersService = this.app.getService('orders');
-    const { examinationIds } = this.request.body;
+    const { examinationIds, eventId } = this.request.body;
 
-    const order = await _ordersService.createOrder(examinationIds, this.request.user.id);
+    const order = await _ordersService.createOrder({
+      examinationIds,
+      userId: this.request.user.id,
+      eventId,
+    });
 
     return this.serialize(order);
   }
@@ -54,7 +58,11 @@ class OrdersDetailController extends BaseDetailController {
       // fetch updated object
       order = await this.getObject();
 
-      enrollInExaminations(order.examinations, this.request.user.id);
+      enrollInExaminations({
+        examinationsIds: order.examinations,
+        userId: this.request.user.id,
+        eventId: order.eventId,
+      });
 
       return this.serialize(order);
     } catch (err) {

api/routes/orders/schema.js

@@ -1,13 +1,16 @@
 const postSchema = {
   body: {
     type: 'object',
-    required: ['examinationIds'],
+    required: ['examinationIds', 'eventId'],
     properties: {
       examinationIds: {
         type: 'array',
         maxItems: 2,
         items: { type: 'integer' },
       },
+      eventId: {
+        type: 'integer',
+      },
     },
   },
 };

api/routes/orders/utils.js

@@ -1,6 +1,6 @@
 const DB = require('models');
 
-const enrollInExaminations = async (examinationsIds, userId) => {
+const enrollInExaminations = async ({ examinationsIds, userId, eventId }) => {
   const result = await DB.sequelize.transaction(async (transaction) => {
     await Promise.all(
       examinationsIds.map(async (examinationId) => {
@@ -11,6 +11,7 @@ const enrollInExaminations = async (examinationsIds, userId) => {
             start: exam.start,
             userId,
             examinationId,
+            eventId,
           },
           { transaction },
         );

api/serializer-opts/admin/event.js

@@ -0,0 +1,12 @@
+module.exports = () => ({
+  attributes: [
+    'id',
+    'title',
+    'description',
+    'examinations',
+    'startDate',
+    'endDate',
+    'primaryPrice',
+    'secondaryPrice',
+  ],
+});

api/serializer-opts/admin/exam-attempts.js

@@ -1,12 +1,17 @@
 const ExaminationSerializerOpts = require('./examination');
 const UserSerializerOpts = require('./user');
+const EventSerializerOpts = require('./event');
 
 module.exports = () => ({
   attributes: ['id', 'start', 'isSubmitted', 'submittedAt', 'result', 'examination', 'user'],
   examination: {
     ref: 'id',
     ...ExaminationSerializerOpts(),
   },
+  event: {
+    ref: 'id',
+    ...EventSerializerOpts(),
+  },
   user: {
     ref: 'id',
     ...UserSerializerOpts(),

api/serializer-opts/event.js

@@ -0,0 +1,15 @@
+module.exports = () => ({
+  attributes: [
+    'id',
+    'title',
+    'description',
+    'examinations',
+    'startDate',
+    'endDate',
+    'primaryPrice',
+    'secondaryPrice',
+  ],
+  meta: {
+    pagination: (records) => records.pagination,
+  },
+});

api/serializer-opts/exam-attempts.js

@@ -1,5 +1,6 @@
 const ExaminationSerializerOpts = require('./examination');
 const UserSerializerOpts = require('./user');
+const EventSerializerOpts = require('./event');
 
 module.exports = () => ({
   attributes: [
@@ -16,6 +17,10 @@ module.exports = () => ({
     ref: 'id',
     ...ExaminationSerializerOpts(),
   },
+  event: {
+    ref: 'id',
+    ...EventSerializerOpts(),
+  },
   user: {
     ref: 'id',
     ...UserSerializerOpts(),