talksik/tixto_server
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

adding in news distribution

Browse Source
This commit is contained in:
talksik
2018-08-24 20:19:07 -07:00
parent f3fd72d34b
commit 3cf17cfeb0
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app.js
+4 -1
View File
@@ -84,13 +84,16 @@ io.on('connection', function (socket) {
let long = input.position.long; let long = input.position.long;
let lat = input.position.lat; let lat = input.position.lat;
var sql = 'SELECT * FROM messages, users WHERE messages.user_id = users.id HAVING (6371393 * acos(cos(radians((?))) * cos(radians(messages.lat)) * cos(radians(messages.lng) - radians((?))) + sin(radians((?))) * sin(radians(messages.lat))) < 300) ORDER BY messages.id' var sql = 'SELECT * FROM users, messages WHERE messages.user_id = users.id HAVING (6371393 * acos(cos(radians((?))) * cos(radians(messages.lat)) * cos(radians(messages.lng) - radians((?))) + sin(radians((?))) * sin(radians(messages.lat))) < 300) ORDER BY messages.id'
con.query(sql, [lat, long, lat], function (err, result, fields) { con.query(sql, [lat, long, lat], function (err, result, fields) {
if (err) throw err; if (err) throw err;
socket.emit('initMessages', result); socket.emit('initMessages', result);
console.log('Sent all ' + result.length + ' initial messages!'); console.log('Sent all ' + result.length + ' initial messages!');
}); });
// temporarily sending the news messages to users on initial
socket.emit('initNews', news);
}); });