mail-connect/server.js

const express = require('express');
const fs = require('fs');
const rateLimit = require('express-rate-limit');
const Docker = require('dockerode');
const validator = require('validator');

const docker = new Docker({ socketPath: '/var/run/docker.sock' });
const app = express();
app.use(express.json());

// Rate limiting

let rateLimitConfig = {};
try {
  const data = fs.readFileSync('./ratelimit.json', 'utf8');
  rateLimitConfig = JSON.parse(data);
} catch (err) {
  console.error('Error loading rate limit config:', err);
}

function createLimiter(options) {
  return rateLimit({
    windowMs: options.windowMs,
    max: options.max,
    message: "Too many requests, please try again another time.",
  });
}

if (rateLimitConfig['/list']) {
  app.use('/list', createLimiter(rateLimitConfig['/list']));
}
if (rateLimitConfig['/add']) {
  app.use('/add', createLimiter(rateLimitConfig['/add']));
}

// Utility fxns

function validateEmail(email) {
  return typeof email === 'string' && validator.isEmail(email);
}

const PasswordValidator = require('password-validator');
const passwordSchema = new PasswordValidator();
passwordSchema
  .is().min(8)
  .is().max(64)
  .has().letters()
  .has().digits()
  .has().not().spaces();

function listAccounts() {
  return new Promise((resolve, reject) => {      
    const container = docker.getContainer('mailserver');
    container.exec({
      Cmd: ['setup', 'email', 'list'],
      AttachStdout: true,
      AttachStderr: true,
    }, (err, exec) => {
      if (err) {
        return reject(err);
      }
      
      exec.start((err, stream) => {
        if (err) {
          return reject(err);
        }
        
        let output = '';
        stream.on('data', (chunk) => {
          output += chunk.toString();
        });
        
        stream.on('end', () => {
          // Remove control characters
          const cleanOutput = output.replace(/[\u0000-\u001F]+/g, '');
          const regex = /\*\s*(\S+)\s*\(\s*([^\s\/]+)\s*\/\s*([^)]+)\s*\)\s*\[(\d+)%]/g;
          const accounts = [];
          
          for (const match of cleanOutput.matchAll(regex)) {
            accounts.push({
              email: match[1],
              used: match[2].trim() === '~' ? 'Unlimited' : match[2].trim(),
              capacity: match[3].trim() === '~' ? 'Unlimited' : match[3].trim(),
              percentage: match[4]
            });
          }
          
          resolve(accounts);
        });
      });
    });
  });
}

// Routes

app.get('/list', (req, res) => {
  listAccounts()
    .then(accounts => res.json({ accounts }))
    .catch(err => res.status(500).json({ error: err.message }));
});

app.post('/add', (req, res) => {
  const { email, password } = req.body;
  if (!email || !validateEmail(email) || !password) {
    return res.status(400).json({ error: "A valid email and password is required." });
  }
  
  const container = docker.getContainer('mailserver');
  container.exec({
    Cmd: ['setup', 'email', 'add', email, password],
    AttachStdout: true,
    AttachStderr: true,
  }, (err, exec) => {
    if (err) {
      return res.status(500).json({ error: err.message });
    }
    
    exec.start((err, stream) => {
      if (err) {
        return res.status(500).json({ error: err.message });
      }
      
      let output = '';
      stream.on('data', (chunk) => {
        output += chunk.toString();
      });
      
      stream.on('end', async () => {
        const cleanOutput = output.replace(/[\u0000-\u001F]+/g, '').trim();
        if (cleanOutput === '') {
          return res.json({ success: true });
        }
        
        try {
          const accounts = await listAccounts();
          const accountFound = accounts.find(acc => acc.email === email);
          if (accountFound) {
            return res.json({ success: true });
          } else {
            return res.json({ success: false, message: "Account creation failed" });
          }
        } catch (error) {
          return res.status(500).json({ error: error.message });
        }
      });
    });
  });
});

app.listen(3000, () => {
  console.log(`API listening on port 3000`);
});