133 lines
4.3 KiB
TypeScript
133 lines
4.3 KiB
TypeScript
import { getServerSession } from "next-auth";
|
|
import { authOptions } from "@/app/api/auth/[...nextauth]/route";
|
|
import { NextResponse } from "next/server";
|
|
|
|
// Helper function to get user token using admin credentials
|
|
async function getUserToken(baseUrl: string) {
|
|
try {
|
|
// Step 1: Use admin token to authenticate
|
|
const adminHeaders = {
|
|
'X-Auth-Token': process.env.ROCKET_CHAT_TOKEN!,
|
|
'X-User-Id': process.env.ROCKET_CHAT_USER_ID!,
|
|
'Content-Type': 'application/json'
|
|
};
|
|
|
|
// Step 2: Create user token using admin credentials
|
|
const createTokenResponse = await fetch(`${baseUrl}/api/v1/users.createToken`, {
|
|
method: 'POST',
|
|
headers: adminHeaders
|
|
});
|
|
|
|
if (!createTokenResponse.ok) {
|
|
console.error('Failed to create user token:', createTokenResponse.status);
|
|
return null;
|
|
}
|
|
|
|
const tokenData = await createTokenResponse.json();
|
|
return {
|
|
authToken: tokenData.data.authToken,
|
|
userId: tokenData.data.userId
|
|
};
|
|
} catch (error) {
|
|
console.error('Error getting user token:', error);
|
|
return null;
|
|
}
|
|
}
|
|
|
|
export async function GET(request: Request) {
|
|
const session = await getServerSession(authOptions);
|
|
|
|
if (!session) {
|
|
console.error('No session found');
|
|
return new Response(JSON.stringify({ error: 'Unauthorized' }), {
|
|
status: 401,
|
|
headers: { 'Content-Type': 'application/json' },
|
|
});
|
|
}
|
|
|
|
try {
|
|
const baseUrl = process.env.NEXT_PUBLIC_IFRAME_PAROLE_URL?.split('/channel')[0];
|
|
if (!baseUrl) {
|
|
console.error('Failed to get Rocket.Chat base URL');
|
|
return new Response(JSON.stringify({ error: 'Server configuration error' }), {
|
|
status: 500,
|
|
headers: { 'Content-Type': 'application/json' },
|
|
});
|
|
}
|
|
|
|
// Use admin token to get messages
|
|
const adminHeaders = {
|
|
'X-Auth-Token': process.env.ROCKET_CHAT_TOKEN!,
|
|
'X-User-Id': process.env.ROCKET_CHAT_USER_ID!,
|
|
'Content-Type': 'application/json'
|
|
};
|
|
|
|
// Get user's subscriptions using admin token
|
|
const subscriptionsResponse = await fetch(`${baseUrl}/api/v1/subscriptions.get`, {
|
|
headers: adminHeaders
|
|
});
|
|
|
|
if (!subscriptionsResponse.ok) {
|
|
console.error('Failed to get subscriptions:', subscriptionsResponse.status);
|
|
return new Response(JSON.stringify({ error: 'Failed to get subscriptions' }), {
|
|
status: subscriptionsResponse.status,
|
|
headers: { 'Content-Type': 'application/json' },
|
|
});
|
|
}
|
|
|
|
const subscriptionsData = await subscriptionsResponse.json();
|
|
const userSubscriptions = subscriptionsData.update;
|
|
const messages: any[] = [];
|
|
const processedRooms = new Set();
|
|
|
|
// Fetch messages using admin token
|
|
for (const subscription of userSubscriptions) {
|
|
if (messages.length >= 6 || processedRooms.has(subscription.rid)) continue;
|
|
processedRooms.add(subscription.rid);
|
|
|
|
try {
|
|
const messagesResponse = await fetch(
|
|
`${baseUrl}/api/v1/chat.getMessage`, {
|
|
method: 'POST',
|
|
headers: adminHeaders,
|
|
body: JSON.stringify({
|
|
msgId: subscription.lastMessage?._id,
|
|
roomId: subscription.rid,
|
|
}),
|
|
});
|
|
|
|
if (!messagesResponse.ok) continue;
|
|
|
|
const messageData = await messagesResponse.json();
|
|
if (messageData.message) {
|
|
messages.push({
|
|
...messageData.message,
|
|
roomName: subscription.fname || subscription.name || 'Direct Message',
|
|
roomType: subscription.t,
|
|
unread: subscription.unread || 0,
|
|
userMentions: subscription.userMentions || 0,
|
|
alert: subscription.alert || false
|
|
});
|
|
}
|
|
} catch (error) {
|
|
console.error(`Error fetching message for room ${subscription.rid}`);
|
|
continue;
|
|
}
|
|
}
|
|
|
|
// Sort messages by timestamp (newest first) and limit to 6
|
|
messages.sort((a, b) => new Date(b.ts).getTime() - new Date(a.ts).getTime());
|
|
const limitedMessages = messages.slice(0, 6);
|
|
|
|
return new Response(JSON.stringify({ messages: limitedMessages }), {
|
|
status: 200,
|
|
headers: { 'Content-Type': 'application/json' },
|
|
});
|
|
} catch (error) {
|
|
console.error('Error fetching messages');
|
|
return new Response(JSON.stringify({ error: 'Internal server error' }), {
|
|
status: 500,
|
|
headers: { 'Content-Type': 'application/json' },
|
|
});
|
|
}
|
|
}
|