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

Neah version calendar fix 3 debuger ???? ??????

Browse Source
This commit is contained in:
alma 2025-04-16 22:50:47 +02:00
parent 48c3ba470c
commit a2ee2d08a0
2 changed files with 104 additions and 166 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
app/api/leantime/status-labels/route.ts
View File

@ -26,8 +26,6 @@ async function getLeantimeUserId(email: string): Promise<number | null> {
} }
try { try {
console.log('Fetching Leantime user with token:', process.env.LEANTIME_TOKEN ? 'Token present' : 'Token missing');
const response = await fetch('https://agilite.slm-lab.net/api/jsonrpc', { const response = await fetch('https://agilite.slm-lab.net/api/jsonrpc', {
method: 'POST', method: 'POST',
headers: { headers: {
@ -45,18 +43,12 @@ async function getLeantimeUserId(email: string): Promise<number | null> {
}); });
if (!response.ok) { if (!response.ok) {
console.error('Failed to fetch user from Leantime:', {
status: response.status,
statusText: response.statusText
});
throw new Error(`Failed to fetch user from Leantime: ${response.status} ${response.statusText}`); throw new Error(`Failed to fetch user from Leantime: ${response.status} ${response.statusText}`);
} }
const data = await response.json(); const data = await response.json();
console.log('Leantime user response:', data);
if (!data.result || data.result === false) { if (!data.result || data.result === false) {
console.log('User not found in Leantime');
return null; return null;
} }
@ -74,7 +66,6 @@ async function getLeantimeUserId(email: string): Promise<number | null> {
export async function GET(request: NextRequest) { export async function GET(request: NextRequest) {
try { try {
const session = await getServerSession(authOptions); const session = await getServerSession(authOptions);
console.log('Session:', session ? 'Present' : 'Missing');
if (!session) { if (!session) {
return NextResponse.json( return NextResponse.json(
@ -90,11 +81,8 @@ export async function GET(request: NextRequest) {
); );
} }
console.log('User email:', session.user.email);
// Get Leantime user ID // Get Leantime user ID
const leantimeUserId = await getLeantimeUserId(session.user.email); const leantimeUserId = await getLeantimeUserId(session.user.email);
console.log('Leantime user ID:', leantimeUserId);
if (!leantimeUserId) { if (!leantimeUserId) {
return NextResponse.json( return NextResponse.json(
@ -104,7 +92,6 @@ export async function GET(request: NextRequest) {
} }
// Get all tasks assigned to the user // Get all tasks assigned to the user
console.log('Fetching tasks for user:', leantimeUserId);
const response = await fetch('https://agilite.slm-lab.net/api/jsonrpc', { const response = await fetch('https://agilite.slm-lab.net/api/jsonrpc', {
method: 'POST', method: 'POST',
headers: { headers: {
@ -125,22 +112,16 @@ export async function GET(request: NextRequest) {
}); });
if (!response.ok) { if (!response.ok) {
console.error('Failed to fetch tasks:', {
status: response.status,
statusText: response.statusText
});
throw new Error(`Failed to fetch tasks: ${response.status} ${response.statusText}`); throw new Error(`Failed to fetch tasks: ${response.status} ${response.statusText}`);
} }
const data = await response.json(); const data = await response.json();
console.log('Tasks response:', data);
if (!data.result) { if (!data.result) {
return NextResponse.json({ projects: [] }); return NextResponse.json({ projects: [] });
} }
// Get project details to include project names // Get project details to include project names
console.log('Fetching projects');
const projectsResponse = await fetch('https://agilite.slm-lab.net/api/jsonrpc', { const projectsResponse = await fetch('https://agilite.slm-lab.net/api/jsonrpc', {
method: 'POST', method: 'POST',
headers: { headers: {
@ -155,15 +136,10 @@ export async function GET(request: NextRequest) {
}); });
if (!projectsResponse.ok) { if (!projectsResponse.ok) {
console.error('Failed to fetch projects:', {
status: projectsResponse.status,
statusText: projectsResponse.statusText
});
throw new Error(`Failed to fetch projects: ${projectsResponse.status} ${projectsResponse.statusText}`); throw new Error(`Failed to fetch projects: ${projectsResponse.status} ${projectsResponse.statusText}`);
} }
const projectsData = await projectsResponse.json(); const projectsData = await projectsResponse.json();
console.log('Projects response:', projectsData);
// Create a map of projects with their tasks grouped by status // Create a map of projects with their tasks grouped by status
const projectMap = new Map<string, Project>(); const projectMap = new Map<string, Project>();
@ -221,7 +197,6 @@ export async function GET(request: NextRequest) {
// Convert the map to an array and sort projects by name // 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)); const projects = Array.from(projectMap.values()).sort((a, b) => a.name.localeCompare(b.name));
console.log('Final projects:', projects);
return NextResponse.json({ projects }); return NextResponse.json({ projects });
} catch (error) { } catch (error) {

245
app/api/leantime/tasks/route.ts
View File

@ -3,6 +3,9 @@ import { getServerSession } from "next-auth/next";
import { authOptions } from "@/app/api/auth/[...nextauth]/route"; import { authOptions } from "@/app/api/auth/[...nextauth]/route";
import { prisma } from "@/lib/prisma"; import { prisma } from "@/lib/prisma";
// Cache for Leantime user IDs
const userCache = new Map<string, number>();
interface Task { interface Task {
id: string; id: string;
headline: string; headline: string;
@ -20,70 +23,45 @@ interface Task {
} }
async function getLeantimeUserId(email: string): Promise<number | null> { async function getLeantimeUserId(email: string): Promise<number | null> {
// Check cache first
if (userCache.has(email)) {
return userCache.get(email)!;
}
try { try {
if (!process.env.LEANTIME_TOKEN) { const response = await fetch('https://agilite.slm-lab.net/api/jsonrpc', {
console.error('LEANTIME_TOKEN is not set in environment variables');
return null;
}
console.log('Fetching Leantime users for email:', email);
console.log('API URL:', process.env.LEANTIME_API_URL);
console.log('Token length:', process.env.LEANTIME_TOKEN.length);
const headers: Record<string, string> = {
'Content-Type': 'application/json',
'X-API-Key': process.env.LEANTIME_TOKEN
};
const response = await fetch(`${process.env.LEANTIME_API_URL}/api/jsonrpc`, {
method: 'POST', method: 'POST',
headers, headers: {
'Content-Type': 'application/json',
'X-API-Key': process.env.LEANTIME_TOKEN || '',
},
body: JSON.stringify({ body: JSON.stringify({
jsonrpc: '2.0', jsonrpc: '2.0',
method: 'leantime.rpc.users.getAll', method: 'leantime.rpc.Users.Users.getUserByEmail',
id: 1 id: 1,
params: {
email: email
}
}), }),
}); });
const responseText = await response.text();
console.log('Raw Leantime response:', responseText);
if (!response.ok) { if (!response.ok) {
console.error('Failed to fetch Leantime users:', { throw new Error(`Failed to fetch user from Leantime: ${response.status} ${response.statusText}`);
status: response.status, }
statusText: response.statusText,
headers: Object.fromEntries(response.headers.entries()) const data = await response.json();
});
if (!data.result || data.result === false) {
return null; return null;
} }
let data; // Cache the user ID
try { userCache.set(email, data.result.id);
data = JSON.parse(responseText); // Clear cache after 5 minutes
} catch (e) { setTimeout(() => userCache.delete(email), 5 * 60 * 1000);
console.error('Failed to parse Leantime response:', e); return data.result.id;
return null;
}
console.log('Leantime users response:', data);
if (!data.result || !Array.isArray(data.result)) {
console.error('Invalid response format from Leantime users API');
return null;
}
const users = data.result;
const user = users.find((u: any) => u.username === email);
if (user) {
console.log('Found Leantime user:', { id: user.id, username: user.username });
} else {
console.log('No Leantime user found for username:', email);
}
return user ? user.id : null;
} catch (error) { } catch (error) {
console.error('Error fetching Leantime user ID:', error); console.error('Error getting Leantime user ID:', error);
return null; return null;
} }
} }
@ -91,116 +69,101 @@ async function getLeantimeUserId(email: string): Promise<number | null> {
export async function GET(request: NextRequest) { export async function GET(request: NextRequest) {
try { try {
const session = await getServerSession(authOptions); const session = await getServerSession(authOptions);
if (!session?.user?.email) {
return NextResponse.json({ error: "Unauthorized" }, { status: 401 }); if (!session) {
return NextResponse.json(
{ error: "Unauthorized", message: "No session found. Please sign in." },
{ status: 401 }
);
} }
console.log('Fetching tasks for user:', session.user.email); if (!session.user?.email) {
const userId = await getLeantimeUserId(session.user.email); return NextResponse.json(
{ error: "Unauthorized", message: "No email found in session. Please sign in again." },
if (!userId) { { status: 401 }
console.error('User not found in Leantime'); );
return NextResponse.json({ error: "User not found in Leantime" }, { status: 404 });
} }
console.log('Fetching tasks for Leantime user ID:', userId); // Get Leantime user ID
const headers: Record<string, string> = { const leantimeUserId = await getLeantimeUserId(session.user.email);
'Content-Type': 'application/json',
'X-API-Key': process.env.LEANTIME_TOKEN!
};
const response = await fetch(`${process.env.LEANTIME_API_URL}/api/jsonrpc`, { if (!leantimeUserId) {
return NextResponse.json(
{ error: "User not found", message: "Could not find user in Leantime. Please check your email." },
{ status: 404 }
);
}
// Get all tasks assigned to the user
const response = await fetch('https://agilite.slm-lab.net/api/jsonrpc', {
method: 'POST', method: 'POST',
headers, headers: {
'Content-Type': 'application/json',
'X-API-Key': process.env.LEANTIME_TOKEN || '',
},
body: JSON.stringify({ body: JSON.stringify({
jsonrpc: '2.0', jsonrpc: '2.0',
method: 'leantime.rpc.tickets.getAll', method: 'leantime.rpc.Tickets.Tickets.getAll',
id: 1,
params: { params: {
userId: userId, projectId: 0, // 0 means all projects
status: "all" userId: leantimeUserId,
}, status: "all",
id: 1 limit: 100
}), }
})
}); });
const responseText = await response.text();
console.log('Tasks API response status:', response.status);
if (!response.ok) { if (!response.ok) {
console.error('Failed to fetch tasks from Leantime:', { throw new Error(`Failed to fetch tasks: ${response.status} ${response.statusText}`);
status: response.status,
statusText: response.statusText
});
throw new Error('Failed to fetch tasks from Leantime');
} }
let data; const data = await response.json();
try {
data = JSON.parse(responseText); if (!data.result) {
} catch (e) { return NextResponse.json({ tasks: [] });
console.error('Failed to parse tasks response');
throw new Error('Invalid response format from Leantime');
} }
if (!data.result || !Array.isArray(data.result)) { // Filter out tasks that are not in progress or new
console.error('Invalid response format from Leantime tasks API'); const filteredTasks = data.result.filter((task: any) => {
throw new Error('Invalid response format from Leantime'); const status = task.status.toString();
} return status === '1' || status === '2'; // 1 = new, 2 = in progress
});
// Log only the number of tasks and their IDs // Get project details to include project names
console.log('Received tasks count:', data.result.length); const projectsResponse = await fetch('https://agilite.slm-lab.net/api/jsonrpc', {
console.log('Task IDs:', data.result.map((task: any) => task.id)); method: 'POST',
headers: {
const tasks = data.result 'Content-Type': 'application/json',
.filter((task: any) => { 'X-API-Key': process.env.LEANTIME_TOKEN || '',
// Log raw task data for debugging },
console.log('Raw task data:', { body: JSON.stringify({
id: task.id, jsonrpc: '2.0',
headline: task.headline, method: 'leantime.rpc.Projects.getAll',
status: task.status, id: 1
type: task.type,
dependingTicketId: task.dependingTicketId
});
// Filter out any task (main or subtask) that has status Done (5)
if (task.status === 5) {
console.log(`Filtering out Done task ${task.id} (type: ${task.type || 'main'}, status: ${task.status})`);
return false;
}
// Convert both to strings for comparison to handle any type mismatches
const taskEditorId = String(task.editorId).trim();
const currentUserId = String(userId).trim();
// Only show tasks where the user is the editor
const isUserEditor = taskEditorId === currentUserId;
console.log(`Task ${task.id}: status=${task.status}, type=${task.type || 'main'}, parentId=${task.dependingTicketId || 'none'}, isUserEditor=${isUserEditor}`);
return isUserEditor;
}) })
.map((task: any) => ({ });
id: task.id.toString(),
headline: task.headline,
projectName: task.projectName,
projectId: task.projectId,
status: task.status,
dateToFinish: task.dateToFinish || null,
milestone: task.type || null,
details: task.description || null,
createdOn: task.dateCreated,
editedOn: task.editedOn || null,
editorId: task.editorId,
editorFirstname: task.editorFirstname,
editorLastname: task.editorLastname,
type: task.type || null, // Added type field to identify subtasks
dependingTicketId: task.dependingTicketId || null // Added parent task reference
}));
console.log(`Found ${tasks.length} tasks assigned to user ${userId}`); if (!projectsResponse.ok) {
return NextResponse.json(tasks); throw new Error(`Failed to fetch projects: ${projectsResponse.status} ${projectsResponse.statusText}`);
}
const projectsData = await projectsResponse.json();
// Map tasks to include project names
const tasksWithProjects = filteredTasks.map((task: any) => {
const project = projectsData.result.find((p: any) => p.id === task.projectId);
return {
...task,
projectName: project ? project.name : `Project ${task.projectId}`
};
});
return NextResponse.json({ tasks: tasksWithProjects });
} catch (error) { } catch (error) {
console.error('Error in tasks route:', error); console.error('Error fetching tasks:', error);
return NextResponse.json( return NextResponse.json(
{ error: "Failed to fetch tasks" }, { error: "Failed to fetch tasks", message: error instanceof Error ? error.message : "Unknown error occurred" },
{ status: 500 } { status: 500 }
); );
} }