Mathis/allianceauth
1
0
Fork 0
mirror of https://gitlab.com/allianceauth/allianceauth.git synced 2025-07-11 05:20:16 +02:00
Code Issues Packages Projects Releases Wiki Activity

Reduced number of api calls to improve response time.

Browse Source
This commit is contained in:
Adarnof 2015-12-02 03:22:18 +00:00
parent 563967bf0d
commit b9db6fc38c
1 changed files with 91 additions and 85 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

176
services/managers/discord_manager.py
View File

@ -8,8 +8,28 @@ DISCORD_URL = "https://discordapp.com/api"
class DiscordAPIManager: class DiscordAPIManager:
def __init__(self): def __init__(self, server_id, email, password):
pass data = {
"email" : email,
"password": password,
}
custom_headers = {'content-type':'application/json'}
path = DISCORD_URL + "/auth/login"
r = requests.post(path, headers=custom_headers, data=json.dumps(data))
r.raise_for_status()
self.token = r.json()['token']
self.email = email
self.password = password
self.server_id = server_id
def __del__(self):
if hasattr(self, 'token'):
if self.token and self.token != "":
data = {'token': self.token}
path = DISCORD_URL + "/auth/logout"
custom_headers = {'content-type':'application/json'}
r = requests.post(path, headers=custom_headers, data=json.dumps(data))
r.raise_for_status()
@staticmethod @staticmethod
def get_auth_token(): def get_auth_token():
@ -23,88 +43,77 @@ class DiscordAPIManager:
r.raise_for_status() r.raise_for_status()
return r.json()['token'] return r.json()['token']
@staticmethod def add_server(self, name):
def add_server(name):
data = {"name": name} data = {"name": name}
custom_headers = {'content-type':'application/json', 'authorization': DiscordAPIManager.get_auth_token()} custom_headers = {'content-type':'application/json', 'authorization': self.token}
path = DISCORD_URL + "/guilds" path = DISCORD_URL + "/guilds"
r = requests.post(path, headers=custom_headers, data=json.dumps(data)) r = requests.post(path, headers=custom_headers, data=json.dumps(data))
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
@staticmethod def rename_server(self, name):
def rename_server(server_id, name):
data = {"name": name} data = {"name": name}
custom_headers = {'content-type':'application/json', 'authorization': DiscordAPIManager.get_auth_token()} custom_headers = {'content-type':'application/json', 'authorization': self.token}
path = DISCORD_URL + "/guilds/" + str(server_id) path = DISCORD_URL + "/guilds/" + str(self.server_id)
r = requests.patch(path, headers=custom_headers, data=json.dumps(data)) r = requests.patch(path, headers=custom_headers, data=json.dumps(data))
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
@staticmethod def delete_server(self):
def delete_server(server_id): custom_headers = {'content-type':'application/json', 'authorization': self.token}
custom_headers = {'content-type':'application/json', 'authorization': DiscordAPIManager.get_auth_token()} path = DISCORD_URL + "/guilds/" + str(self.server_id)
path = DISCORD_URL + "/guilds/" + str(server_id)
r = requests.delete(path, headers=custom_headers) r = requests.delete(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
@staticmethod def get_members(self):
def get_members(server_id): custom_headers = {'accept':'application/json', 'authorization': self.token}
custom_headers = {'accept':'application/json', 'authorization': DiscordAPIManager.get_auth_token()} path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/members"
path = DISCORD_URL + "/guilds/" + str(server_id) + "/members"
r = requests.get(path, headers=custom_headers) r = requests.get(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
@staticmethod def get_bans(self):
def get_bans(server_id): custom_headers = {'accept':'application/json', 'authorization': self.token}
custom_headers = {'accept':'application/json', 'authorization': DiscordAPIManager.get_auth_token()} path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/bans"
path = DISCORD_URL + "/guilds/" + str(server_id) + "/bans"
r = requests.get(path, headers=custom_headers) r = requests.get(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
@staticmethod def ban_user(self, user_id, delete_message_age=0):
def ban_user(server_id, user_id, delete_message_age=0): custom_headers = {'authorization': self.token}
custom_headers = {'authorization': DiscordAPIManager.get_auth_token()} path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/bans/" + str(user_id) + "?delete-message-days=" + str(delete_message_age)
path = DISCORD_URL + "/guilds/" + str(server_id) + "/bans/" + str(user_id) + "?delete-message-days=" + str(delete_message_age)
r = requests.put(path, headers=custom_headers) r = requests.put(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
@staticmethod def unban_user(self, user_id):
def unban_user(server_id, user_id): custom_headers = {'authorization': self.token}
custom_headers = {'authorization': DiscordAPIManager.get_auth_token()} path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/bans/" + str(user_id)
path = DISCORD_URL + "/guilds/" + str(server_id) + "/bans/" + str(user_id)
r = requests.delete(path, headers=custom_headers) r = requests.delete(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
@staticmethod def generate_role(self):
def generate_role(server_id): custom_headers = {'accept':'application/json', 'authorization': self.token}
custom_headers = {'accept':'application/json', 'authorization': DiscordAPIManager.get_auth_token()} path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/roles"
path = DISCORD_URL + "/guilds/" + str(server_id) + "/roles"
r = requests.post(path, headers=custom_headers) r = requests.post(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
@staticmethod def edit_role(self, role_id, name, color=0, hoist=True, permissions=36785152):
def edit_role(server_id, role_id, name, color=0, hoist=True, permissions=36785152): custom_headers = {'content-type':'application/json', 'authorization': self.token}
custom_headers = {'content-type':'application/json', 'authorization': DiscordAPIManager.get_auth_token()}
data = { data = {
'color': color, 'color': color,
'hoist': hoist, 'hoist': hoist,
'name': name, 'name': name,
'permissions': permissions, 'permissions': permissions,
} }
path = DISCORD_URL + "/guilds/" + str(server_id) + "/roles/" + str(role_id) path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/roles/" + str(role_id)
r = requests.patch(path, headers=custom_headers, data=json.dumps(data)) r = requests.patch(path, headers=custom_headers, data=json.dumps(data))
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
def delete_role(self, role_id):
@staticmethod custom_headers = {'authorization': self.token}
def delete_role(server_id, role_id): path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/roles/" + str(role_id)
custom_headers = {'authorization': DiscordAPIManager.get_auth_token()}
path = DISCORD_URL + "/guilds/" + str(server_id) + "/roles/" + str(role_id)
r = requests.delete(path, headers=custom_headers) r = requests.delete(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
@ -124,10 +133,9 @@ class DiscordAPIManager:
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
@staticmethod def create_invite(self, max_age=600, max_uses=1, temporary=True, xkcdpass=False):
def create_invite(server_id, max_age=600, max_uses=1, temporary=True, xkcdpass=False): custom_headers = {'authorization': self.token}
custom_headers = {'authorization': DiscordAPIManager.get_auth_token()} path = DISCORD_URL + "/channels/" + str(self.server_id) + "/invites"
path = DISCORD_URL + "/channels/" + str(server_id) + "/invites"
data = { data = {
'max_age': max_age, 'max_age': max_age,
'max_uses': max_uses, 'max_uses': max_uses,
@ -138,17 +146,15 @@ class DiscordAPIManager:
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
@staticmethod def delete_invite(self, invite_id):
def delete_invite(invite_id): custom_headers = {'authorization': self.token}
custom_headers = {'authorization': DiscordAPIManager.get_auth_token()}
path = DISCORD_URL + "/invite/" + str(invite_id) path = DISCORD_URL + "/invite/" + str(invite_id)
r = requests.delete(path, headers=custom_headers) r = requests.delete(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
@staticmethod def set_roles(self, user_id, role_ids):
def set_roles(server_id, user_id, role_ids): custom_headers = {'authorization': self.token, 'content-type':'application/json'}
custom_headers = {'authorization': DiscordAPIManager.get_auth_token(), 'content-type':'application/json'} path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/members/" + str(user_id)
path = DISCORD_URL + "/guilds/" + str(server_id) + "/members/" + str(user_id)
data = { 'roles': role_ids } data = { 'roles': role_ids }
r = requests.patch(path, headers=custom_headers, data=json.dumps(data)) r = requests.patch(path, headers=custom_headers, data=json.dumps(data))
r.raise_for_status() r.raise_for_status()
@ -167,40 +173,35 @@ class DiscordAPIManager:
r = requests.post(path, headers=custom_headers, data=json.dumps(data)) r = requests.post(path, headers=custom_headers, data=json.dumps(data))
r.raise_for_status() r.raise_for_status()
@staticmethod def kick_user(self, user_id):
def kick_user(server_id, user_id): custom_headers = {'authorization': self.token}
custom_headers = {'authorization': DiscordAPIManager.get_auth_token()} path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/members/" + str(user_id)
path = DISCORD_URL + "/guilds/" + str(server_id) + "/members/" + str(user_id)
r = requests.delete(path, headers=custom_headers) r = requests.delete(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
@staticmethod def get_members(self):
def get_members(server_id): custom_headers = {'authorization': self.token, 'accept':'application/json'}
custom_headers = {'authorization': DiscordAPIManager.get_auth_token(), 'accept':'application/json'} path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/members"
path = DISCORD_URL + "/guilds/" + str(server_id) + "/members"
r = requests.get(path, headers=custom_headers) r = requests.get(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
@staticmethod def get_user_id(self, username):
def get_user_id(server_id, username): all_members = self.get_members()
all_members = DiscordAPIManager.get_members(server_id)
for member in all_members: for member in all_members:
if member['user']['username'] == username: if member['user']['username'] == username:
return member['user']['id'] return member['user']['id']
raise KeyError('User not found on server: ' + username) raise KeyError('User not found on server: ' + username)
@staticmethod def get_roles(self):
def get_roles(server_id): custom_headers = {'authorization': self.token, 'accept':'application/json'}
custom_headers = {'authorization': DiscordAPIManager.get_auth_token(), 'accept':'application/json'} path = DISCORD_URL + "/guilds/" + str(self.server_id) + "/roles"
path = DISCORD_URL + "/guilds/" + str(server_id) + "/roles"
r = requests.get(path, headers=custom_headers) r = requests.get(path, headers=custom_headers)
r.raise_for_status() r.raise_for_status()
return r.json() return r.json()
@staticmethod def get_group_id(self, group_name):
def get_group_id(server_id, group_name): all_roles = self.get_roles()
all_roles = DiscordAPIManager.get_roles(server_id)
for role in all_roles: for role in all_roles:
if role['name'] == group_name: if role['name'] == group_name:
return role['id'] return role['id']
@ -259,9 +260,8 @@ class DiscordAPIManager:
r.raise_for_status r.raise_for_status
return r.json() return r.json()
@staticmethod def check_if_user_banned(self, user_id):
def check_if_user_banned(server_id, user_id): bans = self.get_bans()
bans = DiscordAPIManager.get_bans(server_id)
for b in bans: for b in bans:
if b['user']['id'] == str(user_id): if b['user']['id'] == str(user_id):
return True return True
@ -283,28 +283,31 @@ class DiscordManager:
@staticmethod @staticmethod
def update_groups(user_id, groups): def update_groups(user_id, groups):
group_ids = [] group_ids = []
api = DiscordAPIManager(settings.DISCORD_SERVER_ID, settings.DISCORD_USER_EMAIL, settings.DISCORD_USER_PASSWORD)
if len(groups) == 0: if len(groups) == 0:
group_ids = [] group_ids = []
else: else:
for g in groups: for g in groups:
try: try:
group_id = DiscordAPIManager.get_group_id(settings.DISCORD_SERVER_ID, g) group_id = api.get_group_id(g)
group_ids.append(group_id) group_ids.append(group_id)
except: except:
# need to create role on server for group # need to create role on server for group
group_ids.append(DiscordManager.create_group(g)) group_ids.append(api.create_group(g))
DiscordAPIManager.set_roles(settings.DISCORD_SERVER_ID, user_id, group_ids) api.set_roles(user_id, group_ids)
@staticmethod @staticmethod
def create_group(groupname): def create_group(groupname):
new_group = DiscordAPIManager.generate_role(settings.DISCORD_SERVER_ID) api = DiscordAPIManager(settings.DISCORD_SERVER_ID, settings.DISCORD_USER_EMAIL, settings.DISCORD_USER_PASSWORD)
named_group = DiscordAPIManager.edit_role(settings.DISCORD_SERVER_ID, new_group['id'], groupname) new_group = api.generate_role()
named_group = api.edit_role(new_group['id'], groupname)
return named_group['id'] return named_group['id']
@staticmethod @staticmethod
def lock_user(user_id): def lock_user(user_id):
try: try:
DiscordAPIManager.ban_user(settings.DISCORD_SERVER_ID, user_id) api = DiscordAPIManager(settings.DISCORD_SERVER_ID, settings.DISCORD_USER_EMAIL, settings.DISCORD_USER_PASSWORD)
api.ban_user(user_id)
return True return True
except: except:
return False return False
@ -312,7 +315,8 @@ class DiscordManager:
@staticmethod @staticmethod
def unlock_user(user_id): def unlock_user(user_id):
try: try:
DiscordAPIManager.unban_user(settings.DISCORD_SERVER_ID, user_id) api = DiscordAPIManager(settings.DISCORD_SERVER_ID, settings.DISCORD_USER_EMAIL, settings.DISCORD_USER_PASSWORD)
api.unban_user(user_id)
return True return True
except: except:
return False return False
@ -329,11 +333,12 @@ class DiscordManager:
@staticmethod @staticmethod
def add_user(email, password): def add_user(email, password):
try: try:
api = DiscordAPIManager(settings.DISCORD_SERVER_ID, settings.DISCORD_USER_EMAIL, settings.DISCORD_USER_PASSWORD)
profile = DiscordAPIManager.get_user_profile(email, password) profile = DiscordAPIManager.get_user_profile(email, password)
user_id = profile['id'] user_id = profile['id']
if DiscordAPIManager.check_if_user_banned(settings.DISCORD_SERVER_ID, user_id): if api.check_if_user_banned(user_id):
DiscordAPIManager.unban_user(settings.DISCORD_SERVER_ID, user_id) api.unban_user(user_id)
invite_code = DiscordAPIManager.create_invite(settings.DISCORD_SERVER_ID)['code'] invite_code = api.create_invite()['code']
token = DiscordAPIManager.get_token_by_user(email, password) token = DiscordAPIManager.get_token_by_user(email, password)
DiscordAPIManager.accept_invite(invite_code, token) DiscordAPIManager.accept_invite(invite_code, token)
return user_id return user_id
@ -343,8 +348,9 @@ class DiscordManager:
@staticmethod @staticmethod
def delete_user(user_id): def delete_user(user_id):
try: try:
api = DiscordAPIManager(settings.DISCORD_SERVER_ID, settings.DISCORD_USER_EMAIL, settings.DISCORD_USER_PASSWORD)
DiscordManager.update_groups(user_id, []) DiscordManager.update_groups(user_id, [])
DiscordAPIManager.ban_user(settings.DISCORD_SERVER_ID, user_id) api.ban_user(user_id)
return True return True
except: except:
return False return False