Implement basic functionality of mcchat2.py.

Author: joodicator

en_US.lang

@@ -0,0 +1,72 @@
+from __future__ import print_function
+
+from itertools import *
+import os.path
+import json
+import sys
+import re
+
+class DecodeError(Exception):
+    pass
+
+def load_language(file):
+    language = dict()
+    for line in file:
+        try: name, value = line.split('=', 1)
+        except ValueError: continue
+        language[name] = value.strip()
+    return language
+
+with open(os.path.join(os.path.dirname(__file__), './en_US.lang')) as file:
+    language = load_language(file)
+
+def decode_string(data):
+    try:
+        return decode_struct(json.loads(data))
+    except DecodeError as e:
+        print(e, file=sys.stderr)
+        return data
+
+def decode_struct(data):
+    if type(data) is str or type(data) is unicode:
+        return data
+    elif type(data) is list:
+        return ''.join(decode_struct(part) for part in data)
+    elif type(data) is dict:
+        if 'text' in data:
+            result = decode_struct(data['text'])
+        elif 'translate' in data and ('using' in data or 'with' in data):
+            using = data.get('using') or data.get('with')
+            using = [decode_struct(item) for item in using]
+            result = translate(data['translate'], using)
+        else:
+            raise DecodeError
+        if 'extra' in data:
+            result += decode_struct(data['extra'])
+        return result
+    else:
+        raise DecodeError
+
+def translate(id, params):
+    if id not in language: raise DecodeError
+
+    ord_params = params[:]
+    def repl(match):
+        if match.group() == '%%':
+            return '%'
+        elif match.group('index'):
+            index = int(match.group('index')) - 1
+            if index >= len(params): raise DecodeError(
+                'Index %s in "%s" out of bounds for %s.'
+                % (match.group(), language[id], params))
+            param = params[index]
+        elif match.group('rest') != '%':
+            if not ord_params: raise DecodeError(
+                'Too few arguments for "%s" in %s.'
+                % (language[id], params))
+            param = ord_params.pop(0)
+        return ('%' + match.group('rest')) % param
+
+    return re.sub(
+        r'%((?P<index>\d+)\$)?(?P<rest>(\.\d+)?[a-zA-Z%])',
+        repl, language[id])

json_chat.py

@@ -0,0 +1 @@
+Subproject commit 2a29e1397574d91d2cf488e1fa91e84c3ff0fb98

json_chat.pyc

@@ -0,0 +1 @@
+Subproject commit 79ee31c44e7467339ac6406d66c82788a8bed148

lib/mcstatus

@@ -0,0 +1,130 @@
+#!/usr/bin/env python2.7
+
+from __future__ import print_function
+
+import sys
+import time
+import argparse
+import getpass
+from threading import Thread, Condition
+import thread
+
+import minecraft.authentication as authentication
+import minecraft.networking.connection as connection
+import minecraft.networking.packets as packets
+
+import mcstatus
+import json_chat
+
+KEEPALIVE_TIMEOUT_S = 20
+
+def main():
+    parser = argparse.ArgumentParser()
+    parser.add_argument('addr',  metavar='HOST[:PORT]')
+    parser.add_argument('uname', metavar='USERNAME')
+    parser.add_argument('pword', metavar='PASSWORD', nargs='?')
+    parser.add_argument('--offline', dest='offline', action='store_true')
+
+    args = parser.parse_args()
+    host, port = (
+        (args.addr.rsplit(':', 1)[0], int(args.addr.rsplit(':', 1)[1]))
+        if ':' in args.addr else (args.addr, None))
+    offline = args.offline
+    if args.pword is None and not offline:
+        pword = getpass.getpass(
+            'Enter password for %s, or leave blank for offline mode: '
+            % args.uname) 
+        if not pword: offline = True
+    else:
+        pword = args.pword
+
+    connect(args.uname, pword, host, port, offline=offline)
+
+def connect(uname, pword, host, port=None, offline=False):
+    port = 25565 if port is None else port
+
+    if offline:
+        auth = authentication.AuthenticationToken('-', '-', '-')
+        auth.profile.id_ = '-'
+        auth.profile.name = uname
+    else:
+        auth = authentication.AuthenticationToken()
+        auth.authenticate(uname, pword)
+
+    conn = connection.Connection(host, port, auth)
+    keepalive_cond = Condition()
+
+    conn.register_packet_listener(h_join_game,
+        packets.JoinGamePacket)
+    conn.register_packet_listener(h_chat_message,
+        packets.ChatMessagePacket)
+    conn.register_packet_listener(lambda p: h_keepalive(keepalive_cond, p),
+        packets.KeepAlivePacket)
+    conn.register_packet_listener(h_disconnect,
+        packets.DisconnectPacket, packets.DisconnectPacketPlayState)
+
+    stdin = Thread(name='stdin', target=stdin_thread, args=(
+        conn,))
+    stdin.daemon = True
+
+    timeout = Thread(name='timeout', target=timeout_thread, args=(
+        keepalive_cond,))
+    timeout.daemon = True
+
+    conn.connect()
+    stdin.start()
+    timeout.start()
+    main_thread(conn)
+  
+def h_join_game(packet):
+    print('Connected to server.')
+
+def h_chat_message(packet):
+    print(json_chat.decode_string(packet.json_data))
+
+def h_keepalive(keepalive_cond, packet):
+    keepalive_cond.acquire()
+    keepalive_cond.value = True
+    keepalive_cond.notify_all()
+    keepalive_cond.release()
+
+def h_disconnect(packet):
+    msg = json_chat.decode_string(packet.json_data)
+    print('Disconnected from server: %s' % msg)
+    thread.interrupt_main()
+
+def main_thread(conn):
+    try:
+        while conn.networking_thread.is_alive():
+            conn.networking_thread.join(0.1)
+        print('Disconnected from server.')
+    except KeyboardInterrupt as e:
+        pass
+
+def timeout_thread(keepalive_cond):
+    while True:
+        start = time.clock()
+        keepalive_cond.acquire()
+        keepalive_cond.value = False
+        keepalive_cond.wait(KEEPALIVE_TIMEOUT_S)
+        keepalive_cond.release()
+        if not keepalive_cond.value: break
+
+    print('Disconnected from server: timed out.')
+    thread.interrupt_main()
+
+def stdin_thread(conn):
+    def send_chat(conn, text):
+        packet = packets.ChatPacket()
+        packet.message = text
+        conn.write_packet(packet)
+    while True:
+        text = raw_input().decode('utf8')
+        while len(text) > 100:
+            send_chat(text[:97] + '...')
+            text = '...' + text[97:]
+        if text:
+            send_chat(conn, text)
+
+if __name__ == '__main__':
+    main()

lib/pyCraft

@@ -0,0 +1 @@
+lib/mcstatus/mcstatus/

mcchat2.py

@@ -0,0 +1 @@
+lib/pyCraft/minecraft/