root
117 lines
2.9 KiB
TypeScript
117 lines
2.9 KiB
TypeScript
import { NextResponse } from "next/server";
|
|
import fs from "fs";
|
|
|
|
const MESSAGE_FILE = "/tmp/horus-mc-messages.json";
|
|
const TELEGRAM_CHAT_ID = "382315644"; // Haitham's Telegram ID
|
|
|
|
interface Message {
|
|
id: string;
|
|
role: "user" | "assistant";
|
|
content: string;
|
|
timestamp: number;
|
|
processed: boolean;
|
|
}
|
|
|
|
function getMessages(): Message[] {
|
|
try {
|
|
if (fs.existsSync(MESSAGE_FILE)) {
|
|
return JSON.parse(fs.readFileSync(MESSAGE_FILE, "utf-8"));
|
|
}
|
|
} catch (e) {
|
|
console.error("Error reading messages:", e);
|
|
}
|
|
return [];
|
|
}
|
|
|
|
function saveMessages(messages: Message[]) {
|
|
fs.writeFileSync(MESSAGE_FILE, JSON.stringify(messages, null, 2));
|
|
}
|
|
|
|
async function sendToTelegram(text: string) {
|
|
try {
|
|
const token = process.env.TELEGRAM_BOT_TOKEN;
|
|
if (!token) {
|
|
console.log("No Telegram token, skipping");
|
|
return;
|
|
}
|
|
|
|
await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {
|
|
method: "POST",
|
|
headers: { "Content-Type": "application/json" },
|
|
body: JSON.stringify({
|
|
chat_id: TELEGRAM_CHAT_ID,
|
|
text: `💬 MC Chat:\n${text}`,
|
|
}),
|
|
});
|
|
} catch (e) {
|
|
console.error("Telegram error:", e);
|
|
}
|
|
}
|
|
|
|
export async function POST(request: Request) {
|
|
try {
|
|
const body = await request.json();
|
|
const { message, locale = "es" } = body;
|
|
|
|
if (!message) {
|
|
return NextResponse.json({ error: "Message required" }, { status: 400 });
|
|
}
|
|
|
|
const messages = getMessages();
|
|
|
|
// Add user message
|
|
const userMessage: Message = {
|
|
id: `msg_${Date.now()}`,
|
|
role: "user",
|
|
content: message,
|
|
timestamp: Date.now(),
|
|
processed: false,
|
|
};
|
|
messages.push(userMessage);
|
|
saveMessages(messages);
|
|
|
|
// Forward to Telegram (where Horus is listening)
|
|
await sendToTelegram(message);
|
|
|
|
return NextResponse.json({
|
|
id: userMessage.id,
|
|
status: "sent",
|
|
message: "Message sent to Horus"
|
|
});
|
|
|
|
} catch (error) {
|
|
console.error("Error:", error);
|
|
return NextResponse.json({ error: "Failed" }, { status: 500 });
|
|
}
|
|
}
|
|
|
|
export async function GET(request: Request) {
|
|
const { searchParams } = new URL(request.url);
|
|
const lastId = searchParams.get("after");
|
|
|
|
const messages = getMessages();
|
|
|
|
// Get messages after lastId
|
|
let filtered = messages;
|
|
if (lastId) {
|
|
const idx = messages.findIndex(m => m.id === lastId);
|
|
if (idx >= 0) {
|
|
filtered = messages.slice(idx + 1);
|
|
}
|
|
}
|
|
|
|
// Return only assistant messages that haven't been fetched
|
|
const response = filtered.filter(m => m.role === "assistant" && !m.processed);
|
|
|
|
// Mark as processed
|
|
if (response.length > 0) {
|
|
const processedIds = new Set(response.map(r => r.id));
|
|
const updated = messages.map(m =>
|
|
processedIds.has(m.id) ? { ...m, processed: true } : m
|
|
);
|
|
saveMessages(updated);
|
|
}
|
|
|
|
return NextResponse.json({ messages: response });
|
|
}
|