Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
for item in ContentListWidget.currentcontent['children']:
if item['name'] == str(text):
self.mainwindow.errorbox('That Directory Name Already Exists!')
return
try:
logger.info("Creating New Folder in Personal Folder Tree")
sumo = SumoLogic(id, key, endpoint=url)
error = sumo.create_folder(str(text), str(ContentListWidget.currentcontent['id']),
adminmode=adminmode)
self.updatecontentlist(ContentListWidget, url, id, key, radioselected, directorylabel)
return
except Exception as e:
logger.exception(e)
self.mainwindow.errorbox('Something went wrong:\n\n' + str(e))
else:
self.mainwindow.errorbox("Please update the directory list before trying to create a new folder.")
return
order = auth.create_limit_buy_order(
order_status['symbol'], amount(left), price)
elif (remaining == 0.0 or remaining == 0):
logger.info('Successfully bought ' + target)
self.__notify('Successfully bought ' + target + ' @ ' +
'{0:.8f}'.format(price) + ' ' + base)
break
sleep(self.refreshrate)
except (ccxt.InvalidOrder, ccxt.InsufficientFunds):
logger.info('Invalid order or quantity')
logger.info('Funds: ' + str(self.funds))
logger.info('Amount: ' + str(amount(self.funds)))
except Exception as e:
logger.exception(e)
if not peer:
return await result_queue.put('skipped')
bot_checker.update_bot_details(to_check, peer=peer)
# Check online state
try:
response = await bot_checker.get_ping_response(
to_check,
timeout=30,
try_inline=to_check.inlinequeries)
except UnknownError as e:
await result_queue.put(e.MESSAGE)
return
except Exception as e:
log.exception(e)
await result_queue.put(str(e))
return
for _ in range(2):
await result_queue.put('messages sent')
was_offline = to_check.offline
is_offline = response.empty if isinstance(response, Response) else not bool(response)
now = datetime.now()
to_check.last_ping = now
if not is_offline:
to_check.last_response = now
if was_offline != is_offline:
bot.send_message(settings.BOTLIST_NOTIFICATIONS_ID, '{} went {}.'.format(
def update_FER_listwidget(self, FERListWidget):
try:
FERListWidget.clear()
FERListWidget.setSortingEnabled(True)
for object in FERListWidget.currentcontent:
item_name = object['name']
FERListWidget.addItem(item_name) # populate the list widget in the GUI
FERListWidget.updated = True
except Exception as e:
logger.exception(e)
return
jobrecords = []
if savetofile:
filenameqstring, _ = QtWidgets.QFileDialog.getSaveFileName(self, 'Save CSV', '', filter='*.csv')
filename = str(filenameqstring)
savefilepath = pathlib.Path(filename)
if (re.match(regexprog, id) != None) and (re.match(regexprog, key) != None):
sumo = SumoLogic(id, key, endpoint=url)
if (re.match(regexprog, searchstring)) != None:
try:
searchjob = sumo.search_job(searchstring, starttime, endtime, selectedtimezone)
jobsubmitted = True
except Exception as e:
self.errorbox("Failed to submit search job. Check credentials, endpoint, and query.")
logger.exception(e)
return
if jobsubmitted:
try:
self.labelSearchResultCount.setText('0')
jobstatus = sumo.search_job_status(searchjob)
nummessages = jobstatus['messageCount']
numrecords = jobstatus['recordCount']
self.labelSearchResultCount.setText(str(nummessages))
while jobstatus['state'] == 'GATHERING RESULTS':
jobstatus = sumo.search_job_status(searchjob)
numrecords = jobstatus['recordCount']
nummessages = jobstatus['messageCount']
self.labelSearchResultCount.setText(str(nummessages))
logger.info('Search Job finished. Downloading Results.')
except Exception as e:
logger.exception(e)
def getcollectorid(self, collectorname, url, id, key):
logger.info("Getting Collector IDs")
sumo = SumoLogic(id, key, endpoint=url)
try:
sumocollectors = sumo.get_collectors_sync()
for sumocollector in sumocollectors:
if sumocollector['name'] == collectorname:
return sumocollector['id']
except Exception as e:
logger.exception(e)
return
sumo = SumoLogic(id, key, endpoint=url)
for file in filelist:
try:
with open(file) as filepointer:
sv_backup = json.load(filepointer)
except Exception as e:
logger.exception(e)
self.mainwindow.errorbox(
"Something went wrong reading the file. Do you have the right file permissions? Does it contain valid JSON?")
return
try:
local_time = datetime.now(timezone.utc).astimezone()
status = sumo.create_scheduled_view(sv_backup['indexName'], sv_backup['query'], local_time.isoformat())
except Exception as e:
logger.exception(e)
self.mainwindow.errorbox('Something went wrong:\n\n' + str(e))
return
self.update_SV_list(SVListWidget, url, id, key)
else:
self.mainwindow.errorbox("Please select at least one file to restore.")
return
else:
self.mainwindow.errorbox("Please update the directory list before restoring content")
return
dirname = ''
for dir in ContentListWidget.currentdirlist:
dirname = dirname + '/' + dir['name']
directorylabel.setText(dirname)
ContentListWidget.updated = True
# if we are in the root (Top) of the global folders then we can't manipulate stuff as the entries are actually users, not content
# so turn off the buttons until we change folder type or move down a level
currentdir = ContentListWidget.currentdirlist[-1]
if currentdir['id'] == 'TOP' and radioselected == -3:
self.togglecontentbuttons(ContentListWidget.side, False)
else:
self.togglecontentbuttons(ContentListWidget.side, True)
except Exception as e:
logger.exception(e)
return
dirname = ''
for dir in ContentListWidget.currentdirlist:
dirname = dirname + '/' + dir['name']
directorylabel.setText(dirname)
ContentListWidget.updated = True
# if we are in the root (Top) of the global folders then we can't manipulate stuff as the entries are actually users, not content
# so turn off the buttons until we change folder type or move down a level
currentdir = ContentListWidget.currentdirlist[-1]
if currentdir['id'] == 'TOP' and radioselected == -3:
self.togglecontentbuttons(ContentListWidget.side, False)
else:
self.togglecontentbuttons(ContentListWidget.side, True)
except Exception as e:
logger.exception(e)
return