mirror of
https://github.com/sstent/node.git
synced 2026-01-25 14:42:00 +00:00
added form2js, and mongodb
This commit is contained in:
@@ -5,9 +5,12 @@
|
||||
|
||||
var express = require('express');
|
||||
var store = require('./routes/store');
|
||||
var db_helper = module.exports = require("./routes/db_helper.js");
|
||||
//var db_helper = module.exports = require("./routes/db_helper.js");
|
||||
var app = module.exports = express.createServer();
|
||||
|
||||
var db = require('mongoskin').db('localhost:27017/test');
|
||||
var testcollection = db.collection('testcollection');
|
||||
|
||||
// Configuration
|
||||
|
||||
app.configure(function(){
|
||||
@@ -50,19 +53,20 @@ app.post('/input', store.input_post_handler);
|
||||
|
||||
|
||||
app.get('/items', function(req, res) {
|
||||
var items = db_helper.get_all('employees', function(err, items, fields) {
|
||||
if (err) {
|
||||
console.log("async1: " + err);
|
||||
}
|
||||
var keys = Object.keys( items );
|
||||
var fieldkeys = Object.keys( fields );
|
||||
var employees = items;
|
||||
emitdata('populate',employees);
|
||||
testcollection.find({}, function(err, result) {
|
||||
result.each(function(err, data) {
|
||||
console.log(data);
|
||||
emitdata('populate',data);
|
||||
});
|
||||
});
|
||||
if (typeof req.session.username == 'undefined') res.redirect('/');
|
||||
else res.render('items', { title: 'Ninja Store - Items', username: req.session.username, items:items, keys:keys, fieldkeys:fieldkeys });
|
||||
});
|
||||
else res.render('items', { title: 'Ninja Store - Items'});
|
||||
// else res.render('items', { title: 'Ninja Store - Items', username: req.session.username, items:items, keys:keys, fieldkeys:fieldkeys });
|
||||
// });
|
||||
});
|
||||
|
||||
|
||||
|
||||
// show individual item
|
||||
//app.get('/items', store.items);
|
||||
|
||||
@@ -86,18 +90,6 @@ io.sockets.on('connection', function (socket) {
|
||||
});
|
||||
};
|
||||
|
||||
var addemployee = function(data) {
|
||||
db_helper.add_employee(data, function(lastId) {
|
||||
});
|
||||
db_helper.get_all('employees', function(err, items, fields) {
|
||||
if (err) {
|
||||
console.log("async1: " + err);
|
||||
}
|
||||
emitdata('populate',items);
|
||||
});
|
||||
|
||||
};
|
||||
|
||||
|
||||
var io = require('socket.io');
|
||||
io = io.listen(app);
|
||||
@@ -116,6 +108,10 @@ io.sockets.on('connection', function(client) {
|
||||
});
|
||||
client.on('data', function(data) {
|
||||
console.log("data" + JSON.stringify(data))
|
||||
testcollection.insert(data, function(err, result) {
|
||||
if (err) throw err;
|
||||
if (result) console.log('Added!');
|
||||
});
|
||||
});
|
||||
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user