Feature/api crypto get product [ 2 ]

controllers/cryptoController.js

@@ -0,0 +1,50 @@
+const { fetchProducts, fetchProduct } = require('../models/crypto')
+
+const ERROR_MESSAGE = 'Something went wrong. Please try again or contact admin'
+
+/**
+ * Get the  products details
+ * @param {Object} req - Express request object
+ * @param {Object} res - Express response object
+ */
+
+const getProducts = async (req, res) => {
+  try {
+    const productData = await fetchProducts()
+    return res.json({
+      message: Object.keys(productData).length !== 0 ? 'Products returned successfully!' : 'No products found',
+      products: productData
+    })
+  } catch (err) {
+    logger.error(`Error while retriving products ${err}`)
+    return res.boom.badImplementation(ERROR_MESSAGE)
+  }
+}
+
+/**
+ * Get the  product details
+ * @param {Object} req - Express request object
+ * @param {Object} res - Express response object
+ */
+
+const getProduct = async (req, res) => {
+  try {
+    const productId = req.params.productId
+    const productData = await fetchProduct(productId)
+    if (productData) {
+      return res.json({
+        message: 'Product returned successfully.',
+        product: productData
+      })
+    }
+    return res.boom.notFound('Product doesn\'t exist')
+  } catch (err) {
+    logger.error(`Error while retriving products ${err}`)
+    return res.boom.badImplementation(ERROR_MESSAGE)
+  }
+}
+
+module.exports = {
+  getProducts,
+  getProduct
+}

models/crypto.js

@@ -0,0 +1,49 @@
+const firestore = require('../utils/firestore')
+const cryptoProductsCollection = firestore.collection('crypto-products')
+
+/**
+ * Fetches the data of crypto product
+ * @return {Promise<userModel|Array>}
+ */
+
+const fetchProducts = async () => {
+  try {
+    const snapshot = await cryptoProductsCollection.get()
+
+    const productsData = {}
+
+    snapshot.forEach((doc) => {
+      const data = doc.data()
+      productsData[data.id] = { ...data }
+    })
+    return productsData
+  } catch (err) {
+    logger.error('Error retrieving product data', err)
+    throw err
+  }
+}
+
+/**
+ * Fetches the data of crypto product
+ * @param productId { string }: product id
+ * @return {Promise<userModel|Array>}
+ */
+
+const fetchProduct = async (productId) => {
+  try {
+    const snapshot = await cryptoProductsCollection.doc(productId).get()
+    if (snapshot.exists) {
+      const productData = snapshot.data()
+      return productData
+    }
+    return undefined
+  } catch (err) {
+    logger.error('Error retrieving product data', err)
+    throw err
+  }
+}
+
+module.exports = {
+  fetchProducts,
+  fetchProduct
+}

routes/crypto.js

@@ -0,0 +1,63 @@
+const express = require('express')
+const router = express.Router()
+const cryptoController = require('../controllers/cryptoController')
+
+/**
+ * @swagger
+ * /crypto/products:
+ *   get:
+ *     summary: Used to get all the crypto products data
+ *     tags:
+ *       - crypto
+ *     responses:
+ *       200:
+ *         description: Return product data
+ *         content:
+ *           application/json:
+ *             schema:
+ *               $ref: '#/components/schemas/crypto'
+ *       404:
+ *         description: not found
+ *         content:
+ *           application/json:
+ *             schema:
+ *               $ref: '#/components/schemas/errors/notFound'
+ *       500:
+ *         description: badImplementation
+ *         content:
+ *           application/json:
+ *             schema:
+ *               $ref: '#/components/schemas/errors/badImplementation'
+ */
+router.get('/products', cryptoController.getProducts)
+
+/**
+ * @swagger
+ * /crypto/products/{productid}:
+ *   get:
+ *     summary: Used to get the crypto product data
+ *     tags:
+ *       - crypto
+ *     responses:
+ *       200:
+ *         description: Return product data
+ *         content:
+ *           application/json:
+ *             schema:
+ *               $ref: '#/components/schemas/crypto'
+ *       404:
+ *         description: not found
+ *         content:
+ *           application/json:
+ *             schema:
+ *               $ref: '#/components/schemas/errors/notFound'
+ *       500:
+ *         description: badImplementation
+ *         content:
+ *           application/json:
+ *             schema:
+ *               $ref: '#/components/schemas/errors/badImplementation'
+ */
+router.get('/products/:productId', cryptoController.getProduct)
+
+module.exports = router

routes/index.js

@@ -9,6 +9,7 @@ app.use('/tasks', require('./tasks'))
 app.use('/challenges', require('./challenges.js'))
 app.use('/pullrequests', require('./pullrequests.js'))
 app.use('/contributions', require('./contributions'))
+app.use('/crypto', require('./crypto'))
 app.use('/badges', require('./badges.js'))
 
 module.exports = app