deadcxap/Membarr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cleaning up

Browse Source
This commit is contained in:
Faiz Ahmed
2021-07-17 16:10:35 -04:00
parent 26970ac780
commit 1d1af8f7e6
5 changed files with 45 additions and 196 deletions
Download Patch File Download Diff File Expand all files Collapse all files

198
app/cogs/Invitarr.py
View File

@@ -9,213 +9,25 @@ from discord import Webhook, AsyncWebhookAdapter
import aiohttp import aiohttp
import texttable import texttable
import sys import sys
from app.header.configparser import roleid, PLEXUSER, PLEXPASS, PLEX_SERVER_NAME, Plex_LIBS, chan, ownerid, auto_remove_user from app.header.configparser import roleid, PLEXUSER, PLEXPASS, PLEX_SERVER_NAME, Plex_LIBS, chan, ownerid
sys.stdout = sys.stderr sys.stdout = sys.stderr
Plex_LIBS = list(Plex_LIBS.split(',')) Plex_LIBS = list(Plex_LIBS.split(','))
roleid = list(roleid.split(',')) roleid = list(roleid.split(','))
print(roleid)
if auto_remove_user:
print("auto remove user = True")
import db as db
account = MyPlexAccount(PLEXUSER, PLEXPASS) account = MyPlexAccount(PLEXUSER, PLEXPASS)
plex = account.resource(PLEX_SERVER_NAME).connect() # returns a PlexServer instance plex = account.resource(PLEX_SERVER_NAME).connect() # returns a PlexServer instance
def plexadd(plexname): class app(commands.Cog):
try:
plex.myPlexAccount().inviteFriend(user=plexname, server=plex, sections=Plex_LIBS, allowSync=False,
allowCameraUpload=False, allowChannels=False, filterMovies=None,
filterTelevision=None, filterMusic=None)
except Exception as e: @commands.Cog.listener()
print(e)
return False
else:
print(plexname +' has been added to plex (☞ຈل͜ຈ)☞')
return True
def plexremove(plexname):
try:
plex.myPlexAccount().removeFriend(user=plexname)
except Exception as e:
print(e)
return False
else:
print(plexname +' has been removed from plex (☞ຈل͜ຈ)☞')
return True
class MyClient(discord.Client):
async def on_ready(self): async def on_ready(self):
print('Made by Sleepingpirate https://github.com/Sleepingpirates/') print('Made by Sleepingpirate https://github.com/Sleepingpirates/')
print('Logged in as') print('Logged in as')
print(self.user.name) print(self.user.name)
print(self.user.id) print(self.user.id)
print('------') print('------')
await client.change_presence(activity=discord.Game(name="Admins can do -help"))
async def on_member_update(self, before, after):
secure = client.get_channel(chan)
for role_for_plex in roleid:
role = after.guild.get_role(int(role_for_plex))
if (role in after.roles and role not in before.roles):
await after.send('Welcome To '+ PLEX_SERVER_NAME +'. Just reply with your email so we can add you to Plex!')
await after.send('I will wait 10 minutes for your message, if you do not send it by then I will cancel the command.')
def check(m):
return m.author == after and not m.guild
try:
email = await client.wait_for('message', timeout=600, check=check)
except asyncio.TimeoutError:
await after.send('Timed Out. Message Server Admin So They Can Add You Manually.')
return
else:
await asyncio.sleep(5)
await after.send('Got it we will be processing your email shortly')
print(email.content) #make it go to a log channel
plexname = str(email.content)
if plexadd(plexname):
if auto_remove_user:
db.save_user(str(after.id), email.content)
await asyncio.sleep(20)
await after.send('You have Been Added To Plex!')
await secure.send(plexname + ' ' + after.mention + ' was added to plex')
else:
await after.send('There was an error adding this email address. Message Server Admin.')
return
elif(role not in after.roles and role in before.roles):
if auto_remove_user:
try:
user_id = after.id
email = db.get_useremail(user_id)
plexremove(email)
deleted = db.delete_user(user_id)
if deleted:
print("Removed {} from db".format(email))
await secure.send(plexname + ' ' + after.mention + ' was removed from plex')
else:
print("Cannot remove this user from db.")
except:
print("Cannot remove this user from plex.")
return
async def on_message(self, message):
secure = client.get_channel(chan)
if message.author.id == self.user.id:
return
if message.author.guild_permissions.administrator:
if message.content.startswith('-plex add'):
mgs = message.content.replace('-plex add ','')
if plexadd(mgs):
await secure.send('The email has been added! {0.author.mention}'.format(message))
else:
await secure.send('Error Check Logs! {0.author.mention}'.format(message))
if message.content.startswith('-plex rm'):
mgs = message.content.replace('-plex rm ','')
if plexremove(mgs):
await secure.send('The email has been removed! {0.author.mention}'.format(message))
else:
await secure.send('Error Check Logs! {0.author.mention}'.format(message))
if message.author.guild_permissions.administrator:
if message.content.startswith('-db add'):
mgs = message.content.replace('-db add ','')
try:
mgs = mgs.split(' ')
email = mgs[0]
if(plexadd(email)):
await message.channel.send('User has been added to plex.')
else:
await message.channel.send('Error adding email to plex. Ignore this if the email already exist in plex.')
bad_chars = ['<','>','@','!']
user_id = mgs[1]
for i in bad_chars:
user_id = user_id.replace(i, '')
db.save_user(user_id, email)
await message.channel.send(email + ' ' + mgs[1] + ' was added to the database.')
except:
await message.channel.send('Cannot add this user to db.')
print("Cannot add this user to db.")
#await message.delete()
if message.author.guild_permissions.administrator:
if message.content.startswith('-db ls') or message.content.startswith('-db rm'):
embed = discord.Embed(title='Invitarr Database.')
all = db.read_useremail()
table = texttable.Texttable()
table.set_cols_dtype(["t", "t", "t"])
table.set_cols_align(["c", "c", "c"])
header = ("#", "Name", "Email")
table.add_row(header)
for index, peoples in enumerate(all):
index = index + 1
id = int(peoples[1])
dbuser = client.get_user(id)
dbemail = peoples[2]
try:
username = dbuser.name
except:
username = "User Not Found."
embed.add_field(name=f"**{index}. {username}**", value=dbemail+'\n', inline=False)
table.add_row((index, username, dbemail))
if message.content.startswith('-db ls'):
total = str(len(all))
if(len(all)>25):
f = open("db.txt", "w")
f.write(table.draw())
f.close()
await message.channel.send("Database too large! Total: {total}".format(total = total),file=discord.File('db.txt'))
else:
await message.channel.send(embed = embed)
else:
try:
position = message.content.replace("-db rm", "")
position = int(position) - 1
id = all[position][1]
email = db.get_useremail(id)
deleted = db.delete_user(id)
if deleted:
print("Removed {} from db".format(email))
await secure.send("Removed {} from db".format(email))
else:
print("Cannot remove this user from db.")
except Exception as e:
print(e)
if message.content.startswith('-help'):
embed = discord.Embed(title='Invitarr Bot Commands', description='Made by [Sleepingpirates](https://github.com/Sleepingpirates/Invitarr), [Join Discord Server](https://discord.gg/vcxCytN)')
embed.add_field(name='-plex add <email>', value='This command is used to add an email to plex', inline=False)
embed.add_field(name='-plex rm <email>', value='This command is used to remove an email from plex', inline=False)
embed.add_field(name='-db ls', value='This command is used list Invitarrs database', inline=False)
embed.add_field(name='-db add <email> <@user>', value='This command is used to add exsisting users email and discord id to the DB. Bot tries to add email to plex', inline=False)
embed.add_field(name='-db rm <position>', value='This command is used remove a record from the Db. Use -db ls to determine record position. ex: -db rm 1', inline=False)
await message.channel.send(embed = embed)
async def on_member_remove(self, member): def setup(bot):
if auto_remove_user: bot.add_cog(app(bot))
try:
user_id = member.id ## not there
email = db.get_useremail(user_id)
plexremove(email)
deleted = db.delete_user(user_id)
if deleted:
print("Removed {} from db".format(email))
else:
print("Cannot remove this user from db.")
except:
print("Cannot remove this user from plex.")
client = MyClient()
client.run(Discord_bot_token)

4
app/config/.gitignore vendored
View File

@@ -2,3 +2,7 @@
* *
# Except this file # Except this file
!.gitignore !.gitignore
######################################################################################################
# Only for old docker users who already have config mounted at /app/app/config/config.ini
######################################################################################################

2
app/helper/confighelper.py
View File

@@ -39,7 +39,7 @@ auto_remove_user = ""
switch = 0 switch = 0
try: try:
if(path.exists(CONFIG_PATH)): if(path.exists(CONFIG_PATH)): #Only for old docker users who already have config mounted at /app/app/config/config.ini
config = configparser.ConfigParser() config = configparser.ConfigParser()
config.read(CONFIG_PATH) config.read(CONFIG_PATH)
Discord_bot_token = config.get(BOT_SECTION, 'discord_bot_token') Discord_bot_token = config.get(BOT_SECTION, 'discord_bot_token')

34
app/helper/plexhelper.py Normal file
View File

@@ -0,0 +1,34 @@
from plexapi.myplex import MyPlexAccount
import re
def plexadd(plex, plexname):
try:
plex.myPlexAccount().inviteFriend(user=plexname, server=plex, sections=Plex_LIBS, allowSync=False,
allowCameraUpload=False, allowChannels=False, filterMovies=None,
filterTelevision=None, filterMusic=None)
except Exception as e:
print(e)
return False
else:
print(plexname +' has been added to plex (☞ຈل͜ຈ)☞')
return True
def plexremove(plex, plexname):
try:
plex.myPlexAccount().removeFriend(user=plexname)
except Exception as e:
print(e)
return False
else:
print(plexname +' has been removed from plex (☞ຈل͜ຈ)☞')
return True
def verifyemail(addressToVerify):
regex = '^[_a-z0-9-]+(\.[_a-z0-9-]+)*@[a-z0-9-]+(\.[a-z0-9-]+)*(\.[a-z]{2,})$'
match = re.match(regex, addressToVerify)
if match == None:
return False
else:
return True

3
bot.env
View File

@@ -5,5 +5,4 @@ role_id=
plex_server_name= plex_server_name=
plex_libs= plex_libs=
owner_id= owner_id=
channel_id= channel_id=
auto_remove_user=True