serverless example starter

Author: alexandernnakwue

.gitignore

@@ -0,0 +1,9 @@
+# package directories
+node_modules
+jspm_packages
+
+# Serverless directories
+.serverless
+
+# Environment Variables
+.env

Controller/products.js

@@ -0,0 +1,100 @@
+const serverless = require('serverless-http');
+const express = require('express');
+const app = express();
+
+const bodyParser = require('body-parser');
+const uuid = require('uuid/v4');
+
+const dbConnection = require('../dbConfigs');
+const ProductService = require('../Services/product');
+
+
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ extended: true }));
+
+
+//  base url to test our API
+app.get('/index', async (req, res) => {
+   await res.send("<h3>Welcome to the Product API for LogRocket Blog serverless Example!!</h3>")
+})
+
+//  function for creating a new product
+app.post('/', async (req, res) => {
+
+  try {
+
+   await dbConnection();
+
+   const data  = req.body;
+
+   const {name, type, description, cost} = data;
+
+   if(!data) {
+     return "Please pass all required fields!"
+   }
+
+   const dataToSave = {name,type,description,cost,productId:uuid()};
+
+   let createProduct =  await ProductService.createProduct(dataToSave);
+
+   if (createProduct) {
+     return res.status(200).send(
+       createProduct
+    )
+   }
+  } catch (error) {
+    //  handle errors here
+    console.log(error, "error!!");
+  }
+
+})
+
+
+//  function for getting all products
+app.get('/', async (req, res) => {
+
+  try {
+    await dbConnection();
+
+    const allProducts = await ProductService.getAllProduct();
+
+    if (allProducts) {
+      return res.status(200).send({
+        data: allProducts
+      })
+    }
+  } catch (error) {
+     //  handle errors here
+     console.log(error, "error!!");
+  }
+})
+
+
+//  function for getting a  product by Id
+app.get('/:productId/', async (req, res) => {
+
+  try {
+
+    await dbConnection();
+
+    const {productId} = req.params;
+
+    const getProduct = await ProductService.getProductById({productId});
+
+    if(getProduct) {
+      return res.status(200).send({
+        data: getProduct
+      })
+
+    }
+
+  } catch (error) {
+     //  handle errors here
+     console.log(error, "error!!");
+
+  }
+
+});
+
+
+module.exports.handler = serverless(app);

Model/product.js

@@ -0,0 +1,17 @@
+const mongoose = require("mongoose");
+
+const ProductSchema = new mongoose.Schema (
+  {
+    name: {type: String},
+    type: {type: String},
+    cost: {type: Number},
+    description: {type: String},
+    productId: { type: String },
+  },
+  {timestamps: true}
+);
+
+const ProductModel = mongoose.model("product",ProductSchema);
+
+module.exports = ProductModel;
+

Services/product.js

@@ -0,0 +1,43 @@
+const Product = require('../Model/product');
+
+
+module.exports = {
+
+async createProduct (product) {
+
+  let result = await Product.create(product);
+  if(result) {
+    return {
+      data: product,
+      message: "Product successfully created!"
+    };
+  }
+
+return "Error creating new product"
+
+},
+
+
+async getAllProduct()  {
+
+  let product = await Product.find();
+
+  if(product)  return product;
+
+  return "Error fetching products from db"
+
+},
+
+
+async getProductById(productId)  {
+
+  let product = await Product.findOne(productId);
+
+  if(product) return product;
+
+  return "Error fetching product from db";
+
+},
+
+
+};

dbconfigs.js

@@ -0,0 +1,19 @@
+const mongoose = require('mongoose');
+require("dotenv").config();
+mongoose.Promise = global.Promise;
+
+const connectToDatabase = async () => {
+  let isConnected;
+  if (isConnected) {
+    console.log('using existing database connection');
+    return Promise.resolve();
+  }
+
+  console.log('using new database connection');
+  const database = await mongoose.connect(process.env.MONGODB_URL, {useNewUrlParser: true});
+  isConnected = database.connections[0].readyState;
+  // return isConnected;
+};
+
+module.exports = connectToDatabase;
+