mirror of
https://github.com/wassname/HackFlowy.git
synced 2026-08-12 11:40:31 +08:00
changed MemoryStore to MongoStore
This commit is contained in:
+19
-23
@@ -1,39 +1,26 @@
|
||||
var //cookie = require('cookie'),
|
||||
crypto = require('crypto')
|
||||
//, exchange = require('./exchange')
|
||||
var crypto = require('crypto')
|
||||
, express = require('express')
|
||||
, http = require('http')
|
||||
, MemoryStore = express.session.MemoryStore
|
||||
, ObjectID = require('mongodb').ObjectID,
|
||||
cookie = require('cookie');
|
||||
|
||||
var mongoose = require('mongoose');
|
||||
var User = mongoose.model('User');
|
||||
var Node = require('../models/Node.js');
|
||||
var sessionStore = new MemoryStore();
|
||||
|
||||
var io;
|
||||
var online = [];
|
||||
var lastExchangeData = {};
|
||||
var makeCommit = require("./makeCommit.js").makeCommit;
|
||||
var getAndSendRevHistory = require("./revAlgorithm.js").getAndSendRevHistory;
|
||||
|
||||
|
||||
console.log("\n\nLOOK HERE!!")
|
||||
// console.log(revAlg);
|
||||
|
||||
// var revAlg = require('./revControlAlg.js');
|
||||
// var getTimeHash = revAlg.getTimeHash;
|
||||
console.log("\n\n");
|
||||
|
||||
|
||||
module.exports = {
|
||||
createUser: function(username, password, callback){
|
||||
User.addUser(username, password, callback);
|
||||
},
|
||||
|
||||
getSessionStore: function(){
|
||||
return sessionStore;
|
||||
},
|
||||
safeConnectToDB: function(){
|
||||
var url = require("../config/config.js").DB_URL;
|
||||
try { mongoose.connect(url); }
|
||||
catch(err) { console.log("Error: Sign In to MongoLab") }
|
||||
}
|
||||
|
||||
createSocket: function(server) {
|
||||
io = require('socket.io').listen(server);
|
||||
@@ -66,6 +53,15 @@ module.exports = {
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
function attachLogInListeners(socket){
|
||||
socket.on("COMMIT", function(){
|
||||
makeCommit();
|
||||
@@ -136,12 +132,12 @@ function attachLogInListeners(socket){
|
||||
|
||||
});
|
||||
|
||||
socket.on("removeNode", function(data){
|
||||
// console.log("removeNode!!!");
|
||||
socket.on("removeNode", function(data){
|
||||
var thisId = data[0];
|
||||
var thisIndex = data[1];
|
||||
var parId = data[2];
|
||||
var author = data[3]; data[3] = null;
|
||||
var author = data[3];
|
||||
// data[3] = null; //improve efficiency.
|
||||
socket.broadcast.emit("removeNode", data);
|
||||
Node.removeNode(thisId, thisIndex, parId, author._id);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user