summaryrefslogtreecommitdiff
path: root/server.js
diff options
context:
space:
mode:
Diffstat (limited to 'server.js')
-rw-r--r--server.js17
1 files changed, 13 insertions, 4 deletions
diff --git a/server.js b/server.js
index 183148a..7ab5214 100644
--- a/server.js
+++ b/server.js
@@ -1331,7 +1331,6 @@ const SQL_SELECT_GAME = SQL("SELECT * FROM games WHERE game_id=?")
const SQL_SELECT_GAME_VIEW = SQL("SELECT * FROM game_view WHERE game_id=?")
const SQL_SELECT_GAME_TITLE = SQL("SELECT title_id FROM games WHERE game_id=?").pluck()
-const SQL_SELECT_PLAYERS_ID = SQL("SELECT DISTINCT user_id FROM players WHERE game_id=?").pluck()
const SQL_SELECT_PLAYERS = SQL("select * from players join user_view using(user_id) where game_id=?")
const SQL_SELECT_PLAYERS_WITH_NAME = SQL("select role, user_id, name from players join users using(user_id) where game_id=?")
const SQL_UPDATE_PLAYER_ACCEPT = SQL("UPDATE players SET is_invite=0 WHERE game_id=? AND role=? AND user_id=?")
@@ -2403,6 +2402,10 @@ function send_play_notification(user, game_id, message) {
const QUERY_LIST_YOUR_TURN = SQL("SELECT * FROM your_turn_reminder")
const QUERY_LIST_INVITES = SQL("SELECT * FROM invite_reminder")
+function send_chat_activity_notification(game_id, p) {
+ send_play_notification(p, game_id, "Chat activity")
+}
+
function send_your_turn_notification_to_offline_users(game_id, old_active, active) {
// Only send notifications when the active player changes.
if (old_active === active)
@@ -2879,9 +2882,15 @@ function on_chat(socket, message) {
function send_chat_message(game_id, from_id, from_name, message) {
SQL_INSERT_GAME_CHAT.run(game_id, game_id, from_id, message)
- let users = SQL_SELECT_PLAYERS_ID.all(game_id)
- for (let user_id of users)
- SQL_INSERT_UNREAD_CHAT.run(user_id, game_id)
+ let players = SQL_SELECT_PLAYERS.all(game_id)
+ for (let p of players) {
+ let unread = SQL_SELECT_UNREAD_CHAT.get(p.user_id, game_id)
+ if (!unread) {
+ SQL_INSERT_UNREAD_CHAT.run(p.user_id, game_id)
+ if (!is_player_online(game_id, p.user_id))
+ send_chat_activity_notification(game_id, p)
+ }
+ }
if (game_clients[game_id]) {
for (let other of game_clients[game_id])