feat: add defineApp and beforeRequest

packages/backend/src/helpers/define-app.ts

@@ -0,0 +1,5 @@
+import { IApp } from '@automatisch/types';
+
+export default function defineApp(appDefinition: IApp): IApp {
+  return appDefinition;
+}

packages/backend/src/helpers/global-variable.ts

@@ -24,7 +24,7 @@ const globalVariable = async (
   const trigger = await step?.getTriggerCommand();
   const nextStep = await step?.getNextStep();
 
-  const variable: IGlobalVariable = {
+  const $: IGlobalVariable = {
     auth: {
       set: async (args: IJSONObject) => {
         if (connection) {
@@ -41,7 +41,6 @@ const globalVariable = async (
       data: connection?.formattedData,
     },
     app: app,
-    http: createHttpClient({ baseURL: app.apiBaseUrl }),
     flow: {
       id: flow?.id,
       lastInternalId,
@@ -62,6 +61,12 @@ const globalVariable = async (
     },
   };
 
+  $.http = createHttpClient({
+    $,
+    baseURL: app.apiBaseUrl,
+    beforeRequest: app.beforeRequest,
+  });
+
   if (trigger && trigger.dedupeStrategy === 'unique') {
     const lastInternalIds = await flow?.lastInternalIds();
 
@@ -69,10 +74,10 @@ const globalVariable = async (
       return lastInternalIds?.includes(internalId);
     };
 
-    variable.flow.isAlreadyProcessed = isAlreadyProcessed;
+    $.flow.isAlreadyProcessed = isAlreadyProcessed;
   }
 
-  return variable;
+  return $;
 };
 
 export default globalVariable;

packages/backend/src/helpers/http-client/index.ts

@@ -1,12 +1,18 @@
-import axios from 'axios';
+import axios, { AxiosRequestConfig } from 'axios';
 export { AxiosInstance as IHttpClient } from 'axios';
 import { IHttpClientParams } from '@automatisch/types';
 
-export default function createHttpClient({ baseURL }: IHttpClientParams) {
+export default function createHttpClient({ $, baseURL, beforeRequest = [] }: IHttpClientParams) {
   const instance = axios.create({
     baseURL,
   });
 
+  instance.interceptors.request.use((requestConfig: AxiosRequestConfig): AxiosRequestConfig => {
+    return beforeRequest.reduce((newConfig, beforeRequestFunc) => {
+      return beforeRequestFunc($, newConfig);
+    }, requestConfig);
+  });
+
   instance.interceptors.response.use(
     (response) => response,
     (error) => {