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

wip: finishing fixing the API routes

Browse source
This commit is contained in:
Nabil Ould Hamou 2024-12-02 13:49:39 +01:00
parent a2c494dbd2
commit 869762af25
4 changed files with 75 additions and 53 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/lib/components/ui/ChatItem.svelte
View file

@ -5,7 +5,7 @@
export let time: string; // Heure du dernier message
</script>
<a href={`/chat/${id}`} class="chat-item p-4 border rounded-md hover:bg-gray-100 cursor-pointer flex justify-between items-center">
<a href={`/chats/${id}`} class="chat-item p-4 border rounded-md hover:bg-gray-100 cursor-pointer flex justify-between items-center">
<div>
<p class="font-semibold text-lg">{title}</p>
<p class="text-sm text-gray-500 truncate">{lastMessage}</p>

6
src/routes/api/channels/+server.ts
View file

@ -57,15 +57,13 @@ export async function POST({ request }) {
channels.push(canal);
logger.debug(`Added channel (${canal.id}) to channels cache.`);
await redisClient.set('channels', JSON.stringify(channels), { EX: 600 });
console.log('Liste des canaux mise à jour dans Redis');
// 5. Retourner le canal créé dans la réponse
return json(canal, { status: 201 });
} catch (err) {
// Gérer les erreurs et les retourner
console.error('Erreur lors de la création du canal:', err);
logger.error(err);
return json({ error: 'Erreur lors de la création du canal' }, { status: 500 });
}
}

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

@ -1,42 +1,34 @@
import { json } from '@sveltejs/kit';
import prisma from '$lib/prismaClient';
import redisClient from '$lib/redisClient';
import logger from '$lib/logger';
// Récupérer les informations du canal et le dernier message (avec cache Redis)
export async function GET({ params }) {
const canalId = parseInt(params.id);
const channelId = params.id;
// Clé cache pour les informations du canal et le dernier message
const canalCacheKey = `canal:${canalId}:info`;
const channelCacheKey = `channel:${channelId}:info`;
try {
// Vérifier si les informations du canal et le dernier message sont dans le cache Redis
const cachedCanalData = await redisClient.get(canalCacheKey);
if (cachedCanalData) {
console.log('✅ Cache hit pour les informations du canal et le dernier message');
return json(JSON.parse(cachedCanalData));
const cachedChannel = await redisClient.get(channelCacheKey);
if (cachedChannel) {
logger.debug(`Cache entry found, fetching channel (${channelId}) from cache`);
return json(JSON.parse(cachedChannel));
}
console.log('❌ Cache miss');
// Si non, récupérer les informations du canal et le dernier message depuis Prisma
const canal = await prisma.canal.findUnique({
where: { id: canalId },
include: {
users: true, // Inclut les utilisateurs associés au canal
},
logger.debug(`No cache entry was found, fetching channel (${channelId}) from database`);
const canal = await prisma.channel.findUnique({
where: { id: channelId },
});
if (!canal) {
logger.debug(`No channel for id ${channelId} was found in database`)
return json({ error: 'Canal non trouvé' }, { status: 404 });
}
// Récupérer le dernier message
const lastMessage = await prisma.message.findFirst({
where: { canalId },
include: {
user: { select: { id: true, pseudo: true } },
},
orderBy: { createdAt: 'desc' }, // Trie par date décroissante, donc le dernier message est récupéré en premier
where: { id: channelId },
orderBy: { createdAt: 'desc' },
});
// Créer un objet combiné pour le canal et le dernier message
@ -45,30 +37,51 @@ export async function GET({ params }) {
lastMessage, // Inclure uniquement le dernier message
};
// Mettre en cache les informations du canal et le dernier message pendant 5 minutes
await redisClient.set(canalCacheKey, JSON.stringify(canalData), {EX: 300, NX: true}); // Cache pendant 5 minutes
const cachedChanels = await redisClient.get('channels');
let channels = cachedChanels != null ? JSON.parse(cachedChanels) : [];
channels.push(canal);
channels = channels.sort(
(
a: { messages: { createdAt: Date }[]; createdAt: Date },
b: { messages: { createdAt: Date }[]; createdAt: Date }
) => {
const lastMessageA = a.messages[0]?.createdAt || a.createdAt ? a.createdAt : new Date();
const lastMessageB = b.messages[0]?.createdAt || b.createdAt ? b.createdAt : new Date();
return new Date(lastMessageB).getTime() - new Date(lastMessageA).getTime();
}
);
logger.debug(`Added channel (${canal.id}) to channels cache.`);
await redisClient.set('channels', JSON.stringify(channels), { EX: 600 });
logger.debug(`Creating a new cache entry with key channel:${channelId}:info`);
await redisClient.set(channelCacheKey, JSON.stringify(canalData), {EX: 600, NX: true}); // Cache pendant 5 minutes
console.log('❌ Cache miss - Mise en cache des résultats');
return json(canalData);
} catch (err) {
console.error(err);
logger.error(err);
return json({ error: 'Erreur lors de la récupération du canal ou du dernier message' }, { status: 500 });
}
}
// Supprimer un canal et invalider le cache associé
export async function DELETE({ params }) {
const canalId = parseInt(params.id);
const channelId = params.id;
try {
// Supprimer le canal de la base de données
await prisma.canal.delete({
where: { id: canalId },
await prisma.channel.delete({
where: { id: channelId },
});
logger.debug(`Deleting channel (${channelId}) from database`);
// Invalider le cache
await redisClient.del(`canal:${canalId}:info`);
logger.debug(`Deleting channel (${channelId}) from cache`);
await redisClient.del(`channel:${channelId}:info`);
return json({ message: 'Canal supprimé avec succès' });
} catch (err) {
@ -79,31 +92,24 @@ export async function DELETE({ params }) {
// Modifier un canal
export async function PUT({ params, request }) {
const canalId = parseInt(params.id);
const { nom, domaine } = await request.json(); // On suppose que ce sont les champs à mettre à jour
const channelId = params.id;
const { nom } = await request.json();
// Clé cache pour les informations du canal et le dernier message
const canalCacheKey = `canal:${canalId}:info`;
const canalCacheKey = `channel:${channelId}:info`;
try {
// Mettre à jour les informations du canal dans la base de données
const updatedCanal = await prisma.canal.update({
where: { id: canalId },
const updatedCanal = await prisma.channel.update({
where: { id: channelId },
data: {
nom, // Nom du canal
domaine, // Domaine du canal
},
include: {
users: true, // Inclut les utilisateurs associés au canal
},
name: nom,
}
});
// Récupérer le dernier message associé au canal après mise à jour
const lastMessage = await prisma.message.findFirst({
where: { canalId },
include: {
user: { select: { id: true, pseudo: true } },
},
where: { id: channelId },
orderBy: { createdAt: 'desc' },
});
@ -113,8 +119,26 @@ export async function PUT({ params, request }) {
lastMessage, // Inclure uniquement le dernier message
};
// Mettre en cache les nouvelles informations pendant 5 minutes
await redisClient.set(canalCacheKey, JSON.stringify(canalData), { EX: 300, NX: true });
const cachedChannels = await redisClient.get('channels');
let channelsArrays = cachedChannels != null ? JSON.parse(cachedChannels) : [];
channelsArrays = channelsArrays.filter((u: { id: string }) => u.id !== updatedCanal.id);
channelsArrays.push(canalData);
channelsArrays = channelsArrays.sort(
(
a: { messages: { createdAt: Date }[]; createdAt: Date },
b: { messages: { createdAt: Date }[]; createdAt: Date }
) => {
const lastMessageA = a.messages[0]?.createdAt || a.createdAt ? a.createdAt : new Date();
const lastMessageB = b.messages[0]?.createdAt || b.createdAt ? b.createdAt : new Date();
return new Date(lastMessageB).getTime() - new Date(lastMessageA).getTime();
}
);
logger.debug(`Updated channel (${channelId}) in channels cache`);
await redisClient.set('channels', JSON.stringify(channelsArrays), { EX: 600 })
logger.debug(`Updated cache entry with key channel:${channelId}:info`);
await redisClient.set(canalCacheKey, JSON.stringify(canalData), { EX: 600, NX: true });
return json(canalData);
} catch (err) {

2
src/routes/chats/+page.ts → src/routes/chats/+page.server.ts
View file

@ -1,7 +1,7 @@
export async function load({ fetch }) {
try {
// Appel API ou récupération de données
const res = await fetch('/api/canals', {
const res = await fetch('/api/channels', {
method: 'GET',
headers: {
'Content-Type': 'application/json'