Adding memory + voice + unichat + proactivity changes to development branch (merging feature/memory into development)

Author: Kabeer2004

.gitignore

@@ -265,3 +265,6 @@ settings.local.json
 settings.json
 src/server/celerybeat-schedule-shm
 src/server/celerybeat-schedule-wal
+waha.sqlite3
+waha.sqlite3-shm
+waha.sqlite3-wal

src/client/app/api/chat/[chatId]/route.js

@@ -8,8 +8,17 @@ const appServerUrl =
 		: process.env.NEXT_PUBLIC_APP_SERVER_URL
 
 export const GET = withAuth(async function GET(request, { authHeader }) {
+	const { searchParams } = new URL(request.url)
+	const limit = searchParams.get("limit")
+	const before_timestamp = searchParams.get("before_timestamp")
+
+	const backendUrl = new URL(`${appServerUrl}/chat/history`)
+	if (limit) backendUrl.searchParams.append("limit", limit)
+	if (before_timestamp)
+		backendUrl.searchParams.append("before_timestamp", before_timestamp)
+
 	try {
-		const response = await fetch(`${appServerUrl}/chat/history`, {
+		const response = await fetch(backendUrl.toString(), {
 			method: "GET",
 			headers: { "Content-Type": "application/json", ...authHeader }
 		})

src/client/app/api/chat/history/route.js

@@ -8,7 +8,7 @@ const appServerUrl =
 
 export const POST = withAuth(async function POST(request, { authHeader }) {
 	try {
-		const { messages, chatId } = await request.json()
+		const { messages } = await request.json()
 
 		// Fetch user pricing/credits to pass to the backend
 		const pricingResponse = await fetch(
@@ -28,7 +28,6 @@ export const POST = withAuth(async function POST(request, { authHeader }) {
 			body: JSON.stringify({
 				// Pass `messages` array instead of `input`
 				messages,
-				chatId,
 				pricing, // Note: pricing and credits are still sent for backend logic
 				credits
 			}),

src/client/app/api/chat/message/route.js

@@ -1,4 +1,3 @@
-// src/client/app/api/chat/history/[chatId]/route.js
 import { NextResponse } from "next/server"
 import { withAuth } from "@lib/api-utils"
 
@@ -7,27 +6,22 @@ const appServerUrl =
 		? process.env.INTERNAL_APP_SERVER_URL
 		: process.env.NEXT_PUBLIC_APP_SERVER_URL
 
-export const GET = withAuth(async function GET(
-	request,
-	{ params, authHeader }
-) {
-	const { chatId } = params
-	if (!chatId) {
-		return NextResponse.json(
-			{ error: "Chat ID parameter is required" },
-			{ status: 400 }
-		)
-	}
+export const GET = withAuth(async function GET(request, { authHeader }) {
+	const backendUrl = new URL(`${appServerUrl}/api/memories/`)
 
 	try {
-		const response = await fetch(`${appServerUrl}/chat/history/${chatId}`, {
+		const response = await fetch(backendUrl.toString(), {
+			method: "GET",
 			headers: { "Content-Type": "application/json", ...authHeader }
 		})
+
 		const data = await response.json()
-		if (!response.ok)
-			throw new Error(data.detail || "Failed to fetch chat messages")
+		if (!response.ok) {
+			throw new Error(data.detail || "Failed to fetch memories")
+		}
 		return NextResponse.json(data)
 	} catch (error) {
+		console.error("API Error in /api/memories:", error)
 		return NextResponse.json({ error: error.message }, { status: 500 })
 	}
 })

…t/app/api/chat/history/[chatId]/route.js src/client/app/api/memories/route.jssrc/client/app/api/chat/history/[chatId]/route.js renamed to src/client/app/api/memories/route.js src/client/app/api/chat/history/[chatId]/route.js renamed to src/client/app/api/memories/route.js

@@ -0,0 +1,37 @@
+// src/client/app/api/proactivity/action/route.js
+import { NextResponse } from "next/server"
+import { withAuth } from "@lib/api-utils"
+
+const appServerUrl =
+	process.env.NEXT_PUBLIC_ENVIRONMENT === "selfhost"
+		? process.env.INTERNAL_APP_SERVER_URL
+		: process.env.NEXT_PUBLIC_APP_SERVER_URL
+
+export const POST = withAuth(async function POST(request, { authHeader }) {
+	try {
+		const { notification_id, user_action } = await request.json()
+		if (!notification_id || !user_action) {
+			return NextResponse.json(
+				{ error: "Notification ID and user action are required" },
+				{ status: 400 }
+			)
+		}
+
+		const response = await fetch(`${appServerUrl}/api/proactivity/action`, {
+			method: "POST",
+			headers: { "Content-Type": "application/json", ...authHeader },
+			body: JSON.stringify({ notification_id, user_action })
+		})
+
+		const data = await response.json()
+		if (!response.ok) {
+			throw new Error(
+				data.detail || "Failed to process suggestion action"
+			)
+		}
+		return NextResponse.json(data)
+	} catch (error) {
+		console.error("API Error in /proactivity/action:", error)
+		return NextResponse.json({ error: error.message }, { status: 500 })
+	}
+})

src/client/app/api/proactivity/action/route.js

@@ -3,27 +3,22 @@ import { withAuth } from "@lib/api-utils"
 
 const appServerUrl =
 	process.env.NEXT_PUBLIC_ENVIRONMENT === "selfhost"
-		? process.env.INTERNAL_APP_SERVER_URL
+		? "http://localhost:8000"
 		: process.env.NEXT_PUBLIC_APP_SERVER_URL
 
-// GET handler to fetch the current Supermemory MCP URL
+// GET handler to fetch the current Memory MCP URL
 export const GET = withAuth(async function GET(request, { authHeader }) {
 	try {
-		const response = await fetch(
-			`${appServerUrl}/api/settings/supermemory`,
-			{
-				// Ensure GET is used for fetching data
-				method: "GET",
-				headers: { "Content-Type": "application/json", ...authHeader }
-			}
-		)
+		const response = await fetch(`${appServerUrl}/api/settings/memory`, {
+			// Ensure GET is used for fetching data
+			method: "GET",
+			headers: { "Content-Type": "application/json", ...authHeader }
+		})
 
 		const data = await response.json()
 		if (!response.ok) {
 			throw new Error(
-				data.detail ||
-					data.error ||
-					"Failed to fetch Supermemory settings"
+				data.detail || data.error || "Failed to fetch Memory settings"
 			)
 		}
 		return NextResponse.json(data)
@@ -33,13 +28,13 @@ export const GET = withAuth(async function GET(request, { authHeader }) {
 	}
 })
 
-// POST handler to save the Supermemory MCP URL
+// POST handler to save the Memory MCP URL
 export const POST = withAuth(async function POST(request, { authHeader }) {
 	try {
 		const body = await request.json() // { mcp_url: "..." }
 		const backendResponse = await fetch(
 			// Renamed to avoid conflict with API response
-			`${appServerUrl}/api/settings/supermemory`,
+			`${appServerUrl}/api/settings/memory`,
 			{
 				method: "POST",
 				headers: { "Content-Type": "application/json", ...authHeader },
@@ -50,9 +45,7 @@ export const POST = withAuth(async function POST(request, { authHeader }) {
 		const data = await backendResponse.json()
 		if (!backendResponse.ok) {
 			throw new Error(
-				data.detail ||
-					data.error ||
-					"Failed to save Supermemory settings"
+				data.detail || data.error || "Failed to save Memory settings"
 			)
 		}
 		return NextResponse.json(data) // Return the backend's response directly