框架

lib/mail.js

@@ -4,7 +4,7 @@ var settings = require('../settings');
 var redis = require('redis');
 var Mail = require('../model/mail');
 var client = redis.createClient(settings.redis.port, settings.redis.host);
-var Log = require('./log');
+var Log = require('./log')('[lib-mail]');
 
 var mailSender = NodeMailer.createTransport(smtpTransport({
     host: settings.mail.smtp.host,

server/receive.js

@@ -3,6 +3,7 @@ var settings = require('../settings');
 var Mail = require('../model').mail;
 var Session = require('../model').session;
 var fs = require('fs');
+var Log = require('../lib/log')('[server-receive');
 
 var mailListener = new MailListener({
     username: settings.mail.username,

server/send.js

@@ -3,7 +3,7 @@ var settings = require('../settings');
 var Mail = require('../model/mail');
 var mongoose = require('mongoose');
 var MailSender = require('../lib/mail');
-var Log = require('../lib/log');
+var Log = require('../lib/log')('[server-send]');
 
 var client = redis.createClient(settings.redis.port, settings.redis.host);
 

server/web.js

@@ -1,3 +1,52 @@
-/**
- * Created by yuzhan on 15/6/28.
- */
+var express = require('express');
+var app = express();
+var io = require('io')(app);
+var mongoose = require('mongoose');
+var settings = require('../settings');
+var Log = require('../lib/log')('[server-web]');
+
+mongoose.connect(settings.mongodb, {
+    db: {
+        native_parser: true
+    },
+    server: {
+        poolSize: 10,
+        socketOptions: {
+            keepAlive: 1
+        }
+    },
+    replset: {
+        socketOptions: {
+            keepAlive: 1
+        }
+    }
+});
+var db = mongoose.connection;
+db.on('error', Log.e.bind(Log, 'connection error'));
+
+exports.start = function() {
+    var server = require('http').createServer(app);
+    var port = settings.listen || 3000;
+    app.set('port', port);
+    server.listen(port);
+    server.on('error', function(error) {
+        if(error.syscall !== 'listen') {
+            throw error;
+        }
+        switch(error.code) {
+            case 'EACCES':
+                console.error('Port ' + port + ' requires elevated privileges');
+                process.exit(1);
+                break;
+            case 'EADDRINUSE':
+                console.error('Port ' + port + ' is already in use');
+                process.exit(1);
+                break;
+            default:
+                throw error;
+        }
+    });
+    server.on('listening', function() {
+        console.log('Server listening on ' + port);
+    });
+};

settings.js

@@ -1,10 +1,5 @@
 exports = module.exports = {
-    mysql: {
-        host: 'localhost',
-        port: 3306,
-        username: 'root',
-        password: 'root'
-    },
+    mongodb: 'mongodb://localhost/SRFMail',
     redis: {
         host: 'localhost',
         port: 6379