Create index.js

index.js

@@ -0,0 +1,68 @@
+import express from 'express';
+import helmet from 'helmet';
+import cors from 'cors';
+import compression from 'compression';
+import { Database } from './infrastructure/database/db';
+import { User } from './infrastructure/database/models/user';
+import { Message } from './infrastructure/database/models/message';
+import { Crypto } from './utils/crypto';
+import { Math } from './utils/math';
+
+const app = express();
+app.use(helmet());
+app.use(cors());
+app.use(compression());
+app.use(express.json());
+
+const database = new Database('mongodb://localhost:27017/cosmia', 'redis://localhost:6379');
+await database.connect();
+
+app.post('/register', async (req, res) => {
+  const { username, email, password } = req.body;
+  try {
+    const user = await User.createUser(username, email, password);
+    res.status(201).json({ message: 'User created successfully' });
+  } catch (error) {
+    res.status(500).json({ message: 'Error creating user' });
+  }
+});
+
+app.post('/login', async (req, res) => {
+  const { username, password } = req.body;
+  try {
+    const user = await User.getUserByUsername(username);
+    if (!user) {
+      res.status(401).json({ message: 'Invalid username or password' });
+    } else if (!(await user.authenticate(password))) {
+      res.status(401).json({ message: 'Invalid username or password' });
+    } else {
+      res.status(200).json({ message: 'Login successful' });
+    }
+  } catch (error) {
+    res.status(500).json({ message: 'Error logging in' });
+  }
+});
+
+app.post('/send-message', async (req, res) => {
+  const { from, to, content, type, priority } = req.body;
+  try {
+    const message = await Message.createMessage(from, to, content, type, priority);
+    res.status(201).json({ message: 'Message sent successfully' });
+  } catch (error) {
+    res.status(500).json({ message: 'Error sending message' });
+  }
+});
+
+app.get('/messages', async (req, res) => {
+  const userId = req.query.userId;
+  try {
+    const messages = await Message.getMessagesForUser(userId);
+    res.status(200).json(messages);
+  } catch (error) {
+    res.status(500).json({ message: 'Error retrieving messages' });
+  }
+});
+
+app.listen(3000, () => {
+  console.log('Cosmia Core API listening on port 3000');
+});