added podcast endpoints (#34)

* Add podcast endpoints * added podcast endpoints
cultpodcasts · Aug 5, 2024 · a05c574 · a05c574
1 parent 852cd36
commit a05c574
Show file tree

Hide file tree

Showing 4 changed files with 1,100 additions and 4 deletions.
diff --git a/homepage.json b/homepage.json
diff --git a/src/index.ts b/src/index.ts
@@ -21,6 +21,7 @@ type Env = {
 	secureEpisodeEndpoint: URL;
 	secureDiscoveryCurationEndpoint: URL;
 	securePodcastIndexEndpoint: URL;
+	securePodcastEndpoint: URL;
 }
 
 const allowedOrigins: Array<string> = [
@@ -416,6 +417,7 @@ app.get("/episode/:id", auth0Middleware, async (c) => {
 			return new Response(resp.body);
 		} else {
 			console.log(`Failed to use secure-episode-endpoint. Response code: '${resp.status}'.`);
+			return c.json({ error: "Error" }, 500);
 		}
 	}
 	return c.json({ error: "Unauthorised" }, 403);
@@ -433,7 +435,7 @@ app.post("/episode/:id", auth0Middleware, async (c) => {
 		const authorisation: string = c.req.header("Authorization")!;
 		const url = `${c.env.secureEpisodeEndpoint}/${id}`;
 		const data: any = await c.req.json();
-		const body: string = JSON.stringify(data)	
+		const body: string = JSON.stringify(data);
 		const resp = await fetch(url, {
 			headers: {
 				'Accept': "*/*",
@@ -451,7 +453,79 @@ app.post("/episode/:id", auth0Middleware, async (c) => {
 			return new Response(resp.body);
 		} else {
 			console.log(`Failed to use secure-episode-endpoint. Response code: '${resp.status}'.`);
-			return c.json({ error: "Unauthorised" }, 500);
+			return c.json({ error: "Error" }, 500);
+		}
+	}
+	return c.json({ error: "Unauthorised" }, 403);
+});
+
+app.get("/podcast/:name", auth0Middleware, async (c) => {
+	const auth0Payload: Auth0JwtPayload = c.var.auth0('payload');
+	const name = c.req.param('name')
+	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('curate')) {
+		const authorisation: string = c.req.header("Authorization")!;
+		console.log(`Using auth header '${authorisation.slice(0, 20)}..'`);
+		const url = `${c.env.securePodcastEndpoint}/${encodeURIComponent(name)}`;
+		console.log(url);
+		const resp = await fetch(url, {
+			headers: {
+				'Accept': "*/*",
+				'Authorization': authorisation,
+				"Content-type": "application/json",
+				"Cache-Control": "no-cache",
+				"User-Agent": "cult-podcasts-api",
+				"Host": new URL(c.env.securePodcastEndpoint).host
+			},
+			method: "GET"
+		});
+		if (resp.status == 200) {
+			console.log(`Successfully used secure-podcast-endpoint.`);
+
+			return new Response(resp.body);
+		} else {
+			console.log(`Failed to use secure-podcast-endpoint. Response code: '${resp.status}'.`);
+			return c.json({ error: "Error" }, 500);
+		}
+	}
+	return c.json({ error: "Unauthorised" }, 403);
+});
+
+app.post("/podcast/:id", auth0Middleware, async (c) => {
+	const auth0Payload: Auth0JwtPayload = c.var.auth0('payload');
+	const id = c.req.param('id')
+	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('curate')) {
+		const authorisation: string = c.req.header("Authorization")!;
+		const url = `${c.env.securePodcastEndpoint}/${id}`;
+		const data: any = await c.req.json();
+		const body: string = JSON.stringify(data)
+		const resp = await fetch(url, {
+			headers: {
+				'Accept': "*/*",
+				'Authorization': authorisation,
+				"Content-type": "application/json",
+				"Cache-Control": "no-cache",
+				"User-Agent": "cult-podcasts-api",
+				"Host": new URL(c.env.securePodcastEndpoint).host
+			},
+			method: "POST",
+			body: body
+		});
+		if (resp.status == 202) {
+			console.log(`Successfully used secure-podcast-endpoint.`);
+			return new Response(resp.body);
+		} else {
+			console.log(`Failed to use secure-podcast-endpoint. Response code: '${resp.status}'.`);
+			return c.json({ error: "Error" }, 500);
 		}
 	}
 	return c.json({ error: "Unauthorised" }, 403);
@@ -468,9 +542,8 @@ app.post("/podcast/index/:name", auth0Middleware, async (c) => {
 	if (auth0Payload?.permissions && auth0Payload.permissions.includes('curate')) {
 		const authorisation: string = c.req.header("Authorization")!;
 		const url = `${c.env.securePodcastIndexEndpoint}/${encodeURIComponent(name)}`;
-console.log("URl is "+url);
 		const data: any = await c.req.json();
-		const body: string = JSON.stringify(data)	
+		const body: string = JSON.stringify(data)
 		const resp = await fetch(url, {
 			headers: {
 				'Accept': "*/*",