|
|
|
@ -14,12 +14,12 @@ import random |
|
|
|
import string |
|
|
|
import string |
|
|
|
import uuid |
|
|
|
import uuid |
|
|
|
from threading import Thread |
|
|
|
from threading import Thread |
|
|
|
from config import Configuration |
|
|
|
from .config import Configuration |
|
|
|
from database import DiscordChannel, AccountLinkToken, DiscordAccount |
|
|
|
from .database import DiscordChannel, AccountLinkToken, DiscordAccount |
|
|
|
import database_session |
|
|
|
from . import database_session |
|
|
|
|
|
|
|
|
|
|
|
from datetime import datetime, timedelta, timezone |
|
|
|
from datetime import datetime, timedelta, timezone |
|
|
|
import elasticsearch_logger as el |
|
|
|
from . import elasticsearch_logger as el |
|
|
|
from minecraft import authentication |
|
|
|
from minecraft import authentication |
|
|
|
from minecraft.exceptions import YggdrasilError |
|
|
|
from minecraft.exceptions import YggdrasilError |
|
|
|
from minecraft.networking.connection import Connection |
|
|
|
from minecraft.networking.connection import Connection |
|
|
|
@ -75,7 +75,7 @@ def mc_username_to_uuid(username): |
|
|
|
long_uuid = uuid.UUID(player_uuid) |
|
|
|
long_uuid = uuid.UUID(player_uuid) |
|
|
|
UUID_CACHE.inv[username] = str(long_uuid) |
|
|
|
UUID_CACHE.inv[username] = str(long_uuid) |
|
|
|
return player_uuid |
|
|
|
return player_uuid |
|
|
|
except: |
|
|
|
except requests.RequestException: |
|
|
|
log.error("Failed to lookup {}'s UUID using the Mojang API.".format(username)) |
|
|
|
log.error("Failed to lookup {}'s UUID using the Mojang API.".format(username)) |
|
|
|
else: |
|
|
|
else: |
|
|
|
return UUID_CACHE.inv[username] |
|
|
|
return UUID_CACHE.inv[username] |
|
|
|
@ -129,7 +129,7 @@ def setup_logging(level): |
|
|
|
log_level = logging.INFO |
|
|
|
log_level = logging.INFO |
|
|
|
log_format = "%(asctime)s:%(name)s:%(levelname)s:%(message)s" |
|
|
|
log_format = "%(asctime)s:%(name)s:%(levelname)s:%(message)s" |
|
|
|
logging.basicConfig(filename="bridge_log.log", format=log_format, level=log_level) |
|
|
|
logging.basicConfig(filename="bridge_log.log", format=log_format, level=log_level) |
|
|
|
stdout_logger=logging.StreamHandler(sys.stdout) |
|
|
|
stdout_logger = logging.StreamHandler(sys.stdout) |
|
|
|
stdout_logger.setFormatter(logging.Formatter(log_format)) |
|
|
|
stdout_logger.setFormatter(logging.Formatter(log_format)) |
|
|
|
logging.getLogger().addHandler(stdout_logger) |
|
|
|
logging.getLogger().addHandler(stdout_logger) |
|
|
|
|
|
|
|
|
|
|
|
@ -138,7 +138,7 @@ def run_auth_server(port): |
|
|
|
# We need to import twisted after setting up the logger because twisted hijacks our logging |
|
|
|
# We need to import twisted after setting up the logger because twisted hijacks our logging |
|
|
|
# TODO: Fix this in a cleaner way |
|
|
|
# TODO: Fix this in a cleaner way |
|
|
|
from twisted.internet import reactor |
|
|
|
from twisted.internet import reactor |
|
|
|
from auth_server import AuthFactory |
|
|
|
from .auth_server import AuthFactory |
|
|
|
|
|
|
|
|
|
|
|
# Create factory |
|
|
|
# Create factory |
|
|
|
factory = AuthFactory() |
|
|
|
factory = AuthFactory() |
|
|
|
@ -294,7 +294,7 @@ def main(): |
|
|
|
'embeds': [{'color': 65280, 'title': '**Joined the game**'}] |
|
|
|
'embeds': [{'color': 65280, 'title': '**Joined the game**'}] |
|
|
|
} |
|
|
|
} |
|
|
|
for webhook in WEBHOOKS: |
|
|
|
for webhook in WEBHOOKS: |
|
|
|
post = requests.post(webhook,json=webhook_payload) |
|
|
|
requests.post(webhook, json=webhook_payload) |
|
|
|
if config.es_enabled: |
|
|
|
if config.es_enabled: |
|
|
|
el.log_connection( |
|
|
|
el.log_connection( |
|
|
|
uuid=action.uuid, reason=el.ConnectionReason.CONNECTED, count=len(PLAYER_LIST)) |
|
|
|
uuid=action.uuid, reason=el.ConnectionReason.CONNECTED, count=len(PLAYER_LIST)) |
|
|
|
@ -305,8 +305,8 @@ def main(): |
|
|
|
ACCEPT_JOIN_EVENTS = True |
|
|
|
ACCEPT_JOIN_EVENTS = True |
|
|
|
if config.es_enabled: |
|
|
|
if config.es_enabled: |
|
|
|
diff = set(PREVIOUS_PLAYER_LIST.keys()) - set(PLAYER_LIST.keys()) |
|
|
|
diff = set(PREVIOUS_PLAYER_LIST.keys()) - set(PLAYER_LIST.keys()) |
|
|
|
for idx, uuid in enumerate(diff): |
|
|
|
for idx, player_uuid in enumerate(diff): |
|
|
|
el.log_connection(uuid=uuid, reason=el.ConnectionReason.DISCONNECTED, |
|
|
|
el.log_connection(uuid=player_uuid, reason=el.ConnectionReason.DISCONNECTED, |
|
|
|
count=len(PREVIOUS_PLAYER_LIST) - (idx + 1)) |
|
|
|
count=len(PREVIOUS_PLAYER_LIST) - (idx + 1)) |
|
|
|
# Don't bother announcing the bot's own join message (who cares) but log it for analytics still |
|
|
|
# Don't bother announcing the bot's own join message (who cares) but log it for analytics still |
|
|
|
if config.es_enabled: |
|
|
|
if config.es_enabled: |
|
|
|
@ -326,7 +326,7 @@ def main(): |
|
|
|
'embeds': [{'color': 16711680, 'title': '**Left the game**'}] |
|
|
|
'embeds': [{'color': 16711680, 'title': '**Left the game**'}] |
|
|
|
} |
|
|
|
} |
|
|
|
for webhook in WEBHOOKS: |
|
|
|
for webhook in WEBHOOKS: |
|
|
|
post = requests.post(webhook,json=webhook_payload) |
|
|
|
requests.post(webhook, json=webhook_payload) |
|
|
|
del UUID_CACHE[action.uuid] |
|
|
|
del UUID_CACHE[action.uuid] |
|
|
|
del PLAYER_LIST[action.uuid] |
|
|
|
del PLAYER_LIST[action.uuid] |
|
|
|
if config.es_enabled: |
|
|
|
if config.es_enabled: |
|
|
|
@ -346,7 +346,7 @@ def main(): |
|
|
|
chat_string += chat_component["text"] |
|
|
|
chat_string += chat_component["text"] |
|
|
|
|
|
|
|
|
|
|
|
# Handle chat message |
|
|
|
# Handle chat message |
|
|
|
regexp_match = re.match("<(.*?)> (.*)", chat_string, re.M|re.I) |
|
|
|
regexp_match = re.match("<(.*?)> (.*)", chat_string, re.M | re.I) |
|
|
|
if regexp_match: |
|
|
|
if regexp_match: |
|
|
|
username = regexp_match.group(1) |
|
|
|
username = regexp_match.group(1) |
|
|
|
original_message = regexp_match.group(2) |
|
|
|
original_message = regexp_match.group(2) |
|
|
|
@ -373,7 +373,7 @@ def main(): |
|
|
|
'content': '{}'.format(message) |
|
|
|
'content': '{}'.format(message) |
|
|
|
} |
|
|
|
} |
|
|
|
for webhook in WEBHOOKS: |
|
|
|
for webhook in WEBHOOKS: |
|
|
|
post = requests.post(webhook, json=webhook_payload) |
|
|
|
requests.post(webhook, json=webhook_payload) |
|
|
|
if config.es_enabled: |
|
|
|
if config.es_enabled: |
|
|
|
el.log_chat_message( |
|
|
|
el.log_chat_message( |
|
|
|
uuid=player_uuid, display_name=username, message=original_message, message_unformatted=chat_string) |
|
|
|
uuid=player_uuid, display_name=username, message=original_message, message_unformatted=chat_string) |
|
|
|
@ -405,7 +405,7 @@ def main(): |
|
|
|
channel_webhooks = await discord_channel.webhooks() |
|
|
|
channel_webhooks = await discord_channel.webhooks() |
|
|
|
found = False |
|
|
|
found = False |
|
|
|
for webhook in channel_webhooks: |
|
|
|
for webhook in channel_webhooks: |
|
|
|
if webhook.name == "_minecraft": |
|
|
|
if webhook.name == "_minecraft" and webhook.user == discord_bot.user: |
|
|
|
WEBHOOKS.append(webhook.url) |
|
|
|
WEBHOOKS.append(webhook.url) |
|
|
|
found = True |
|
|
|
found = True |
|
|
|
log.debug("Found webhook {} in channel {}".format(webhook.name, discord_channel.name)) |
|
|
|
log.debug("Found webhook {} in channel {}".format(webhook.name, discord_channel.name)) |
|
|
|
@ -545,16 +545,20 @@ def main(): |
|
|
|
deleted = session.query(DiscordChannel).filter_by(channel_id=this_channel).delete() |
|
|
|
deleted = session.query(DiscordChannel).filter_by(channel_id=this_channel).delete() |
|
|
|
session.commit() |
|
|
|
session.commit() |
|
|
|
session.close() |
|
|
|
session.close() |
|
|
|
for webhook in message.channel: |
|
|
|
for webhook in await message.channel.webhooks(): |
|
|
|
if webhook.name == "_minecraft": |
|
|
|
if webhook.name == "_minecraft" and webhook.user == discord_bot.user: |
|
|
|
del WEBHOOKS[webhook.url] |
|
|
|
# Copy the list to avoid some problems since |
|
|
|
|
|
|
|
# we're deleting indicies form it as we loop |
|
|
|
|
|
|
|
# through it |
|
|
|
|
|
|
|
if webhook.url in WEBHOOKS[:]: |
|
|
|
|
|
|
|
WEBHOOKS.remove(webhook.url) |
|
|
|
await webhook.delete() |
|
|
|
await webhook.delete() |
|
|
|
if deleted < 1: |
|
|
|
if deleted < 1: |
|
|
|
msg = "The bot was not chatting here!" |
|
|
|
msg = "The bot was not chatting here!" |
|
|
|
await message.channel.send(msg) |
|
|
|
await message.channel.send(msg) |
|
|
|
return |
|
|
|
return |
|
|
|
else: |
|
|
|
else: |
|
|
|
msg = "The bot will no longer here!" |
|
|
|
msg = "The bot will no longer chat here!" |
|
|
|
await message.channel.send(msg) |
|
|
|
await message.channel.send(msg) |
|
|
|
return |
|
|
|
return |
|
|
|
|
|
|
|
|
|
|
|
@ -663,7 +667,8 @@ def main(): |
|
|
|
PREVIOUS_MESSAGE = message_to_send |
|
|
|
PREVIOUS_MESSAGE = message_to_send |
|
|
|
NEXT_MESSAGE_TIME = datetime.now(timezone.utc) + timedelta(seconds=config.message_delay) |
|
|
|
NEXT_MESSAGE_TIME = datetime.now(timezone.utc) + timedelta(seconds=config.message_delay) |
|
|
|
|
|
|
|
|
|
|
|
log.info("Outgoing message from discord: Username: {} Message: {}".format(minecraft_username, message_to_send)) |
|
|
|
log.info("Outgoing message from discord: Username: {} Message: {}".format( |
|
|
|
|
|
|
|
minecraft_username, message_to_send)) |
|
|
|
|
|
|
|
|
|
|
|
for channel in channels: |
|
|
|
for channel in channels: |
|
|
|
webhooks = await discord_bot.get_channel(channel.channel_id).webhooks() |
|
|
|
webhooks = await discord_bot.get_channel(channel.channel_id).webhooks() |
|
|
|
@ -685,8 +690,8 @@ def main(): |
|
|
|
if not dm_channel: |
|
|
|
if not dm_channel: |
|
|
|
await message.author.create_dm() |
|
|
|
await message.author.create_dm() |
|
|
|
send_channel = message.author.dm_channel |
|
|
|
send_channel = message.author.dm_channel |
|
|
|
msg = "Unable to send chat message: there is no Minecraft account linked to this discord account," \ |
|
|
|
msg = "Unable to send chat message: there is no Minecraft account linked to this discord " \ |
|
|
|
"please run `mc!register`." |
|
|
|
"account, please run `mc!register`." |
|
|
|
await send_channel.send(msg) |
|
|
|
await send_channel.send(msg) |
|
|
|
except discord.errors.Forbidden: |
|
|
|
except discord.errors.Forbidden: |
|
|
|
if isinstance(message.author, discord.abc.User): |
|
|
|
if isinstance(message.author, discord.abc.User): |
Tristan Gosselin-Hane
6 years ago