[+] Encapsulate Scheduler.updateInterval
This commit is contained in:
+3
-1
@@ -173,14 +173,16 @@ def interval(update: Update, context: CallbackContext):
|
|||||||
name = context.args[0]
|
name = context.args[0]
|
||||||
if name not in database.userRequests[user]:
|
if name not in database.userRequests[user]:
|
||||||
return "*Error:* %s doesn't exist." % name
|
return "*Error:* %s doesn't exist." % name
|
||||||
|
request = database.userRequests[user][name]
|
||||||
|
|
||||||
# Validate the interval of the interval
|
# Validate the interval of the interval
|
||||||
i = int(context.args[1])
|
i = int(context.args[1])
|
||||||
if i < 40 or i > 60*60*24:
|
if i < 40 or i > 60*60*24:
|
||||||
return "*Error:* %s is too long or too short. (Min: 40s, Max: 60 * 60 * 24s)" % i
|
return "*Error:* %s is too long or too short. (Min: 40s, Max: 60 * 60 * 24s)" % i
|
||||||
|
|
||||||
database.userRequests[user][name]['interval'] = i
|
request['interval'] = i
|
||||||
database.save()
|
database.save()
|
||||||
|
scheduler.updateInterval(user, name, request)
|
||||||
|
|
||||||
return "Success!"
|
return "Success!"
|
||||||
|
|
||||||
|
|||||||
@@ -84,3 +84,10 @@ class Scheduler:
|
|||||||
def isStarted(self, user: str, name: str):
|
def isStarted(self, user: str, name: str):
|
||||||
return user in self.tasks and name in self.tasks[user]
|
return user in self.tasks and name in self.tasks[user]
|
||||||
|
|
||||||
|
def updateInterval(self, user: str, name: str, request):
|
||||||
|
if not self.isStarted(user, name):
|
||||||
|
return False
|
||||||
|
|
||||||
|
self.stop(user, name)
|
||||||
|
self.start(user, request)
|
||||||
|
return True
|
||||||
|
|||||||
Reference in New Issue
Block a user