full upgrade to dev
This commit is contained in:
86
app/api/n8n/chat/route.ts
Normal file
86
app/api/n8n/chat/route.ts
Normal file
@@ -0,0 +1,86 @@
|
||||
import { NextResponse } from 'next/server';
|
||||
|
||||
export async function POST(request: Request) {
|
||||
try {
|
||||
const { message } = await request.json();
|
||||
|
||||
if (!message || typeof message !== 'string') {
|
||||
return NextResponse.json(
|
||||
{ error: 'Message is required' },
|
||||
{ status: 400 }
|
||||
);
|
||||
}
|
||||
|
||||
// Call your n8n chat webhook
|
||||
const n8nWebhookUrl = process.env.N8N_WEBHOOK_URL;
|
||||
|
||||
if (!n8nWebhookUrl) {
|
||||
console.error('N8N_WEBHOOK_URL not configured');
|
||||
// Return fallback response
|
||||
return NextResponse.json({
|
||||
reply: getFallbackResponse(message)
|
||||
});
|
||||
}
|
||||
|
||||
const response = await fetch(`${n8nWebhookUrl}/webhook/chat`, {
|
||||
method: 'POST',
|
||||
headers: {
|
||||
'Content-Type': 'application/json',
|
||||
...(process.env.N8N_API_KEY && {
|
||||
'Authorization': `Bearer ${process.env.N8N_API_KEY}`
|
||||
}),
|
||||
},
|
||||
body: JSON.stringify({ message }),
|
||||
});
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error(`n8n webhook failed: ${response.status}`);
|
||||
}
|
||||
|
||||
const data = await response.json();
|
||||
return NextResponse.json({ reply: data.reply || data.message || data.response });
|
||||
} catch (error) {
|
||||
console.error('Chat API error:', error);
|
||||
|
||||
// Fallback to mock responses if n8n is down
|
||||
const { message } = await request.json();
|
||||
return NextResponse.json(
|
||||
{ reply: getFallbackResponse(message) }
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
function getFallbackResponse(message: string): string {
|
||||
const lowerMessage = message.toLowerCase();
|
||||
|
||||
if (lowerMessage.includes('skill') || lowerMessage.includes('tech')) {
|
||||
return "Dennis specializes in full-stack development with Next.js, Flutter for mobile, and DevOps with Docker Swarm. He's passionate about self-hosting and runs his own infrastructure!";
|
||||
}
|
||||
|
||||
if (lowerMessage.includes('project')) {
|
||||
return "Dennis has built Clarity (a Flutter app for people with dyslexia) and runs a complete self-hosted infrastructure with Docker Swarm, Traefik, and automated CI/CD pipelines. Check out the Projects section for more!";
|
||||
}
|
||||
|
||||
if (lowerMessage.includes('contact') || lowerMessage.includes('email') || lowerMessage.includes('reach')) {
|
||||
return "You can reach Dennis via the contact form on this site or email him at contact@dk0.dev. He's always open to discussing new opportunities and interesting projects!";
|
||||
}
|
||||
|
||||
if (lowerMessage.includes('location') || lowerMessage.includes('where')) {
|
||||
return "Dennis is based in Osnabrück, Germany. He's a student who's passionate about technology and self-hosting.";
|
||||
}
|
||||
|
||||
if (lowerMessage.includes('hobby') || lowerMessage.includes('free time')) {
|
||||
return "When Dennis isn't coding or managing servers, he enjoys gaming, jogging, and experimenting with new technologies. He also uses pen and paper for notes despite automating everything else!";
|
||||
}
|
||||
|
||||
if (lowerMessage.includes('devops') || lowerMessage.includes('docker') || lowerMessage.includes('infrastructure')) {
|
||||
return "Dennis runs his own infrastructure on IONOS and OVHcloud using Docker Swarm, Traefik for reverse proxy, and custom CI/CD pipelines. He loves self-hosting and managing game servers!";
|
||||
}
|
||||
|
||||
if (lowerMessage.includes('student') || lowerMessage.includes('study')) {
|
||||
return "Yes, Dennis is currently a student in Osnabrück while also working on various tech projects and managing his own infrastructure. He's always learning and exploring new technologies!";
|
||||
}
|
||||
|
||||
// Default response
|
||||
return "That's a great question! Dennis is a full-stack developer and DevOps enthusiast who loves building things with Next.js, Flutter, and Docker. Feel free to ask me more specific questions about his skills, projects, or experience!";
|
||||
}
|
||||
176
app/api/n8n/generate-image/route.ts
Normal file
176
app/api/n8n/generate-image/route.ts
Normal file
@@ -0,0 +1,176 @@
|
||||
import { NextRequest, NextResponse } from "next/server";
|
||||
|
||||
/**
|
||||
* POST /api/n8n/generate-image
|
||||
*
|
||||
* Triggers AI image generation for a project via n8n workflow
|
||||
*
|
||||
* Body:
|
||||
* {
|
||||
* projectId: number;
|
||||
* regenerate?: boolean; // Force regenerate even if image exists
|
||||
* }
|
||||
*/
|
||||
export async function POST(req: NextRequest) {
|
||||
try {
|
||||
const body = await req.json();
|
||||
const { projectId, regenerate = false } = body;
|
||||
|
||||
// Validate input
|
||||
if (!projectId) {
|
||||
return NextResponse.json(
|
||||
{ error: "projectId is required" },
|
||||
{ status: 400 },
|
||||
);
|
||||
}
|
||||
|
||||
// Check environment variables
|
||||
const n8nWebhookUrl = process.env.N8N_WEBHOOK_URL;
|
||||
const n8nSecretToken = process.env.N8N_SECRET_TOKEN;
|
||||
|
||||
if (!n8nWebhookUrl) {
|
||||
return NextResponse.json(
|
||||
{
|
||||
error: "N8N_WEBHOOK_URL not configured",
|
||||
message:
|
||||
"AI image generation is not set up. Please configure n8n webhooks.",
|
||||
},
|
||||
{ status: 503 },
|
||||
);
|
||||
}
|
||||
|
||||
// Optional: Check if project already has an image
|
||||
if (!regenerate) {
|
||||
const checkResponse = await fetch(
|
||||
`${process.env.NEXT_PUBLIC_API_URL || "http://localhost:3000"}/api/projects/${projectId}`,
|
||||
{
|
||||
method: "GET",
|
||||
cache: "no-store",
|
||||
},
|
||||
);
|
||||
|
||||
if (checkResponse.ok) {
|
||||
const project = await checkResponse.json();
|
||||
if (project.imageUrl && project.imageUrl !== "") {
|
||||
return NextResponse.json(
|
||||
{
|
||||
success: true,
|
||||
message:
|
||||
"Project already has an image. Use regenerate=true to force regeneration.",
|
||||
projectId: projectId,
|
||||
existingImageUrl: project.imageUrl,
|
||||
regenerated: false,
|
||||
},
|
||||
{ status: 200 },
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Call n8n webhook to trigger AI image generation
|
||||
const n8nResponse = await fetch(`${n8nWebhookUrl}/ai-image-generation`, {
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "application/json",
|
||||
...(n8nSecretToken && {
|
||||
Authorization: `Bearer ${n8nSecretToken}`,
|
||||
}),
|
||||
},
|
||||
body: JSON.stringify({
|
||||
projectId: projectId,
|
||||
regenerate: regenerate,
|
||||
triggeredBy: "api",
|
||||
timestamp: new Date().toISOString(),
|
||||
}),
|
||||
});
|
||||
|
||||
if (!n8nResponse.ok) {
|
||||
const errorText = await n8nResponse.text();
|
||||
console.error("n8n webhook error:", errorText);
|
||||
|
||||
return NextResponse.json(
|
||||
{
|
||||
error: "Failed to trigger image generation",
|
||||
message: "n8n workflow failed to execute",
|
||||
details: errorText,
|
||||
},
|
||||
{ status: 500 },
|
||||
);
|
||||
}
|
||||
|
||||
const result = await n8nResponse.json();
|
||||
|
||||
return NextResponse.json(
|
||||
{
|
||||
success: true,
|
||||
message: "AI image generation started successfully",
|
||||
projectId: projectId,
|
||||
imageUrl: result.imageUrl,
|
||||
generatedAt: result.generatedAt,
|
||||
fileSize: result.fileSize,
|
||||
regenerated: regenerate,
|
||||
},
|
||||
{ status: 200 },
|
||||
);
|
||||
} catch (error) {
|
||||
console.error("Error in generate-image API:", error);
|
||||
return NextResponse.json(
|
||||
{
|
||||
error: "Internal server error",
|
||||
message: error instanceof Error ? error.message : "Unknown error",
|
||||
},
|
||||
{ status: 500 },
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* GET /api/n8n/generate-image?projectId=123
|
||||
*
|
||||
* Check the status of image generation for a project
|
||||
*/
|
||||
export async function GET(req: NextRequest) {
|
||||
try {
|
||||
const searchParams = req.nextUrl.searchParams;
|
||||
const projectId = searchParams.get("projectId");
|
||||
|
||||
if (!projectId) {
|
||||
return NextResponse.json(
|
||||
{ error: "projectId query parameter is required" },
|
||||
{ status: 400 },
|
||||
);
|
||||
}
|
||||
|
||||
// Fetch project to check image status
|
||||
const projectResponse = await fetch(
|
||||
`${process.env.NEXT_PUBLIC_API_URL || "http://localhost:3000"}/api/projects/${projectId}`,
|
||||
{
|
||||
method: "GET",
|
||||
cache: "no-store",
|
||||
},
|
||||
);
|
||||
|
||||
if (!projectResponse.ok) {
|
||||
return NextResponse.json({ error: "Project not found" }, { status: 404 });
|
||||
}
|
||||
|
||||
const project = await projectResponse.json();
|
||||
|
||||
return NextResponse.json({
|
||||
projectId: parseInt(projectId),
|
||||
title: project.title,
|
||||
hasImage: !!project.imageUrl,
|
||||
imageUrl: project.imageUrl || null,
|
||||
updatedAt: project.updatedAt,
|
||||
});
|
||||
} catch (error) {
|
||||
console.error("Error checking image status:", error);
|
||||
return NextResponse.json(
|
||||
{
|
||||
error: "Internal server error",
|
||||
message: error instanceof Error ? error.message : "Unknown error",
|
||||
},
|
||||
{ status: 500 },
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -1,19 +1,115 @@
|
||||
import { NextResponse } from 'next/server';
|
||||
import { NextResponse } from "next/server";
|
||||
import { PrismaClient } from "@prisma/client";
|
||||
|
||||
const prisma = new PrismaClient();
|
||||
|
||||
export const dynamic = "force-dynamic";
|
||||
export const revalidate = 0;
|
||||
|
||||
export async function GET() {
|
||||
// Mock data - in real integration this would fetch from n8n webhook or database
|
||||
return NextResponse.json({
|
||||
activity: {
|
||||
type: 'coding', // coding, listening, watching
|
||||
details: 'Portfolio Website',
|
||||
timestamp: new Date().toISOString(),
|
||||
},
|
||||
music: {
|
||||
isPlaying: true,
|
||||
track: 'Midnight City',
|
||||
artist: 'M83',
|
||||
platform: 'spotify'
|
||||
},
|
||||
watching: null
|
||||
});
|
||||
try {
|
||||
// Fetch from activity_status table
|
||||
const result = await prisma.$queryRawUnsafe<any[]>(
|
||||
`SELECT * FROM activity_status WHERE id = 1 LIMIT 1`,
|
||||
);
|
||||
|
||||
if (!result || result.length === 0) {
|
||||
return NextResponse.json({
|
||||
activity: null,
|
||||
music: null,
|
||||
watching: null,
|
||||
gaming: null,
|
||||
status: null,
|
||||
});
|
||||
}
|
||||
|
||||
const data = result[0];
|
||||
|
||||
// Check if activity is recent (within last 2 hours)
|
||||
const lastUpdate = new Date(data.updated_at);
|
||||
const now = new Date();
|
||||
const hoursSinceUpdate =
|
||||
(now.getTime() - lastUpdate.getTime()) / (1000 * 60 * 60);
|
||||
const isRecent = hoursSinceUpdate < 2;
|
||||
|
||||
return NextResponse.json(
|
||||
{
|
||||
activity:
|
||||
data.activity_type && isRecent
|
||||
? {
|
||||
type: data.activity_type,
|
||||
details: data.activity_details,
|
||||
project: data.activity_project,
|
||||
language: data.activity_language,
|
||||
repo: data.activity_repo,
|
||||
link: data.activity_repo, // Use repo URL as link
|
||||
timestamp: data.updated_at,
|
||||
}
|
||||
: null,
|
||||
|
||||
music: data.music_playing
|
||||
? {
|
||||
isPlaying: data.music_playing,
|
||||
track: data.music_track,
|
||||
artist: data.music_artist,
|
||||
album: data.music_album,
|
||||
platform: data.music_platform || "spotify",
|
||||
progress: data.music_progress,
|
||||
albumArt: data.music_album_art,
|
||||
spotifyUrl: data.music_track
|
||||
? `https://open.spotify.com/search/${encodeURIComponent(data.music_track + " " + data.music_artist)}`
|
||||
: null,
|
||||
}
|
||||
: null,
|
||||
|
||||
watching: data.watching_title
|
||||
? {
|
||||
title: data.watching_title,
|
||||
platform: data.watching_platform || "youtube",
|
||||
type: data.watching_type || "video",
|
||||
}
|
||||
: null,
|
||||
|
||||
gaming: data.gaming_game
|
||||
? {
|
||||
game: data.gaming_game,
|
||||
platform: data.gaming_platform || "steam",
|
||||
status: data.gaming_status || "playing",
|
||||
}
|
||||
: null,
|
||||
|
||||
status: data.status_mood
|
||||
? {
|
||||
mood: data.status_mood,
|
||||
customMessage: data.status_message,
|
||||
}
|
||||
: null,
|
||||
},
|
||||
{
|
||||
headers: {
|
||||
"Cache-Control": "no-store, no-cache, must-revalidate, max-age=0",
|
||||
Pragma: "no-cache",
|
||||
},
|
||||
},
|
||||
);
|
||||
} catch (error) {
|
||||
console.error("Error fetching activity status:", error);
|
||||
|
||||
// Return empty state on error (graceful degradation)
|
||||
return NextResponse.json(
|
||||
{
|
||||
activity: null,
|
||||
music: null,
|
||||
watching: null,
|
||||
gaming: null,
|
||||
status: null,
|
||||
},
|
||||
{
|
||||
status: 200, // Return 200 to prevent frontend errors
|
||||
headers: {
|
||||
"Cache-Control": "no-store, no-cache, must-revalidate, max-age=0",
|
||||
},
|
||||
},
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user