merged latest changes with queue branch and ready for prod

3 files changed, 42 insertions, 5 deletions

diff --git a/apps/web/app/api/store/helper.ts b/apps/web/app/api/store/helper.ts
index 6ab7fb23..db13ca91 100644
--- a/apps/web/app/api/store/helper.ts
+++ b/apps/web/app/api/store/helper.ts
@@ -24,8 +24,8 @@ export const createMemoryFromAPI = async (input: {
 			method: "POST",
 			body: JSON.stringify({
 				pageContent: input.data.pageContent,
-				title: input.data.title,
-				description: input.data.description,
+				title: input.data.title.slice(0, 500),
+				description: input.data.description.slice(0, 500),
 				url: input.data.url,
 				spaces: input.data.spaces,
 				user: input.userId,
diff --git a/apps/web/app/api/store/route.ts b/apps/web/app/api/store/route.ts
index 12af7894..ad81c7c4 100644
--- a/apps/web/app/api/store/route.ts
+++ b/apps/web/app/api/store/route.ts
@@ -2,6 +2,7 @@ import { type NextRequest } from "next/server";
 import { addFromAPIType } from "@repo/shared-types";
 import { ensureAuth } from "../ensureAuth";
 import { createMemoryFromAPI } from "./helper";
+import { getRawTweet } from "@repo/shared-types/utils";
 
 export const runtime = "edge";
 
@@ -16,7 +17,43 @@ export async function POST(req: NextRequest) {
 		return new Response("Missing BACKEND_SECURITY_KEY", { status: 500 });
 	}
 
-	const body = await req.json();
+	let body;
+
+	try {
+		body = await req.json();
+	} catch (e) {
+		const error = (e as Error).message;
+
+		console.log(error);
+
+		const tryJson = getRawTweet(await req.text());
+		console.log(tryJson);
+
+		if (tryJson) {
+			try {
+				body = JSON.parse(tryJson);
+			} catch (e) {
+				console.log(e);
+				return new Response(
+					JSON.stringify({
+						message: "Raw found but not json?" + error,
+					}),
+					{
+						status: 400,
+					},
+				);
+			}
+		} else {
+			return new Response(
+				JSON.stringify({
+					message: "Raw not found & not json." + error,
+				}),
+				{
+					status: 400,
+				},
+			);
+		}
+	}
 
 	const validated = addFromAPIType.safeParse(body);
 
diff --git a/apps/web/app/api/telegram/route.ts b/apps/web/app/api/telegram/route.ts
index dddfa2f4..c629e409 100644
--- a/apps/web/app/api/telegram/route.ts
+++ b/apps/web/app/api/telegram/route.ts
@@ -68,9 +68,9 @@ bot.on("message", async (ctx) => {
 	if (response.status !== 200) {
 		console.log("Failed to get response from backend");
 		console.log(response.status);
-		console.log(await response.text());
 		await ctx.reply(
-			"Sorry, I am not able to process your request at the moment.",
+			"Sorry, I am not able to process your request at the moment." +
+				(await response.text()),
 		);
 		return;
 	}