basic layout and communication setup for user settings

Author: jsajal

packages/flowtest-electron/package.json

@@ -38,6 +38,7 @@
     "@smithy/signature-v4": "^3.0.0",
     "@smithy/util-utf8": "^3.0.0",
     "axios": "^1.6.7",
+    "axios-retry": "^4.4.0",
     "chokidar": "^3.6.0",
     "dotenv": "^16.4.5",
     "electron-store": "^8.1.0",

packages/flowtest-electron/src/ipc/axiosClient.js

@@ -0,0 +1,29 @@
+// lib/axiosClient.ts
+const axios = require('axios');
+const axiosRetry = require('axios-retry').default;
+
+const axiosClient = (baseUrl, accessId, accessKey) => {
+  const client = axios.create({
+    baseURL: `${baseUrl}/api`,
+    headers: {
+      'Content-Type': 'application/json',
+    },
+  });
+
+  axiosRetry(client, {
+    retries: 3, // Number of retries
+    retryDelay: (retryCount) => {
+      return retryCount * 1000; // Time interval between retries (1000 ms = 1 second)
+    },
+    retryCondition: (error) => {
+      // Retry on network errors or rate limit errors or 5xx server errors
+      return error.response?.status === 500 || error.response?.status === 429 || error.code === 'ECONNABORTED';
+    },
+  });
+
+  return client;
+};
+
+module.exports = {
+  axiosClient,
+};

packages/flowtest-electron/src/ipc/collection.js

@@ -17,6 +17,7 @@ const readFile = require('../utils/filemanager/readfile');
 const FlowtestAI = require('../ai/flowtestai');
 const { stringify, parse } = require('flatted');
 const { deserialize, serialize } = require('../utils/flowparser/parser');
+const { axiosClient } = require('./axiosClient');
 
 const collectionStore = new Collections();
 const flowTestAI = new FlowtestAI();
@@ -336,6 +337,55 @@ const registerRendererEventHandlers = (mainWindow, watcher) => {
       return Promise.reject(error);
     }
   });
+
+  ipcMain.handle('renderer:upload-logs', async (event, name, config, logs) => {
+    function bytesToBase64(bytes) {
+      const binString = Array.from(bytes, (byte) => String.fromCodePoint(byte)).join('');
+      return btoa(binString);
+    }
+
+    try {
+      const data = {
+        version: 1,
+        name,
+        scan: logs,
+      };
+      try {
+        const response = await axiosClient(config.hostUrl, config.accessId, config.accessKey).post(
+          '/upload',
+          bytesToBase64(new TextEncoder().encode(JSON.stringify(data))),
+        );
+        return {
+          upload: 'success',
+          url: `${config.hostUrl}/scan/${response.data.data[0].id}`,
+        };
+      } catch (error) {
+        if (error?.response) {
+          if (error.response?.status === 403 || error.response?.status === 429) {
+            return {
+              upload: 'fail',
+              message: 'Unable to upload build scan',
+              reason: `${JSON.stringify(error.response?.data)}`,
+            };
+          }
+
+          if (error.response?.status === 500) {
+            return {
+              upload: 'fail',
+              message: 'Unable to upload build scan',
+              reason: 'Internal Server Error',
+            };
+          }
+        }
+        return {
+          upload: 'fail',
+          message: 'Unable to upload build scan',
+        };
+      }
+    } catch (error) {
+      return Promise.reject(error);
+    }
+  });
 };
 
 module.exports = registerRendererEventHandlers;

packages/flowtest-electron/src/ipc/settings.js

@@ -0,0 +1,25 @@
+const { ipcMain, shell, dialog, app } = require('electron');
+const Settings = require('../store/settings');
+
+const settingsStore = new Settings();
+
+const registerSettingsEventHandlers = (mainWindow) => {
+  ipcMain.handle('renderer:settings-window-ready', async (event) => {
+    const savedSettings = settingsStore.getAll();
+
+    mainWindow.webContents.send('main:saved-settings', savedSettings);
+  });
+
+  ipcMain.handle('renderer:add-logsyncconfig', async (event, config) => {
+    try {
+      settingsStore.addLogSyncConfig(...config);
+      const savedSettings = settingsStore.getAll();
+
+      mainWindow.webContents.send('main:saved-settings', savedSettings);
+    } catch (error) {
+      return Promise.reject(error);
+    }
+  });
+};
+
+module.exports = registerSettingsEventHandlers;

packages/flowtest-electron/src/store/settings.js

@@ -0,0 +1,23 @@
+const Store = require('electron-store');
+
+class Settings {
+  constructor() {
+    this.store = new Store();
+  }
+
+  addLogSyncConfig(enabled, hostUrl, accessId, accessKey) {
+    this.store.set('logSyncConfig', { enabled, hostUrl, accessId, accessKey });
+  }
+
+  getAll() {
+    return {
+      logSyncConfig: this.store.get('logSyncConfig') || {},
+    };
+  }
+
+  clearAll() {
+    this.store.set('logSyncConfig', {});
+  }
+}
+
+module.exports = Settings;

packages/flowtest-electron/tests/store/settings-store.test.js

@@ -0,0 +1,18 @@
+const Settings = require('../../src/store/settings');
+
+describe('settings-store', () => {
+  it('should create and get settings', async () => {
+    const store = new Settings();
+    store.clearAll();
+
+    expect(store.getAll().logSyncConfig).toEqual({});
+
+    // adding a collection whose directory doesn't exist
+    store.addLogSyncConfig(true, 'http://localhost:3000', 'access_id', 'access_key');
+    const config = store.getAll().logSyncConfig;
+    expect(config.enabled).toEqual(true);
+    expect(config.hostUrl).toEqual('http://localhost:3000');
+    expect(config.accessId).toEqual('access_id');
+    expect(config.accessKey).toEqual('access_key');
+  });
+});

pnpm-lock.yaml

@@ -27,6 +27,7 @@ import Button from 'components/atoms/common/Button';
 import { BUTTON_INTENT_TYPES, BUTTON_TYPES } from 'constants/Common';
 import GraphLogger, { LogLevel } from './graph/GraphLogger';
 import Mousetrap from 'mousetrap';
+import useSettingsStore from 'stores/SettingsStore';
 
 const StartNode = () => (
   <FlowNode title='Start' handleLeft={false} handleRight={true} handleRightData={{ type: 'source' }}></FlowNode>
@@ -87,6 +88,7 @@ const Flow = ({ tab, collectionId }) => {
     useCanvasStore(selector);
 
   const setLogs = useTabStore((state) => state.updateFlowTestLogs);
+  const logSyncConfig = useSettingsStore((state) => state.logSyncConfig);
 
   const [reactFlowInstance, setReactFlowInstance] = useState(null);
 
@@ -196,9 +198,9 @@ const Flow = ({ tab, collectionId }) => {
   const onGraphComplete = (status, logs) => {
     setLogs(tab.id, logs);
     if (status == 'Success') {
-      toast.success(`FlowTest Run Success! \n View Logs`);
+      toast.success(`FlowTest Run Success!`);
     } else if (status == 'Failed') {
-      toast.error(`FlowTest Run Failed! \n View Logs`);
+      toast.error(`FlowTest Run Failed!`);
     }
     runnableEdges(false);
   };