From f0b718442c9b2f0076929f10a8ac1fd49e0d39e9 Mon Sep 17 00:00:00 2001 From: Alma Date: Sat, 12 Apr 2025 14:20:58 +0200 Subject: [PATCH] working leantime widget 32 --- app/api/leantime/status-labels/route.ts | 209 +++++++++--------------- 1 file changed, 78 insertions(+), 131 deletions(-) diff --git a/app/api/leantime/status-labels/route.ts b/app/api/leantime/status-labels/route.ts index bfdfc006..729f3299 100644 --- a/app/api/leantime/status-labels/route.ts +++ b/app/api/leantime/status-labels/route.ts @@ -1,4 +1,3 @@ -import { NextRequest } from "next/server"; import { getServerSession } from "next-auth/next"; import { authOptions } from "@/app/api/auth/[...nextauth]/route"; import { NextResponse } from "next/server"; @@ -6,12 +5,14 @@ import { NextResponse } from "next/server"; interface StatusLabel { id: string; name: string; - statusType: string; class: string; + statusType: string; + kanbanCol: boolean | string; + sortKey: number | string; } interface Project { - id: string; + id: number; name: string; labels: StatusLabel[]; } @@ -19,93 +20,52 @@ interface Project { // Cache for user IDs to avoid repeated lookups const userCache = new Map(); -async function getLeantimeUserId(email: string): Promise { - // Check cache first - if (userCache.has(email)) { - return userCache.get(email)!; - } - - try { - const response = await fetch('https://agilite.slm-lab.net/api/jsonrpc', { - method: 'POST', - headers: { - 'Content-Type': 'application/json', - 'X-API-Key': process.env.LEANTIME_TOKEN || '', - }, - body: JSON.stringify({ - jsonrpc: '2.0', - method: 'leantime.rpc.users.getAll', - id: 1, - }), - }); - - if (!response.ok) { - throw new Error('Failed to fetch users from Leantime'); - } - - const data = await response.json(); - const user = data.result.find((u: any) => u.email === email); - - if (user) { - // Cache the user ID - userCache.set(email, user.id); - // Clear cache after 5 minutes - setTimeout(() => userCache.delete(email), 5 * 60 * 1000); - return user.id; - } - - return null; - } catch (error) { - console.error('Error getting Leantime user ID:', error); - return null; - } -} - -export async function GET(request: NextRequest) { +export async function GET() { try { const session = await getServerSession(authOptions); - if (!session || !session.user?.email) { + if (!session?.user?.email) { return NextResponse.json({ error: "Unauthorized" }, { status: 401 }); } - // Get Leantime user ID - const leantimeUserId = await getLeantimeUserId(session.user.email); + // Check cache first + let leantimeUserId = userCache.get(session.user.email); + // If not in cache, fetch from API if (!leantimeUserId) { - return NextResponse.json({ error: "User not found in Leantime" }, { status: 404 }); + const userResponse = await fetch('https://agilite.slm-lab.net/api/jsonrpc', { + method: 'POST', + headers: { + 'Content-Type': 'application/json', + 'X-API-Key': process.env.LEANTIME_TOKEN || '', + }, + body: JSON.stringify({ + jsonrpc: '2.0', + method: 'leantime.rpc.Users.Users.getUserByEmail', + id: 1, + params: { + email: session.user.email + } + }) + }); + + if (!userResponse.ok) { + throw new Error('Failed to fetch user from Leantime'); + } + + const userData = await userResponse.json(); + + if (!userData.result || !userData.result.id) { + return NextResponse.json({ error: "User not found in Leantime" }, { status: 404 }); + } + + leantimeUserId = userData.result.id; + // Cache the user ID for 5 minutes + userCache.set(session.user.email, leantimeUserId); + setTimeout(() => userCache.delete(session.user.email!), 5 * 60 * 1000); } - // Get all tasks assigned to the user - const response = await fetch('https://agilite.slm-lab.net/api/jsonrpc', { - method: 'POST', - headers: { - 'Content-Type': 'application/json', - 'X-API-Key': process.env.LEANTIME_TOKEN || '', - }, - body: JSON.stringify({ - jsonrpc: '2.0', - method: 'leantime.rpc.Tickets.Tickets.getAllByUserId', - id: 1, - params: { - userId: leantimeUserId, - status: "all", - limit: 100 - } - }) - }); - - if (!response.ok) { - throw new Error('Failed to fetch tasks from Leantime'); - } - - const data = await response.json(); - - if (!data.result) { - return NextResponse.json({ projects: [] }); - } - - // Get project details to include project names + // Get projects const projectsResponse = await fetch('https://agilite.slm-lab.net/api/jsonrpc', { method: 'POST', headers: { @@ -125,60 +85,47 @@ export async function GET(request: NextRequest) { const projectsData = await projectsResponse.json(); - // Create a map of projects with their tasks grouped by status - const projectMap = new Map(); - - data.result.forEach((task: any) => { - const project = projectsData.result.find((p: any) => p.id === task.projectId); - const projectName = project ? project.name : `Project ${task.projectId}`; - const projectId = task.projectId.toString(); - - if (!projectMap.has(projectId)) { - projectMap.set(projectId, { - id: projectId, - name: projectName, - labels: [] - }); - } - - const currentProject = projectMap.get(projectId)!; - - // Check if this status label already exists for this project - const existingLabel = currentProject.labels.find(label => label.name === task.status); - - if (!existingLabel) { - let statusType; - let statusClass; - - switch (task.status.toLowerCase()) { - case 'new': - statusType = 'NEW'; - statusClass = 'bg-blue-100 text-blue-800'; - break; - case 'in_progress': - statusType = 'INPROGRESS'; - statusClass = 'bg-yellow-100 text-yellow-800'; - break; - case 'done': - statusType = 'DONE'; - statusClass = 'bg-green-100 text-green-800'; - break; - default: - statusType = 'NONE'; - statusClass = 'bg-gray-100 text-gray-800'; + // Get status labels + const labelsResponse = await fetch('https://agilite.slm-lab.net/api/jsonrpc', { + method: 'POST', + headers: { + 'Content-Type': 'application/json', + 'X-API-Key': process.env.LEANTIME_TOKEN || '', + }, + body: JSON.stringify({ + jsonrpc: '2.0', + method: 'leantime.rpc.Tickets.Tickets.getAllStatusLabelsByUserId', + id: 1, + params: { + userId: leantimeUserId } - - currentProject.labels.push({ - id: `${projectId}-${task.status}`, - name: task.status, - statusType: statusType, - class: statusClass - }); - } + }) }); - // Convert the map to an array and sort projects by name - const projects = Array.from(projectMap.values()).sort((a, b) => a.name.localeCompare(b.name)); + if (!labelsResponse.ok) { + throw new Error('Failed to fetch status labels from Leantime'); + } + + const labelsData = await labelsResponse.json(); + + // Transform the data into the required format + const projects: Project[] = projectsData.result.map((project: any) => { + const projectLabels = labelsData.result[project.id]; + const labels: StatusLabel[] = projectLabels ? Object.entries(projectLabels).map(([key, value]: [string, any]) => ({ + id: key, + name: value.name, + class: value.class, + statusType: value.statusType, + kanbanCol: value.kanbanCol, + sortKey: value.sortKey + })).sort((a: StatusLabel, b: StatusLabel) => Number(a.sortKey) - Number(b.sortKey)) : []; + + return { + id: project.id, + name: project.name, + labels + }; + }).filter((project: Project) => project.labels.length > 0); return NextResponse.json({ projects }); } catch (error) {