Add media download api endpoint

packages/api/src/index.ts

@@ -19,12 +19,15 @@ import {
 	logger,
 	getObjectText,
 	getS3Client,
+	sendMessage,
 } from '@guardian/transcription-service-backend-common';
 import {
 	ClientConfig,
 	TranscriptExportRequest,
 	inputBucketObjectMetadata,
 	transcribeFileRequestBody,
+	transcribeUrlRequestBody,
+	MediaDownloadJob,
 } from '@guardian/transcription-service-common';
 import type { SignedUrlResponseBody } from '@guardian/transcription-service-common';
 import {
@@ -71,6 +74,43 @@ const getApp = async () => {
 		}),
 	]);
 
+	apiRouter.post('/transcribe-url', [
+		checkAuth,
+		asyncHandler(async (req, res) => {
+			const userEmail = req.user?.email;
+			const body = transcribeUrlRequestBody.safeParse(req.body);
+			const id = uuid4();
+			if (!body.success || !userEmail) {
+				res.status(422).send('missing request params');
+				return;
+			}
+			const downloadJob: MediaDownloadJob = {
+				id,
+				url: body.data.url,
+				languageCode: body.data.languageCode,
+				translationRequested: body.data.translationRequested,
+				userEmail,
+			};
+
+			const sendResult = await sendMessage(
+				sqsClient,
+				config.app.mediaDownloadQueueUrl,
+				JSON.stringify(downloadJob),
+				id,
+			);
+			if (isSqsFailure(sendResult)) {
+				res.status(500).send(sendResult.errorMsg);
+				return;
+			}
+			logger.info('API successfully sent the message to SQS', {
+				id,
+				url: body.data.url,
+				userEmail,
+			});
+			res.send('Message sent');
+		}),
+	]);
+
 	apiRouter.post('/transcribe-file', [
 		checkAuth,
 		asyncHandler(async (req, res) => {