Skip to content

Commit

Permalink
Adding inital code for socket node
Browse files Browse the repository at this point in the history
  • Loading branch information
alex-ac2 committed Apr 18, 2018
0 parents commit 3aaefc7
Show file tree
Hide file tree
Showing 3 changed files with 106 additions and 0 deletions.
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
node_modules/
25 changes: 25 additions & 0 deletions package.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
{
"name": "socketnode",
"version": "1.0.0",
"description": "Socket node to pipe data transfers",
"main": "server.js",
"scripts": {
"test": "echo \"Error: no test specified\" && exit 1"
},
"keywords": [
"socket.io",
"node.js",
"p5.js",
"data",
"send",
"transfer",
"node"
],
"author": "ac2",
"license": "ISC",
"dependencies": {
"express": "^4.16.2",
"mongodb": "^3.0.2",
"socket.io": "^2.0.4"
}
}
80 changes: 80 additions & 0 deletions server.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,80 @@
var express = require('express');
var app = express();


/*
//Mongo DataBase Config
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://192.168.2.156:27017';
var insertData = {};
var dataRequest;
*/

// Socket Server
var server = app.listen(8085);
console.log("Socket Node running on port 8085...");

var socket = require('socket.io');
var io = socket(server);

io.sockets.on('connection', newConnection);

// New Socket Connection
function newConnection(socket) {
var id = socket.id;
console.log("new connection: " + socket.id);

// socket.on('getData', dataRelease);

// Find Data Function
function dataRelease(boolean) {
console.log("Socket boolean message received...");
if (boolean == "true") {
MongoClient.connect(url, function(err, client) {
if (client) {
var db = client.db('learning_mongo');
var collection = db.collection('testData5');
collection.find({}).toArray(function(err, dataResult) {
if (err) throw err;
socket.emit('dataRelease', dataResult);
console.log(dataResult);
console.log("Data Release Sent.")
client.close();
});
}
})
}
}


// socket.on('dataPoint', dataAdd);

// Write Data Function
function dataAdd(data1) {
MongoClient.connect(url, function(err, client) {
if (client) {
var db = client.db('NMPL');
var collection = db.collection('NMPL_tinfoil');
//console.log(data1)
collection.insertOne(data1, function(err, res) {
if (err) throw err;
client.close();
});
} else if (err) {
console.log("ERROR: " + err);
}
});
}






socket.on('dataMessage', dataMsg);

function dataMsg(data1) {
socket.broadcast.emit('dataMessage', data1);
console.log(data1);
}
}

0 comments on commit 3aaefc7

Please sign in to comment.