orders updated

Author: ZhongyanLiang

examples_new/microservices/orders/src/controllers/order-controller.ts

@@ -2,14 +2,12 @@ import { Request, Response } from 'express';
 import axios from 'axios';
 import { Order } from '../models/Order';
 import { BadRequestError, CurrentUserRequest, Events } from '@chronosrx/common';
-import { Inventory } from '../models/Inventory';
 
 export const createOrder = async (req: CurrentUserRequest, res: Response) => {
   //deconstruct req.body
-  const buyerId = req.currentUser;
-  const { itemId, amount, totalPrice, sellerId } = req.body;
+  const { itemId, amount } = req.body;
   //create Order document in the databse
-  const newOrder = Inventory.build({});
+  const newOrder = Order.build({ itemId, amount });
   await newOrder.save();
   //send created order to event bus
   await axios.post('http://localhost:3005/', {
@@ -21,31 +19,22 @@ export const createOrder = async (req: CurrentUserRequest, res: Response) => {
   res.status(201).send(newOrder);
 };
 
-export const getOrder = async (req: Request, res: Response) => {
-  // check if order already exists
-  const { buyerId } = req.body;
-  const exsitingOrder = await Order.findOne({ buyerId });
-  if (!exsitingOrder) {
-    throw new BadRequestError('Order with that id does not exists');
-  }
-  //check inventory itemId, amount
-  res.status(200).send(exsitingOrder);
-};
-
-export const getSale = async (req: Request, res: Response) => {
-  const { sellerId } = req.body;
-  const sales = await Order.find({ sellerId });
-  if (!sales) {
-    throw new BadRequestError('Sales with that sellerId does not exist');
-  }
-  res.status(200).send(sales);
-};
+// export const getOrder = async (req: Request, res: Response) => {
+//   // check if order already exists
+//   const { buyerId } = req.body;
+//   const exsitingOrder = await Order.findOne({ buyerId });
+//   if (!exsitingOrder) {
+//     throw new BadRequestError('Order with that id does not exists');
+//   }
+//   //check inventory itemId, amount
+//   res.status(200).send(exsitingOrder);
+// };
 
-export const deleteOrder = async (req: Request, res: Response) => {
-  const { id } = req.body;
-  const deletedOrder = await Order.findOneAndDelete({ id });
-  if (!deletedOrder) {
-    throw new BadRequestError(`Could not find that order by id to delete`);
-  }
-  res.status(200).send(deletedOrder);
-};
+// export const deleteOrder = async (req: Request, res: Response) => {
+//   const { id } = req.body;
+//   const deletedOrder = await Order.findOneAndDelete({ id });
+//   if (!deletedOrder) {
+//     throw new BadRequestError(`Could not find that order by id to delete`);
+//   }
+//   res.status(200).send(deletedOrder);
+// };

examples_new/microservices/orders/src/models/Inventory.ts

@@ -3,8 +3,6 @@ import mongoose from 'mongoose';
 interface OrderAttrs {
   itemId: string;
   amount: number;
-  totalPrice: number;
-  sellerId: string;
 }
 
 interface OrderModel extends mongoose.Model<OrderDoc> {
@@ -14,8 +12,6 @@ interface OrderModel extends mongoose.Model<OrderDoc> {
 interface OrderDoc extends mongoose.Document {
   itemId: string;
   amount: number;
-  totalPrice: number;
-  sellerId: string;
 }
 
 //create the Schema in mongoose with defined requirements
@@ -30,14 +26,6 @@ const OrderSchema = new mongoose.Schema(
       type: Number,
       required: true,
     },
-    totalPrice: {
-      type: Number,
-      required: true,
-    },
-    sellerId: {
-      type: String,
-      require: true,
-    },
   },
   {
     //anytime we create Json formatted data, transform the user document as following
@@ -55,8 +43,6 @@ OrderSchema.statics.build = (attrs: OrderAttrs) => {
   return new Order({
     itemId: attrs.itemId,
     amount: attrs.amount,
-    totalPrice: attrs.totalPrice,
-    sellerId: attrs.sellerId,
   });
 };
 

examples_new/microservices/orders/src/models/Order.ts

@@ -1,22 +1,18 @@
-import { EventTypes, Events } from '@chronosrx/common';
+import { EventTypes } from '@chronosrx/common';
 import express from 'express';
-import { Inventory } from '../models/Inventory';
 import { User } from '../models/user';
 
 const router = express.Router();
 
 router.post('/', async (req, res) => {
   const event: Events = req.body.event;
   console.log(event);
-  switch (event) {
+  switch (event.type) {
     case EventTypes.USER_CREATED:
       // console.log(event);
       const newUser = User.build(event.payload);
       await newUser.save();
       break;
-    case EventTypes.ITEM_CREATED:
-      const newInventory = Inventory.build(event.payload);
-      await newInventory.save();
     default:
       res.send({});
   }

examples_new/microservices/orders/src/models/user.ts

@@ -1,5 +1,5 @@
 import express from 'express';
-import { getOrder, getSale, createOrder, deleteOrder } from '../controllers/order-controller';
+import { createOrder } from '../controllers/order-controller';
 import { currentUser, requireAuth } from '@chronosrx/common';
 
 const router = express.Router();