summary refs log tree commit diff
path: root/src/api/routes/connections/#connection_name/callback.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/api/routes/connections/#connection_name/callback.ts')
-rw-r--r--src/api/routes/connections/#connection_name/callback.ts81
1 files changed, 35 insertions, 46 deletions
diff --git a/src/api/routes/connections/#connection_name/callback.ts b/src/api/routes/connections/#connection_name/callback.ts
index ee0db94a..f47c48f3 100644
--- a/src/api/routes/connections/#connection_name/callback.ts
+++ b/src/api/routes/connections/#connection_name/callback.ts
@@ -17,55 +17,44 @@
 */
 
 import { route } from "@spacebar/api";
-import {
-	ConnectionCallbackSchema,
-	ConnectionStore,
-	emitEvent,
-	FieldErrors,
-} from "@spacebar/util";
+import { ConnectionCallbackSchema, ConnectionStore, emitEvent, FieldErrors } from "@spacebar/util";
 import { Request, Response, Router } from "express";
 
 const router = Router();
 
-router.post(
-	"/",
-	route({ requestBody: "ConnectionCallbackSchema" }),
-	async (req: Request, res: Response) => {
-		const { connection_name } = req.params;
-		const connection = ConnectionStore.connections.get(connection_name);
-		if (!connection)
-			throw FieldErrors({
-				provider_id: {
-					code: "BASE_TYPE_CHOICES",
-					message: req.t("common:field.BASE_TYPE_CHOICES", {
-						types: Array.from(
-							ConnectionStore.connections.keys(),
-						).join(", "),
-					}),
-				},
-			});
-
-		if (!connection.settings.enabled)
-			throw FieldErrors({
-				provider_id: {
-					message: "This connection has been disabled server-side.",
-				},
-			});
-
-		const body = req.body as ConnectionCallbackSchema;
-		const userId = connection.getUserId(body.state);
-		const connectedAccnt = await connection.handleCallback(body);
-
-		// whether we should emit a connections update event, only used when a connection doesnt already exist
-		if (connectedAccnt)
-			emitEvent({
-				event: "USER_CONNECTIONS_UPDATE",
-				data: { ...connectedAccnt, token_data: undefined },
-				user_id: userId,
-			});
-
-		res.sendStatus(204);
-	},
-);
+router.post("/", route({ requestBody: "ConnectionCallbackSchema" }), async (req: Request, res: Response) => {
+	const { connection_name } = req.params;
+	const connection = ConnectionStore.connections.get(connection_name);
+	if (!connection)
+		throw FieldErrors({
+			provider_id: {
+				code: "BASE_TYPE_CHOICES",
+				message: req.t("common:field.BASE_TYPE_CHOICES", {
+					types: Array.from(ConnectionStore.connections.keys()).join(", "),
+				}),
+			},
+		});
+
+	if (!connection.settings.enabled)
+		throw FieldErrors({
+			provider_id: {
+				message: "This connection has been disabled server-side.",
+			},
+		});
+
+	const body = req.body as ConnectionCallbackSchema;
+	const userId = connection.getUserId(body.state);
+	const connectedAccnt = await connection.handleCallback(body);
+
+	// whether we should emit a connections update event, only used when a connection doesnt already exist
+	if (connectedAccnt)
+		emitEvent({
+			event: "USER_CONNECTIONS_UPDATE",
+			data: { ...connectedAccnt, token_data: undefined },
+			user_id: userId,
+		});
+
+	res.sendStatus(204);
+});
 
 export default router;