Demo/umn database microservice

02_A_Mini_Microservices_App/app/.gitignore

@@ -0,0 +1,30 @@
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# Dependencies
+node_modules/
+package-lock.json
+.pnp/
+.pnp.js
+
+# Testing
+coverage/
+
+# Production
+build/
+
+# Miscellaneous
+.DS_Store
+
+# Environment Variables
+.env
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+
+# Logs
+logs/
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*

02_A_Mini_Microservices_App/app/comments/index.js

@@ -10,66 +10,80 @@ app.use(cors());
 
 const commentsByPostId = {};
 
+// Handler untuk memproses event yang masuk
+const handleEvent = (event) => {
+  const { type, data } = event;
+
+  if (type === 'CommentCreated') {
+    const { id, content, postId, status } = data;
+    const comments = commentsByPostId[postId] || [];
+    comments.push({ id, content, status });
+    commentsByPostId[postId] = comments;
+  }
+
+  if (type === 'CommentModerated') {
+    const { postId, id, status, content } = data;
+    const comments = commentsByPostId[postId];
+
+    if (comments) {
+      const comment = comments.find((comment) => comment.id === id);
+      if (comment) {
+        comment.status = status;
+      }
+    }
+
+    axios.post('http://localhost:4005/events', {
+      type: 'CommentUpdated',
+      data: { id, status, postId, content },
+    }).catch(err => console.error('Error sending CommentUpdated event:', err.message));
+  }
+
+  console.log('Handled event:', type);
+};
+
+// Endpoint untuk mendapatkan semua komentar dari post tertentu
 app.get('/posts/:id/comments', (req, res) => {
   return res.send(commentsByPostId[req.params.id] || []);
 });
 
+// Endpoint untuk menambahkan komentar ke sebuah post
 app.post('/posts/:id/comments', async (req, res) => {
   const commentId = randomBytes(4).toString('hex');
   const { content } = req.body;
 
   const comments = commentsByPostId[req.params.id] || [];
-
-  comments.push({
-    id: commentId,
-    content,
-    status: 'pending',
-  });
+  comments.push({ id: commentId, content, status: 'pending' });
 
   commentsByPostId[req.params.id] = comments;
 
+  // Kirim event ke event bus
   await axios.post('http://localhost:4005/events', {
     type: 'CommentCreated',
-    data: {
-      id: commentId,
-      content,
-      postId: req.params.id,
-      status: 'pending',
-    },
-  });
+    data: { id: commentId, content, postId: req.params.id, status: 'pending' },
+  }).catch(err => console.error('Error sending CommentCreated event:', err.message));
 
   return res.status(201).send(comments);
 });
 
-app.post('/events', async (req, res) => {
-  console.log('Event Received', req.body.type);
-
-  const { type, data } = req.body;
-
-  if (type === 'CommentModerated') {
-    const { postId, id, status, content } = data;
-    const comments = commentsByPostId[postId];
-
-    const comment = comments.find((comment) => {
-      return comment.id === id;
-    });
-
-    comment.status = status;
-
-    await axios.post('http://localhost:4005/events', {
-      type: 'CommentUpdated',
-      data: {
-        id,
-        status,
-        postId,
-        content,
-      },
-    });
-  }
-
+// Endpoint untuk menerima event dari event bus
+app.post('/events', (req, res) => {
+  console.log('Event Received:', req.body.type);
+  handleEvent(req.body);
   return res.send({});
 });
 
-app.listen(4001, () => {
+// Start server dan replay event dari event service saat startup
+app.listen(4001, async () => {
   console.log('Listening on 4001');
+
+  try {
+    const res = await axios.get('http://localhost:4005/events');
+
+    for (let event of res.data) {
+      console.log('Processing event:', event.type);
+      handleEvent(event);
+    }
+  } catch (error) {
+    console.error('Error fetching events:', error.message);
+  }
 });