Merge pull request #612 from AutomationSolutionz/node-installer-2

Async Zeuz Node with Node-installer functions

Author: Muntasib-creator

.gitignore

@@ -58,4 +58,7 @@ web_modules/
 custom_profiles/
 
 # Security tools
-/tools/security/*
+/tools/security/*
+Apps/Windows/inspector.exe
+Apps/Windows/Element.xml
+Framework/settings.conf.lock

Framework/Built_In_Automation/Built_In_Utility/CrossPlatform/BuiltInUtilityFunction.py

@@ -857,60 +857,6 @@ def download_file_using_url(file_url, location_of_file, headers=dict()):
             sys.exc_info(), None, "Error downloading file"
         )
 
-
-# Method to download and unzip file
-# def download_and_unzip_file(file_url, location_of_file): #!!!change this to call download_file_using_url instead of duplicating work, or just remove download part, and whatever is calling this can call the two pieces separately
-#
-#     sModuleInfo = inspect.currentframe().f_code.co_name + " : " + MODULE_NAME
-#
-#
-#     try:
-#         ''' Setting stream parameter to True will cause the download of response headers only and the connection remains open.
-#           This avoids reading the content all at once into memory for large responses.
-#          A fixed chunk will be loaded each time while r.iter_content is iterated.'''
-#         r = requests.get(file_url, stream=True)
-#
-#         list_the_parts_of_url = file_url.split("/") #get file name from the url
-#         file_name = os.path.join(location_of_file, list_the_parts_of_url[len(list_the_parts_of_url) - 1])
-#         actual_file_name = list_the_parts_of_url[len(list_the_parts_of_url) - 1]
-#         with open(file_name, "wb") as f:
-#             for chunk in r.iter_content(chunk_size=1024):
-#
-#             # writing one chunk at a time to pdf file
-#                 if chunk:
-#                     f.write(chunk)
-#         # after performing the download operation we have to check that if the file with new name exists in correct location.
-#         # if the file exists in correct position then return passed
-#         # if the file doesn't exist in correct position then return failed
-#         if os.path.isfile(file_name):
-#             CommonUtil.ExecLog(sModuleInfo, "file exists... downloading file using url function is done properly", 0)
-#         else:
-#             CommonUtil.ExecLog(sModuleInfo, "file doesn't exist... downloading file using url function is not done properly", 3)
-#             return "zeuz_failed"
-#         unzip_location = os.path.join(location_of_file,"latest_directory" )
-#         CommonUtil.ExecLog(sModuleInfo, "Creating the directory '%s' " % unzip_location, 0)
-#         result1 = CreateFolder(unzip_location)
-#         if result1 in failed_tag_list:
-#             CommonUtil.ExecLog(sModuleInfo, "Can't not create folder '%s' " % unzip_location, 3)
-#             return "zeuz_failed"
-#         CommonUtil.ExecLog(sModuleInfo, "Folder '%s' is created " % unzip_location, 1)
-#         result = UnZip(file_name,unzip_location)
-#         if result in failed_tag_list:
-#             CommonUtil.ExecLog(sModuleInfo, "Can't not unzip file '%s' to '%s'" % (file_name, unzip_location), 3)
-#             return "zeuz_failed"
-#         CommonUtil.ExecLog(sModuleInfo, "Unzipping file '%s' to '%s' is complete" % (file_name, unzip_location), 0)
-#         CommonUtil.ExecLog(sModuleInfo, "Saving directory location to shared resources" , 1)
-#         #Shared_Resources.Set_Shared_Variables("latest_directory", unzip_location)
-#         downloaded_file = os.path.join(unzip_location,actual_file_name )
-#         Shared_Resources.Set_Shared_Variables("downloaded_file", downloaded_file)
-#         Shared_Resources.Show_All_Shared_Variables()
-#         return "passed"
-#
-#
-#     except Exception:
-#         return CommonUtil.Exception_Handler(sys.exc_info())
-
-
 # not done properly...need more works
 """def change_path_for_windows(src):
     sModuleInfo = inspect.currentframe().f_code.co_name + " : " + MODULE_NAME

Framework/Built_In_Automation/Sequential_Actions/common_functions.py

@@ -3754,28 +3754,31 @@ def execute_python_code(data_set):
         try: exec(Code, sr.shared_variables)
         except: return CommonUtil.Exception_Handler(sys.exc_info())
 
-        current_vars = set(sr.shared_variables)
-        new_variables = current_vars - previous_vars - {'__builtins__'}
-        removed_variables = previous_vars - current_vars  - {'__builtins__'}
+        try:
+            current_vars = set(sr.shared_variables)
+            new_variables = current_vars - previous_vars - {'__builtins__'}
+            removed_variables = previous_vars - current_vars  - {'__builtins__'}
 
-        text = ("Newly declared variables:\n" +
-                "\n".join([f"{str(i)[:50] + (' ...' if len(str(i)) > 50 else '')} = {str(sr.shared_variables[i])[:200] + (' ...' if len(str(sr.shared_variables[i])) > 200 else '')}" for i in new_variables]) if new_variables else ""
-                )
-        text += (
-            "\n\nBy default all the newly declared variables, functions are added in shared_variables\n" +
-            "and accessible in next python_code action or in %| |%.\n" +
-            "But if you dont want your newly declared variables accessible in next actions\n" +
-            "Cleanup the variables at the end of the code. Such as:\n" +
-            "del account_name\ndel function_name" if new_variables and CommonUtil.debug_status else ""
-        )
-        text += "\nRemoved variables:\n" + "\n".join([f"{i} = {str(sr.shared_variables[i])[:200]}" for i in removed_variables]) if removed_variables else ""
-        CommonUtil.ExecLog(sModuleInfo, text, 5)
+            text = ("Newly declared variables:\n" +
+                    "\n".join([f"{str(i)[:50] + (' ...' if len(str(i)) > 50 else '')} = {str(sr.shared_variables[i])[:200] + (' ...' if len(str(sr.shared_variables[i])) > 200 else '')}" for i in new_variables]) if new_variables else ""
+                    )
+            text += (
+                "\n\nBy default all the newly declared variables, functions are added in shared_variables\n" +
+                "and accessible in next python_code action or in %| |%.\n" +
+                "But if you dont want your newly declared variables accessible in next actions\n" +
+                "Cleanup the variables at the end of the code. Such as:\n" +
+                "del account_name\ndel function_name" if new_variables and CommonUtil.debug_status else ""
+            )
+            text += "\nRemoved variables:\n" + "\n".join([f"{i} = {str(sr.shared_variables[i])[:200]}" for i in removed_variables]) if removed_variables else ""
+            CommonUtil.ExecLog(sModuleInfo, text, 5)
 
-        for var in sr.shared_variables:
-            if var.startswith("zeuz_session_"):
-                CommonUtil.global_var[var] = sr.Get_Shared_Variables("run_id")
-        CommonUtil.ExecLog(sModuleInfo, "Executed the python code which was provided", 1)
-        return "passed"
+            for var in sr.shared_variables:
+                if var.startswith("zeuz_session_"):
+                    CommonUtil.global_var[var] = sr.Get_Shared_Variables("run_id")
+            CommonUtil.ExecLog(sModuleInfo, "Executed the python code which was provided", 1)
+            return "passed"
+        except:
+            pass
     except:
         return CommonUtil.Exception_Handler(sys.exc_info())
 

Framework/Built_In_Automation/Web/Selenium/BuiltInFunctions.py

@@ -1606,20 +1606,18 @@ def Enter_Text_In_Text_Box(step_data):
                     sModuleInfo, "Entering text without clicking the element", 2
                 )
             if clear:
-                # Element.clear()
-                # Safari Keys are extremely slow and not working
-                if selenium_driver.capabilities["browserName"] == "Safari":
-                    Element.clear()
-                else:
-                    if sys.platform == "darwin":
-                        Element.send_keys(Keys.COMMAND, "a")
+                try:
+                    if selenium_driver.capabilities["browserName"] == "Safari":
+                        Element.clear()
                     else:
-                        Element.send_keys(Keys.CONTROL, "a")
-                    Element.send_keys(Keys.DELETE)
-                    try:
+                        if sys.platform == "darwin":
+                            Element.send_keys(Keys.COMMAND, "a")
+                        else:
+                            Element.send_keys(Keys.CONTROL, "a")
+                        Element.send_keys(Keys.DELETE)
                         Element.clear()  # some cases it works .. so adding it here just incase
-                    except:
-                        pass
+                except:
+                    pass
             if delay == 0:
                 Element.send_keys(text_value)
             else:
@@ -1636,7 +1634,7 @@ def Enter_Text_In_Text_Box(step_data):
         return "passed"
     except Exception:
         errMsg = "Could not select/click your element."
-        return CommonUtil.Exception_Handler(sys.exc_info(), None, errMsg)
+        return CommonUtil.Exception_Handler(sys.exc_info(), None)
 
 
 @logger

Framework/Utilities/ConfigModule.py

@@ -1,12 +1,17 @@
 # -*- coding: utf-8 -*-
 # -*- coding: cp1252 -*-
-
+from filelock import FileLock
 import configparser, os
 from . import FileUtilities as FL
+from pathlib import Path
+from datetime import date
+from configobj import ConfigObj
+import traceback
 
 """constants"""
 file_name = "settings.conf"
-
+settings_file_lock = FileLock(os.getcwd().split("Framework")[0] + os.sep + "Framework" + os.sep + file_name + ".lock")
+settings_conf_path = os.getcwd().split("Framework")[0] + os.sep + "Framework" + os.sep + file_name
 remote_config = {
     "threading": False,
     "local_run": False,
@@ -15,7 +20,46 @@
     "upload_log_file_only_for_fail": True,
 }
 
-
+@settings_file_lock
+def create_settings_config_file():
+    if Path(settings_conf_path).exists():
+        return
+
+    today = date.today().strftime("%Y-%m-%d")
+
+    config = ConfigObj()
+    config["Authentication"] = {"username": "", "api-key": "", "server_address": ""}
+    config["Advanced Options"] = {
+        "log_delete_interval": 7,
+        "last_module_update_date": today,
+        "last_log_delete_date": today,
+        "element_wait": 10,
+        "available_to_all_project": False,
+        "_file": "temp_config.ini",
+        "_file_upload_path": "TestExecutionLog",
+        "stop_live_log": False,
+    }
+    config["Inspector"] = {
+        "Window": "",
+        "No_of_level_to_skip": 0,
+        "ai_plugin": True,
+    }
+    config["server"] = {"port": 0}
+    config.filename = str(settings_conf_path)
+    config.write()
+    print(f"Created settings.conf at {settings_conf_path}")
+
+def remove_settings_lock_file():
+    """Remove stale lock file if the process that created it is no longer running."""
+    try:
+        lock_file_path = Path(settings_file_lock.lock_file)
+        if not lock_file_path.exists():
+            return
+        lock_file_path.unlink(missing_ok=True)
+    except Exception:
+        traceback.print_exc()
+
+@settings_file_lock
 def get_config_value(section, key, location: os.PathLike | None = None):
     """
     :param section: name of section
@@ -30,7 +74,7 @@ def get_config_value(section, key, location: os.PathLike | None = None):
         config = configparser.ConfigParser()
         config.optionxform = str  # Retain text case (default is to change to lowercase without this line)
         if not location:
-            _file_name = os.getcwd() + os.sep + file_name
+            _file_name = os.getcwd().split("Framework")[0] + os.sep + "Framework" + os.sep + file_name
         else:
             _file_name = location
         try:
@@ -46,7 +90,7 @@ def get_config_value(section, key, location: os.PathLike | None = None):
         # print "No option in that name: %s"%key
         return ""
 
-
+@settings_file_lock
 def remove_config_value(section, value, location=False):
     try:
         config = configparser.ConfigParser()
@@ -69,7 +113,7 @@ def remove_config_value(section, value, location=False):
         # print "No section in that name: %s"%section
         return ""
 
-
+@settings_file_lock
 def add_config_value(section, key, value, location: os.PathLike | None = None):
     try:
         config = configparser.ConfigParser()
@@ -98,44 +142,16 @@ def add_config_value(section, key, value, location: os.PathLike | None = None):
         else:
             config.set(section, key, value)
 
-        with (open(_file_name, "w")) as open_file:
+        with open(_file_name, "w") as open_file:
             config.write(open_file)  # Write all configuration to file
         open_file.close()
         return True
     except configparser.NoSectionError:
-        # print "No section in that name: %s"%section
         return ""
     except configparser.NoOptionError:
-        # print "No option in that name: %s"%key
         return ""
 
 
-def get_all_option(section_name, location: os.PathLike | None = None):
-    """
-    :param section_name: given section name
-    :return: list of all option on that section
-    """
-    try:
-        config = configparser.ConfigParser()
-        config.optionxform = str  # Retain text case (default is to change to lowercase without this line)
-        if not location:
-            _file_name = os.getcwd() + os.sep + file_name
-        else:
-            _file_name = location
-        try:
-            config.read(_file_name)  # Read current configuration, if the file exists
-        except:
-            FL.DeleteFile(location)
-            config.read(_file_name)
-        return config.options(section_name)
-    except configparser.NoSectionError as e:
-        # print("Found no section with name %s" % section_name)
-        return []
-    except configparser.NoOptionError as e:
-        # print("Found no options on the section %s" % section_name)
-        return []
-
-
 def add_section(section_name, location: os.PathLike | None = None):
     """
     :param section_name: name of the section to add
@@ -184,46 +200,3 @@ def clean_config_file(location: os.PathLike | None = None):
     except Exception as e:
         print(e)
         return False
-
-
-def get_all_sections(location: os.PathLike | None = None):
-    try:
-        config = configparser.ConfigParser()
-        config.optionxform = str  # Retain text case (default is to change to lowercase without this line)
-        if not location:
-            _file_name = os.getcwd() + os.sep + file_name
-        else:
-            _file_name = location
-        try:
-            config.read(_file_name)  # Read current configuration, if the file exists
-        except:
-            FL.DeleteFile(location)
-            config.read(_file_name)
-        return config.sections()
-    except configparser.NoSectionError as e:
-        print("found no sections")
-        return []
-    except configparser.NoOptionError as e:
-        print("found no options")
-        return []
-
-def has_section(section_name, location: os.PathLike | None = None):
-    try:
-        config = configparser.ConfigParser()
-        config.optionxform = str  # Retain text case (default is to change to lowercase without this line)
-        if not location:
-            _file_name = os.getcwd() + os.sep + file_name
-        else:
-            _file_name = location
-        try:
-            config.read(_file_name)  # Read current configuration, if the file exists
-        except:
-            FL.DeleteFile(location)
-            config.read(_file_name)
-        return config.has_section(section_name)
-    except configparser.NoSectionError as e:
-        print("found no sections")
-        return []
-    except configparser.NoOptionError as e:
-        print("found no options")
-        return []