Merge 0c11336 into 7dfff99

src/controllers/TransactionController.js

@@ -0,0 +1,112 @@
+import Response from '../helpers/response';
+import transaction from '../db/service/transaction';
+
+/** Transaction Controller Class */
+class TransactionController {
+  /**
+   * @static
+   * @desc POST /api/v1/transaction/purchase/:item
+   * @param {object} req
+   * @param {object} res
+   * @memberof TransactionController
+   * @returns {object} res
+   */
+  static async purchaseItem(req, res) {
+    const { artId } = req.params;
+    const { artistId, price } = req.body;
+    const { id } = req.verifyUser;
+    try {
+      const purchaseItemResponse = await transaction
+        .saveTransaction(artId, artistId, id, price);
+      if (purchaseItemResponse) {
+        const response = new Response(
+          'Created',
+          201,
+          'Art has been purchased',
+          purchaseItemResponse
+        );
+        return res.status(response.code).json(response);
+      }
+    } catch (error) {
+      const response = new Response(
+        'Internal Server Error',
+        500,
+        `${error}`
+      );
+      return res.status(response.code).json(response);
+    }
+  }
+
+  /**
+     * @static
+     * @desc GET /api/v1/transaction/receipt/:item
+     * @param {object} req
+     * @param {object} res
+     * @memberof TransactionController
+     * @returns {object} res
+     */
+  static async getItemReceipt(req, res) {
+    const { artId } = req.params;
+
+    try {
+      const getItemReceiptResponse = await transaction.getItemReceipt(artId);
+      if (getItemReceiptResponse) {
+        const response = new Response(
+          'Ok',
+          200,
+          'Receipt was found',
+          getItemReceiptResponse
+        );
+        return res.status(response.code).json(response);
+      }
+    } catch (error) {
+      const response = new Response(
+        'Not Ok',
+        500,
+        `${error}`
+      );
+      return res.status(response.code).json(response);
+    }
+  }
+
+  /**
+     * @static
+     * @desc GET /api/v1/transaction
+     * @param {object} req
+     * @param {object} res
+     * @memberof TransactionController
+     * @returns {object} res
+     */
+  static async getTransactions(req, res) {
+    const { id } = req.verifyUser;
+    try {
+      const allUserTransactions = await transaction.getTransactions(id);
+      if (allUserTransactions) {
+        const response = new Response(
+          'Ok',
+          200,
+          `${allUserTransactions.length} transaction(s) found`,
+          allUserTransactions
+        );
+        return res.status(response.code).json(response);
+      }
+      if (!allUserTransactions) {
+        const response = new Response(
+          'Not found',
+          404,
+          `${allUserTransactions.length} transaction(s) found`,
+          allUserTransactions
+        );
+        return res.status(response.code).json(response);
+      }
+    } catch (error) {
+      const response = new Response(
+        'Internal Server Error',
+        500,
+        `${error}`
+      );
+      return res.status(response.code).json(response);
+    }
+  }
+}
+export default TransactionController;

src/db/migrations/20190115154728-create-transaction.js

@@ -32,7 +32,7 @@ module.exports = {
         }
       },
       amount: {
-        type: Sequelize.INTEGER
+        type: Sequelize.DECIMAL(10, 2),
       },
       createdAt: {
         allowNull: false,

src/db/migrations/20190126225837-add-column-price-to-art.js

@@ -0,0 +1,8 @@
+module.exports = {
+  up: (queryInterface, Sequelize) => queryInterface.addColumn('Arts', 'price', {
+    type: Sequelize.DECIMAL(10, 2),
+    defaultValue: 0.00,
+    after: 'featuredImg'
+  }),
+  down: queryInterface => queryInterface.removeColumn('Arts', 'price'),
+};

src/db/models/art.js

@@ -7,6 +7,7 @@ module.exports = (sequelize, DataTypes) => {
     description: DataTypes.TEXT,
     categoryId: DataTypes.INTEGER,
     featuredImg: DataTypes.STRING,
+    price: DataTypes.DECIMAL(10, 2),
     status: DataTypes.BOOLEAN
   }, {});
   Art.associate = function (models) {

src/db/models/transaction.js

@@ -3,24 +3,27 @@ module.exports = (sequelize, DataTypes) => {
     buyerId: DataTypes.INTEGER,
     sellerId: DataTypes.INTEGER,
     artId: DataTypes.INTEGER,
-    amount: DataTypes.INTEGER
+    amount: DataTypes.DECIMAL(10, 2),
   }, {});
   Transaction.associate = function (models) {
     // associations can be defined here
     Transaction.belongsTo(models.User, {
       foreignKey: 'sellerId',
       onDelete: 'CASCADE',
       onUpdate: 'CASCADE',
+      as: 'seller'
     });
     Transaction.belongsTo(models.User, {
       foreignKey: 'buyerId',
       onDelete: 'CASCADE',
       onUpdate: 'CASCADE',
+      as: 'buyer'
     });
     Transaction.belongsTo(models.Art, {
       foreignKey: 'artId',
       onDelete: 'CASCADE',
       onUpdate: 'CASCADE',
+      as: 'art'
     });
   };
   return Transaction;

src/db/seeders/c_artSeeder.js

@@ -6,7 +6,8 @@ module.exports = {
     description: 'Some descriptions',
     categoryId: 1,
     featuredImg: 'some link',
-    status: true,
+    status: false,
+    price: 2000,
     createdAt: new Date(),
     updatedAt: new Date()
   },
@@ -18,6 +19,7 @@ module.exports = {
     categoryId: 1,
     featuredImg: 'some link',
     status: true,
+    price: 3000,
     createdAt: new Date(),
     updatedAt: new Date()
   }

src/db/seeders/c_rateSeeder.js

@@ -7,6 +7,7 @@ module.exports = {
     categoryId: 1,
     featuredImg: 'www.imageurl.com/myImage',
     status: true,
+    price: 6000,
     createdAt: new Date(),
     updatedAt: new Date()
   }, {
@@ -17,6 +18,7 @@ module.exports = {
     categoryId: 1,
     featuredImg: 'www.imageurl.com/myImage',
     status: true,
+    price: 9000,
     createdAt: new Date(),
     updatedAt: new Date()
   }], {}),

src/db/service/transaction.js

@@ -0,0 +1,101 @@
+import models from '../models';
+
+const {
+  Transaction,
+  Art,
+  User,
+} = models;
+
+module.exports = {
+  async getItemReceipt(artId) {
+    const query = await Transaction
+      .findOne({
+        include: [
+          {
+            model: User,
+            as: 'buyer',
+            attributes: ['id', 'username'],
+          },
+          {
+            model: User,
+            as: 'seller',
+            attributes: ['id', 'username'],
+          },
+          {
+            model: Art,
+            as: 'art',
+            attributes: [
+              'id',
+              'title',
+              'description',
+              'featuredImg',
+              'price',
+              'createdAt'
+            ],
+          }
+        ],
+        attributes: ['id', 'amount', 'createdAt'],
+        where: { artId }
+      });
+    return query;
+  },
+  async saveTransaction(artId, artistId, userId, amount) {
+    const query = await Transaction.create({
+      artId,
+      sellerId: artistId,
+      buyerId: userId,
+      amount
+    });
+
+    if (query) {
+      /** Check if Art exists, if so update status for unavailability */
+      const artExists = await Art.findOne({ where: { id: artId } });
+      if (artExists) {
+        artExists.status = false;
+        artExists.save();
+      }
+    }
+    return query;
+  },
+  async getTransactions(userId) {
+    const query = await Transaction.findAll({
+      include: [
+        {
+          model: User,
+          as: 'buyer',
+          attributes: ['id', 'username'],
+        },
+        {
+          model: User,
+          as: 'seller',
+          attributes: ['id', 'username'],
+        },
+        {
+          model: Art,
+          as: 'art',
+          attributes: [
+            'id',
+            'title',
+            'description',
+            'featuredImg',
+            'price',
+            'createdAt'
+          ],
+        }
+      ],
+      attributes: ['id', 'amount', 'createdAt'],
+      where: {
+        $or: [
+          {
+            buyerId: userId
+          },
+          {
+            sellerId: userId
+          }
+        ]
+      },
+      order: [['createdAt', 'DESC']]
+    });
+    return query;
+  },
+};