import discord
import asyncio

import os
from bdsPing import bdsPing
import re
import datetime

server='YourServerIP'
port=19132

class MyClient(discord.Client):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)

        # create the background task and run it in the background
        self.bg_task = self.loop.create_task(self.my_background_task())

    async def on_ready(self):
        print('Logged in as')
        print(self.user.name)
        print(self.user.id)
        print('------')

    async def on_message(self, message):

        if message.content.startswith('!server'):
            datas = bdsPing(server,port)
            await message.channel.send("Server: {}:{}\nServer Name: {}\nPlayer: {}/{}\nGame Mode: {}".format(server,port,datas['ServerName'],datas['PlayerCount'],datas['PlayerLimit'],datas['GameMode']))

        if message.content.startswith('!stats'):
           stream = os.popen('docker stats --no-stream --format "table {{.Container}}\t{{.CPUPerc}}\t{{.MemUsage}}" Minecraft')
           out = stream.read()
           await message.channel.send(out)

        if message.content.startswith('!setDay'):
           os.popen('screen -S Minecraft -p 0 -X stuff "time set day^M"')
           await message.channel.send('set time to [day]')

        if message.content.startswith('!setNight'):
           os.popen('screen -S Minecraft -p 0 -X stuff "time set night^M"')
           await message.channel.send('set time to [night]')

        if message.content.startswith('!normal'):
           os.popen('screen -S Minecraft -p 0 -X stuff "difficulty normal^M"')
           await message.channel.send('set difficulty to [normal]')

        if message.content.startswith('!hard'):
           os.popen('screen -S Minecraft -p 0 -X stuff "difficulty hard^M"')
           await message.channel.send('set difficulty to [hard]')

        if message.content.startswith('!thunder'):
           os.popen('screen -S Minecraft -p 0 -X stuff "weather thunder^M"')
           await message.channel.send('set weather to [thunder]')

        if message.content.startswith('!sun'):
           os.popen('screen -S Minecraft -p 0 -X stuff "weather clear^M"')
           await message.channel.send('set weather to [clear]')

        if message.content.startswith('!help'):
           msg = "Prefix cmd with <!> \nserver : show server info \nstats : show server stat \nsetDay : set day \nsetNight : set night \nnormal : set difficulty to normal \nhard : set difficulty to hard \nthunder : set weather to thunder \nsun : set weather to sun\nopAdmin : set User operator \ndeOpAdmin : remove User operator \ncreativeAdmin : set creative mode to User \nsurvieAdmin : set survie mode to User"
           await message.channel.send(msg)

        if message.content.startswith('!opAdmin'):
           os.popen('screen -S Minecraft -p 0 -X stuff "op MicrosoftGameName^M"')
           await message.channel.send('set operator [MicrosoftGameName]')

        if message.content.startswith('!deOpAdmin'):
           os.popen('screen -S Minecraft -p 0 -X stuff "deop MicrosoftGameName^M"')
           await message.channel.send('set deoperator [MicrosoftGameName]')

        if message.content.startswith('!creativeAdmin'):
           os.popen('screen -S Minecraft -p 0 -X stuff "gamemode 1 MicrosoftGameName^M"')
           await message.channel.send('set gamemode [creative MicrosoftGameName]')

        if message.content.startswith('!survieAdmin'):
           os.popen('screen -S Minecraft -p 0 -X stuff "gamemode 0 MicrosoftGameName^M"')
           await message.channel.send('set gamemode [survie MicrosoftGameName]')


    async def my_background_task(self):
        await self.wait_until_ready()
        oldLines = []
        channel = self.get_channel(YourChannelID) # channel ID goes here
        while not self.is_closed():
            currentLines = []
            f = open("/var/log/dockerMinecraftLast.log", "r")
            lines = f.readlines()
            for line in lines:
                m = re.search(r"Player (connected|disconnected): ([a-zA-Z0-9]{1,}), xuid: ([0-9]{1,})",line)
                if m is not None:
                    currentTime = datetime.datetime.now() + datetime.timedelta(hours=2)
                    prettyTime = "{}:{}".format(currentTime.hour,currentTime.minute)
                    log = "[{}] {} {}".format(prettyTime,m.group(2),m.group(1))
                    currentLines.append(log)

            for current in currentLines:
                if current not in oldLines:
                    await channel.send(current)

            await asyncio.sleep(60) # task runs every 60 seconds
            oldLines = currentLines

client = MyClient()
client.run('YOUR DISCORD KEY')

import socket
import json

server='YourServerIp'
port=19132

def bdsPing(server,port):
        #Ping
        bytesToSend = b'\x01\x00\x00\x00\x00\x00\x00\x00\x00\x00\xff\xff\x00\xfe\xfe\xfe\xfe\xfd\xfd\xfd\xfd\x12\x34\x56\x78\x00\x00\x00\x00\x00\x00\x00\x00'

        serverAddressPort = (server,port)
        bufferSize = 1024

        # Create a UDP socket at client side
        UDPClientSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)

        # Send to server using created UDP socket
        UDPClientSocket.sendto(bytesToSend, serverAddressPort)

        msgFromServer = UDPClientSocket.recvfrom(bufferSize)

        #msg = "Message from Server {}".format(msgFromServer[0])
        data = msgFromServer[0][35:].decode("utf-8")
        indexes = ['Game','ServerName','ProtocolVersion','ServerVersion','PlayerCount','PlayerLimit','ServerId','WorldName','GameMode','NintendoLimited','Ipv4Port','Ipv6Port']
        datas = data[:-1].split(';')
        out = {}
        for i in range(len(indexes)):
                out[indexes[i]] = datas[i]

        return out
        #return json.dumps(out)


if __name__ == '__main__':

        print(bdsPing(server,port))