rparodi/ft_transcendence
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge pull request #52 from Maix0/nigel/invite_pong draft

Browse source 
Initial draft of how chat and pong game service should interact in global chat space.
This commit is contained in:
G.C.L. Baptiste 2025-12-10 18:09:37 +01:00 • committed by GitHub
commit 918b69a8a6
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
5 changed files with 339 additions and 128 deletions
Download patch file Download diff file Expand all files Collapse all files

34
frontend/src/chat/chat.css
View file

@ -223,6 +223,40 @@ div-private {
right-12 right-12
} }
.popup-b-invite {
@apply
absolute
bottom-52
right-12
}
.popUpMessage {
@apply
bg-white
p-6 rounded-xl
shadow-xl
w-[800px]
h-[100px]
p-[10px]
border-1
border-black
}
.gamePopup {
@apply
fixed
inset-0
bg-black/50
flex
justify-center
items-center;
}
.hidden{ .hidden{
display: none; display: none;
} }

10
frontend/src/pages/chat/chat.html
View file

@ -1,6 +1,7 @@
<div class="displaybox"> <div class="displaybox">
<div id="mainbox" class="mainboxDisplay"> <div id="mainbox" class="mainboxDisplay">
<button id="b-whoami" class="btn-style absolute top-4 left-6">Who am i</button> <button id="b-whoami" class="btn-style absolute top-4 left-6">Who am i</button>
<button id="b-nextGame" class="btn-style absolute top-4 left-34">nextGame</button>
<h1 class="text-3xl font-bold text-gray-800"> <h1 class="text-3xl font-bold text-gray-800">
ChatterBox<span id="t-username"></span> ChatterBox<span id="t-username"></span>
</h1><br> </h1><br>
@ -26,9 +27,6 @@
<p id="ping-title" class="ping-title">Ping Buddies</p> <p id="ping-title" class="ping-title">Ping Buddies</p>
<div id="ping-list" class="flex-1 overflow-y-auto"> <div id="ping-list" class="flex-1 overflow-y-auto">
<div id = "div-buddies"> <div id = "div-buddies">
<!-- <p>Alice</p>
<p>Bob</p>
<p>Charlie</p> -->Marks
</div> </div>
</div> </div>
<div id="profile-modal" class="profilPopup hidden"> <div id="profile-modal" class="profilPopup hidden">
@ -37,6 +35,12 @@
<button id="close-modal" class="btn-style absolute bottom-32 right-12">Close</button> <button id="close-modal" class="btn-style absolute bottom-32 right-12">Close</button>
</div> </div>
</div> </div>
<div id="game-modal" class="gamePopup hidden">
<div class="popUpMessage">
<p class="" id="modal-message"></p>
<button id="close-modal-message" class="btn-style absolute bottom-67 right-12">Close</button>
</div>
</div>
</div> </div>
</div> </div>
</div> </div>

225
frontend/src/pages/chat/chat.ts
View file

@ -22,6 +22,35 @@ export type ClientMessage = {
}; };
export type ClientProfil = {
command: string,
destination: string,
type: string,
user: string,
loginName: string,
userID: string,
text: string,
timestamp: number,
SenderWindowID:string,
SenderName: string,
innerHtml?: string,
};
// export type inviteGame = {
// command?: string,
// destination?: string,
// type?: string,
// user?: string,
// loginName?: string,
// userID?: string,
// innerHtml?: string,
// timestamp?: number,
// SenderWindowID?:string,
// };
// get the name of the machine used to connect // get the name of the machine used to connect
const machineHostName = window.location.hostname; const machineHostName = window.location.hostname;
console.log('connect to login at %chttps://' + machineHostName + ':8888/app/login',color.yellow); console.log('connect to login at %chttps://' + machineHostName + ':8888/app/login',color.yellow);
@ -58,24 +87,47 @@ function addMessage(text: string) {
return ; return ;
}; };
function clearText() { function clear(senderSocket: Socket) {
const chatWindow = document.getElementById("t-chatbox") as HTMLDivElement; const chatWindow = document.getElementById("t-chatbox") as HTMLDivElement;
if (!chatWindow) return; if (!chatWindow) return;
chatWindow.innerHTML = ""; chatWindow.innerHTML = "";
// senderSocket.emit('nextGame');
} }
function isLoggedIn() { function isLoggedIn() {
return getUser() || null; return getUser() || null;
}; };
function actionBtnPopUp() { function inviteToPlayPong(profil: ClientProfil, senderSocket: Socket) {
profil.SenderName = getUser()?.name ?? '';
if (profil.SenderName === profil.user) return;
addMessage(`You invited to play: ${profil.user}🏓`)
senderSocket.emit('inviteGame', JSON.stringify(profil));
};
function actionBtnPopUpClear(profil: ClientProfil, senderSocket: Socket) {
setTimeout(() => { setTimeout(() => {
const clearTextBtn = document.querySelector("#popup-b-clear"); const clearTextBtn = document.querySelector("#popup-b-clear");
clearTextBtn?.addEventListener("click", () => { clearTextBtn?.addEventListener("click", () => {
clearText(); clear(senderSocket);
}); });
}, 0) }, 0)
} };
function actionBtnPopUpInvite(invite: ClientProfil, senderSocket: Socket) {
setTimeout(() => {
const InvitePongBtn = document.querySelector("#popup-b-invite");
InvitePongBtn?.addEventListener("click", () => {
inviteToPlayPong(invite, senderSocket);
});
}, 0)
};
// getProfil get the profil of user // getProfil get the profil of user
function getProfil(socket: Socket, user: string) { function getProfil(socket: Socket, user: string) {
@ -190,16 +242,9 @@ async function listBuddies(socket: Socket, buddies: HTMLDivElement, listBuddies:
}); });
buddiesElement.addEventListener("dblclick", () => { buddiesElement.addEventListener("dblclick", () => {
console.log("Open profile:", listBuddies); console.log("Open profile:", listBuddies);
getProfil(socket, listBuddies); getProfil(socket, listBuddies);
// openProfilePopup(`${profile}`); sendtextbox.value = "";
// setTimeout(() => {
// const clearTextBtn = document.querySelector("#popup-b-clear");
// clearTextBtn?.addEventListener("click", () => {
// clearText();
// });
// }, 0)
// actionBtnPopUp();
}); });
buddies.appendChild(buddiesElement); buddies.appendChild(buddiesElement);
@ -274,22 +319,24 @@ function broadcastMsg (socket: Socket, msgCommand: string[]): void {
async function connected(socket: Socket): Promise<void> { async function connected(socket: Socket): Promise<void> {
try { try {
const buddies = document.getElementById('div-buddies') as HTMLDivElement; const buddies = document.getElementById('div-buddies') as HTMLDivElement;
const loggedIn = await isLoggedIn(); const loggedIn = isLoggedIn();
console.log('%cloggedIn:',color.blue, loggedIn?.name); console.log('%cloggedIn:',color.blue, loggedIn?.name);
let oldUser = localStorage.getItem("oldName") ?? ""; let oldUser = localStorage.getItem("oldName") ?? "";
console.log('%coldUser:',color.yellow, oldUser); console.log('%coldUser:',color.yellow, oldUser);
if (loggedIn?.name === undefined) {console.log('');return ;} if (loggedIn?.name === undefined) {console.log('');return ;}
oldUser = loggedIn.name ?? ""; setTimeout(() => {
// const res = await client.guestLogin(); oldUser = loggedIn.name ?? "";
let user = await updateUser(); }, 0);
console.log('%cUser?name:',color.yellow, user?.name); // const res = await client.guestLogin();
localStorage.setItem("oldName", oldUser); let user = await updateUser();
buddies.textContent = ""; console.log('%cUser?name:',color.yellow, user?.name);
socket.emit('list', { localStorage.setItem("oldName", oldUser);
oldUser: oldUser, buddies.textContent = "";
user: user?.name, socket.emit('list', {
}); oldUser: oldUser,
user: user?.name,
});
} catch (e) { } catch (e) {
console.error("Login error:", e); console.error("Login error:", e);
showError('Failed to login: Unknown error'); showError('Failed to login: Unknown error');
@ -326,18 +373,49 @@ async function whoami(socket: Socket) {
} }
}; };
async function openProfilePopup(profil: string) { async function openProfilePopup(profil: ClientProfil) {
const modalname = document.getElementById("modal-name") ?? null; const modalname = document.getElementById("modal-name") ?? null;
if (modalname) if (modalname)
modalname.innerHTML = `${profil}`; modalname.innerHTML = `
const profilList = document.getElementById("profile-modal") ?? null; <div class="profile-info">
<div-profil-name id="profilName"> Profil of ${profil.user} </div>
<div-login-name id="loginName"> Login Name: '${profil.loginName ?? 'Guest'}' </div>
</br>
<div-login-name id="loginName"> Login ID: '${profil.userID ?? ''}' </div>
</br>
<button id="popup-b-clear" class="btn-style popup-b-clear">Clear Text</button>
<button id="popup-b-invite" class="btn-style popup-b-invite">U Game ?</button>
<div id="profile-about">About: '${profil.text}' </div>
</div>
`;
const profilList = document.getElementById("profile-modal") ?? null;
if (profilList) if (profilList)
profilList.classList.remove("hidden"); profilList.classList.remove("hidden");
// The popup now exists → attach the event // The popup now exists → attach the event
} }
async function openMessagePopup(message: string) {
const modalmessage = document.getElementById("modal-message") ?? null;
if(!message) return
const obj:any = JSON.parse(message);
if (modalmessage)
modalmessage.innerHTML = `
<div class="profile-info">
</br>
<div id="profile-about">Next Game Message: ${obj.link}</div>
</div>`;
const gameMessage = document.getElementById("game-modal") ?? null;
if (gameMessage)
gameMessage.classList.remove("hidden");
// The popup now exists → attach the event
}
function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn { function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn {
@ -374,9 +452,6 @@ function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn
// Listen for messages from the server "MsgObjectServer" // Listen for messages from the server "MsgObjectServer"
socket.on("MsgObjectServer", (data: { message: ClientMessage}) => { socket.on("MsgObjectServer", (data: { message: ClientMessage}) => {
console.log("%cDEBUG LOGS - Message Obj Recieved:", color.green, data);
console.log("%cDEBUG LOGS - Recieved data.message.text: ", color.green, data.message.text);
console.log("%cDEBUG LOGS - Recieved data.message.user: ", color.green, data.message.user);
// Display the message in the chat window // Display the message in the chat window
const systemWindow = document.getElementById('system-box') as HTMLDivElement; const systemWindow = document.getElementById('system-box') as HTMLDivElement;
const chatWindow = document.getElementById("t-chatbox") as HTMLDivElement; const chatWindow = document.getElementById("t-chatbox") as HTMLDivElement;
@ -416,12 +491,19 @@ function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn
console.log("Getuser():", getUser()); console.log("Getuser():", getUser());
}); });
socket.on('profilMessage', (profil) => { socket.on('profilMessage', (profil: ClientProfil) => {
openProfilePopup(profil); openProfilePopup(profil);
actionBtnPopUp(); actionBtnPopUpClear(profil, socket);
actionBtnPopUpInvite(profil, socket);
});
socket.on('inviteGame', (invite: ClientProfil) => {
const chatWindow = document.getElementById("t-chatbox") as HTMLDivElement;
const messageElement = document.createElement("div");
messageElement.innerHTML =`🏓${invite.SenderName}: ${invite.innerHtml}`;
chatWindow.appendChild(messageElement);
}); });
socket.on('logout', () => { socket.on('logout', () => {
quitChat(socket); quitChat(socket);
}); });
@ -430,37 +512,39 @@ function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn
addMessage(message); addMessage(message);
}) })
type Providers = { //receives broadcast of the next GAME
name: string, socket.on('nextGame', (message) => {
display_name: string, openMessagePopup(message);
icon_url?: string, // addMessage(message);
color?: { default: string, hover: string }, })
};
let toggle = false let toggle = false
window.addEventListener("focus", () => { window.addEventListener("focus", async () => {
//nst bwhoami = document.getElementById('b-whoami') as HTMLButtonElement; //nst bwhoami = document.getElementById('b-whoami') as HTMLButtonElement;
if (window.location.pathname === '/app/chat') {
setTimeout(() => {
connected(socket); connected(socket);
console.log("%cWindow is focused on /chat:" + socket.id, color.green); }, 0);
if (window.location.pathname === '/app/chat') {
console.log('%cWindow is focused on /chat:' + socket.id, color.green);
if (socket.id) { if (socket.id) {
windowStateVisable(); await windowStateVisable();
} }
toggle = true; toggle = true;
} }
}); });
window.addEventListener("blur", () => { window.addEventListener("blur", () => {
console.log("%cWindow is not focused on /chat", color.red); console.log('%cWindow is not focused on /chat', color.red);
if (socket.id) if (socket.id)
windowStateHidden(); windowStateHidden();
toggle = false; toggle = false;
}); });
// setInterval(async () => { // setInterval(async () => {
// //connected(socket); // //connected(socket);
// },10000); // every 10 seco // },10000); // every 10 sec
socket.on('listBud', async (myBuddies: string) => { socket.on('listBud', async (myBuddies: string) => {
const buddies = document.getElementById('div-buddies') as HTMLDivElement; const buddies = document.getElementById('div-buddies') as HTMLDivElement;
console.log('List buddies connected ', myBuddies); console.log('List buddies connected ', myBuddies);
@ -493,6 +577,7 @@ function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn
const buddies = document.getElementById('div-buddies') as HTMLDivElement; const buddies = document.getElementById('div-buddies') as HTMLDivElement;
const bquit = document.getElementById('b-quit') as HTMLDivElement; const bquit = document.getElementById('b-quit') as HTMLDivElement;
const systemWindow = document.getElementById('system-box') as HTMLDivElement; const systemWindow = document.getElementById('system-box') as HTMLDivElement;
const bnextGame = document.getElementById('b-nextGame') as HTMLDivElement;
chatWindow.textContent = ''; chatWindow.textContent = '';
chatWindow.innerHTML = ''; chatWindow.innerHTML = '';
@ -519,6 +604,18 @@ function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn
if (profilList) profilList.classList.add("hidden"); if (profilList) profilList.classList.add("hidden");
}); });
const buttonMessage = document.getElementById("close-modal-message") ?? null;
if (buttonMessage)
buttonMessage.addEventListener("click", () => {
const gameMessage = document.getElementById("game-modal") ?? null;
if (gameMessage) gameMessage.classList.add("hidden");
});
// Send button // Send button
sendButton?.addEventListener("click", () => { sendButton?.addEventListener("click", () => {
if (sendtextbox && sendtextbox.value.trim()) { if (sendtextbox && sendtextbox.value.trim()) {
@ -535,21 +632,6 @@ function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn
break; break;
case '@profil': case '@profil':
getProfil(socket, msgCommand[1]); getProfil(socket, msgCommand[1]);
// Ensure we have a user AND socket is connected
// if (!socket.connected) return;
// const profil = {
// command: msgCommand[0],
// destination: 'profil',
// type: "chat",
// user: msgCommand[1],
// token: document.cookie ?? "",
// text: msgCommand[1],
// timestamp: Date.now(),
// SenderWindowID: socket.id,
// };
// //socket.emit('MsgObjectServer', message);
// addMessage(JSON.stringify(profil));
// socket.emit('profilMessage', JSON.stringify(profil));
break; break;
case '@cls': case '@cls':
chatWindow.innerHTML = ''; chatWindow.innerHTML = '';
@ -587,6 +669,14 @@ function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn
if (chatWindow) { if (chatWindow) {
chatWindow.innerHTML = ''; chatWindow.innerHTML = '';
} }
clear(socket); //DEV testing broadcastGames
});
// Dev Game message button
bnextGame?.addEventListener("click", () => {
if (chatWindow) {
socket.emit('nextGame');
}
}); });
bquit?.addEventListener('click', () => { bquit?.addEventListener('click', () => {
@ -608,5 +698,4 @@ function handleChat(_url: string, _args: RouteHandlerParams): RouteHandlerReturn
} }
} }
}; };
addRoute('/chat', handleChat, { bypass_auth: true }); addRoute('/chat', handleChat, { bypass_auth: true });

8
src/@shared/src/utils/index.ts
View file

@ -142,3 +142,11 @@ export function typeResponse<K extends string, T extends TProperties>(
export function isNullish<T>(v: T | undefined | null): v is null | undefined { export function isNullish<T>(v: T | undefined | null): v is null | undefined {
return v === null || v === undefined; return v === null || v === undefined;
} }
/**
/* EXPERIMENTAL: how to send a starting game link to chat
**/
export async function sendGameLinkToChatService(link: string) :Promise<string> {
const payload = { link };
return JSON.stringify(payload);
}

190
src/chat/src/app.ts
View file

@ -7,6 +7,7 @@ import * as swagger from '@shared/swagger';
import * as utils from '@shared/utils'; import * as utils from '@shared/utils';
import { Server, Socket } from 'socket.io'; import { Server, Socket } from 'socket.io';
import type { User } from '@shared/database/mixin/user'; import type { User } from '@shared/database/mixin/user';
import { sendGameLinkToChatService } from '../../@shared/src/utils/index';
// colors for console.log // colors for console.log
export const color = { export const color = {
@ -42,6 +43,43 @@ export type ClientMessage = {
SenderWindowID: string; SenderWindowID: string;
}; };
export type ClientProfil = {
command: string,
destination: string,
type: string,
user: string,
loginName: string,
userID: string,
text: string,
timestamp: number,
SenderWindowID:string,
SenderName: string,
innerHtml?: string,
};
/**
/* TODO find the description info for profil / or profil game link and return
**/
function createNextGame() {
return '<a href=\'https://localhost:8888/app/\' style=\'color: blue; text-decoration: underline; cursor: pointer;\'>The next Game is Starting click here to watch</a>';
};
function setAboutPlayer(about: string): string {
if (!about) {
about = 'Player is good Shape - This is a default description';
}
return about;
};
function setGameLink(link: string): string {
if (!link) {
link = '<a href=\'https://google.com\' style=\'color: blue; text-decoration: underline; cursor: pointer;\'>Click me</a>';
}
return link;
};
const clientChat = new Map<string, ClientInfo>(); const clientChat = new Map<string, ClientInfo>();
// @ts-expect-error: import.meta.glob is a vite thing. Typescript doesn't know this... // @ts-expect-error: import.meta.glob is a vite thing. Typescript doesn't know this...
@ -85,8 +123,10 @@ declare module 'fastify' {
hello: (message: string) => string; hello: (message: string) => string;
MsgObjectServer: (data: { message: ClientMessage }) => void; MsgObjectServer: (data: { message: ClientMessage }) => void;
privMessage: (data: string) => void; privMessage: (data: string) => void;
profilMessage: (data: string) => void; profilMessage: (data: ClientProfil) => void;
inviteGame: (data: ClientProfil) => void;
privMessageCopy: (msg: string) => void; privMessageCopy: (msg: string) => void;
nextGame: (msg: string) => void;
message: (msg: string) => void; message: (msg: string) => void;
listBud: (msg: string) => void; listBud: (msg: string) => void;
testend: (sock_id_client: string) => void; testend: (sock_id_client: string) => void;
@ -117,15 +157,12 @@ async function onReady(fastify: FastifyInstance) {
// If we have the io instance, attempt to validate the socket is still connected // If we have the io instance, attempt to validate the socket is still connected
if (io && typeof io.sockets?.sockets?.get === 'function') { if (io && typeof io.sockets?.sockets?.get === 'function') {
const s = io.sockets.sockets.get(socketId) as const s = io.sockets.sockets.get(socketId) as Socket | undefined;
| Socket
| undefined;
// If socket not found or disconnected, remove from map and skip // If socket not found or disconnected, remove from map and skip
if (!s || s.disconnected) { if (!s || s.disconnected) {
clientChat.delete(socketId); clientChat.delete(socketId);
continue; continue;
} }
// Skip duplicates (DO NOT delete them — just don't count) // Skip duplicates (DO NOT delete them — just don't count)
if (seen.has(username.user)) { if (seen.has(username.user)) {
continue; continue;
@ -133,23 +170,11 @@ async function onReady(fastify: FastifyInstance) {
// socket exists and is connected // socket exists and is connected
seen.add(username.user); seen.add(username.user);
count++; count++;
// console.log(color.green,"count: ", count);
// console.log(color.yellow, 'Client:', color.reset, username.user);
const targetSocketId = target; const targetSocketId = target;
io.to(targetSocketId!).emit('listBud', username.user); io.to(targetSocketId!).emit('listBud', username.user);
// console.log(
// color.yellow,
// 'Chat Socket ID:',
// color.reset,
// socketId,
// );
continue; continue;
} }
// If no io provided, assume entries in the map are valid and count them.
count++; count++;
console.log(color.red, 'DEBUG LOG: - Client (unverified):', color.reset, username);
console.log(color.red, 'DEBUG LOG: - Chat Socket ID (unverified):', color.reset, socketId);
} }
return count; return count;
} }
@ -169,58 +194,99 @@ async function onReady(fastify: FastifyInstance) {
socket.emit('MsgObjectServer', { message: data }); socket.emit('MsgObjectServer', { message: data });
// Debug logs // Debug logs
console.log(color.green, `'Broadcast to:', ${data.command} message: ${data.text}`); console.log(color.green, `'Broadcast to:', ${data.command} message: ${data.text}`);
// console.log('DEBUG - Target socket ID:', s.id);
// console.log('DEBUG - Target rooms:', [...s.rooms]);
// console.log('DEBUG - Sender socket ID:', sender ?? 'none');
} }
}); });
} }
async function broadcastNextGame(gameLink?: Promise<string>) {
const link = gameLink ? await gameLink : undefined;
const sockets = await fastify.io.fetchSockets();
// fastify.io.fetchSockets().then((sockets) => {
for (const socket of sockets) {
// Skip sender's own socket
const clientInfo = clientChat.get(socket.id);
if (!clientInfo?.user) {
console.log(color.yellow, `Skipping socket ${socket.id} (no user found)`);
continue;
}
// Emit structured JSON object
if (link) {
socket.emit('nextGame', link);
}
// Debug logs
// console.log(color.green, `'DEBUG LOG: Broadcast to:', ${data.command} message: ${data.text}`);
}
};
// function formatTimestamp(ms: number) { // function formatTimestamp(ms: number) {
// const d = new Date(ms); // const d = new Date(ms);
// return d.toLocaleString('fr-FR', { timeZone: 'Europe/Paris' }); // return d.toLocaleString('fr-FR', { timeZone: 'Europe/Paris' });
// } // }
function getUserByName(users: User[], name: string) { function getUserByName(users: User[], name: string) {
return users.find(u => u.name === name) || null; return users.find(user => user.name === name) || null;
} }
// this function returns html the profil pop up in CHAT of a user 'nickname unique' TODO .... // this function returns html the profil pop up in CHAT of a user 'nickname unique' TODO ....
async function getProfil(user: string): Promise <string> { async function getProfil(user: string, socket: Socket): Promise <ClientProfil> {
let profilHtmlPopup = '404: Error: Profil not found';
let clientProfil!: ClientProfil;
const users: User[] = fastify.db.getAllUsers() ?? []; const users: User[] = fastify.db.getAllUsers() ?? [];
const allUsers: User | null = getUserByName(users, user); const allUsers: User | null = getUserByName(users, user);
console.log(color.yellow, `'userFound is:'${allUsers?.name}`); console.log(color.yellow, `'userFound is:'${allUsers?.name}`);
if (user === allUsers?.name) { if (user === allUsers?.name) {
console.log(color.yellow, `'login Name: '${allUsers.login}' user: '${user}'`); console.log(color.yellow, `'login Name: '${allUsers.login}' user: '${user}'`);
profilHtmlPopup = `<div class="profile-info">
<div-profil-name id="profilName"> Profil of ${allUsers.name} </div>
<div-login-name id="loginName"> Login Name: '${allUsers?.login ?? 'Guest'}' </div>
</br>
<button id="popup-b-clear" class="btn-style popup-b-clear">Clear Text</button>
<div id="profile-about">About: No description</div>
</div>`;
}
return profilHtmlPopup; clientProfil =
{
command: 'getProfil',
destination: 'profilMsg',
type: 'chat' as const,
user: `${allUsers.name}`,
loginName: `${allUsers?.login ?? 'Guest'}`,
userID: `${allUsers?.id ?? ''}`,
text: setAboutPlayer(''),
timestamp: Date.now(),
SenderWindowID: socket.id,
SenderName: '',
innerHtml: '',
};
}
return clientProfil;
}; };
function sendProfil(data: ClientMessage, clientProfil?: string) { function sendProfil(data: ClientProfil, clientProfil?: string) {
fastify.io.fetchSockets().then((sockets) => { fastify.io.fetchSockets().then((sockets) => {
const senderSocket = sockets.find(socket => socket.id === clientProfil); const senderSocket = sockets.find(socket => socket.id === clientProfil);
for (const socket of sockets) { if (senderSocket) {
const clientInfo = clientChat.get(socket.id); console.log(color.yellow, 'user inFO:', data.user);
if (clientInfo?.user === data.user) { senderSocket.emit('profilMessage', data);
if (senderSocket) {
socket.emit('profilMessage', `${data.text}`);
}
}
} }
}); });
} }
function sendInvite(innerHtml: string, data: ClientProfil) {
fastify.io.fetchSockets().then((sockets) => {
let targetSocket;
for (const socket of sockets) {
const clientInfo: string = clientChat.get(socket.id)?.user || '';
if (clientInfo === data.user) {
console.log(color.yellow, 'FOUND:', data.user);
targetSocket = socket || '';
break;
}
}
data.innerHtml = innerHtml ?? '';
if (targetSocket) {
targetSocket.emit('inviteGame', data);
}
});
}
function sendPrivMessage(data: ClientMessage, sender?: string) { function sendPrivMessage(data: ClientMessage, sender?: string) {
fastify.io.fetchSockets().then((sockets) => { fastify.io.fetchSockets().then((sockets) => {
const senderSocket = sockets.find(s => s.id === sender); const senderSocket = sockets.find(s => s.id === sender);
@ -286,6 +352,13 @@ async function onReady(fastify: FastifyInstance) {
console.log('testend received from client socket id:', sock_id_cl); console.log('testend received from client socket id:', sock_id_cl);
}); });
socket.on('nextGame', () => {
const link = createNextGame();
const game: Promise<string> = sendGameLinkToChatService(link);
broadcastNextGame(game);
});
socket.on('list', (object) => { socket.on('list', (object) => {
const userFromFrontend = object || null; const userFromFrontend = object || null;
@ -425,7 +498,7 @@ async function onReady(fastify: FastifyInstance) {
} }
}); });
socket.on('profilMessage', async (data) => { socket.on('profilMessage', async (data: string) => {
const clientName: string = clientChat.get(socket.id)?.user || ''; const clientName: string = clientChat.get(socket.id)?.user || '';
const profilMessage: ClientMessage = JSON.parse(data) || ''; const profilMessage: ClientMessage = JSON.parse(data) || '';
const users: User[] = fastify.db.getAllUsers() ?? []; const users: User[] = fastify.db.getAllUsers() ?? [];
@ -435,26 +508,29 @@ async function onReady(fastify: FastifyInstance) {
`DEBUG LOG: ClientName: '${clientName}' id Socket: '${socket.id}' target profil:`, `DEBUG LOG: ClientName: '${clientName}' id Socket: '${socket.id}' target profil:`,
profilMessage.user, profilMessage.user,
); );
const profileHtml: string = await getProfil(profilMessage.user); const profileHtml: ClientProfil = await getProfil(profilMessage.user, socket);
if (clientName !== null) { if (clientName !== null) {
const testuser: User | null = getUserByName(users, profilMessage.user); const testuser: User | null = getUserByName(users, profilMessage.user);
console.log(color.yellow, 'user:', testuser?.login ?? 'Guest'); console.log(color.yellow, 'user:', testuser?.name ?? 'Guest');
const obj = { console.log(color.blue, 'DEBUG - profil message MESSAGE OUT :', profileHtml.SenderWindowID);
command: profilMessage.command, sendProfil(profileHtml, profileHtml.SenderWindowID);
destination: 'profilMsg',
type: 'chat',
user: clientName,
token: '',
text: profileHtml,
timestamp: Date.now(),
SenderWindowID: socket.id,
};
console.log(color.blue, 'DEBUG - profil message MESSAGE OUT :', obj.SenderWindowID);
sendProfil(obj, obj.SenderWindowID);
// clientChat.delete(obj.user); // clientChat.delete(obj.user);
} }
}); });
socket.on('inviteGame', async (data: string) => {
const clientName: string = clientChat.get(socket.id)?.user || '';
const profilInvite: ClientProfil = JSON.parse(data) || '';
// const users: User[] = fastify.db.getAllUsers() ?? [];
const inviteHtml: string = 'invites you to a game ' + setGameLink('');
if (clientName !== null) {
// const testuser: User | null = getUserByName(users, profilInvite.user ?? '');
// console.log(color.yellow, 'user:', testuser?.name ?? 'Guest');
sendInvite(inviteHtml, profilInvite);
}
});
socket.on('client_entered', (data) => { socket.on('client_entered', (data) => {
// data may be undefined (when frontend calls emit with no payload) // data may be undefined (when frontend calls emit with no payload)