Merge pull request #14 from Shahnawaz-Sk/master

replacing all request api calls by axios

Author: Shivanshu-lambdatest

index.js

@@ -1,4 +1,6 @@
 var lambdaAutomationClient = require("./lib/automation_client");
+var lambdaAutomationClientV2 = require("./lib/automation_client_v2");
 module.exports = {
     AutomationClient: lambdaAutomationClient.AutomationClient,
-};
+    AutomationClientV2: lambdaAutomationClientV2.AutomationClient,
+};

lib/api_client_v2.js

@@ -0,0 +1,63 @@
+const axios = require('axios');
+const { version, appVersion, baseUrl, baseUrlApp } = require("./config");
+const packageVersion = require("../package.json").version;
+let logger;
+
+var ApiClient = function (settings) {
+    settings = settings || {};
+    /**
+     * Required check for username.
+     * @return {Error|null}
+     */
+    if (!settings.username) {
+        throw new Error("Username is required.");
+    }
+    /**
+     * Required check for accessKey.
+     * @return {Error|null}
+     */
+    if (!settings.accessKey) {
+        throw new Error("Access Key is required.");
+    }
+    if (!logger) {
+        logger = require("./logger")(settings.logFile);
+    }
+    logger.info("Imported ApiClient and User Credenetials", settings);
+    ApiClient.basicAuth = "Basic " + Buffer.from(settings.username + ":" + settings.accessKey).toString("base64");
+
+    ApiClient.apiBaseUrl = settings.isApp ? baseUrlApp + appVersion.latestVersion : baseUrl + version.latestVersion;
+
+    this.makeRequest = async function(method, path, body = null, params = {}) {
+        // Validate path
+        if (!path) {
+            throw new Error('Path is required');
+        }
+
+        // Use instance-specific baseUrl
+        const url = `${ApiClient.apiBaseUrl}${path}`;
+        
+        // Prepare request options
+        const options = {
+            method: method,
+            headers: { Authorization: ApiClient.basicAuth },
+            url: url,
+        };
+        
+
+        if (body) options.data = JSON.stringify(body);
+        if (Object.keys(params).length) options.params = params;
+
+        logger.info("Api request options ", options);
+        // Axios request
+        try {
+            const response = await axios(options);
+            return response.data;
+        } catch (error) {
+            logger.error("Error ", error);
+            throw error;
+        }
+    };
+
+};
+module.exports = ApiClient;
+

lib/automation_client_v2.js

@@ -0,0 +1,120 @@
+const ApiClient = require("./api_client_v2");
+
+function ApiClientInstance(settings) {
+    // Create an instance of ApiClient
+    const apiClient = new ApiClient(settings);
+
+    this.fetchBuilds = async function(params) {
+        return await apiClient.makeRequest('GET', '/builds', null, params);
+    };
+
+    this.fetchBuildById = async function(buildId) {
+        if(!buildId) {
+            throw new Error('buildId is not found');
+        }
+        return await apiClient.makeRequest('GET', `/builds/${buildId}`);
+    };
+
+    this.deleteBuildById =  async function(buildId) {
+        if(!buildId) {
+            throw new Error('buildId is not found');
+        }
+        return await apiClient.makeRequest('DELETE', `/builds/${buildId}`);
+    };
+
+    this.updateBuildById =  async function(buildId, requestBody) {
+        if(!buildId || !requestBody) {
+            throw new Error('buildId || requestBody is not found');
+        }
+        return await apiClient.makeRequest('PATCH', `/builds/${buildId}`, requestBody);
+    };
+
+    this.fetchSessions = async function(params) {
+        return await apiClient.makeRequest('GET', '/sessions', null, params);
+    };
+
+    this.fetchSessionById =  async function(sessionId) {
+        if(!sessionId) {
+            throw new Error('session Id not correct');
+        }
+        return await apiClient.makeRequest('GET', `/sessions/${sessionId}`);
+    };
+
+    this.deleteSessionById =  async function(sessionId) {
+        if(!sessionId) {
+            throw new Error('session Id not correct');
+        }
+        return await apiClient.makeRequest('DELETE', `/sessions/${sessionId}`);
+    };
+
+    this.updateSessionById =  async function(sessionId, requestBody) {
+        if(!sessionId || !requestBody) {
+            throw new Error('session Id || requestBody not correct');
+        }
+        return await apiClient.makeRequest('PATCH', `/sessions/${sessionId}`, requestBody);
+    };
+
+    this.fetchSessionScreenshot =  async function(sessionId) {
+        if(!sessionId) {
+            throw new Error('session Id not correct');
+        }
+        return await apiClient.makeRequest('GET', `/sessions/${sessionId}/screenshots`);
+    };
+
+    this.fetchSessionVideo =  async function(sessionId) {
+        if(!sessionId) {
+            throw new Error('session Id not correct');
+        }
+        return await apiClient.makeRequest( 'GET', `/sessions/${sessionId}/video`);
+    };
+
+    this.fetchSessionCommandLogs = async function(sessionId) {
+        if(!sessionId) {
+            throw new Error('session Id not correct');
+        }
+        return await apiClient.makeRequest('GET', `/sessions/${sessionId}/log/command`);
+    };
+
+    this.fetchSessionSeleniumLogs = async function(sessionId) {
+        if(!sessionId) {
+            throw new Error('session Id not correct');
+        }
+        return await apiClient.makeRequest( 'GET', `/sessions/${sessionId}/log/selenium`);
+    };
+
+    this.fetchSessionNetworkLogs = async function(sessionId) {
+        if(!sessionId) {
+            throw new Error('session Id not correct');
+        }
+        return await apiClient.makeRequest('GET', `/sessions/${sessionId}/log/network`);
+    };
+
+    this.fetchSessionConsoleLogs = async function(sessionId) {
+        if(!sessionId) {
+            throw new Error('session Id not correct');
+        }
+        return await apiClient.makeRequest('GET', `/sessions/${sessionId}/log/console`);
+    };
+
+    this.fetchTunnels= async function() {
+        return await apiClient.makeRequest('GET', '/tunnels');
+    };
+
+    this.deleteTunnelById = async function(tunnelId) {
+        if(!tunnelId) {
+            throw new Error('tunnel Id not correct');
+        }
+        return await apiClient.makeRequest('DELETE', `/tunnels/${tunnelId}`);
+    };
+
+    this.fetchPlatforms= async function() {
+        return await apiClient.makeRequest('GET', '/platforms');
+    };
+
+}
+
+module.exports = {
+    AutomationClient: function (settings) {
+        return new ApiClientInstance(settings);
+    },
+};