alma/NeahFront7
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

widget parole 17

Browse Source
This commit is contained in:
Alma 2025-04-13 01:12:53 +02:00
parent 4e7c22d97c
commit de02d31a5c
1 changed files with 24 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
app/api/rocket-chat/messages/route.ts
View File

@ -98,14 +98,32 @@ export async function GET(request: Request) {
id: currentUser._id id: currentUser._id
}); });
// Step 3: Use admin token for all requests // Step 3: Create a token for the current user
const createTokenResponse = await fetch(`${baseUrl}/api/v1/users.createToken`, {
method: 'POST',
headers: adminHeaders,
body: JSON.stringify({
userId: currentUser._id
})
});
if (!createTokenResponse.ok) {
console.error('Failed to create user token:', createTokenResponse.status);
const errorText = await createTokenResponse.text();
console.error('Create token error details:', errorText);
return NextResponse.json({ messages: [] }, { status: 200 });
}
const tokenData = await createTokenResponse.json();
// Use the user's token for subsequent requests
const userHeaders = { const userHeaders = {
'X-Auth-Token': process.env.ROCKET_CHAT_TOKEN!, 'X-Auth-Token': tokenData.data.authToken,
'X-User-Id': process.env.ROCKET_CHAT_USER_ID!, 'X-User-Id': currentUser._id,
'Content-Type': 'application/json' 'Content-Type': 'application/json'
}; };
// Step 4: Get user's subscriptions // Step 4: Get user's subscriptions using user token
const subscriptionsResponse = await fetch(`${baseUrl}/api/v1/subscriptions.get`, { const subscriptionsResponse = await fetch(`${baseUrl}/api/v1/subscriptions.get`, {
method: 'GET', method: 'GET',
headers: userHeaders headers: userHeaders
@ -150,7 +168,7 @@ export async function GET(request: Request) {
const messages: any[] = []; const messages: any[] = [];
const processedRooms = new Set(); const processedRooms = new Set();
// Step 5: Fetch messages // Step 5: Fetch messages using user token
for (const subscription of userSubscriptions) { for (const subscription of userSubscriptions) {
if (messages.length >= 7 || processedRooms.has(subscription._id)) continue; if (messages.length >= 7 || processedRooms.has(subscription._id)) continue;
processedRooms.add(subscription._id); processedRooms.add(subscription._id);
@ -159,7 +177,7 @@ export async function GET(request: Request) {
// Determine the correct endpoint based on room type // Determine the correct endpoint based on room type
const endpoint = subscription.t === 'c' ? 'channels.messages' : 'im.messages'; const endpoint = subscription.t === 'c' ? 'channels.messages' : 'im.messages';
// Get the latest messages from the room // Get the latest messages from the room using user token
const messagesResponse = await fetch( const messagesResponse = await fetch(
`${baseUrl}/api/v1/${endpoint}?roomId=${subscription.rid}&count=1`, { `${baseUrl}/api/v1/${endpoint}?roomId=${subscription.rid}&count=1`, {
method: 'GET', method: 'GET',