diff --git a/packages/backend/src/routes/index.ts b/packages/backend/src/routes/index.js similarity index 100% rename from packages/backend/src/routes/index.ts rename to packages/backend/src/routes/index.js diff --git a/packages/backend/src/routes/paddle.ee.js b/packages/backend/src/routes/paddle.ee.js new file mode 100644 index 00000000..de6e17f5 --- /dev/null +++ b/packages/backend/src/routes/paddle.ee.js @@ -0,0 +1,16 @@ +import { Router } from 'express'; +import webhooksHandler from '../controllers/paddle/webhooks.ee'; + +const router = Router(); + +const exposeError = (handler) => async (req, res, next) => { + try { + await handler(req, res, next); + } catch (err) { + next(err); + } +}; + +router.post('/webhooks', exposeError(webhooksHandler)); + +export default router; diff --git a/packages/backend/src/routes/paddle.ee.ts b/packages/backend/src/routes/paddle.ee.ts deleted file mode 100644 index 3f6aa004..00000000 --- a/packages/backend/src/routes/paddle.ee.ts +++ /dev/null @@ -1,19 +0,0 @@ -import { Response, Router, NextFunction, RequestHandler } from 'express'; -import { IRequest } from '@automatisch/types'; -import webhooksHandler from '../controllers/paddle/webhooks.ee'; - -const router = Router(); - -const exposeError = - (handler: RequestHandler) => - async (req: IRequest, res: Response, next: NextFunction) => { - try { - await handler(req, res, next); - } catch (err) { - next(err); - } - }; - -router.post('/webhooks', exposeError(webhooksHandler)); - -export default router; diff --git a/packages/backend/src/routes/webhooks.ts b/packages/backend/src/routes/webhooks.js similarity index 52% rename from packages/backend/src/routes/webhooks.ts rename to packages/backend/src/routes/webhooks.js index fc24ca2a..77889ae3 100644 --- a/packages/backend/src/routes/webhooks.ts +++ b/packages/backend/src/routes/webhooks.js @@ -1,7 +1,6 @@ -import express, { Response, Router, NextFunction, RequestHandler } from 'express'; +import express, { Router } from 'express'; import multer from 'multer'; -import { IRequest } from '@automatisch/types'; import appConfig from '../config/app'; import webhookHandlerByFlowId from '../controllers/webhooks/handler-by-flow-id'; import webhookHandlerByConnectionIdAndRefValue from '../controllers/webhooks/handler-by-connection-id-and-ref-value'; @@ -11,22 +10,24 @@ const upload = multer(); router.use(upload.none()); -router.use(express.text({ - limit: appConfig.requestBodySizeLimit, - verify(req, res, buf) { - (req as IRequest).rawBody = buf; - }, -})); +router.use( + express.text({ + limit: appConfig.requestBodySizeLimit, + verify(req, res, buf) { + req.rawBody = buf; + }, + }) +); -const exposeError = (handler: RequestHandler) => async (req: IRequest, res: Response, next: NextFunction) => { +const exposeError = (handler) => async (req, res, next) => { try { await handler(req, res, next); } catch (err) { next(err); } -} +}; -function createRouteHandler(path: string, handler: (req: IRequest, res: Response, next: NextFunction) => void) { +function createRouteHandler(path, handler) { const wrappedHandler = exposeError(handler); router @@ -35,10 +36,16 @@ function createRouteHandler(path: string, handler: (req: IRequest, res: Response .put(wrappedHandler) .patch(wrappedHandler) .post(wrappedHandler); -}; +} -createRouteHandler('/connections/:connectionId/:refValue', webhookHandlerByConnectionIdAndRefValue); -createRouteHandler('/connections/:connectionId', webhookHandlerByConnectionIdAndRefValue); +createRouteHandler( + '/connections/:connectionId/:refValue', + webhookHandlerByConnectionIdAndRefValue +); +createRouteHandler( + '/connections/:connectionId', + webhookHandlerByConnectionIdAndRefValue +); createRouteHandler('/flows/:flowId', webhookHandlerByFlowId); createRouteHandler('/:flowId', webhookHandlerByFlowId);