Added new get-podcasts endpoint (#23)

* Added new get-podcasts endpoint * Fix typo --------- Co-authored-by: Jon Breen <[email protected]>
cultpodcasts · May 15, 2024 · 67ff35f · 67ff35f
1 parent a65dee0
commit 67ff35f
Show file tree

Hide file tree

Showing 3 changed files with 76 additions and 42 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -9,7 +9,7 @@
   "devDependencies": {
     "@cloudflare/workers-types": "^4.20240423.0",
     "typescript": "^5.0.4",
-    "wrangler": "^3.53.1"
+    "wrangler": "^3.56.0"
   },
   "dependencies": {
     "@cfworker/jwt": "^4.0.6",

diff --git a/src/index.ts b/src/index.ts
@@ -18,7 +18,8 @@ type Env = {
 	gatewayKey: string;
 	auth0Issuer: string;
 	auth0Audience: string;
-	secureSubmitEndpoint: string;
+	secureSubmitEndpoint: URL;
+	securePodcastsEndpoint: URL;
 }
 
 const allowedOrigins: Array<string> = [
@@ -326,7 +327,7 @@ app.post("/submit", auth0Middleware, async (c) => {
 	try {
 		const record = {
 			url: url.toString(),
-			ip_address: c.req.header("CF-Connecting-IP") ?? null,
+			ip_address: c.req.header("CF-Connecting-IP") ?? "Unkown",
 			user_agent: c.req.header("User-Agent") ?? null,
 			country: c.req.header("CF-IPCountry") ?? null
 		};
@@ -342,5 +343,38 @@ app.post("/submit", auth0Middleware, async (c) => {
 	return c.json({ success: "Submitted" });
 });
 
+app.get("/podcasts", auth0Middleware, async (c) => {
+	const auth0Payload: Auth0JwtPayload = c.var.auth0('payload');
+	c.header("Cache-Control", "max-age=600");
+	c.header("Content-Type", "application/json");
+	c.header("Access-Control-Allow-Origin", getOrigin(c.req.header("Origin")));
+	c.header("Access-Control-Allow-Methods", "POST,GET,OPTIONS");
+
+	if (auth0Payload?.permissions && auth0Payload.permissions.includes('submit')) {
+		const authorisation: string = c.req.header("Authorization")!;
+		console.log(`Using auth header '${authorisation.slice(0, 20)}..'`);
+		const resp = await fetch(c.env.securePodcastsEndpoint, {
+			headers: {
+				'Accept': "*/*",
+				'Authorization': authorisation,
+				"Content-type": "application/json",
+				"Cache-Control": "no-cache",
+				"User-Agent": "cultvault-podcasts-api",
+				"Host": new URL(c.env.securePodcastsEndpoint).host
+			},
+			method: "GET"
+		});
+		if (resp.status == 200) {
+			console.log(`Successfully used secure enpoint.`);
+
+			return new Response(resp.body);
+		} else {
+			console.log(`Failed to use secure submit endpoint. Response code: '${resp.status}'.`);
+		}
+
+	}
+	return c.json({ error: "Unauthorised" }, 403);
+});
+
 
 export default app;