Use json post body

cultpodcasts · Feb 17, 2024 · 3b394c9 · 3b394c9
1 parent 39c905f
commit 3b394c9
Showing 1 changed file with 24 additions and 20 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -120,26 +120,30 @@ export default {
 				}
 
 				if (pathname.startsWith(submitRoute) && request.method === "POST") {
-						let url: URL | undefined;
-						let urlParam = searchParams.get("url");
-						if (urlParam == null) {
-								return new Error("Missing url param.");
-						}
-						try {
-								url = new URL(urlParam);
-						} catch {
-								return new Error(`Invalid url '${url}'.`);
-						}
-						let insert = env.DB
-								.prepare("INSERT INTO submissions (url, timestamp, timestamp_date, ip_address, country, user_agent) VALUES (?, ?, ?, ?, ?)")
-								.bind(url.toString(), Date.now(), new Date().toLocaleString(), request.headers.get("CF-Connecting-IP"), request.headers.get("CF-Connecting-IP"), request.headers.get("User-Agent"));
-						let result = await insert.run();
-
-						if (result.success) {
-								return new Response();
-						} else {
-								return new Error();
-						}
+						return request
+								.json()
+								.then(async (data: any) => {
+										let url: URL | undefined;
+										let urlParam = data.url;
+										if (urlParam == null) {
+												return new Error("Missing url param.");
+										}
+										try {
+												url = new URL(urlParam);
+										} catch {
+												return new Error(`Invalid url '${url}'.`);
+										}
+										let insert = env.DB
+												.prepare("INSERT INTO submissions (url, timestamp, timestamp_date, ip_address, country, user_agent) VALUES (?, ?, ?, ?, ?)")
+												.bind(url.toString(), Date.now(), new Date().toLocaleString(), request.headers.get("CF-Connecting-IP"), request.headers.get("CF-Connecting-IP"), request.headers.get("User-Agent"));
+										let result = await insert.run();
+
+										if (result.success) {
+												return new Response();
+										} else {
+												return new Error();
+										}
+								});
 				}
 
 				return new Response(