From 628cdc593cef243b414320187f87f7b04d1dbb33 Mon Sep 17 00:00:00 2001 From: Ivan Maslov Date: Mon, 14 Feb 2022 18:19:43 +0300 Subject: [PATCH] Managers.Git in progress --- .../pyOpenRPA/Orchestrator/Managers/Git.py | 73 +++++++++++++++++-- 1 file changed, 67 insertions(+), 6 deletions(-) diff --git a/Sources/pyOpenRPA/Orchestrator/Managers/Git.py b/Sources/pyOpenRPA/Orchestrator/Managers/Git.py index 5c89e841..dd6e6f9b 100644 --- a/Sources/pyOpenRPA/Orchestrator/Managers/Git.py +++ b/Sources/pyOpenRPA/Orchestrator/Managers/Git.py @@ -4,12 +4,14 @@ import os from .. import __Orchestrator__ from . import Process +from typing import List + class Git(): mAgentHostNameStr = None mAgentUserNameStr = None mAbsPathStr = None - mProcessList = [] # List of the key turples of the Process instance + mProcessList: List[Process] = [] # List of the key turples of the Process instance def __init__(self, inAgentHostNameStr=None, inAgentUserNameStr=None, inGitPathStr=""): """ @@ -43,9 +45,25 @@ class Git(): else: raise Exception(f"Process with current key is already exists in Git process list.") + def ProcessListSaveStopSafe(self): + """ + Save the state and do the stop safe for the all processes + """ + for lProcessItem in self.mProcessList: + lProcessItem.StatusSave() + lProcessItem.StopSafe() + + def ProcessListRestore(self): + """ + Restore the process state for the all processes + """ + for lProcessItem in self.mProcessList: + lProcessItem.StatusRestore() + + def __OSCMDShell__(self, inCMDStr): """ - Detect the way of use and send the cmd + Detect the way of use and send the cmd. Wait for command execution! :return: None is not exists """ @@ -82,19 +100,62 @@ class Git(): lIsLastBool = True return lIsLastBool + def BranchRevLastGet(self, inBranchLocalStr: str, inBranchRemoteStr: str, inBranchRestoreBool: bool = True): + """Do some action to get the last revision + + :param inBranchLocalStr: [description] + :type inBranchLocalStr: str + :param inBranchRemoteStr: [description] + :type inBranchRemoteStr: str + """ + # check if the correct revision + if self.BranchRevIsLast(inBranchLocalStr=inBranchLocalStr, inBranchRemoteStr=inBranchRemoteStr) == False: + lBranchNameCurrentStr = self.BranchNameGet() + # reset all changes in local folder + self.Clear() + # checkout + self.BranchCheckout(inBranchNameStr=inBranchLocalStr) + # merge + lCMDStr = f"cd \"{self.mAbsPathUpperStr}\" && git merge {inBranchRemoteStr}" + lCMDResultStr = self.__OSCMDShell__(inCMDStr=lCMDStr) + if inBranchRestoreBool == True: + # checkout to the source branch which was + self.BranchCheckout(inBranchNameStr=lBranchNameCurrentStr) + def BranchRevCheck(self, inBranchRemoteStr): - pass + """Check if branch is last. If not last -> do some actions to get last - def BranchNameGet(self): + :param inBranchRemoteStr: [description] + :type inBranchRemoteStr: [type] + """ pass - "git rev-parse --abbrev-ref HEAD" + + def BranchNameGet(self) -> str: + """Get the current local branch name + + :return: current local branch name + """ + #"git rev-parse --abbrev-ref HEAD" + lCMDStr = f"cd \"{self.mAbsPathUpperStr}\" && git rev-parse --abbrev-ref HEAD" + lCMDResultStr = self.__OSCMDShell__(inCMDStr=lCMDStr) + return lCMDResultStr def BranchCheckout(self, inBranchNameStr): pass f"git clean -f -d" # Очистить от лишних файлов - f"git reset --hard" # Откатить файлы, которые отслеживаются Git и которые были изменены + f"git checkout {inBranchNameStr}" + def Clear(self): + """Clear the all changes in the local folder. Get up to the current revision + """ + # f"git clean -f -d" # Очистить от лишних файлов + lCMDStr = f"cd \"{self.mAbsPathUpperStr}\" && git clean -f -d" + lCMDResultStr = self.__OSCMDShell__(inCMDStr=lCMDStr) + # f"git reset --hard" # Откатить файлы, которые отслеживаются Git и которые были изменены + lCMDStr = f"cd \"{self.mAbsPathUpperStr}\" && git reset --hard" + lCMDResultStr = self.__OSCMDShell__(inCMDStr=lCMDStr) + def Fetch(self): """ Get updates from the git server.