nabil_oh/M1_ProjetWeb
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Reglages de l'api de message avec le cache

Browse source
This commit is contained in:
Bilal Dieumegard 2024-12-11 15:32:04 +01:00
parent ab3e81d020
commit 45fb025065
1 changed files with 38 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

65
src/routes/api/channels/[id]/messages/+server.ts
View file

@ -6,30 +6,32 @@ import { sortChannels } from '$lib/utils/sort.ts';
export async function GET({ params, url }) { export async function GET({ params, url }) {
const channelId = params.id; const channelId = params.id;
logger.debug(`GET /api/channels/${channelId}/messages`);
// Gestion des paramètres de pagination const limit = parseInt(url.searchParams.get('limit') || '10');
const limit = parseInt(url.searchParams.get('limit') || '20'); // Par défaut, 20 messages const page = parseInt(url.searchParams.get('page') || '1');
const page = parseInt(url.searchParams.get('page') || '1'); // Par défaut, page 1
const offset = (page - 1) * limit; const offset = (page - 1) * limit;
try { try {
// Essayer de récupérer les messages du cache Redis
logger.debug(`Tentative de récupération des messages du cache pour le channel : ${channelId}`); logger.debug(`Tentative de récupération des messages du cache pour le channel : ${channelId}`);
let redisMessages = await redisClient.zRange(`channel:${channelId}:messages`, offset, limit, {REV:true}); const redisMessageKeys = await redisClient.zRange(
`channel:${channelId}:messages`,
offset,
offset + limit - 1,
{ REV: true }
);
if (redisMessages && redisMessages.length > 0) { if (redisMessageKeys.length > 0) {
logger.debug(`Messages trouvés dans le cache pour le channel : ${channelId}`); const messages = await Promise.all(
const messages = await redisClient.mGet(redisMessages).then( redisMessageKeys.map(async (key) => {
(messages) => messages.map((m) => JSON.parse(m)).reverse() const message = await redisClient.get(key);
return JSON.parse(message);
})
); );
return json({ limit, page, messages: messages.reverse() });
return json({ limit, page, messages });
} else {
logger.debug(`Aucun message trouvé dans le cache, récupération depuis MongoDB pour le channel : ${channelId}`);
} }
// Si aucun message n'est trouvé dans Redis, charger depuis MongoDB logger.debug(`Aucun message trouvé dans le cache, récupération depuis MongoDB pour le channel : ${channelId}`);
const messagesFromDB = await prisma.message.findMany({ const messagesFromDB = await prisma.message.findMany({
where: { channelId }, where: { channelId },
select: { select: {
@ -46,23 +48,26 @@ export async function GET({ params, url }) {
}, },
}, },
}, },
orderBy: [{ createdAt: 'desc' }], orderBy: { createdAt: 'desc' },
skip: offset,
take: limit,
}); });
if (messagesFromDB.length > 0) { if (messagesFromDB.length > 0) {
// Stocker les messages dans Redis const redisPipeline = redisClient.multi();
for (const message of messagesFromDB) { for (const message of messagesFromDB) {
await redisClient.set(`message:${message.id}`, JSON.stringify(message)); const messageKey = `message:${message.id}`;
await redisClient.zAdd(`channel:${channelId}:messages`, { redisPipeline.set(messageKey, JSON.stringify(message));
redisPipeline.zAdd(`channel:${channelId}:messages`, {
score: new Date(message.createdAt).getTime(), score: new Date(message.createdAt).getTime(),
value: `message:${message.id}`, value: messageKey,
}); });
} }
logger.debug(`Messages ajoutés au cache Redis pour le channel : ${channelId}`); await redisPipeline.exec();
} }
return json({ limit, page, messages: messagesFromDB }); return json({ limit, page, messages: messagesFromDB.reverse() });
} catch (err) { } catch (err) {
logger.error(`Erreur lors de la récupération des messages : ${err.message}`); logger.error(`Erreur lors de la récupération des messages : ${err.message}`);
return json({ error: 'Erreur lors de la récupération des messages' }, { status: 500 }); return json({ error: 'Erreur lors de la récupération des messages' }, { status: 500 });
@ -112,12 +117,18 @@ export async function POST({ params, request }) {
//update the channels cache with the new message //update the channels cache with the new message
const cachedChannels = await redisClient.get('channels'); const cachedChannels = await redisClient.get('channels');
let channels = JSON.parse(cachedChannels); let channels = cachedChannels ? JSON.parse(cachedChannels) : [];
const channel = channels.find((c) => c.id === channelId); const channel = channels.find((c) => c.id === channelId);
channel.lastMessage = newMessage; if(channel){
channel.lastUpdate = newMessage.createdAt; channel.lastMessage = newMessage;
channels = sortChannels(channels); channel.lastUpdate = newMessage.createdAt;
await redisClient.set('channels', JSON.stringify(channels), { EX: 600 }); channels = sortChannels(channels);
await redisClient.set('channels', JSON.stringify(channels), { EX: 600 });
}else{
channels = [newMessage.channel, ...channels];
await redisClient.set('channels', JSON.stringify(channels), { EX: 600 });
}
logger.debug(`Nouveau message ajouté pour le channel : ${channelId}`); logger.debug(`Nouveau message ajouté pour le channel : ${channelId}`);
return json(newMessage, { status: 201 }); return json(newMessage, { status: 201 });