Nemcio/CyberPanel
1
0
Fork 0
mirror of https://github.com/usmannasir/cyberpanel.git synced 2026-06-26 19:50:06 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix gdrive token update

Browse Source
This commit is contained in:
usman@cyberpersons.com
2023-04-08 23:40:11 +05:00
parent 9969aa5dd9
commit f4952072c4
2 changed files with 47 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

69
plogical/Backupsv2.py
View File

@@ -61,36 +61,56 @@ class CPBackupsV2(multi.Thread):
reponame = self.data['BackendName']
path = '/home/%s/.config/rclone/rclone.conf' % (self.data['domain'])
try:
### refresh token if gdrie
command = f"rclone config dump"
token = json.loads(ProcessUtilities.outputExecutioner(command, self.website.externalApp, True).rstrip('\n'))
command = 'cat %s' % (path)
CurrentContent = pu.outputExecutioner(command)
refreshToken = json.loads(token[reponame]['token'])['refresh_token']
logging.CyberCPLogFileWriter.writeToFile(f"Refresh Token: {refreshToken}")
new_Acess_token = self.refresh_V2Gdive_token(refreshToken)
command = f"""rclone config update {reponame} token '{{"access_token":"{new_Acess_token}","token_type":"Bearer","refresh_token":"{refreshToken}","expiry":"2024-04-08T21:53:00.123456789Z"}}' --non-interactive"""
result = ProcessUtilities.outputExecutioner(command, self.website.externalApp, True)
if os.path.exists(ProcessUtilities.debugPath):
logging.CyberCPLogFileWriter.writeToFile(result)
if CurrentContent.find(reponame) > -1:
config = configparser.ConfigParser()
config.read_string(CurrentContent)
except BaseException as msg:
logging.CyberCPLogFileWriter.writeToFile(f"Token Not upadate inside. Error: {str(msg)}")
pass
token_str = config.get(reponame, 'token')
token_dict = json.loads(token_str)
refresh_token = token_dict['refresh_token']
# command = 'cat %s' % (path)
# CurrentContent = pu.outputExecutioner(command)
new_Acess_token = self.refresh_V2Gdive_token(refresh_token)
old_access_token = token_dict['access_token']
new_content = CurrentContent.replace(str(old_access_token), new_Acess_token)
command = f"cat /dev/null > {self.ConfigFilePath}"
pu.executioner(command, self.website.externalApp, True)
command = f"echo '{new_content}' >> {self.ConfigFilePath}"
ProcessUtilities.executioner(command, self.website.externalApp, True)
command = f"chmod 600 {self.ConfigFilePath}"
ProcessUtilities.executioner(command, self.website.externalApp)
else:
logging.CyberCPLogFileWriter.writeToFile("Token Not upadate..........")
# if CurrentContent.find(reponame) > -1:
# config = configparser.ConfigParser()
# config.read_string(CurrentContent)
#
# token_str = config.get(reponame, 'token')
# token_dict = json.loads(token_str)
# refresh_token = token_dict['refresh_token']
#
# new_Acess_token = self.refresh_V2Gdive_token(refresh_token)
#
# old_access_token = token_dict['access_token']
#
# new_content = CurrentContent.replace(str(old_access_token), new_Acess_token)
#
# command = f"cat /dev/null > {self.ConfigFilePath}"
# pu.executioner(command, self.website.externalApp, True)
#
# command = f"echo '{new_content}' >> {self.ConfigFilePath}"
# ProcessUtilities.executioner(command, self.website.externalApp, True)
#
# command = f"chmod 600 {self.ConfigFilePath}"
# ProcessUtilities.executioner(command, self.website.externalApp)
# else:
# logging.CyberCPLogFileWriter.writeToFile("Token Not upadate..........")
except BaseException as msg:
logging.CyberCPLogFileWriter.writeToFile("Error update token............%s"%msg)
@@ -826,6 +846,7 @@ team_drive =
newtoken = json.loads(r.text)['access_token']
return newtoken
except BaseException as msg:
logging.CyberCPLogFileWriter.writeToFile(f'Error in tkupdate: {str(msg)}')
print("Error Update token:%s" % msg)
return None

2
plogical/test.py
View File

@@ -0,0 +1,2 @@
LaterCommand = """awk '/access_token/ {print $3}' | sed 's/[",]//g'"""
print(LaterCommand)