Merge pull request #24 from oslabs-beta/orders

added service name when connected to each PORT

Author: seantokuzo

examples_new/microservices/auth/src/index.ts

@@ -25,7 +25,7 @@ const start = async () => {
   }
 
   app.listen(PORT, async () => {
-    console.log(`💥 App listening on ${PORT}`);
+    console.log(`💥 Auth listening on ${PORT}`);
   });
 };
 

examples_new/microservices/event-bus/src/index.ts

@@ -2,7 +2,7 @@ import { app } from './app';
 
 const start = () => {
   app.listen(3005, () => {
-    console.log('💥 App listening on port 3005');
+    console.log('💥 Event-bus listening on port 3005');
   });
 };
 

examples_new/microservices/inventory/src/index.ts

@@ -22,7 +22,7 @@ const start = async () => {
   }
 
   app.listen(PORT, async () => {
-    console.log(`💥 App listening on ${PORT}`);
+    console.log(`💥 Inventory listening on ${PORT}`);
   });
 };
 

examples_new/microservices/items/src/index.ts

@@ -22,7 +22,7 @@ const start = async () => {
   }
 
   app.listen(PORT, async () => {
-    console.log(`App listening on ${PORT}`);
+    console.log(`Items listening on ${PORT}`);
   });
 };
 

examples_new/microservices/orders/src/index.ts

@@ -21,7 +21,7 @@ const start = async () => {
   }
 
   app.listen(PORT, async () => {
-    console.log(`💥 App listening on ${PORT}`);
+    console.log(`💥 Orders listening on ${PORT}`);
   });
 };
 

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

@@ -0,0 +1,48 @@
+import mongoose from 'mongoose';
+
+//define attrs
+interface UserAttrs {
+  username: string;
+  id: string;
+}
+// add a method 'build' to the UserModel
+// mongoose has built-in Model class that takes 'UserDoc'
+interface UserModel extends mongoose.Model<UserDoc> {
+  build(attrs: UserAttrs): UserDoc;
+}
+//create user data in the database in this shape
+interface UserDoc extends mongoose.Document {
+  username: string;
+}
+//create the Schema in mongoose with defined requirements
+const userSchema = new mongoose.Schema(
+  {
+    username: {
+      type: String,
+      required: true,
+      unique: true,
+    },
+  },
+  {
+    //anytime we create Json formatted data, transform the user document as following
+    toJSON: {
+      transform(doc, ret) {
+        ret.id = ret._id;
+        delete ret._id;
+        delete ret.__v;
+      },
+    },
+  }
+);
+
+userSchema.statics.build = (attrs: UserAttrs) => {
+  //returning user document with (attrs) passed in
+  return new User({
+    _id: attrs.id,
+    username: attrs.username,
+  });
+};
+
+const User = mongoose.model<UserDoc, UserModel>('User', userSchema);
+
+export { User };

examples_new/microservices/orders/src/routes/event-router.ts

@@ -1,26 +1,22 @@
 import { EventTypes, Events } from '@chronosrx/common';
 import express from 'express';
-import { Order } from '../models/Order';
-
+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.type) {
-  //   case EventTypes.USER_CREATED:
-  //     // console.log(event);
-  //     const newUser = User.build(event.payload);
-  //     await newUser.save();
-  //     break;
-  // default:
-  //   res.send({});
-  // }
-  res.send({ message: 'Event received' });
+  switch (event.type) {
+    case EventTypes.USER_CREATED:
+      // console.log(event);
+      const newUser = User.build(event.payload);
+      await newUser.save();
+      break;
+  }
+  return res.send({ message: 'Event received' });
 });
 
 // router.get('/events');
 
-
 export default router;