Added rename podcast endpoint (#49)

* Added rename podcast endpoint

* Added handling for response

* Updated route

src/index.ts

@@ -14,6 +14,7 @@ import { publish } from './publish';
 import { getOutgoing } from './getOutgoing';
 import { getPodcastByName } from './getPodcastByName';
 import { updatePodcast } from './updatePodcast';
+import { renamePodcast } from "./renamePodcast";
 import { indexPodcastByName } from './indexPodcastByName';
 import { getSubjectByName } from './getSubjectByName';
 import { updateSubject } from './updateSubject';
@@ -47,5 +48,6 @@ app.post("/discovery-curation", Auth0Middleware, submitDiscovery);
 app.post("/searchindex/run", Auth0Middleware, runSearchIndexer);
 app.post("/publish/homepage", Auth0Middleware, publishHomepage);
 app.post("/terms", Auth0Middleware, publishTerm);
+app.post("/podcast/name/:name", Auth0Middleware, renamePodcast)
 
 export default app;

src/renamePodcast.ts

@@ -0,0 +1,38 @@
+import { AddResponseHeaders } from "./AddResponseHeaders";
+import { Auth0ActionContext } from "./Auth0ActionContext";
+import { Auth0JwtPayload } from "./Auth0JwtPayload";
+import { buildFetchHeaders } from "./buildFetchHeaders";
+
+export async function renamePodcast(c: Auth0ActionContext): Promise<Response> {
+    const auth0Payload: Auth0JwtPayload = c.var.auth0('payload');
+    const podcastName = c.req.param('name');
+    const newName = c.req.param('newName');
+    AddResponseHeaders(c, { methods: ["POST", "GET", "OPTIONS"] });
+    if (auth0Payload?.permissions && auth0Payload.permissions.includes('admin')) {
+        const url = `${c.env.securePodcastEndpoint}/name/${podcastName}`;
+        const data: any = await c.req.json();
+        const body: string = JSON.stringify(data);
+        const resp = await fetch(url, {
+            headers: buildFetchHeaders(c.req, c.env.securePodcastEndpoint),
+            method: "POST",
+            body: body
+        });
+        if (resp.status == 200) {
+            console.log(`Successfully used secure-podcast-endpoint to rename podcast.`);
+            return new Response(resp.body);
+        } else if (resp.status == 400) {
+            console.log(`Unable to find podcast to rename podcast.`);
+            return new Response(resp.body, { status: resp.status });
+        } else if (resp.status == 404) {
+            console.log(`Unable to find podcast to rename podcast. Podccast not found.`);
+            return new Response(resp.body, { status: resp.status });
+        } else if (resp.status == 409) {
+            console.log(`Unable to find podcast to rename podcast. Podcast exists with new-name.`);
+            return new Response(resp.body, { status: resp.status });
+        } else {
+            console.log(`Failed to use secure-podcast-endpoint to rename podcast. Response code: '${resp.status}'.`);
+            return c.json({ error: "Error" }, 500);
+        }
+    }
+    return c.json({ error: "Unauthorised" }, 403);
+}

src/updatePodcast.ts

@@ -12,7 +12,7 @@ export async function updatePodcast(c: Auth0ActionContext): Promise<Response> {
 		const data: any = await c.req.json();
 		const body: string = JSON.stringify(data);
 		const resp = await fetch(url, {
-			headers: buildFetchHeaders(c.req, c.env.secureEpisodeEndpoint),
+			headers: buildFetchHeaders(c.req, c.env.securePodcastEndpoint),
 			method: "POST",
 			body: body
 		});