-const url = require('url');
+const Discord = require('discord.js');
+const { token, channel } = require('./config/discord.json');
// Node version in Ubuntu 16.04 does not know about URL class
-// NOTE: url is already transformed, without ?xxx=yyy... parts
function getJsonFromUrl(url) {
const query = url.substr(2); //starts with "/?"
let result = {};
// NOTE: only purpose of sidToPages = know when to delete keys in idToSid
let sidToPages = {};
let idToSid = {};
+ const discordClient = new Discord.Client();
+ let discordChannel = null;
+ if (token.length > 0) {
+ discordClient.login(token).then( () => {
+ discordChannel = discordClient.channels.cache.get(channel);
+ });
+ }
wss.on("connection", (socket, req) => {
const query = getJsonFromUrl(req.url);
const sid = query["sid"];
// When page changes:
doDisconnect();
break;
- case "killme": {
- // Self multi-connect: manual removal + disconnect
- const doKill = (pg) => {
- Object.keys(clients[pg][obj.sid]).forEach(x => {
- send(clients[pg][obj.sid][x].socket, { code: "killed" });
- });
- delete clients[pg][obj.sid];
- };
- const disconnectFromOtherConnexion = (pg,code,o={}) => {
- Object.keys(clients[pg]).forEach(k => {
- if (k != obj.sid) {
- Object.keys(clients[pg][k]).forEach(x => {
- send(
- clients[pg][k][x].socket,
- Object.assign({ code: code, from: obj.sid }, o)
- );
- });
- }
- });
- };
- Object.keys(clients).forEach(pg => {
- if (clients[pg][obj.sid]) {
- doKill(pg);
- disconnectFromOtherConnexion(pg, "disconnect");
- if (pg.indexOf("/game/") >= 0 && clients["/"])
- disconnectFromOtherConnexion("/", "gdisconnect", { page: pg });
- }
- });
- break;
- }
case "pollclients": {
// From Game
let sockIds = {};
case "rematchoffer":
case "draw":
// "newgame" message can provide a page (corr Game --> Hall)
- notifyRoom(obj.page || page, obj.code, {data: obj.data}, obj.excluded);
+ notifyRoom(
+ obj.page || page, obj.code, {data: obj.data}, obj.excluded);
+ if (
+ obj.code == "newchallenge" &&
+ !obj.data.to && //filter out targeted challenges
+ obj.data.cadence.indexOf('d') < 0 //and correspondance games
+ ) {
+ const challMsg = (
+ "New challenge: **" + obj.data.vname + "** " +
+ "[" + obj.data.cadence + "]"
+ );
+ if (!!discordChannel) discordChannel.send(challMsg);
+ else
+ // Log when running locally (dev, debug):
+ console.log(challMsg);
+ }
break;
case "rnewgame":
case "getfocus":
case "losefocus":
- clients[page][sid][tmpId].focus = (obj.code == "getfocus");
+ if (
+ !!clients[page] &&
+ !!clients[page][sid] &&
+ !!clients[page][sid][tmpId]
+ ) {
+ clients[page][sid][tmpId].focus = (obj.code == "getfocus");
+ }
if (page == "/") notifyRoom("/", obj.code, { page: "/" }, [sid]);
else {
// Notify game room + Hall:
case "lastate":
{
const pg = obj.target[2] || page; //required for identity and game
- // NOTE: if in game we ask identity to opponent still in Hall,
- // but leaving Hall, clients[pg] or clients[pg][target] could be undefined
+ // NOTE: if in game we ask identity to opponent still in Hall, but
+ // leaving Hall, clients[pg] or clients[pg][target] could be undef.
if (!!clients[pg] && !!clients[pg][obj.target[0]]) {
send(
clients[pg][obj.target[0]][obj.target[1]].socket,