add basic event bus and handle USER_CREATED

Author: seantokuzo

examples_new/microservices/auth/package-lock.json

@@ -19,6 +19,7 @@
   "license": "ISC",
   "dependencies": {
     "@chronosrx/common": "^1.0.2",
+    "axios": "^1.6.2",
     "bcryptjs": "^2.4.3",
     "cookie-parser": "^1.4.6",
     "dotenv": "^16.3.1",

examples_new/microservices/auth/package.json

@@ -4,19 +4,21 @@ import dotenv from 'dotenv';
 dotenv.config();
 import { NotFoundError, errorHandler } from '@chronosrx/common';
 import authRouter from './routes/auth-router';
+import eventRouter from './routes/event-router';
 import cookieParser from 'cookie-parser';
 
 const app = express();
 
 app.use(express.json());
-app.use(cookieParser())
+app.use(cookieParser());
 
 // app.get('/', (req, res) => {
 //   console.log('💥 Test Route');
 //   res.status(200).send({ msg: '💥 Test route' });
 // });
 
 app.use('/api/auth', authRouter);
+app.use('/events', eventRouter);
 
 app.use('*', (req, res) => {
   throw new NotFoundError();

examples_new/microservices/auth/src/app.ts

@@ -1,5 +1,6 @@
-import { BadRequestError, CurrentUserRequest } from '@chronosrx/common';
 import { Request, Response } from 'express';
+import axios from 'axios';
+import { BadRequestError, CurrentUserRequest, Events } from '@chronosrx/common';
 import { User } from '../models/user';
 import { attachCookie } from '../util/attachCookie';
 
@@ -27,6 +28,13 @@ export const signup = async (req: Request, res: Response) => {
   await newUser.save();
 
   // TODO PUBLISH AN EVENT TO THE EVENT BUS - type USER_CREATED, with data of user - user.id & username
+  // console.log('Publishing event USER_CREATED');
+  await axios.post('http://localhost:3005/', {
+    event: {
+      type: Events.USER_CREATED,
+      payload: newUser,
+    },
+  });
 
   // create a JWT w/ userId store on it
   // note: createJwt method created on the userSchema
@@ -98,6 +106,5 @@ export const getCurrentUser = async (req: CurrentUserRequest, res: Response) =>
   // if it does exist - use req.currentUser to find user in database by id
   const user = await User.findById(req.currentUser);
   // send back 200 with object with property currentUser set to the user from the database
-  res.status(200).send({currentUser: user});
-
+  res.status(200).send({ currentUser: user });
 };

examples_new/microservices/auth/src/controllers/auth-controller.ts

@@ -0,0 +1,12 @@
+import express from 'express';
+
+const router = express.Router();
+
+router.post('/', (req, res) => {
+  const { event } = req.body;
+  // console.log('Event received:', event);
+
+  res.send({ message: 'Event received' });
+});
+
+export default router;