Valheim plus discord bot

18 files changed, 654 insertions, 0 deletions

diff --git a/code/config.py b/code/config.py
new file mode 100644
index 0000000..ea7abdc
--- /dev/null
+++ b/code/config.py
@@ -0,0 +1,46 @@
+# Still working on discord-side triggering
+
+# IMPORTANT! You must have a log for event reports and death leaderboards
+# logs are achieved by using -logfile flag on launch, or by logging stdout
+# Windows Users use forward slashes
+file = '/var/log/valheim.log'
+
+BOT_TOKEN = ""
+
+# Change ? to command prefix you want to use
+BOT_PREFIX = "!"
+
+# Server ip and port for A2S port needs to be +1 of the port number used in -port
+SERVER_ADDRESS = ("0.0.0.0",2457)
+
+# Shows up in embeds for stats report
+SERVER_NAME = "Server Name"
+
+# LOGCHAIN - where the bot outputs death and random mob events
+LOGCHAN_ID  = 000000000000000
+
+# use a locked VC channel to report player count, if not, set as False
+USEVCSTATS = True
+
+# VCHANNEL - where the bot shows server ticker, must be voice channel
+VCHANNEL_ID = 000000000000000000
+
+# MYSQL server info
+SQL_HOST = 'localhost'
+SQL_PORT = '3306'
+SQL_USER = 'username'
+SQL_PASS = 'password'
+SQL_DATABASE = 'database'
+
+# EXSERVERINFO - used to enable extra server data info gathering from logs ***Must add the extra server info table in mysql***
+EXSERVERINFO = True
+
+# World file location used for showing file size.
+WORLDSIZE = True
+worldfile = '/home/user/valheim/.config/unity3d/IronGate/Valheim/worlds/world.db.old'
+
+# Enable sending debug info to a channel
+USEDEBUGCHAN = True
+
+# BUGCHANNEL - where the bot shows debug info
+BUGCHANNEL_ID = 7293481670000121
diff --git a/code/img/Boar.png b/code/img/Boar.png
new file mode 100644
index 0000000..338e337
--- /dev/null
+++ b/code/img/Boar.png
diff --git a/code/img/Bonemass.png b/code/img/Bonemass.png
new file mode 100644
index 0000000..e2d62f6
--- /dev/null
+++ b/code/img/Bonemass.png
diff --git a/code/img/Drake.png b/code/img/Drake.png
new file mode 100644
index 0000000..252037a
--- /dev/null
+++ b/code/img/Drake.png
diff --git a/code/img/Draugr.png b/code/img/Draugr.png
new file mode 100644
index 0000000..5464d01
--- /dev/null
+++ b/code/img/Draugr.png
diff --git a/code/img/Eikthyr.png b/code/img/Eikthyr.png
new file mode 100644
index 0000000..86f4909
--- /dev/null
+++ b/code/img/Eikthyr.png
diff --git a/code/img/Fuling.png b/code/img/Fuling.png
new file mode 100644
index 0000000..ea201d9
--- /dev/null
+++ b/code/img/Fuling.png
diff --git a/code/img/Greydwarf.png b/code/img/Greydwarf.png
new file mode 100644
index 0000000..040a583
--- /dev/null
+++ b/code/img/Greydwarf.png
diff --git a/code/img/Moder.png b/code/img/Moder.png
new file mode 100644
index 0000000..086db8a
--- /dev/null
+++ b/code/img/Moder.png
diff --git a/code/img/Ooze.png b/code/img/Ooze.png
new file mode 100644
index 0000000..4bdae51
--- /dev/null
+++ b/code/img/Ooze.png
diff --git a/code/img/The_Elder.png b/code/img/The_Elder.png
new file mode 100644
index 0000000..6a722f7
--- /dev/null
+++ b/code/img/The_Elder.png
diff --git a/code/img/Yagluth.png b/code/img/Yagluth.png
new file mode 100644
index 0000000..d36b290
--- /dev/null
+++ b/code/img/Yagluth.png
diff --git a/code/img/skeleton.png b/code/img/skeleton.png
new file mode 100644
index 0000000..c6f44fa
--- /dev/null
+++ b/code/img/skeleton.png
diff --git a/code/img/surtling.png b/code/img/surtling.png
new file mode 100644
index 0000000..5b94211
--- /dev/null
+++ b/code/img/surtling.png
diff --git a/code/img/temp.png b/code/img/temp.png
new file mode 100644
index 0000000..8c40edc
--- /dev/null
+++ b/code/img/temp.png
diff --git a/code/img/troll.png b/code/img/troll.png
new file mode 100644
index 0000000..ee2fdb8
--- /dev/null
+++ b/code/img/troll.png
diff --git a/code/img/wolf.png b/code/img/wolf.png
new file mode 100644
index 0000000..9a5f612
--- /dev/null
+++ b/code/img/wolf.png
diff --git a/code/plusbot.py b/code/plusbot.py
new file mode 100644
index 0000000..cf026b7
--- /dev/null
+++ b/code/plusbot.py
@@ -0,0 +1,608 @@
+import os, time, re, discord, asyncio, config, emoji, sys, colorama, typing, signal, errno, mysql.connector, a2s
+from matplotlib import pyplot as plt
+from datetime import datetime, timedelta
+from colorama import Fore, Style, init
+from config import LOGCHAN_ID as lchanID
+from config import VCHANNEL_ID as chanID
+from config import BUGCHANNEL_ID as dbchanID
+from config import SQL_HOST as MYhost
+from config import SQL_PORT as MYport
+from config import SQL_USER as MYuser
+from config import SQL_PASS as MYpass
+from config import SQL_DATABASE as MYbase
+from config import file
+from discord.ext import commands
+import matplotlib.dates as md
+import matplotlib.ticker as ticker
+import matplotlib.spines as ms
+import pandas as pd
+
+######################### Code below ##########################
+##### Dont complain if you edit it and something dont work ####
+
+#Color init
+colorama.init()
+
+pdeath = '^\[Info\s+:\s+Unity Log\].*? Got character ZDOID from (\w+) : 0:0$'
+pevent = '^\[Info\s+:\s+Unity Log\].*? Random event set:(\w+)$'
+pjoin = '^\[Info\s+:\s+Unity Log\].*? Got character ZDOID from (\w+) : ([-0-9]*:[-0-9]*)$'
+pquit = '^\[Info\s+:\s+Unity Log\].*? Destroying abandoned non persistent zdo ([-0-9]*:[0-9]*) owner [-0-9]*$'
+pfind = '^\[Info\s+:\s+Unity Log\].*? Found location of type (\w+)$'
+# Extra Server Info
+ssaved1 = '.*? Saved ([0-9]+) zdos$'
+ssaved2 = '.*? World saved \( ([0-9]+\.[0-9]+)ms \)$'
+sversion = '^\[Info\s+:\s+Unity Log\].*? Valheim version:([\.0-9]+)@([\.0-9]+)$'
+gdays = '^\[Info\s+:\s+Unity Log\].*? Time [\.0-9]+, day:([0-9]+)\s{1,}nextm:[\.0-9]+\s+skipspeed:[\.0-9]+$'
+
+
+bot = commands.Bot(command_prefix=config.BOT_PREFIX, help_command=None)
+server_name = config.SERVER_NAME
+sonline = 1
+
+# Connect to MYSQL
+async def mydbconnect():
+    global mydb
+    mydb = mysql.connector.connect(
+        host=MYhost,
+        user=MYuser,
+        password=MYpass,
+        database=MYbase,
+        port=MYport,
+        )
+    bugchan = bot.get_channel(dbchanID)
+    try:
+        if mydb.is_connected():
+            db_Info = mydb.get_server_info()
+            print(Fore.GREEN + "Connected to MySQL database... MySQL Server version ", db_Info + Style.RESET_ALL)
+            if config.USEDEBUGCHAN == True:
+                buginfo = discord.Embed(title=":white_check_mark: **INFO** :white_check_mark:", description="Connected to MySQL database... MySQL Server version " + db_Info, color=0x7EFF00)
+                buginfo.set_author(name=server_name)
+                await bugchan.send(embed=buginfo)
+    except mysql.connector.Error as err:
+        print(Fore.RED + err + Style.RESET_ALL)
+        if config.USEDEBUGCHAN == True:
+            bugerror = discord.Embed(title=":sos: **ERROR** :sos:", description=err, color=0xFF001E)
+            bugerror.set_author(name=server_name)
+            await bugchan.send(embed=bugerror)
+
+async def get_cursor():
+    try:
+        mydb.ping(reconnect=True, attempts=3, delay=5)
+    except mysql.connector.Error as err:
+        await mydbconnect()
+        print(Fore.RED + "Connection to MySQL database went away... Reconnecting " + Style.RESET_ALL)
+        if config.USEDEBUGCHAN == True:
+            bugchan = bot.get_channel(dbchanID)
+            bugerror = discord.Embed(title=":sos: **ERROR** :sos:", description="Connection to MySQL database went away... Reconnecting", color=0xFF001E)
+            bugerror.set_author(name=server_name)
+            await bugchan.send(embed=bugerror)
+    return mydb.cursor()
+
+# Method for catching SIGINT, cleaner output for restarting bot
+def signal_handler(signal, frame):
+  os._exit(0)
+
+signal.signal(signal.SIGINT, signal_handler)
+
+async def timenow():
+    now = datetime.now()
+    gettime = now.strftime("%m/%d/%Y %H:%M:%S")
+    return gettime
+
+async def convert(n):
+    return str(timedelta(seconds = n))
+
+@bot.event
+async def on_ready():
+    print(Fore.GREEN + f'Bot connected as {bot.user} :)' + Style.RESET_ALL)
+    print('Command prefix: %s' % config.BOT_PREFIX)
+    print('Log channel: #%s' % (bot.get_channel(lchanID)))
+    if config.USEVCSTATS == True:
+        print('VoIP channel: %d' % (chanID))
+    if config.USEDEBUGCHAN == True:
+        print('Debug channel: #%s' % (bot.get_channel(dbchanID)))
+        bugchan = bot.get_channel(dbchanID)
+        buginfo = discord.Embed(title=":white_check_mark: **INFO** :white_check_mark:", color=0x7EFF00)
+        buginfo.set_author(name=server_name)
+        buginfo.add_field(name="Bot connected as:",
+                          value="{}".format(bot.user),
+                          inline=False)
+        buginfo.add_field(name="Command prefix:",
+                          value="{}".format(config.BOT_PREFIX),
+                          inline=False)
+        buginfo.add_field(name="Log channel:",
+                          value="#{}".format(bot.get_channel(lchanID)),
+                          inline=False)
+        if config.USEVCSTATS == True:
+            buginfo.add_field(name="VoIP channel:",
+                              value="#{}".format(chanID),
+                              inline=False)
+        buginfo.add_field(name="Debug channel",
+                          value="#{}".format(bot.get_channel(dbchanID)),
+                          inline=False)
+        await bugchan.send(embed=buginfo)
+    bot.loop.create_task(serveronline())
+    await mydbconnect()
+
+@bot.command(name='help')
+async def help_ctx(ctx):
+    help_embed = discord.Embed(description="[**Valheim Plus Discord Bot**](https://github.com/stolenvw/ValheimPlus-Discord_Bot)", color=0x33a163,)
+    help_embed.add_field(name="{}stats <n>".format(bot.command_prefix),
+                        value="Plots a graph of connected players over the last X hours.\n Example: `{}stats 12` \n Available: 24, 12, w (*default: 24*)".format(bot.command_prefix),
+                        inline=True)
+    help_embed.add_field(name="{}deaths <n>".format(bot.command_prefix),
+                        value="Shows a top 5 leaderboard of players with the most deaths. \n Example:`{}deaths 3` \n Available: 1-10 (*default: 10*)".format(bot.command_prefix),
+                        inline=True)
+    help_embed.add_field(name="{}playerstats <playername>".format(bot.command_prefix),
+                        value="Shows player stats on active monitored world. \n Example: `{}playerstats bob`".format(bot.command_prefix),
+                        inline=True)
+    help_embed.add_field(name="{}active".format(bot.command_prefix),
+                        value="Shows who is currently logged into the server and how long they have been on for. \n Example: `{}active`".format(bot.command_prefix),
+                        inline=True)
+    help_embed.add_field(name="{}version".format(bot.command_prefix),
+                        value="Shows current version of Valheim and Valheim Plus server is running. \n Example: `{}version`".format(bot.command_prefix),
+                        inline=True)
+    is_owner = await ctx.bot.is_owner(ctx.author)
+    if is_owner:
+        help_embed.add_field(name="**Owner**",
+                            value="Owner only commands",
+                            inline=False)
+        help_embed.add_field(name="{}setstatus <type> <message>".format(bot.command_prefix),
+                            value='Set status message of the bot. \n Example: `{}setstatus playing "Valheim"` \n Available type: playing, watching, listening'.format(bot.command_prefix),
+                            inline=True)
+        if config.EXSERVERINFO == True:
+            help_embed.add_field(name="{}savestats".format(bot.command_prefix),
+                                value="Shows how many zods where saved and time it took to save them. \n Example: `{}savestats`".format(bot.command_prefix),
+                                inline=True)
+    help_embed.set_footer(text="stolenvw ValPlusBot v0.10")
+    await ctx.send(embed=help_embed)
+
+@bot.command(name="deaths")
+async def leaderboards(ctx, arg: typing.Optional[str] = '5'):
+    ldrembed = discord.Embed(title=":skull_crossbones: __Death Leaderboards (top " + arg + ")__ :skull_crossbones:", color=0xFFC02C)
+    mycursor = await get_cursor()
+    sql = """SELECT user, deaths FROM players WHERE deaths > 0 ORDER BY deaths DESC LIMIT %s""" % (arg)
+    mycursor.execute(sql)
+    Info = mycursor.fetchall()
+    row_count = mycursor.rowcount
+    l = 1
+    for ind in Info:
+        grammarnazi = 'deaths'
+        leader = ''
+        pdname = ind[0]
+        pddeath = ind[1]
+        if pddeath == 1 :
+            grammarnazi = 'death'
+        if l == 1:
+            leader = ':crown:'
+        ldrembed.add_field(name="{} {}".format(pdname,leader),
+                           value='{} {}'.format(pddeath,grammarnazi),
+                           inline=False)
+        l += 1
+    mycursor.close()
+    await ctx.send(embed=ldrembed)
+
+@bot.command(name="stats")
+async def gen_plot(ctx, tmf: typing.Optional[str] = '24'):
+    user_range = 0
+    if tmf.lower() in ['w', 'week', 'weeks']:
+        user_range = 168 - 1
+        tlookup = int(time.time()) - 604800
+        interval = 24
+        date_format = '%m/%d'
+        timedo = 'week'
+        description = 'Players online in the past ' + timedo + ':'
+    elif tmf.lower() in ['12', '12hrs', '12h', '12hr']:
+        user_range = 12 - 0.15
+        tlookup = int(time.time()) - 43200
+        interval = 1
+        date_format = '%H'
+        timedo = '12hrs'
+        description = 'Players online in the past ' + timedo + ':'
+    else:
+        user_range = 24 - 0.30
+        tlookup = int(time.time()) - 86400
+        interval = 2
+        date_format = '%H'
+        timedo = '24hrs'
+        description = 'Players online in the past ' + timedo + ':'
+
+    #Get data from mysql
+    mycursor = await get_cursor()
+    mycursor.close()
+    sqls = """SELECT date, users FROM serverstats WHERE timestamp BETWEEN '%s' AND '%s'""" % (tlookup, int(time.time()))
+    df = pd.read_sql(sqls, mydb, parse_dates=['date'])
+    lastday = datetime.now() - timedelta(hours = user_range)
+
+    # Plot formatting / styling matplotlib
+    plt.style.use('seaborn-pastel')
+    plt.minorticks_off()
+    fig, ax = plt.subplots()
+    ax.grid(b=True, alpha=0.2)
+    ax.set_xlim(lastday, datetime.now())
+    # ax.set_ylim(0, 10) Not sure about this one yet
+    for axis in [ax.xaxis, ax.yaxis]:
+        axis.set_major_locator(ticker.MaxNLocator(integer=True))
+    ax.xaxis.set_major_formatter(md.DateFormatter(date_format))
+    ax.xaxis.set_major_locator(md.HourLocator(interval=interval))
+    for spine in ax.spines.values():
+        spine.set_visible(False)
+    for tick in ax.get_xticklabels():
+        tick.set_color('gray')
+    for tick in ax.get_yticklabels():
+        tick.set_color('gray')
+
+    #Plot and rasterize figure
+    plt.gcf().set_size_inches([5.5,3.0])
+    plt.plot(df['date'], df['users'], drawstyle='steps-post')
+    plt.tick_params(axis='both', which='both', bottom=False, left=False)
+    plt.margins(x=0,y=0,tight=True)
+    plt.tight_layout()
+    fig.savefig('img/temp.png', transparent=True, pad_inches=0) # Save and upload Plot
+    image = discord.File('img/temp.png', filename='temp.png')
+    plt.close()
+    embed = discord.Embed(title=server_name, description=description, colour=12320855)
+    embed.set_image(url='attachment://temp.png')
+    await ctx.send(file=image, embed=embed)
+
+@bot.command(name="playerstats")
+async def playstats(ctx, arg):
+    mycursor = await get_cursor()
+    sql = """SELECT user, deaths, startdate, playtime FROM players WHERE user = '%s'""" % (arg)
+    mycursor.execute(sql)
+    Info = mycursor.fetchall()
+    row_count = mycursor.rowcount
+    if row_count == 1:
+        Info=Info[0]
+        plsembed = discord.Embed(title=":bar_chart: __Player Stats For " + Info[0] + "__ :bar_chart:", color=0x4A90E2)
+        plsembed.add_field(name="Server Join Date:",
+                           value='{}'.format(Info[2]),
+                           inline=True)
+        plsembed.add_field(name="Play Time:",
+                          value=await convert(Info[3]),
+                          inline=True)
+        plsembed.add_field(name="Deaths:",
+                          value=Info[1],
+                          inline=True)
+        await ctx.send(embed=plsembed)
+    else:
+        await ctx.send(content=':no_entry_sign: **' + arg + '** Not Found')
+    mycursor.close()
+
+@bot.command(name="active")
+async def actives(ctx):
+    mycursor = await get_cursor()
+    sql = """SELECT user, jointime FROM players WHERE ingame = 1 ORDER BY jointime LIMIT 10"""
+    mycursor.execute(sql)
+    Info = mycursor.fetchall()
+    row_count = mycursor.rowcount
+    if row_count == 0:
+       await ctx.send(content=':globe_with_meridians: 0 Players Active')
+    else:
+         ldrembed = discord.Embed(title=":man_raising_hand: __Active Users__ :woman_raising_hand:", color=0x50E3C2)
+         EndTime = int(time.time())
+         for ind in Info:
+             pname = ind[0]
+             onfor = "Online For:"
+             ponline = await convert(EndTime - ind[1])
+             ldrembed.add_field(name="{}".format(pname),
+                                value='{} {}'.format(onfor,ponline),
+                                inline=False)
+         await ctx.send(embed=ldrembed)
+    mycursor.close()
+
+@bot.command(name="version")
+async def versions(ctx):
+    mycursor = await get_cursor()
+    sql = """SELECT serverversion, plusversion FROM exstats WHERE id = 1"""
+    mycursor.execute(sql)
+    Info = mycursor.fetchall()
+    row_count = mycursor.rowcount
+    if row_count == 1:
+        Info=Info[0]
+        sembed = discord.Embed(title="Server Versions", color=0x407500)
+        sembed.add_field(name="Valheim:",
+                           value='{}'.format(Info[0]),
+                           inline=True)
+        sembed.add_field(name="Valheim Plus:",
+                          value='{}'.format(Info[1]),
+                          inline=True)
+        await ctx.send(embed=sembed)
+    else:
+        await ctx.send(content=':no_entry_sign: Sorry no game version info found in the DB')
+    mycursor.close()
+
+@bot.command(name="setstatus")
+@commands.is_owner()
+async def setstatus(ctx, arg: typing.Optional[str] = '0', arg1: typing.Optional[str] = '1'):
+      if arg == "playing":
+         await bot.change_presence(activity=discord.Game(arg1))
+#      elif arg == "streaming":
+#         await bot.change_presence(activity=discord.Streaming(name=arg1, url=arg2))
+      elif arg == "watching":
+         await bot.change_presence(activity=discord.Activity(type=discord.ActivityType.watching, name=arg1))
+      elif arg == "listening":
+         await bot.change_presence(activity=discord.Activity(type=discord.ActivityType.listening, name=arg1))
+      else:
+           await ctx.channel.send('Usage: `{}setstatus <playing|watching|listening> "<Some activity>"`'.format(bot.command_prefix))
+
+@bot.command(name="savestats")
+@commands.is_owner()
+async def savestats(ctx):
+    if config.EXSERVERINFO == True:
+        mycursor = await get_cursor()
+        sql = """SELECT savezdos, savesec, worldsize, timestamp FROM exstats WHERE savesec is not null AND savezdos is not null ORDER BY timestamp DESC LIMIT 1"""
+        mycursor.execute(sql)
+        Info = mycursor.fetchall()
+        row_count = mycursor.rowcount
+        if row_count == 1:
+            Info=Info[0]
+            sembed = discord.Embed(title="World File Save Stats", color=0x407500, timestamp=datetime.utcfromtimestamp(Info[3]))
+            sembed.set_footer(text="Last saved")
+            sembed.add_field(name="Zdos Saved:",
+                           value='{}'.format(Info[0]),
+                           inline=True)
+            sembed.add_field(name="Saving Took:",
+                          value='{}ms'.format(Info[1]),
+                          inline=True)
+            if config.WORLDSIZE == True:
+                sembed.add_field(name="World Size:",
+                              value='{}MB'.format(Info[2]),
+                              inline=True)
+            await ctx.send(embed=sembed)
+        else:
+            await ctx.send(content=':no_entry_sign: No World File Save Stats Found')
+        mycursor.close()
+    else:
+        await ctx.send(content=':no_entry_sign: Extra Server Info is turned off, turn on to see save stats')
+# Main loop for reading log file and outputing events
+async def mainloop(file):
+    await bot.wait_until_ready()
+    lchannel = bot.get_channel(lchanID)
+    bugchan = bot.get_channel(dbchanID)
+    print('Main loop: init')
+    if config.USEDEBUGCHAN == True:
+        buginfo = discord.Embed(title=":white_check_mark: **INFO** :white_check_mark:", description="Main Loop Started", color=0x7EFF00)
+        buginfo.set_author(name=server_name)
+        await bugchan.send(embed=buginfo)
+    try:
+        testfile = open(file)
+        testfile.close()
+        while not bot.is_closed():
+            with open(file, encoding='utf-8', mode='r') as f:
+                f.seek(0,2)
+                while True:
+                    try:
+                        line = f.readline()
+                    except UnicodeDecodeError:
+                        print('Got an invalid utf-8 character! Skipping moving to next line')
+                        if config.USEDEBUGCHAN == True:
+                            bugerror = discord.Embed(title=":sos: **ERROR** :sos:", description="Got an invalid utf-8 character! Skipping.. moving to next line", color=0xFF001E)
+                            bugerror.set_author(name=server_name)
+                            await bugchan.send(embed=bugerror)
+                    else:
+                        if(re.search(pdeath, line)):
+                            pname = re.search(pdeath, line).group(1)
+                            mycursor = await get_cursor()
+                            sql = """UPDATE players SET deaths = deaths + 1 WHERE user = '%s'""" % (pname)
+                            mycursor.execute(sql)
+                            mydb.commit()
+                            mycursor.close()
+                            await lchannel.send(':skull: **' + pname + '** just died!')
+                        if(re.search(pevent, line)):
+                            eventID = re.search(pevent, line).group(1)
+                            mycursor = await get_cursor()
+                            sql = """SELECT type, smessage, image FROM events WHERE type = '%s' LIMIT 1""" % (eventID)
+                            mycursor.execute(sql)
+                            Info = mycursor.fetchall()
+                            Info=Info[0]
+                            image = discord.File('img/' + Info[2], filename=Info[2])
+                            embed = discord.Embed(title=Info[0], colour=discord.Colour(0xb6000e), description="*" + Info[1] + "*")
+                            embed.set_thumbnail(url='attachment://' + Info[2])
+                            embed.set_author(name="📢 Random Mob Event")
+                            await lchannel.send(file=image, embed=embed)
+                            mycursor.close()
+                        if(re.search(pjoin, line)):
+                            logJoin = re.search(pjoin, line).group(1)
+                            logID = re.search(pjoin, line).group(2)
+                            mycursor = await get_cursor()
+                            sql = """SELECT id, ingame FROM players WHERE user = '%s'""" % (logJoin)
+                            mycursor.execute(sql)
+                            Info = mycursor.fetchall()
+                            row_count = mycursor.rowcount
+                            if row_count == 0:
+                                StartDate = await timenow()
+                                JoinTime = int(time.time())
+                                InGame = 1
+                                sql = """INSERT INTO players (user, valid, startdate, jointime, ingame) VALUES ('%s', '%s', '%s', '%s', '%s')""" % (logJoin, logID, StartDate, JoinTime, InGame)
+                                mycursor.execute(sql)
+                                mydb.commit()
+                                await lchannel.send(':airplane_arriving: New player **' + logJoin + '** has joined the party!')
+                            else:
+                                Info=Info[0]
+                                if Info[1] == 1:
+                                    sql = """UPDATE players SET valid = '%s' WHERE id = '%s'""" % (logID, Info[0])
+                                    mycursor.execute(sql)
+                                    mydb.commit()
+                                else:
+                                    JoinTime = int(time.time())
+                                    InGame = 1
+                                    sql = """UPDATE players SET valid = '%s', jointime = '%s', ingame = '%s' WHERE user = '%s'""" % (logID, JoinTime, InGame, logJoin)
+                                    mycursor.execute(sql)
+                                    mydb.commit()
+                                    await lchannel.send(':airplane_arriving: **' + logJoin + '** has joined the party!')
+                            sql2 = """INSERT INTO serverstats (date, timestamp, users) VALUES ('%s', '%s', '%s')""" % (await timenow(), int(time.time()), await serverstatsupdate())
+                            mycursor.execute(sql2)
+                            mydb.commit()
+                            mycursor.close()
+                    # Announcing when a player leaves the server, updates db with playtime
+                        if(re.search(pquit, line)):
+                            logquit = re.search(pquit, line).group(1)
+                            mycursor = await get_cursor()
+                            sql = """SELECT id, user, jointime, playtime FROM players WHERE valid = '%s'""" % (logquit)
+                            mycursor.execute(sql)
+                            Info = mycursor.fetchall()
+                            row_count = mycursor.rowcount
+                            if row_count == 1:
+                                Info=Info[0]
+                                EndTime = int(time.time())
+                                Ptime = EndTime - Info[2] + Info[3]
+                                ponline = await convert(EndTime - Info[2])
+                                InGame = 0
+                                sql = """UPDATE players SET playtime = '%s', ingame = '%s' WHERE id = '%s'""" % (Ptime, InGame, Info[0])
+                                mycursor.execute(sql)
+                                mydb.commit()
+                                await lchannel.send(':airplane_departure: **' + Info[1] + '** has left the party! Online for: ' + ponline + '')
+                                sql2 = """INSERT INTO serverstats (date, timestamp, users) VALUES ('%s', '%s', '%s')""" % (await timenow(), int(time.time()), await serverstatsupdate())
+                                mycursor.execute(sql2)
+                                mydb.commit()
+                            mycursor.close()
+                        # Annocing that a boss location was found
+                        if(re.search(pfind, line)):
+                            newitem = re.search(pfind, line).group(1)
+                            mycursor = await get_cursor()
+                            sql = """SELECT type, smessage, image FROM events WHERE type = '%s' LIMIT 1""" % (newitem)
+                            mycursor.execute(sql)
+                            Info = mycursor.fetchall()
+                            Info=Info[0]
+                            image = discord.File('img/' + Info[2], filename=Info[2])
+                            embed = discord.Embed(title=Info[0], colour=discord.Colour(0x77ac18))
+                            embed.set_thumbnail(url='attachment://' + Info[2])
+                            embed.set_author(name="📢 Location Found")
+                            await lchannel.send(file=image, embed=embed)
+                            mycursor.close()
+                        # Extra Server Info DB After this point
+                        if config.EXSERVERINFO == True:
+                            if(re.search(ssaved1, line)):
+                                save1 = re.search(ssaved1, line).group(1)
+                                mycursor = await get_cursor()
+                                sql = """INSERT INTO exstats (savezdos, timestamp) VALUES ('%s', '%s')""" % (save1, int(time.time()))
+                                mycursor.execute(sql)
+                                mydb.commit()
+                                mycursor.close()
+                            # Getting time it took for the save
+                            if(re.search(ssaved2, line)):
+                                save2 = re.search(ssaved2, line).group(1)
+                                mycursor = await get_cursor()
+                                tlookup = int(time.time()) - 60
+                                sql = """SELECT id FROM exstats WHERE savesec is null AND timestamp BETWEEN '%s' AND '%s' LIMIT 1""" % (tlookup, int(time.time()))
+                                mycursor.execute(sql)
+                                Info = mycursor.fetchall()
+                                row_count = mycursor.rowcount
+                                if row_count == 1:
+                                    Info=Info[0]
+                                    if config.WORLDSIZE == True:
+                                        sql ="""UPDATE exstats SET savesec = '%s', worldsize = '%s' WHERE id = '%s'""" % (save2, '{:,.2f}'.format(os.path.getsize(config.worldfile)/float(1<<20)), Info[0])
+                                    else:
+                                        sql = """UPDATE exstats SET savesec = '%s' WHERE id = '%s'""" % (save2, Info[0])
+                                    mycursor.execute(sql)
+                                    mydb.commit()
+                                else:
+                                    print(Fore.RED + 'ERROR: Could not find save zdos info' + Style.RESET_ALL)
+                                    if config.USEDEBUGCHAN == True:
+                                        bugerror = discord.Embed(title=":sos: **ERROR** :sos:", description="Could not find save zdos info", color=0xFF001E)
+                                        bugerror.set_author(name=server_name)
+                                        await bugchan.send(embed=bugerror)
+                                mycursor.close()
+                            # Getting and storing server version and Valheim Plus number in db, and announcing in channel if version was updated
+                            if(re.search(sversion, line)):
+                                serversion = re.search(sversion, line).group(1)
+                                vplversion = re.search(sversion, line).group(2)
+                                mycursor = await get_cursor()
+                                sql = """SELECT id, serverversion, plusversion FROM exstats WHERE id = 1"""
+                                mycursor.execute(sql)
+                                Info = mycursor.fetchall()
+                                row_count = mycursor.rowcount
+                                if row_count == 0:
+                                    print(Fore.RED + 'ERROR: Extra server info is set, but missing database table/info' + Style.RESET_ALL)
+                                    if config.USEDEBUGCHAN == True:
+                                        bugerror = discord.Embed(title=":sos: **ERROR** :sos:", description="Extra server info is set, but missing database table/info", color=0xFF001E)
+                                        bugerror.set_author(name=server_name)
+                                        await bugchan.send(embed=bugerror)
+                                else:
+                                    Info=Info[0]
+                                    vcount = 0
+                                    if serversion != Info[1]:
+                                        sqlv = 'serverversion = "' + serversion + '"'
+                                        vcount = 1
+                                        await lchannel.send('**INFO:** Server has been updated to version: ' + serversion + '')
+                                    if vplversion != Info[2]:
+                                        if vcount == 1:
+                                            sqlv = sqlv + ', plusversion = "' + vplversion + '"'
+                                        else:
+                                            sqlv = 'plusversion = "' + vplversion + '"'
+                                            vcount = 1
+                                        await lchannel.send('**INFO:** Valheim Plus has been updated to version: ' + vplversion + '')
+                                    if vcount == 1:
+                                        sql = """UPDATE exstats SET %s WHERE id = '%s'""" % (sqlv, Info[0])
+                                        mycursor.execute(sql)
+                                        mydb.commit()
+                                mycursor.close()
+                            # Getting and storing game day in db (only reported in log when doing a sleep) reports day of sleep not day after waking up
+                            if(re.search(gdays, line)):
+                                gamedays = re.search(gdays, line).group(1)
+                                mycursor = await get_cursor()
+                                sql = """INSERT INTO exstats (gameday, timestamp) VALUES ('%s', '%s')""" % (gamedays, int(time.time()))
+                                mycursor.execute(sql)
+                                mydb.commit()
+                                await lchannel.send('**INFO:** Server reported in game day as: ' + gamedays + '')
+                                mycursor.close()
+                        await asyncio.sleep(0.2)
+    except IOError:
+        print('No valid log found, event reports disabled. Please check config.py')
+        print('To generate server logs, run server with -logfile launch flag')
+        print('Or permission error getting world file size')
+        if config.USEDEBUGCHAN == True:
+            bugerror = discord.Embed(title=":sos: **ERROR** :sos:", description="No valid log found, event reports disabled. Please check config.py \n To generate server logs, run server with -logfile launch flag \n Or permission error getting world file size", color=0xFF001E)
+            bugerror.set_author(name=server_name)
+            await bugchan.send(embed=bugerror)
+
+async def serverstatsupdate():
+    try:
+        if a2s.info(config.SERVER_ADDRESS):
+            channel = bot.get_channel(chanID)
+            oplayers = a2s.info(config.SERVER_ADDRESS).player_count
+            if config.USEVCSTATS == True:
+                await channel.edit(name=f"{emoji.emojize(':house:')} In-Game: {oplayers}" +" / 10")
+    except Exception as e:
+        print(Fore.RED + await timenow(), e, 'from A2S' + Style.RESET_ALL)
+        channel = bot.get_channel(chanID)
+        oplayers = 0
+        if config.USEVCSTATS == True:
+            await channel.edit(name=f"{emoji.emojize(':cross_mark:')} Server Offline")
+    else:
+        return oplayers
+
+async def serveronline():
+    global sonline
+    await bot.wait_until_ready()
+    while not bot.is_closed():
+        try:
+            if a2s.info(config.SERVER_ADDRESS):
+                meonline = a2s.info(config.SERVER_ADDRESS).player_count
+                if sonline == 0:
+                    sonline = 1
+                    if config.USEVCSTATS == True:
+                        channel = bot.get_channel(chanID)
+                        await channel.edit(name=f"{emoji.emojize(':house:')} Server OnLine")
+        except Exception as e:
+            if config.USEVCSTATS == True:
+                channel = bot.get_channel(chanID)
+                await channel.edit(name=f"{emoji.emojize(':cross_mark:')} Server Offline")
+            if sonline == 1:
+                sonline = 0
+                mycursor = await get_cursor()
+                sql2 = """INSERT INTO serverstats (date, timestamp, users) VALUES ('%s', '%s', '%s')""" % (await timenow(), int(time.time()), sonline)
+                mycursor.execute(sql2)
+                mydb.commit()
+                mycursor.close()
+            print(Fore.RED + await timenow(), e, 'from A2S, retrying (60s)...' + Style.RESET_ALL)
+            if config.USEDEBUGCHAN == True:
+                bugchan = bot.get_channel(dbchanID)
+                bugerror = discord.Embed(title=":sos: **ERROR** :sos:", description=e, color=0xFF001E)
+                bugerror.set_author(name=server_name)
+                await bugchan.send(embed=bugerror)
+        await asyncio.sleep(60)
+
+bot.loop.create_task(mainloop(file))
+bot.run(config.BOT_TOKEN)