storing and retrieving long and lat values

server/app.js

@@ -20,32 +20,39 @@ app.get('/', function (req, res) {
 io.on('connection', function (socket) {
   console.log('Client connected: ' + socket.id);
 
-  con.query('SELECT * FROM messages', function (err, result, fields) {
-    if (err) throw err;
-    socket.emit('initMessages', result);
-    console.log('sent all initial messages');
+  socket.on('initial', (position) => {
+    console.log(position.long + ' ' + position.lat);
+    //var sql = 'select * from messages where lng = 0';
+    var sql = 'SELECT * FROM messages HAVING (6371393 * acos(cos(radians((?))) * cos(radians(lat)) * cos(radians(lng) - radians((?))) + sin(radians((?))) * sin(radians(lat))) < 100) ORDER BY id;'
+    con.query(sql, [position.lat, position.long, position.lat], function (err, result, fields) {
+      if (err) throw err;
+      socket.emit('initMessages', result);
+      console.log('sent all initial messages');
+    });
   });
 
   //io.on('test', () => console.log('worked~')); // test with web page
 
   socket.on('newMessage', function(msg) {
-    var sql = "INSERT INTO messages (userId, text, createdAt) VALUES (?, ?, ?)";
+    var sql = "INSERT INTO messages (userId, text, createdAt, lng, lat) VALUES (?, ?, ?, ?, ?)";
     var currTime = new Date().toString();
-    con.query(sql, [msg.userId, msg.text, currTime], function(err, result) {
+    con.query(sql, [msg.userId, msg.text, currTime, msg.lng, msg.lat], function(err, result) {
       if (err) throw err;
       console.log('Message sent to db!');
 
       var msgId = 0;
       con.query('SELECT LAST_INSERT_ID()', function(err, result) {
         if(err) throw err;
-        msgId = result.'LAST_INSERT_ID()';
+        msgId = result;
         console.log(msgId);
       });
       var uploadedMsg = {
         id: msgId,
         userId: msg.userId,
         text: msg.text,
-        createdAt: currTime
+        createdAt: currTime,
+        lng: msg.lng,
+        lat: msg.lat
       };
       io.emit('newMessage', uploadedMsg);
     });