summaryrefslogtreecommitdiff
path: root/code
diff options
context:
space:
mode:
Diffstat (limited to 'code')
-rw-r--r--code/config.py46
-rw-r--r--code/img/Boar.pngbin0 -> 4381 bytes
-rw-r--r--code/img/Bonemass.pngbin0 -> 6196 bytes
-rw-r--r--code/img/Drake.pngbin0 -> 4540 bytes
-rw-r--r--code/img/Draugr.pngbin0 -> 10559 bytes
-rw-r--r--code/img/Eikthyr.pngbin0 -> 7332 bytes
-rw-r--r--code/img/Fuling.pngbin0 -> 3126 bytes
-rw-r--r--code/img/Greydwarf.pngbin0 -> 2888 bytes
-rw-r--r--code/img/Moder.pngbin0 -> 5706 bytes
-rw-r--r--code/img/Ooze.pngbin0 -> 8982 bytes
-rw-r--r--code/img/The_Elder.pngbin0 -> 5801 bytes
-rw-r--r--code/img/Yagluth.pngbin0 -> 7304 bytes
-rw-r--r--code/img/skeleton.pngbin0 -> 4630 bytes
-rw-r--r--code/img/surtling.pngbin0 -> 4645 bytes
-rw-r--r--code/img/temp.pngbin0 -> 4399 bytes
-rw-r--r--code/img/troll.pngbin0 -> 6122 bytes
-rw-r--r--code/img/wolf.pngbin0 -> 5146 bytes
-rw-r--r--code/plusbot.py608
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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
Binary files differ
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)