NeahFront7/app/api/leantime/tasks/route.ts
2025-04-12 15:00:55 +02:00

109 lines
3.0 KiB
TypeScript

import { NextRequest, NextResponse } from "next/server";
import { getServerSession } from "next-auth/next";
import { authOptions } from "@/app/api/auth/[...nextauth]/route";
interface Task {
id: string;
headline: string;
projectName: string;
projectId: number;
status: number;
dueDate: string | null;
milestone: string | null;
details: string | null;
}
async function getLeantimeUserId(email: string): Promise<number | null> {
try {
const response = await fetch(`${process.env.LEANTIME_API_URL}/api/jsonrpc`, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
'Authorization': `Bearer ${process.env.LEANTIME_TOKEN}`,
},
body: JSON.stringify({
jsonrpc: '2.0',
method: 'leantime.rpc.users.getAll',
id: 1,
}),
});
if (!response.ok) {
console.error('Failed to fetch Leantime users');
return null;
}
const data = await response.json();
const users = data.result;
const user = users.find((u: any) => u.email === email);
return user ? user.id : null;
} catch (error) {
console.error('Error fetching Leantime user ID:', error);
return null;
}
}
export async function GET(request: NextRequest) {
try {
const session = await getServerSession(authOptions);
if (!session?.user?.email) {
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
}
const userId = await getLeantimeUserId(session.user.email);
if (!userId) {
return NextResponse.json({ error: "User not found in Leantime" }, { status: 404 });
}
// Fetch tasks assigned to the user
const response = await fetch(`${process.env.LEANTIME_API_URL}/api/jsonrpc`, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
'Authorization': `Bearer ${process.env.LEANTIME_TOKEN}`,
},
body: JSON.stringify({
jsonrpc: '2.0',
method: 'leantime.rpc.tickets.getAll',
params: {
userId: userId,
status: "all",
},
id: 1,
}),
});
if (!response.ok) {
throw new Error('Failed to fetch tasks from Leantime');
}
const data = await response.json();
const tasks = data.result.map((task: any) => ({
id: task.id.toString(),
headline: task.headline,
projectName: task.projectName,
projectId: task.projectId,
status: task.status,
dueDate: task.dateToFinish || null,
milestone: task.type || null,
details: task.description || null,
editTo: task.editTo || null,
dependingTicketId: task.dependingTicketId || null
}));
// Sort tasks by due date
tasks.sort((a: any, b: any) => {
if (!a.dueDate) return 1;
if (!b.dueDate) return -1;
return new Date(a.dueDate).getTime() - new Date(b.dueDate).getTime();
});
return NextResponse.json({ tasks });
} catch (error) {
console.error('Error in tasks route:', error);
return NextResponse.json(
{ error: "Failed to fetch tasks" },
{ status: 500 }
);
}
}