Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use sendCloseWindow method in fMBT

Best Python code snippet using fMBT_python

tick.py

Source:tick.py

...150        if r.isCraftedBy(c):151            slots[0].stack = copy.copy(r.outputs)152            break153    154def sendCloseWindow(app, windowId: int):155    if hasattr(app, 'server'):156        server: ServerState = app.server157        player = server.getLocalPlayer()158        if windowId != 0:159            server.openWindows.pop(windowId)160        if player.entityId in server.craftSlots:161            craftSlots = server.craftSlots.pop(player.entityId)162            for craftSlot in craftSlots[1:]:163                player.pickUpItem(app, craftSlot.stack)164    else:165        network.c2sQueue.put(network.CloseWindowC2S(windowId))166def sendUseItem(app, hand: int):167    if hasattr(app, 'server'):168        server: ServerState = app.server...

peon-legacy.py

Source:peon-legacy.py

1#!/usr/bin/python2import mc3import astar4import json5import re6from scipy.spatial.distance import cityblock, euclidean7import pickle8import csv9import collections10import functools11import math12import Queue13import socket14import struct15import sys16import threading17import time18import random19import itertools20import logging21import optparse22import atexit23import os24class MoveException(Exception):25  pass26class MineCraftBot(mc.MineCraftProtocol):27  def __init__(self, host, port, username, password=None, fighting=True):28    super(MineCraftBot, self).__init__()29    self._host = host30    self._port = port31    self._username = username32    self._password = password33    self._serverId = None34    self._status = 'idle'35    self._health = 036    self._food = 037    self._food_saturation = 038    self._xp_bar = -139    self._xp_level = -140    self._xp_total = -141    self._available_enchantments = {}42    self._open_window_id = 043    self._held_slot_num = 044    self.world = mc.World()45    self.windows = {}46    self._pos = mc.Position(0.0, 0.0, 0.0, 0.0, 0.0, 0.0, 1)47    self._entityId = None48    self._levelType = None49    self._serverMode = None50    self._dimension = None51    self._difficulty = None52    self._maxPlayers = None53    self._cursor_slot = mc.Slot(itemId=-1, count=None, meta=None, data=None) 54    self._action_id = itertools.count(1)55    self._confirmations = {}56    self.bot_file = os.path.join('/tmp', self._username)57    self._threadFuncs.extend([58        #self._DoCrashThread,59        #self._DoWatchdogThread,60        self._DoPositionUpdateThread,61        ])62    if fighting:63      self._threadFuncs.append(self._DoFightingThread)64    self._handlers = {65        '\x00': self.OnKeepAlive,66        '\x01': self.OnLogin,67        '\x02': self.OnHandshake,68        '\x03': self.OnChatMessage,69        '\x05': self.OnEntityEquipment,70        '\x08': self.OnUpdateHealth,71        '\x0d': self.OnPlayerPositionLook,72        '\x14': self.OnSpawnNamedEntity,73        '\x18': self.OnSpawnMob,74        '\x1d': self.OnDestroyEntity,75        '\x1f': self.OnEntityRelativeMove,76        '\x21': self.OnEntityLookRelativeMove,77        '\x22': self.OnEntityTeleport,78        '\x2b': self.OnSetExperience,79        '\x33': self.world.MapChunk,80        '\x34': self.OnMultiBlockChange,81        '\x35': self.OnBlockChange,82        '\x64': self.OnOpenWindow,83        '\x67': self.OnSetSlot,84        '\x68': self.OnSetWindowItems,85        '\x69': self.OnUpdateWindowProperty,86        '\x6a': self.OnConfirmTransaction,87        }88    self._block_names, self._block_ids = self.get_blocktypes()89    if os.path.isfile(self.bot_file):90      raise Exception("%s is already logged in" % self._username)91    open(self.bot_file, 'w').close()92    atexit.register(self.delbotfile)93    if password is None:94      self.Login()95    else:96      self.Login(authenticate=True)97    #self.FloatDown()98  def get_blocktypes(self, filename='blocktypes.csv'):99    c = [ l for l in csv.DictReader(open(filename), skipinitialspace=True) ]100    block_names = dict([(int(l['dec']), l['type']) for l in c ])101    block_ids = dict([(l['type'], int(l['dec'])) for l in  c ])102    return block_names, block_ids103  def delbotfile(self):104    os.remove(self.bot_file)105  def Login(self, authenticate=False):106    self._sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)107    self._sock.connect((self._host, self._port))108    self._sockGeneration += 1109    self.StartThreads()110    if authenticate:111      self._sessionId = self.GetSessionId(self._username, self._password)112      logging.info('sessionId: %d', self._sessionId)113      self.SendHandshake(self._username, self._host, self._port)114      self.WaitFor(lambda: self._serverId is not None)115      logging.info('serverId: %d', self._serverId)116      logging.info('joinserver status: %s', str(self.JoinServer(self._username, self._sessionId, self._serverId)))117    logging.info('sending login. server: %s username: %s', self._host, self._username)118    self.SendLogin(self._username)119  def _DoCrashThread(self):120    time.sleep(60)121    while self._sock is not None:122      self._buf = '\x1bADIDEA'123      time.sleep(1)124  def _DoWatchdogThread(self):125    try:126      myGeneration = self._sockGeneration127      time.sleep(5)128      while all(t.is_alive() for t in self._threads):129        time.sleep(1)130      deadTime = time.time()131      self._sock = None132      self._sendQueue.put(None)133      self._sendQueue = None134      def OtherThreadIsAlive():135        return len([t for t in self._threads if t.is_alive()]) > 1136      while OtherThreadIsAlive() and time.time() - deadTime < 5:137        time.sleep(1)138      if OtherThreadIsAlive():139        time.sleep(3)140      self._buf = ''141      self._sendQueue = Queue.Queue(10)142      self._pos = mc.Position(0.0, 0.0, 0.0, 0.0, 0.0, 0.0, 1)143      self.world = mc.World()144      self.windows = {}145      self.Login()146      self.FloatDown()147    finally:148      logging.error("Watchdog thread exiting, %s", str(myGeneration))149  def _DoPositionUpdateThread(self):150    try:151      self.WaitFor(lambda: self._pos.x != 0.0 and self._pos.y != 0.0)152      myGeneration = self._sockGeneration153      while myGeneration == self._sockGeneration:154        time.sleep(0.010)155        self.SendPositionLook()156        if os.getppid() != self.parentPID:157          logging.erro("Position update thread exiting, %s", srt(myGeneration))158    finally:159      os.kill(self.parentPID, 0)160  def _DoFightingThread(self):161    HOSTILE_MOBS = set([50, 51, 52, 53, 54, 55, 56, 58, 59, 61, 62, 63])162    try:163      self.WaitFor(lambda: self._pos.x != 0.0 and self._pos.y != 0.0)164      while True:165        time.sleep(0.10)166        if os.getppid() != self.parentPID:167          logging.erro("Fighting thread exiting, %s", srt(myGeneration))168        for eid, entity in self.world._entities.items():169          if entity._type in HOSTILE_MOBS:170            if euclidean(entity._pos.xzy(), self._pos.xzy()) <= 4:171              self.attack_entity(eid)172    finally:173      os.kill(self.parentPID, 0)174  def OnKeepAlive(self, token):175    self.Send(176        '\x00' +177        struct.pack('!i', token)178        )179  def SendPositionLook(self, pos=None):180    if pos is None:181      pos = self._pos182    self.SendPlayerPositionAndLook(pos.x, pos.y, pos.stance, pos.z, pos.yaw, pos.pitch, pos.on_ground) 183  def OnLogin(self, entityId, levelType, serverMode, dimension, difficulty, maxPlayers):184      self._entityId = entityId185      self._levelType = levelType186      self._serverMode = serverMode187      self._dimension = dimension188      self._difficulty = difficulty189      self._maxPlayers = maxPlayers190  def OnHandshake(self, serverId):191      self._serverId = serverId192  def OnChatMessage(self, chat):193    logging.info("Chat: %s", chat)194    m = re.match('<\w+> peon, (.*)', chat)195    if m is not None:196        self.run_cmd(m.group(1))197  def OnEntityEquipment(self, entity_id, slot_num, item_id, damage):198    return199  def OnUpdateHealth(self, health, food, food_saturation):200    self._health = health201    self._food= food202    self._food_saturation = food_saturation203    if health <= 0:204      self.WaitFor(lambda: self._dimension is not None)205      self.SendRespawn(self._dimension, self._difficulty, self._levelType)206  def OnPlayerPositionLook(self, x, stance, y, z, yaw, pitch, onGround):207    pos = mc.Position(x, y, stance, z, yaw, pitch, onGround)208    self.SendPositionLook(pos)209    self._pos = mc.Position(x, y, stance, z, yaw, pitch, 1)210  def OnSpawnNamedEntity(self, eid, player_name, x, y, z, yaw, pitch, current_item):211    self.world._entities[eid] = mc.Entity(212      eid, 0, x, y, z, yaw, pitch, player_name=player_name, current_item=current_item)213  def OnSpawnMob(self, eid, etype, x, y, z, yaw, pitch, head_yaw, metadata):214    self.world._entities[eid] = mc.Entity(215      eid, etype, x, y, z, yaw, pitch, head_yaw=head_yaw, metadata=metadata)216  def OnDestroyEntity(self, eid):217    if eid in self.world._entities:218      del self.world._entities[eid]219  def OnEntityRelativeMove(self, eid, x, y, z):220    if eid in self.world._entities:221      self.world._entities[eid].Move(x, y, z)222  def OnEntityLookRelativeMove(self, eid, x, y, z, yaw, pitch):223    if eid in self.world._entities:224      self.world._entities[eid].Move(x, y, z)225  def OnEntityTeleport(self, eid, x, y, z, yaw, pitch):226    if eid in self.world._entities:227      self.world._entities[eid].Teleport(x, y, z)228  def OnEntityHeadLook(self, eid, head_yaw):229    if eid in self.world._entities:230      self.world._entities[eid]._head_yaw = head_yaw231  def OnEntityStatus(self, eid, status):232    if eid in self.world._entities and status == 3:233      del self.world._entities[eid]234  def OnSetExperience(self, bar, level, total):235    self._xp_bar = bar236    self._xp_level = level237    self._xp_total = total238  def OnMultiBlockChange(self, blocks):239    for x, z, y, newType, newMeta in blocks:240      self.world.SetBlock(x, z, y, newType, newMeta)241  def OnBlockChange(self, x, y, z, newType, newMeta):242    self.world.SetBlock(x, z, y, newType, newMeta)243  def OnOpenWindow(self, window_id, inventory_type, window_title, num_slots):244    self._open_window_id = window_id245    if window_id not in self.windows:246      time.sleep(1)247    if window_id in self.windows:248      self.windows[window_id].inventory_type = inventory_type249      self.windows[window_id].window_title = window_title250  def OnCloseWindow(self, window_id):251    self._open_window_id = 0252  def OnMapChunks(self, chunk):253    self._chunks[chunk.chunkX, chunk.chunkZ] = chunk254  def OnSetSlot(self, windowId, slotIndex, slot):255    if windowId == -1 and slotIndex == -1:256      self._cursor_slot = slot257    elif windowId in self.windows:258      self.windows[windowId].SetSlot(slotIndex, slot)259  def OnSetWindowItems(self, windowId, slots):260    window = mc.Window(windowId, slots)261    self.windows[windowId] = window262  def OnUpdateWindowProperty(self, window_id, window_property, value):263    self._available_enchantments[window_property] = value264  def OnConfirmTransaction(self, window_id, action_id, accepted):265    self._confirmations[action_id] = mc.Confirmation(window_id, action_id, accepted)266    if not accepted:267        self.SendConfirmTransaction(window_id, action_id, accepted)268  def break_block(self, x, z, y, face=1, retries=3, auto_move=True):269    xzy = mc.Xzy(x, z, y)270    if auto_move:271      m= self.iter_nearest_moveable(xzy)272      block = m.next()273      while euclidean(xzy, block) <= 6:274        if self.nav_to(*block): break275        block = m.next()276      else:277        logging.error('too far to break block')278        return False279    blocktype = self.world.GetBlock(*xzy)280    if blocktype is not None:281      self.get_best_tool(blocktype)282    for i in range(retries):283      logging.debug('sending dig command for: %s', str(xzy))284      self.SendPlayerDigging(0, x, y, z, face)285      time.sleep(0.1)286      self.SendPlayerDigging(2, x, y, z, face)287      if self.WaitFor(lambda: self.world.GetBlock(x, z, y) == 0, timeout=5):288        return True289    else:290      logging.error('could not break block: %s, type: %d', str(xzy), blocktype)291      return False292  def nav_to(self, x, z, y): 293    if not self.WaitFor(lambda: self._pos.x != 0.0 and self._pos.y != 0.0):294      logging.error('current position could not be found')295      return False296    botXzy = self._pos.xzy()297    nextXzy = mc.Xzy(x, z, y)298    if botXzy == nextXzy:299      return True300    distance = cityblock(botXzy, nextXzy)301    path = self.find_path(nextXzy, limit=min(sys.maxint, distance**2))302    if path is None:303      logging.error('could not find path')304      return False305    for step in path:306      if not self.MoveTo(*step):307        logging.error('could not make it to: %s failed at: %s', str(nextXzy), str(step))308        return False309    return True310  def MoveTo(self, x, z, y, speed=4.25, onGround=True):311    x+=0.5312    z+=0.5313    def MyDist(x, z, y):314      return abs(pos.x - x) + abs(pos.z - z) + abs(pos.y - y)315    def Go(x=None, z=None, y=None):316      logging.debug('moving to: (%d, %d, %d)', x, z, y)317      self._pos = mc.Position(x, y, y+1, z, yaw, 0, onGround)318    pos = self._pos319    yaw = pos.yaw320    if z - pos.z > .9:321      yaw = 0322    if z - pos.z < - .9:323      yaw = 180324    if x - pos.x > .9:325      yaw = 270326    if x - pos.x < - .9:327      yaw = 90328    tau = 0.010329    delta = speed * tau330    while MyDist(x, z, y) > (delta * 2):331      if pos.x - x > 0:332        new_x = pos.x - delta333      else:334        new_x = pos.x + delta335      if pos.z - z > 0:336        new_z = pos.z - delta337      else:338        new_z = pos.z + delta339      if pos.y - y > 0:340        new_y = pos.y - delta341      else:342        new_y = pos.y + delta343      Go(new_x, new_z, new_y)344      time.sleep(tau)345      if (self._pos.x, self._pos.z, self._pos.y) != (new_x, new_z, new_y):346        logging.error('did not move: %s', str(self._pos.xzy()))347        return False348      pos = self._pos349    Go(x, z, y)350    time.sleep(tau)351    if (self._pos.x, self._pos.z, self._pos.y) != (x, z, y):352      logging.error('did not move: %s', str(self._pos.xzy()))353      return False354    return True355  def FloatDown(self):356    logging.debug('floating down')357    logging.debug('waiting for pos to load')358    self.WaitFor(lambda: self._pos.x != 0.0 and self._pos.y != 0.0)359    logging.debug('waiting for block to load')360    self.WaitFor(lambda: self.world.GetBlock(361      self._pos.x, self._pos.z, self._pos.y) is not None)362    pos = self._pos.xzy()363    logging.debug('waiting for block to load')364    self.MoveTo(*pos)365    for y in range(pos.y + 1, 0, -1):366      pos = pos._replace(y=y)367      logging.debug('floating down: %s', str(pos))368      if self.world.IsStandable(*pos):369        logging.info('floating down: %s', str(pos))370        self.MoveTo(*pos)371        return372  def attack_entity(self, eid, times=5, delay=0.01):373    for i in xrange(times):374      self.SendUseEntity(self._entityId, eid, 1)375      time.sleep(delay)376  def get_best_tool(self, blockType):377    best_tools = (378        (set([1,4,14,15,16,48,61,87,89,98,109,112,113,114]), set([257, 278])), # pickaxe379        (set([2,3,12,13,88]), set([256, 277])), # shovel380        (set([5,17,18,47,53,54,58,64,72,106,107,125,126]), set([258, 279])), # axe381      )382    for blocktypes, tool_ids in best_tools:383      if blockType in blocktypes:384        for tool_id in tool_ids:385          if self.equip_tool(tool_id):386            return True387        return False388    return False389  def change_held_slot(self, slot_num):390    self.SendHeldItemChange(slot_num)391    self._held_slot_num = slot_num392  def get_slot(self, window_id, slot_num):393    return self.windows[window_id]._slots[slot_num]394  def click_slot(self, window_id, slot_num, right_click=0, shift=0):395    action_id = self._action_id.next()396    if slot_num in range(len(self.windows[window_id]._slots)):397      slot_data = self.get_slot(window_id, slot_num)398    else:399      slot_data = mc.Slot(itemId=-1, count=None, meta=None, data=None) 400    self.SendClickWindow(window_id, slot_num, right_click, action_id, shift, slot_data)401    if self.WaitFor(lambda: action_id in self._confirmations.keys(), timeout=5):402      if self._confirmations[action_id].accepted:403        if shift == 0:404          if slot_num in range(len(self.windows[window_id]._slots)):405            self.windows[window_id]._slots[slot_num] = self._cursor_slot406          self._cursor_slot = slot_data407        return True408    return False409  def find_tool(self, tool_id, window_id=0, storage_only=False, inventory_only=False, held_only=False, no_data=False):410    if storage_only:411      start = 0412      end = len(self.windows[window_id]._slots) - 35413    elif inventory_only:414      start = len(self.windows[window_id]._slots) - 36415      end = len(self.windows[window_id]._slots)416    elif held_only:417      start = len(self.windows[window_id]._slots) - 9418      end = len(self.windows[window_id]._slots)419    else:420      start = 0421      end = len(self.windows[window_id]._slots)422    for i, slot in enumerate(self.windows[window_id]._slots[start:end], start):423      if slot.itemId == tool_id and (not no_data or slot.data is None):424        return i425      elif tool_id is None and slot.itemId != -1 and (not no_data or slot.data is None):426        return i427    return None428  def equip_tool(self, tool_id):429    if self.get_slot(0, self._held_slot_num+36).itemId == tool_id: return True430    slot_num = self.find_tool(tool_id, held_only=True)431    if slot_num is not None:432      self.change_held_slot(slot_num-36)433      return True434    slot_num = self.find_tool(tool_id, inventory_only=True)435    if slot_num is None: 436      logging.debug('could not find tool_id: %d', tool_id)437      return False438    open_slot_num = self.find_tool(-1, held_only=True)439    if open_slot_num is None:440      held_slot_num = random.randrange(36,45)441      if not self.click_slot(0, held_slot_num, shift=True):442        logging.debug('could not move held item to inventory: %d', held_slot_num)443        return False444    if not self.click_slot(0, slot_num): 445      logging.debug('could not click on slot num: %d', slot_num)446      return False447    if not self.click_slot(0, open_slot_num):448      logging.debug('could not click on slot num: %d', open_slot_num)449      return False450  def run_cmd(self, cmd):451        args = cmd.split()452        if len(args) == 0:453            return454        elif cmd == 'where are you?':455            self.SendChat('x: %d, y: %d, z: %d' % (self._pos.x, self._pos.y, self._pos.z))456  def dig_area(self, bbox, home=None, dump=False, dig_height=0, ignore_blocktypes = [0]):457    logging.info('going to dig: %s', str(bbox))458    time.sleep(3)459    best_against = {460      'pick': [1,4,14,15,16],461      'shovel': [2,3,12,13]462      }463    last_block_type = -1 464    y_range = range(max(bbox['y']), min(bbox['y']), -1)465    z_range = range(min(bbox['z']), max(bbox['z']))466    random.shuffle(z_range)467    x_range = range(min(bbox['x']), max(bbox['x']))468    for y in y_range:469        for z in z_range:470           for x in x_range:471                blockXzy = mc.Xzy(x, z, y)472                if self.world.GetBlock(*blockXzy) is None:473                    logging.info("Waiting for chunks to load...")474                    self.nav_to(x, z, max(bbox['y']))475                    self.WaitFor(lambda: self.world.GetBlock(*blockXzy) is not None)476                blockType = self.world.GetBlock(*blockXzy)477                if blockType in ignore_blocktypes:478                    continue479                if last_block_type != blockType:480                    last_block_type = blockType481                    for tool_name, block_list in best_against.iteritems():482                        if blockType in block_list:483                            if not self.get_best_tool(blockType, tool_name) and home is not None:484                              logging.info('going home to get better tools: %s', str(home))485                              self.nav_to(*home)486                              while not self.get_best_tool(blockType, tool_name):487                                  self.remove_non_tools()488                                  self.move_tools_to_held()489                                  time.sleep(10)490                              self.nav_to(x, z, y + dig_height)491                self.nav_to(x, z, y + dig_height)492                if self.break_block(x, z, y):493                  sys.stdout.write('.')494                else:495                  sys.stdout.write('!')496                sys.stdout.flush()497  def dig_to(self, x, z, y):498    self.MoveTo(*self._pos.xzy())499    path = self.find_path(mc.Xzy(x,z,y), reachable_test=self.world.IsDiggable)500    if path is None:501      logging.error('could not find path')502      return False503    logging.debug('path: %s', str(path))504    for p in path:505      logging.debug('dig: %s, type: %d', str(p), self.world.GetBlock(*p))506      if self.break_block(*p, auto_move=False) and self.break_block(p.x, p.z, p.y + 1, auto_move=False):507        if not self.MoveTo(*p):508          logging.error('could not move to: %s made it to: %s', str(p), str(self._pos.xzy()))509          return False510      else:511        logging.error('could not reach: %s made it to: %s', str((x,z,y)), str(self._pos.xzy()))512        return False513    #logging.info('done')514    return True515  def find_path(self, end, reachable_test=None, limit=None):516    if limit is None:517      limit = cityblock(self._pos.xzy(), end)**2518    def iter_moveable_adjacent(start):519      l = []520      for xzy, block_type in self.world.IterAdjacent(*start):521        if reachable_test(*xzy):522          l.append(xzy)523      return l524    def at_goal(xzy):525      if xzy == end:526        return True527      else:528        return False529    def distance(a, b):530      return cityblock(a, b)531    def distance_to_goal(a):532      return cityblock(a, end)533    if reachable_test is None:534      reachable_test = self.world.IsMoveable535    pos = self._pos.xzy()536    logging.debug('looking for path from: %s to: %s', str(pos), str(end))537    path = astar.astar(538        pos, iter_moveable_adjacent, at_goal, 0, 539        distance, distance_to_goal, limit=limit)540    logging.debug('path: %s', str(path))541    return path542  def get_adjacent_blocks(self, block, min_height=0, max_height=255):543    blocks = []544    for offset_y in range(-1, 2):545      for offset_x in range(-1, 2):546        for offset_z in range(-1, 2):547          x = block.x + offset_x548          z = block.z + offset_z549          y = block.y + offset_y550          if y > 0 and y <= max_height and y >= min_height:551            blocks.append(mc.Xzy(x, z, y))552    for xzy in blocks:553      yield xzy554  def iter_find_blocktype(self, types, start=None):555    if start is None:556      start = self._pos557    start_x, start_z = int(start.x / 16), int(start.z / 16)558    s=self._iter_spiral()559    offset_x, offset_z = s.next()560    cx, cz = start_x + offset_x, start_z + offset_z561    while (cx, cz) in self.world._chunks:562      logging.info('chunk: %s', str((cx, cz)))563      for i, b in enumerate(self.world._chunks[(cx, cz)]._blocks): 564        if b in types:565          logging.info('blocktype: %d', b)566          y, r = divmod(i, 256)567          z, x = divmod(r, 16)568          yield mc.Xzy(x + cx*16, z + cz*16, y)569      offset_x, offset_z = s.next()570      cx, cz = start_x + offset_x, start_z + offset_z571  def _iter_spiral(self):572    x = 0573    y = 0574    dx = 0575    dy = -1576    while True:577      yield (x, y)578      if x == y or (x < 0 and x == -y) or (x > 0 and x == 1-y):579        dx, dy = -dy, dx580      x, y = x+dx, y+dy581  def iter_find_nearest_blocktype(self, start, types=[15], max_height=96, min_height=0):582    height_dict = {583      14: 32, #gold584      15: 64, #iron585      56: 17, #diamonds586    }587    if max_height is None:588      if set(types).issubset(height_dict.keys()):589        max_height = max([h for t, h in height_dict.items() if t in types])590      else:591        max_height = 96592    checked_blocks = set([])593    unchecked_blocks = collections.deque([start])594    block_type = 0595    while len(unchecked_blocks) != 0:596      block = unchecked_blocks.popleft()597      checked_blocks.add(block)598      for block in self.get_adjacent_blocks(block, min_height=min_height, max_height=max_height):599        if block not in checked_blocks and block not in unchecked_blocks and self.world.GetBlock(*block) is not None:600          unchecked_blocks.append(block)601      block_type = self.world.GetBlock(*block)602      if block_type in types:603        yield block604  def help_find_blocks(self, types=[14, 56], chat=True, start=None):605    LAVA = set([10,11])606    if start is None:607      start = self._pos.xzy()608    else:609      self.nav_to(start.x, start.z, 200)610    logging.info('waiting for world to load...')611    self.WaitFor(lambda: self.world.GetBlock(self._pos.x, self._pos.z, self._pos.y) is not None)612    block_iter = self.iter_find_blocktype(types, start=start)613    while True:614      block = block_iter.next()615      if block.y <= 5: continue616      if LAVA.issubset([blocktype for xzy, blocktype in bot.world.IterAdjacent(*block)]): continue617      blocktype = self.world.GetBlock(*block)618      logging.info('%s, %s', str(block), str(self._block_names[blocktype]))619      if chat:620        self.SendChat('%s. type: %s' % (str(block), self._block_names[blocktype]))621      try:622        while not self.WaitFor(lambda: self.world.GetBlock(*block) not in types):623          pass624      except KeyboardInterrupt:625        try:626          print 'break again to stop'627          time.sleep(1)628          continue629        except KeyboardInterrupt:630          return631  def get_player_position(self, player_name):632    for entity in self.world._entities.values():633      if entity._player_name == player_name:634        return entity._pos.xzy()635  def move_to_player(self, player_name):636    xzy = self.get_player_position(player_name)637    logging.info('moving to player: %s at: %s', player_name, str(xzy))638    if xzy is not None:639      self.nav_to(*xzy)640  def click_inventory_block(self, xzy):641    if self._open_window_id != 0:642      return False643    s = mc.Slot(itemId=-1, count=None, meta=None, data=None)644    self.SendPlayerBlockPlacement(xzy.x, xzy.y, xzy.z, 1,  s)645    if self.WaitFor(lambda: self._open_window_id != 0):646      if self.WaitFor(lambda: self._open_window_id in self.windows):647        return True648    return False649  def iter_nearest(self, start):650    checked_blocks = set([])651    unchecked_blocks = collections.deque([start])652    while len(unchecked_blocks) != 0:653      block = unchecked_blocks.popleft()654      checked_blocks.add(block)655      for block in self.get_adjacent_blocks(block):656        if block not in checked_blocks and block not in unchecked_blocks and self.world.GetBlock(*block) is not None:657          unchecked_blocks.append(block)658        yield block659  def iter_nearest_moveable(self, start):660    for block in self.iter_nearest(start):661      if self.world.IsMoveable(*block):662        yield block663  def iter_nearest_radius(self, start, radius):664    block = self.iter_nearest(start)665    while euclidean(start, block.next()) <= radius:666      yield block.next()667  def place_block(self, xzy):668    def get_block_direction(a, b):669      if a.y < b.y: return 0670      elif a.y > b.y: return 1671      elif a.z < b.z: return 2672      elif a.z > b.z: return 3673      elif a.x < b.x: return 4674      elif a.x > b.x: return 5675    SOLID = set(range(1, 5) + [7] + range(12, 27))676    m= self.iter_nearest_moveable(xzy)677    block = m.next()678    while euclidean(xzy, block) <= 6:679      if self.nav_to(*block): break680      block = m.next()681    else:682      logging.error('too far to place block')683      return False684    slot = self.get_slot(0, self._held_slot_num+36)685    for block, blocktype in self.world.IterAdjacent(*xzy):686      if blocktype in SOLID:687        direction = get_block_direction(xzy, block)688        logging.debug('sending block placement command: %s, direction: %d, slot_data: %s', str(block), direction, str(slot))689        self.SendPlayerBlockPlacement(block.x, block.y, block.z, direction,  slot)690        if self.WaitFor(lambda: self.world.GetBlock(*xzy) == slot.itemId, timeout=5):691          return True692        else:693          logging.error('placed blocktype did not change')694          return False695    else:696      logging.error('could not find solid adjacent block')697      return False698  def fill_adjacent_liquid(self, xzy):699    LIQUID = set(range(8,12))700    SOLID = set([1,3,4])701    for block, blocktype in self.world.IterAdjacent(*xzy):702      if blocktype in LIQUID:703        solid_blocktype = SOLID.intersection(self.get_inventory_ids())704        if len(solid_blocktype) == 0: return False705        if not self.equip_tool(solid_blocktype): return False706        if not self.place_block(block): return False707        return True708  def close_window(self):709    window_id = self._open_window_id710    self._open_window_id = 0711    self.SendCloseWindow(window_id)712    if window_id != 0:713      del self.windows[window_id]714    time.sleep(1)715  def enchant(self, tool_id, max_distance=100):716    ENCHANTMENT_TABLE=116717    pos = self._pos.xzy()718    logging.info('finding nearest enchanting table')719    table = self.iter_find_nearest_blocktype(pos, types=[ENCHANTMENT_TABLE]).next()720    if cityblock(pos, table) > max_distance:721      logging.error('too far from enchanting table') 722      return False723    logging.info('moving to enchanting table')724    if not self.nav_to(*table):725      logging.error('did not make it to enchanting table')726      return False727    self.close_window()728    logging.info('opening enchantment window')729    if not self.click_inventory_block(table):730      logging.error('could not open enchantment window')731      return False732    window_id = self._open_window_id733    logging.info('looking for tool')734    slot_num = self.find_tool(tool_id, window_id=window_id, inventory_only=True, no_data=True)735    if slot_num is None:736      logging.error('could not find tool to enchant')737      return False738    if not self.click_slot(window_id, slot_num):739      logging.error('could not grab tool to enchant')740      return False741    logging.info('looking for best enchantment level')742    target_level = min(self._xp_level, 50)743    while target_level not in self._available_enchantments.values():744      if not self.click_slot(window_id, 0):745        logging.error('failed to place tool on enchanting table')746        return False747      if self._cursor_slot.itemId == -1:748        self.WaitFor(lambda: sum(self._available_enchantments.values()) != 0, timeout=5)749        logging.debug('enchantment level: %d', max(self._available_enchantments.values()))750    enchantment_num = [ k for k, v in self._available_enchantments.items() if v == target_level ][0]751    logging.info('enchanting item')752    self.SendEnchantItem(self._open_window_id, enchantment_num)753    if not self.WaitFor(lambda: self.windows[window_id]._slots[0].data is not None, timeout=5):754      logging.error('enchant tool command failed')755      return False756    if not self.click_slot(window_id, 0):757      logging.error('could not grab enchanted tool')758      return False759    if not self.click_slot(window_id, slot_num):760      logging.error('could not place enchanted tool in inventory')761      return False762    logging.info('closing enchantment window')763    self.close_window()764    return True765  def eat(self, target_food_level=20):766    logging.info('eating')767    BREAD = 297768    if not self.equip_tool(BREAD):769      logging.debug('could not equip bread')770      return False771    slot = self.get_slot(0, self._held_slot_num+36)772    if slot is None:773      return False774    while slot.itemId == BREAD and slot.count > 0 and self._food < target_food_level:775      self.SendPlayerBlockPlacement(-1, -1, -1, -1, slot)776      time.sleep(1)777      slot = self.get_slot(0, self._held_slot_num+36)778    time.sleep(1)779    self.SendPlayerDigging(5, 0, 0, 0, 255)780    logging.debug('food level: %d, bread slot: %s', self._food, str(slot))781    if self._food == target_food_level:782      return True783    else:784      return False785  def get_inventory(self):786    return [ (slot_num, item) for slot_num, item in enumerate(self.windows[0]._slots) if item.itemId != -1 ]787  def get_inventory_ids(self):788    return [ item.itemId for slot_num, item in enumerate(self.windows[0]._slots) if item.itemId != -1 ]789  def drop_items(self, item_ids, invert=False, single=False):790    if self._open_window_id != 0:791      return False792    if len(item_ids) == 0:793      drop_list = [ slot_num for slot_num, item in self.get_inventory() ]794    elif invert:795      drop_list = [ slot_num for slot_num, item in self.get_inventory() if item.itemId not in item_ids ]796    else:797      drop_list = [ slot_num for slot_num, item in self.get_inventory() if item.itemId in item_ids ]798    for slot_num in drop_list:799      if slot_num >= 9:800        if not self.click_slot(0, slot_num):801          return False802        if not self.click_slot(0, -999):803          return False804      if single:805        return True806    else:807      return True808  def find_chest_with_item(self, tool_id, timeout=60):809    start_time = time.time()810    self.close_window()811    for chest_block in self.iter_find_blocktype([self._block_ids['chest']]):812      self.nav_to(*chest_block)813      if self.click_inventory_block(chest_block):814        if tool_id in [ item.itemId for item in self.windows[self._open_window_id]._slots ]:815          self.close_window()816          return chest_block817      self.close_window()818    if time.time() > start_time + timeout:819      logging.error('timed out looking for tool')820      self.close_window()821      return None822  def get_item_from_chest(self, tool_id, chest_block, ignore_special=False):823    if not self.click_inventory_block(chest_block): return False824    source_slot_num = self.find_tool(tool_id, window_id=self._open_window_id, storage_only=True, no_data=ignore_special)825    source_tool_id = self.windows[self._open_window_id]._slots[source_slot_num].itemId826    if source_slot_num is None: return False827    if not self.click_slot(self._open_window_id, source_slot_num, shift=1): return False828    if tool_id is None:829      self.close_window()830      return source_tool_id831    else:832      self.close_window()833      return True834  def put_item_into_chest(self, tool_id, chest_block):835    if self.click_inventory_block(chest_block):836      source_slot_num = self.find_tool(tool_id, window_id=self._open_window_id, inventory_only=True)837      target_slot_num = self.find_tool(-1, window_id=self._open_window_id, storage_only=True)838      if source_slot_num is not None and target_slot_num is not None:839        if self.click_slot(self._open_window_id, source_slot_num):840          if self.click_slot(self._open_window_id, target_slot_num):841            self.close_window()842            return True843    self.close_window()844    return False845if __name__ == '__main__':846  parser = optparse.OptionParser()847  parser.add_option("-s", "--server", dest="server", default="localhost",848                        help="server", metavar="SERVER")849  parser.add_option("-P", "--port", dest="port", default=25565, type="int",850                        help="port", metavar="PORT")851  parser.add_option("-u", "--user", dest="user",852                        help="user to login as", metavar="USER")853  parser.add_option("-p", "--pass", dest="password",854                        help="password", metavar="PASSWORD")855  parser.add_option("-b", "--bbox", dest="bbox", default='jungle',856                        help="digging bbox", metavar="BBOX")857  parser.add_option("-r", "--return-base", dest="return_base", default='base',858                        help="base to return to for better tools", metavar='BASE')859  parser.add_option('-v', '--verbose', dest='verbose', action='count',860                  help="Increase verbosity (specify multiple times for more)")861  (options, args) = parser.parse_args()862  if options.verbose >= 1: log_level = logging.DEBUG863  else: log_level = logging.INFO864  logging.basicConfig(level=log_level)865  with open('sites.json') as f:866    sites = json.load(f)867    bboxes = sites['bboxes']868    return_bases = sites['return_bases']869  bbox = bboxes[options.bbox]870  home = return_bases[options.return_base] 871  server = options.server872  port = options.port873  password = options.password874  if options.user is not None: 875    username = options.user876  else:877    bot_names = ['peon', 'serf', 'grunt', 'slave', 'drudge', 'farmboy', 'peasant']878    for name in bot_names:879      if not os.path.isfile(os.path.join('/tmp', name)):880        username = name881        break882    else:883      raise Exception('All usernames are logged in')884  if len(args) > 0: 885    cmd = args.pop(0)886    if cmd in ['kill', 'terraform']:887      import scrap888      funcs = {'kill': scrap.kill, 'terraform': scrap.terraform}889      users = {'kill': 'merlin', 'terraform': 'bob'}890      fighting = {'kill': False, 'terraform': True}891      server = 'mc.gmendiola.com'892      bot = MineCraftBot(server, port, users[cmd], password=password, fighting=fighting[cmd])893      bot.WaitFor(lambda: bot._pos.x != 0.0 and bot._pos.y != 0.0)894      time.sleep(5)895      funcs[cmd](bot)896    elif cmd == 'explore':897      username = 'dora'898      bot = MineCraftBot(server, port, username, password=password)899      bot.WaitFor(lambda: bot._pos.x != 0.0 and bot._pos.y != 0.0)900      time.sleep(2)901      import scrap902      scrap.explore(bot)903    if cmd == 'test':904      bot = MineCraftBot(server, port, username, password=password)905      bot.WaitFor(lambda: bot._pos.x != 0.0 and bot._pos.y != 0.0)906      logging.info('bot ready')907    elif cmd == 'help':908      types = [14,15,16,56]909      bot = MineCraftBot(server, port, username, password=password)910      time.sleep(5)911      print bot._pos.xzy()912      start = bot.get_player_position('magahet')913      if start is None:914        x = float(raw_input('x: ').strip())915        z = float(raw_input('z: ').strip())916        start = mc.Xzy(x, z, 0)917      bot.help_find_blocks(start, types=types)918    elif cmd == 'dig':919      bot = MineCraftBot(server, port, username, password=password)...

mc.py

Source:mc.py

1import array2import collections3import Queue4import struct5import sys6import os7import threading8import time9import urllib10import urllib211import zlib12import math13import logging14class Slot(collections.namedtuple('Slot', ('itemId', 'count', 'meta', 'data'))):15  pass16class Window(object):17  def __init__(self, windowId, slots):18    self._slots = slots19    self._count = len(slots)20    self.inventory_type = None21    self.window_title = None22  def GetMainInventory(self):23    return self._slots[-36:-9]24  def GetHeld(self):25    return self._slots[-9:]26  def SetSlot(self, index, slot):27    self._slots[index] = slot28class Xzy(collections.namedtuple('Xzy', ('x', 'z', 'y'))):29  def __new__(cls, *args, **kwargs):30    args = map(math.floor, args)31    args = map(int, args)32    for k, v in kwargs.iteritems():33      kwargs[k] = int(math.floor(v))34    return super(Xzy, cls).__new__(cls, *args, **kwargs)35  def Offset(self, x=0, z=0, y=0):36    return Xzy(self.x + x, self.z + z, self.y + y)37class World(object):38  def __init__(self):39    self._chunks = {}40    self._entities= {}41    pass42  def MapChunk(self, chunk):43    self._chunks[chunk.chunkX, chunk.chunkZ] = chunk44  def SetBlock(self, x, z, y, newType, newMeta):45    chunk = self._chunks.get((int(x/16), int(z/16)))46    if not chunk:47      return None48    return chunk.SetBlock(int(x), int(z), int(y), newType, newMeta)49  def GetBlock(self, x, z, y):50    chunk = self._chunks.get((int(x/16), int(z/16)))51    if chunk is None:52      return None53    return chunk.GetBlock(int(x), int(z), int(y))54  def IsJumpable(self, x, z, y):55    SOLID = set(range(1, 5) + [7] + range(12, 27))56    return (57        (self.GetBlock(x, z, y - 2) in SOLID or58         self.GetBlock(x, z, y - 1) in SOLID) and59        self.GetBlock(x, z, y)     not in SOLID and60        self.GetBlock(x, z, y + 1) == 061        )62  def IsMoveable(self, x, z, y):63    NON_SOLID = set([0,6,27,28,31,32,37,38,39,40,50,55,59,63,65,66,68,69,70,72,75,76,78,93,94,96,106,111,115,])64    standable = (65        self.GetBlock(x, z, y) in NON_SOLID and66        self.GetBlock(x, z, y + 1) in NON_SOLID67    )68    return standable69  def IsStandable(self, x, z, y):70    SOLID = set(range(1, 5) + [7] + range(12, 27))71    standable = (72        self.GetBlock(x, z, y - 1) in SOLID and73        self.GetBlock(x, z, y)     == 0 and74        self.GetBlock(x, z, y + 1) == 075    )76    return standable77  def IsDiggable(self, x, z, y):78    UNDIGGABLE= set([7])79    NON_SOLID = set(range(8, 14))80    if self.GetBlock(x, z, y) in UNDIGGABLE or self.GetBlock(x, z, y + 1) in UNDIGGABLE:81      return False82    for xzy, block_type in self.IterAdjacent(x, z, y):83      if block_type in NON_SOLID:84        return False85    for xzy, block_type in self.IterAdjacent(x, z, y + 1):86      if block_type in NON_SOLID:87        return False88    return True89  def IterAdjacent(self, x, z, y):90    adjacents = [91        Xzy(x, z, y - 1),92        Xzy(x + 1, z, y),93        Xzy(x - 1, z, y),94        Xzy(x, z - 1, y),95        Xzy(x, z + 1, y),96        Xzy(x, z, y + 1),97        ]98    for xzy in adjacents:99      yield xzy, self.GetBlock(*xzy)100  def find_nearest_standable(self, xzy, within=100):101    maxD = 100102    d = {}103    d[xzy] = 0104    queue = [xzy]105    while queue:106      current_xzy = queue.pop(0)107      xzyD = d[current_xzy]108      if xzyD > maxD:109        break110      if self.IsStandable(*current_xzy) and cityblock(xzy, current_xzy) < within:111        return xzy112      for xzyAdj, blockAdj in self.IterAdjacent(*xzy):113        if xzyAdj in d:114          continue115        if self.IsJumpable(*xzyAdj):116          d[xzyAdj] = xzyD + 1117          queue.append(xzyAdj)118    return None119  def FindNearestStandable(self, xzy, condition):120    maxD = 100121    d = {}122    d[xzy] = 0123    queue = [xzy]124    while queue:125      xzy = queue.pop(0)126      xzyD = d[xzy]127      if xzyD > maxD:128        break129      if self.IsStandable(*xzy) and condition(xzy):130        return xzy131      for xzyAdj, blockAdj in self.IterAdjacent(*xzy):132        if xzyAdj in d:133          continue134        if self.IsJumpable(*xzyAdj):135          d[xzyAdj] = xzyD + 1136          queue.append(xzyAdj)137    return None138  def FindPath(self, xzyA, xzyB):139    xzyA = Xzy(*xzyA)140    xzyB = Xzy(*xzyB)141    d = {}142    d[xzyA] = 0143    queue = [xzyA]144    while queue and xzyB not in d:145      xzy = queue.pop(0)146      xzyD = d[xzy]147      for xzyAdj, blockAdj in self.IterAdjacent(*xzy):148        if xzyAdj not in d and self.IsMoveable(*xzyAdj):149          d[xzyAdj] = xzyD + 1150          queue.append(xzyAdj)151    if xzyB not in d:152      return None153    path = [xzyB]154    while path[-1] != xzyA:155      for xzyAdj, blockAdj in self.IterAdjacent(*path[-1]):156        if xzyAdj in d and d[xzyAdj] < d[path[-1]]:157          path.append(xzyAdj)158          break159    path.reverse()160    return path161class Position(collections.namedtuple('Position',162    ('x', 'y', 'stance', 'z', 'yaw', 'pitch', 'on_ground'))):163  def xzy(self):164      return Xzy(self.x, self.z, self.y)165class Confirmation(collections.namedtuple('Confirmation', ('window_id', 'action_id', 'accepted'))):166  pass167class Entity(object):168  def __init__(self, eid, etype, x, y, z, yaw, pitch, player_name=None, current_item=None, head_yaw=0, metadata=None):169    self._eid = eid170    self._type= etype171    self._pos = Position(x/32, y/32, (y/32)+1, z/32, yaw, pitch, 1)172    self._player_name = player_name173    self._current_item = current_item174    self._head_yaw = head_yaw175    self._metadata = metadata176  def Move(self, dx, dy, dz):177    if None not in self._pos.xzy():178      x = self._pos.x + (dx/32.0)179      z = self._pos.z + (dz/32.0)180      y = self._pos.y + (dy/32.0)181      yaw = self._pos.yaw182      pitch = self._pos.pitch183      self._pos = Position(x, y, y+1, z, yaw, pitch, 1)184  def Teleport(self, x, y, z):185    yaw = self._pos.yaw186    pitch = self._pos.pitch187    self._pos = Position(x/32.0, y/32.0, (y/32.0)+1, z/32.0, yaw, pitch, 1)188class ChunkColumn(object):189  def __init__(self, chunkX, chunkZ,190      blockData, blockMeta, lightData, skyLightData, addArray, biomeData):191    self.chunkX = chunkX192    self.chunkZ = chunkZ193    self._blocks = blockData194    self._meta = blockMeta195    self._light = lightData196    self._skylight = skyLightData197    self._addArray = addArray198    self._skyLightData = skyLightData199    self._biome = biomeData200  def _GetOffset(self, x, z, y):201    x, z, y = int(x), int(z), int(y)202    return (       (x - self.chunkX * 16) +203            (16 *  (z - self.chunkZ * 16)) +204            (256 * (y))205           )206  def SetBlock(self, x, z, y, newType, newMeta):207    # TODO: what about extra 4 bits?208    offset = self._GetOffset(x, z, y)209    self._blocks[offset] = (newType & 0xff)210    return newType211  def GetBlock(self, x, z, y):212    offset = self._GetOffset(x, z, y)213    if offset < len(self._blocks):214      blocktype = self._blocks[offset]215      return blocktype216class MineCraftProtocol(object):217  def __init__(self):218    self._sock = None219    self._sockGeneration = 0220    self._recvCondition = threading.Condition()221    self._buf = ""222    self._sendQueue = Queue.Queue(10)223    self.parentPID = os.getppid()224    self._threads = []225    self._threadFuncs = [226        self._DoReadThread,227        self._DoSendThread,228        ]229    self._parsers = {230        '\x00': self.ParseKeepAlive,231        '\x01': self.ParseLogin,232        '\x02': self.ParseHandshake,233        '\x03': self.ParseChatMessage,234        '\x04': self.ParseTimeUpdate,235        '\x05': self.ParseEntityEquipment,236        '\x06': self.ParseSpawn,237        #'\x07': client only238        '\x08': self.ParseUpdateHealth,239        '\x09': self.ParseRespawn,240        '\x10': self.ParseHeldItemChange,241        #'\x0a': client only242        #'\x0b': client only243        '\x0c': self.ParsePlayerLook,244        '\x0d': self.ParsePlayerPositionLook,245        #'\x0e': client only246        #'\x0f': client only247        #'\x10': client only248        '\x11': self.ParseUseBed,249        '\x12': self.ParseAnimation,250        #'\x13': client only251        '\x14': self.ParseSpawnNamedEntity,252        '\x15': self.ParseSpawnDroppedItem,253        '\x16': self.ParseCollectItem,254        '\x17': self.ParseSpawnObjectVehicle,255        '\x18': self.ParseSpawnMob,256        '\x19': self.ParseSpawnPainting,257        '\x1a': self.ParseSpawnExperienceOrb,258        #'\x1b': self.ParseStanceUpdate,259        '\x1c': self.ParseEntityVelocity,260        '\x1d': self.ParseDestroyEntity,261        '\x1e': self.ParseEntity,262        '\x1f': self.ParseEntityRelativeMove,263        '\x20': self.ParseEntityLook,264        '\x21': self.ParseEntityRelativeLookAndMove,265        '\x22': self.ParseEntityTeleport,266        '\x23': self.ParseEntityHeadLook,267        '\x26': self.ParseEntityStatus,268        '\x27': self.ParseAttachEntity,269        '\x28': self.ParseEntityMetadata,270        '\x29': self.ParseEntityEffect,271        '\x2a': self.ParseRemoveEntityEffect,272        '\x2b': self.ParseSetExperience,273        '\x32': self.ParseMapColumnAllocation,274        '\x33': self.ParseMapChunks,275        '\x34': self.ParseMultiBlockChange,276        '\x35': self.ParseBlockChange,277        '\x36': self.ParseBlockAction,278        '\x3c': self.ParseExplosion,279        '\x3d': self.ParseSoundParticleEffect,280        '\x46': self.ParseChangeGameState,281        '\x47': self.ParseThunderbolt,282        '\x64': self.ParseOpenWindow,283        '\x65': self.ParseCloseWindow,284        '\x67': self.ParseSetSlot,285        '\x68': self.ParseSetWindowItems,286        '\x69': self.ParseUpdateWindowProperty,287        '\x6a': self.ParseConfirmTransaction,288        '\x6b': self.ParseCreativeInventoryAction,289        '\x82': self.ParseUpdateSign,290        '\x83': self.ParseItemData,291        '\x84': self.ParseUpdateTileEntity,292        '\xc8': self.ParseIncrementStatistic,293        '\xc9': self.ParsePlayerListItem,294        '\xca': self.ParsePlayerAbility,295        '\xff': self.ParseKick,296        }297    self._interesting = set([298        #'\x00', #KeepAlive299        #'\x01', #Login300        #'\x02', #Handshake301        #'\x03', #ChatMessage302        #'\x04', #TimeUpdate303        #'\x05', #EntityEquipment304        #'\x06', #Spawn305        #'\x08', #UpdateHealth306        #'\x09', #Respawn307        #'\x0e', #PlayerDigging308        #'\x10', #HeldItemChange309        #'\x0c', #PlayerLook310        #'\x0d', #PlayerPositionLook311        #'\x11', #UseBed312        #'\x12', #Animation313        #'\x14', #SpawnNamedEntity314        #'\x15', #SpawnDroppedItem315        #'\x16', #CollectItem316        #'\x17', #SpawnObjectVehicle317        #'\x18', #SpawnMob318        #'\x19', #SpawnPainting319        #'\x1a', #SpawnExperienceOrb320        #'\x1b', #StanceUpdate321        #'\x1c', #EntityVelocity322        #'\x1d', #DestroyEntity323        #'\x1f', #EntityRelativeMove324        #'\x20', #EntityLook325        #'\x21', #EntityRelativeLookAndMove326        #'\x22', #EntityTeleport327        #'\x23', #EntityHeadLook328        #'\x26', #EntityStatus329        #'\x27', #AttachEntity330        #'\x28', #EntityMetadata331        #'\x29', #EntityEffect332        #'\x2a', #RemoveEntityEffect333        #'\x2b', #SetExperience334        #'\x32', #MapColumnAllocation335        #'\x33', #MapChunks336        #'\x34', #MultiBlockChange337        #'\x35', #BlockChange338        #'\x36', #BlockAction339        #'\x3c', #Explosion340        #'\x3d', #SoundParticleEffect341        #'\x46', #ChangeGameState342        #'\x47', #Thunderbolt343        #'\x64', #OpenWindow344        #'\x65', #CloseWindow345        #'\x67', #SetSlot346        #'\x68', #SetWindowItems347        #'\x69', #UpdateWindowProperty348        #'\x6a', #ConfirmTransaction349        #'\x6b', #CreativeInventoryAction350        #'\x82', #UpdateSign351        #'\x83', #ItemData352        #'\x84', #UpdateTileEntity353        #'\xc8', #IncrementStatistic354        #'\xc9', #PlayerListItem355        #'\xca', #PlayerAbility356        #'\xff', #Kick357        ])358    self._handlers = {}359  ##############################################################################360  # minecraft.net methods361  def GetSessionId(self, username, password):362    data = urllib.urlencode((363        ('user', username),364        ('password', password),365        ('version', '1337'),366        ))367    sessionString = urllib2.urlopen('https://login.minecraft.net/', data).read()368    return sessionString.split(':')[3]369  def JoinServer(self, username, sessionId, serverId):370    data = urllib.urlencode((371        ('user', username),372        ('sessionId', sessionId),373        ('serverId', serverId),374        ))375    url = 'http://session.minecraft.net/game/joinserver.jsp?' + data376    return urllib2.urlopen(url).read()377  ##############################################################################378  # Thread functions379  def StartThreads(self):380    self._threads = []381    for func in self._threadFuncs:382      thread = threading.Thread(target=func)383      thread.daemon = True384      thread.start()385      self._threads.append(thread)386    return self387  def _DoReadThread(self):388    try:389      myGeneration = self._sockGeneration390      while myGeneration == self._sockGeneration:391        self.RecvPacket()392        if os.getppid() != self.parentPID:393          pass394          #print "ReadThread exiting", myGeneration395          #sys.exit()396    finally:397      os.kill(self.parentPID, 0)398  def _DoSendThread(self):399    try:400      myGeneration = self._sockGeneration401      sock = self._sock402      queue = self._sendQueue403      while myGeneration == self._sockGeneration and self._sock is not None:404        sock.sendall(queue.get())405        if os.getppid() != self.parentPID:406          pass407          #print "SendThread exiting", myGeneration408    finally:409      os.kill(self.parentPID, 0)410  ##############################################################################411  # Protocol convenience methods412  def Send(self, packet):413    if packet[0] in self._interesting:414    #if True:415      sys.stderr.write('\nSending packet: %s\n' % hex(ord(packet[0])))416    self._sendQueue.put(packet)417  def Read(self, size):418    while len(self._buf) < size:419      recieved = self._sock.recv(4096)420      self._buf += recieved421    ret = self._buf[:size]422    self._buf = self._buf[size:]423    return ret424  def RecvPacket(self):425    ilk = self.Read(1)426    try:427      parsed = self._parsers[ilk]()428      if ilk in self._interesting:429        logging.debug('Parsed packet: %s (buf: %d)', hex(ord(ilk)), len(self._buf))430      handler = self._handlers.get(ilk)431      if handler:432        handler(*parsed)433      with self._recvCondition:434        self._recvCondition.notifyAll()435    except KeyError:436      sys.stderr.write('unknown packet: %s\n' % hex(ord(ilk)))437      raise438      i = ''439      while i != '\x00':440        i = self.Read(1)441        sys.stderr.write('%s  ' % hex(ord(i)))442      sys.stderr.write('back on track\n')443  def WaitFor(self, what, timeout=10):444    start = time.time()445    with self._recvCondition:446      while not what() and time.time() - start < timeout:447        self._recvCondition.wait(timeout=1)448    return what()449  def PackString(self, string):450    return struct.pack('!h', len(string)) + string.encode('utf_16_be')451  def PackSlot(self, slot_data):452    itemId, count, meta, data = slot_data453    packet = struct.pack('!h', itemId)454    if itemId == -1:455      return packet456    packet += (struct.pack('!b', count) +457      struct.pack('!h', meta)458      )459    if ((256 <= itemId <= 259) or460        (267 <= itemId <= 279) or461        (283 <= itemId <= 286) or462        (290 <= itemId <= 294) or463        (298 <= itemId <= 317) or464        itemId == 261 or itemId == 359 or itemId == 346):465      if data is None:466        packet += struct.pack('!h', -1)467      else:468        packet += struct.pack('!h', len(data)) + data469    return packet470  def UnpackInt8(self):471    value, = struct.unpack('!b', self.Read(1))472    return value473  def UnpackUint8(self):474    value, = struct.unpack('!B', self.Read(1))475    return value476  def UnpackInt16(self):477    value, = struct.unpack('!h', self.Read(2))478    return value479  def UnpackInt32(self):480    value, = struct.unpack('!i', self.Read(4))481    return value482  def UnpackInt64(self):483    value, = struct.unpack('!q', self.Read(8))484    return value485  def UnpackFloat(self):486    value, = struct.unpack('!f', self.Read(4))487    return value488  def UnpackDouble(self):489    value, = struct.unpack('!d', self.Read(8))490    return value491  def UnpackBool(self):492    value, = struct.unpack('?', self.Read(1))493    return value494  def UnpackString(self):495    strlen = self.UnpackInt16()496    string = self.Read(strlen * 2).decode('utf_16_be')497    return string498  def UnpackSlot(self):499    itemId = self.UnpackInt16()500    if itemId == -1:501      return Slot(itemId, None, None, None)502    itemCount = self.UnpackInt8()503    meta = self.UnpackInt16()  # damage, or block meta504    data = None505    # These certain items are capable of having meta/enchantments506    if ((256 <= itemId <= 259) or507        (267 <= itemId <= 279) or508        (283 <= itemId <= 286) or509        (290 <= itemId <= 294) or510        (298 <= itemId <= 317) or511        itemId == 261 or itemId == 359 or itemId == 346):512      arraySize = self.UnpackInt16()513      if arraySize != -1:514        data = self.Read(arraySize)515    return Slot(itemId, itemCount, meta, data)516  517  def UnpackMetadata(self):518    metadata = {}519    x = self.UnpackUint8()520    while x != 127:521        index = x & 0x1F # Lower 5 bits522        ty    = x >> 5   # Upper 3 bits523        if ty == 0: val = self.UnpackInt8()524        if ty == 1: val = self.UnpackInt16()525        if ty == 2: val = self.UnpackInt32()526        if ty == 3: val = self.UnpackFloat()527        if ty == 4: val = self.UnpackString()528        if ty == 5:529            val = {}530            val["id"]     = self.UnpackInt16()531            val["count"]  = self.UnpackInt8()532            val["damage"] = self.UnpackInt16()533        if ty == 6:534            val = []535            for i in range(3):536                val.append(self.UnpackInt32())537        metadata[index] = (ty, val)538        x = self.UnpackInt8()539    return metadata540  ##############################################################################541  # Parsers542  def ParseKick(self):543    sys.stderr.write('Kicked: ' + self.UnpackString() + '\n')544    raise Exception()545  def ParseHandshake(self):546    return (self.UnpackString(),)547  def ParseChatMessage(self):548    chat = self.UnpackString()549    return (chat,)550  def ParseKeepAlive(self):551    return (self.UnpackInt32(),)552  def ParseLogin(self):553    entityId = self.UnpackInt32()554    trash = self.UnpackString()555    levelType = self.UnpackString()556    serverMode = self.UnpackInt32()557    dimension = self.UnpackInt32()558    difficulty = self.UnpackInt8()559    trash = self.UnpackUint8()560    maxPlayers = self.UnpackUint8()561    return (entityId, levelType, serverMode, dimension, difficulty, maxPlayers)562  def ParseSpawn(self):563    return (564        self.UnpackInt32(),565        self.UnpackInt32(),566        self.UnpackInt32(),567        )568  def ParseUpdateHealth(self):569    return (570        self.UnpackInt16(),571        self.UnpackInt16(),572        self.UnpackFloat(),573        )574  def ParseRespawn(self):575    return (576        self.UnpackInt32(),577        self.UnpackInt8(),578        self.UnpackInt8(),579        self.UnpackInt16(),580        self.UnpackString(),581        )582  def ParseHeldItemChange(self):583    return (584        self.UnpackInt16(),585        )586  def ParsePlayerLook(self):587    return (588        self.UnpackFloat(),589        self.UnpackFloat(),590        self.UnpackInt8(),591        )592  def ParsePlayerPositionLook(self):593    return (594        self.UnpackDouble(),595        self.UnpackDouble(),596        self.UnpackDouble(),597        self.UnpackDouble(),598        self.UnpackFloat(),599        self.UnpackFloat(),600        self.UnpackInt8(),601        )602  def ParseUseBed(self):603    return (604        self.UnpackInt32(),605        self.UnpackInt8(),606        self.UnpackInt32(),607        self.UnpackInt8(),608        self.UnpackInt32(),609        )610  def ParseAnimation(self):611    return (612        self.UnpackInt32(),613        self.UnpackInt8(),614        )615  def ParseSpawnNamedEntity(self):616    return (617        self.UnpackInt32(),618        self.UnpackString(),619        self.UnpackInt32(),620        self.UnpackInt32(),621        self.UnpackInt32(),622        self.UnpackInt8(),623        self.UnpackInt8(),624        self.UnpackInt16(),625        )626  def ParseSpawnDroppedItem(self):627    return (628        self.UnpackInt32(),629        self.UnpackInt16(),630        self.UnpackInt8(),631        self.UnpackInt16(),632        self.UnpackInt32(),633        self.UnpackInt32(),634        self.UnpackInt32(),635        self.UnpackInt8(),636        self.UnpackInt8(),637        self.UnpackInt8(),638        )639  def ParseCollectItem(self):640    return (641        self.UnpackInt32(),642        self.UnpackInt32(),643        )644  def ParseSpawnObjectVehicle(self):645    return (646        self.UnpackInt32(),647        self.UnpackInt8(),648        self.UnpackInt32(),649        self.UnpackInt32(),650        self.UnpackInt32(),651        self.UnpackInt32(),652        self.UnpackInt16(),653        self.UnpackInt16(),654        self.UnpackInt16(),655        )656  def ParseSpawnMob(self):657    return (658        self.UnpackInt32(),659        self.UnpackInt8(),660        self.UnpackInt32(),661        self.UnpackInt32(),662        self.UnpackInt32(),663        self.UnpackInt8(),664        self.UnpackInt8(),665        self.UnpackInt8(),666        self.UnpackMetadata(),667        )668  def ParseSpawnPainting(self):669    return (670        self.UnpackInt32(),671        self.UnpackString(),672        self.UnpackInt32(),673        self.UnpackInt32(),674        self.UnpackInt32(),675        self.UnpackInt32(),676        )677  def ParseSpawnExperienceOrb(self):678    return (679        self.UnpackInt32(),680        self.UnpackInt32(),681        self.UnpackInt32(),682        self.UnpackInt32(),683        self.UnpackInt16(),684        )685  def ParseStanceUpdate(self):686    return (687        self.UnpackFloat(),688        self.UnpackFloat(),689        self.UnpackFloat(),690        self.UnpackFloat(),691        self.UnpackBool(),692        self.UnpackBool(),693        )694  def ParseEntityVelocity(self):695    return (696        self.UnpackInt32(),697        self.UnpackInt16(),698        self.UnpackInt16(),699        self.UnpackInt16(),700        )701  def ParseDestroyEntity(self):702    return (703        self.UnpackInt32(),704        )705  def ParseEntity(self):706    return (707        self.UnpackInt32(),708        )709  def ParseEntityRelativeMove(self):710    return (711        self.UnpackInt32(),712        self.UnpackInt8(),713        self.UnpackInt8(),714        self.UnpackInt8(),715        )716  def ParseEntityLook(self):717    return (718        self.UnpackInt32(),719        self.UnpackInt8(),720        self.UnpackInt8(),721        )722  def ParseEntityRelativeLookAndMove(self):723    return (724        self.UnpackInt32(),725        self.UnpackInt8(),726        self.UnpackInt8(),727        self.UnpackInt8(),728        self.UnpackInt8(),729        self.UnpackInt8(),730        )731  def ParseEntityTeleport(self):732    return (733        self.UnpackInt32(),734        self.UnpackInt32(),735        self.UnpackInt32(),736        self.UnpackInt32(),737        self.UnpackInt8(),738        self.UnpackInt8(),739        )740  def ParseEntityHeadLook(self):741    return (742        self.UnpackInt32(),743        self.UnpackInt8(),744        )745  def ParseEntityStatus(self):746    return (747        self.UnpackInt32(),748        self.UnpackInt8(),749        )750  def ParseAttachEntity(self):751    return (752        self.UnpackInt32(),753        self.UnpackInt32(),754        )755  def ParseEntityMetadata(self):756    return (757        self.UnpackInt32(),758        self.UnpackMetadata(),759        )760  def ParseEntityEffect(self):761    return (762        self.UnpackInt32(),763        self.UnpackInt8(),764        self.UnpackInt8(),765        self.UnpackInt16(),766        )767  def ParseRemoveEntityEffect(self):768    return (769        self.UnpackInt32(),770        self.UnpackInt8(),771        )772  def ParseSetExperience(self):773    return (774        self.UnpackFloat(),775        self.UnpackInt16(),776        self.UnpackInt16(),777        )778  def ParsePlayerAbility(self):779    return (780        self.UnpackInt8(),781        self.UnpackInt8(),782        self.UnpackInt8(),783        self.UnpackInt8(),784        )785  def ParseIncrementStatistic(self):786    return (787        self.UnpackInt32(),788        self.UnpackInt8(),789        )790  def ParsePlayerListItem(self):791    return (792        self.UnpackString(),793        self.UnpackInt8(),794        self.UnpackInt16(),795        )796  def ParseTimeUpdate(self):797    return (798        self.UnpackInt64(),)799  def ParseEntityEquipment(self):800    return (801        self.UnpackInt32(),802        self.UnpackInt16(),803        self.UnpackInt16(),804        self.UnpackInt16(),805        )806  def ParseMapColumnAllocation(self):807    return (808        self.UnpackInt32(),809        self.UnpackInt32(),810        self.UnpackInt8(),811        )812  def ParseMapChunks(self):813    chunkX = self.UnpackInt32()814    chunkZ = self.UnpackInt32()815    withBiome = self.UnpackInt8()816    primaryBitMap = self.UnpackInt16()817    addBitMap = self.UnpackInt16()818    arraySize = self.UnpackInt32()819    trash = self.UnpackInt32()  # "unused"820    compressed = self.Read(arraySize)821    data = [zlib.decompress(compressed)]822    #print len(data[0]), hex(primaryBitMap)823    def PopByteArray(size):824      if len(data[0]) < size:825        raise Exception('data not big enough!')826      ret = array.array('B', data[0][:size])827      data[0] = data[0][size:]828      return  ret829    blocks = array.array('B')830    for i in range(16):831      if primaryBitMap & (1 << i):832        blocks.extend(PopByteArray(4096))833      else:834        blocks.extend([0] * 4096)835    meta = []836    for i in range(16):837      if primaryBitMap & (1 << i):838        meta.append(PopByteArray(2048))839      else:840        meta.append(array.array('B', [0] * 2048))841    light = []842    for i in range(16):843      if primaryBitMap & (1 << i):844        light.append(PopByteArray(2048))845      else:846        light.append(array.array('B', [0] * 2048))847    skylight = []848    for i in range(16):849      if primaryBitMap & (1 << i):850        skylight.append(PopByteArray(2048))851      else:852        skylight.append(array.array('B', [0] * 2048))853    addArray = []854    for i in range(16):855      if addBitMap & (1 << i):856        addArray.append(PopByteArray(2048))857      else:858        addArray.append(array.array('B', [0] * 2048))859    if withBiome:860      biome = PopByteArray(256)861    else:862      biome = None863    if len(data[0]) > 0:864      raise Exception('Unused bytes!')865    return (ChunkColumn(chunkX, chunkZ,866        blocks, meta, light, skylight, addArray, biome),)867    return [chunkX, chunkZ, blocks, meta, light, skylight, addArray, biome]868    ret = [869        self.UnpackInt32(),870        self.UnpackInt32(),871        self.UnpackInt8(),872        self.UnpackInt16(),873        self.UnpackInt16(),874        ]875    arraySize = self.UnpackInt32()876    ret.append(self.UnpackInt32())  # "unused"877    ret.append(self.Read(arraySize))878    return ret879  def ParseMultiBlockChange(self):880    blocks = []881    chunkX = self.UnpackInt32()882    chunkZ = self.UnpackInt32()883    count = self.UnpackInt16()884    size = self.UnpackInt32()885    if count *4 != size:886      pass887      #print "WTF:", count, size888    for i in range(count):889      record = self.UnpackInt32()890      meta = record & 0xf # 4 bits891      record >> 4892      blockId = record & 0xfff # 12 bits893      record >> 12894      y = record & 0xf # 8 bits895      record >> 8896      relativeZ  = record & 0xf # 4 bits897      record >> 4898      relativeX  = record & 0xf # 4 bits899      record >> 4900      blocks.append((chunkX * 16 + relativeX,901                     chunkZ * 16 + relativeZ,902                     y,903                     blockId,904                     meta))905    return (blocks,)906  def ParseBlockChange(self):907    return (908        self.UnpackInt32(),909        self.UnpackInt8(),910        self.UnpackInt32(),911        self.UnpackInt8(),912        self.UnpackInt8(),913        )914  def ParseExplosion(self):915    x = self.UnpackDouble()916    y = self.UnpackDouble()917    z = self.UnpackDouble()918    unknown = self.UnpackFloat()919    record_count = self.UnpackInt32()920    records = []921    for i in range(record_count):922      records.append(self.Read(3))923    return (x, y, z, unknown, record_count, records)924  def ParseSoundParticleEffect(self):925    return (926        self.UnpackInt32(),927        self.UnpackInt32(),928        self.UnpackInt8(),929        self.UnpackInt32(),930        self.UnpackInt32(),931        )932  def ParseChangeGameState(self):933    return (934        self.UnpackInt8(),935        self.UnpackInt8(),936        )937  def ParseThunderbolt(self):938    return (939        self.UnpackInt32(),940        self.UnpackBool(),941        self.UnpackInt32(),942        self.UnpackInt32(),943        self.UnpackInt32(),944        )945  def ParseOpenWindow(self):946    return (947        self.UnpackInt8(),948        self.UnpackInt8(),949        self.UnpackString(),950        self.UnpackInt8(),951        )952  def ParseCloseWindow(self):953    return (954        self.UnpackInt8(),955        )956  def ParseBlockAction(self):957    return (958        self.UnpackInt32(),959        self.UnpackInt16(),960        self.UnpackInt32(),961        self.UnpackInt8(),962        self.UnpackInt8(),963        )964  def ParseSetSlot(self):965    return (966        self.UnpackInt8(),967        self.UnpackInt16(),968        self.UnpackSlot(),969        )970  def ParseSetWindowItems(self):971    windowId = self.UnpackInt8()972    slotCount = self.UnpackInt16()973    # enchantment table lies about its custom slot count974    if windowId != 0 and slotCount == 9:975      slotCount = 1 + 27 + 9976    slots = []977    for i in range(slotCount):978      slots.append(self.UnpackSlot())979    return (windowId, slots)980  def ParseUpdateWindowProperty(self):981    return (982        self.UnpackInt8(),983        self.UnpackInt16(),984        self.UnpackInt16(),985        )986  def ParseConfirmTransaction(self):987    return (988        self.UnpackInt8(),989        self.UnpackInt16(),990        self.UnpackBool(),991        )992  def ParseCreativeInventoryAction(self):993    return (994        self.UnpackInt16(),995        self.UnpackSlot(),996        )997  def ParseUpdateTileEntity(self):998    return (999        self.UnpackInt32(),1000        self.UnpackInt16(),1001        self.UnpackInt32(),1002        self.UnpackInt8(),1003        self.UnpackInt32(),1004        self.UnpackInt32(),1005        self.UnpackInt32(),1006        )1007  def ParseUpdateSign(self):1008    return (1009        self.UnpackInt32(),1010        self.UnpackInt16(),1011        self.UnpackInt32(),1012        self.UnpackString(),1013        self.UnpackString(),1014        self.UnpackString(),1015        self.UnpackString(),1016        )1017  def ParseItemData(self):1018    item_type = self.UnpackInt16()1019    item_id = self.UnpackInt16()1020    array_length = self.UnpackInt8()1021    text = self.Read(arrayLength)1022    return (item_type, item_id, array_length, text)1023  ##############################################################################1024  # Senders1025  def SendLogin(self, username):1026    packet = (1027        '\x01' +1028        struct.pack('!i', 29) +1029        self.PackString(username) +1030        self.PackString('') +1031        struct.pack('!i', 0) +1032        struct.pack('!i', 0) +1033        struct.pack('!b', 0) +1034        struct.pack('!B', 0) +1035        struct.pack('!B', 0)1036        )1037    self.Send(packet)1038  def SendHandshake(self, username, server, port):1039    self.Send(1040        '\x02' +1041        self.PackString(u'%s;%s;%d' % (username, server, port))1042        )1043  def SendChat(self, msg):1044    self.Send(1045        '\x03' +1046        self.PackString(u'%s' % (msg))1047        )1048  def SendUseEntity(self, user, target, mouse_button):1049    self.Send(1050        '\x07' +1051        struct.pack('!i', user) +1052        struct.pack('!i', target) +1053        struct.pack('!b', mouse_button)1054        )1055  def SendRespawn(self, dimension, difficulty, levelType):1056    packet = (1057        '\x09' +1058        struct.pack('!i', dimension) +1059        struct.pack('!b', difficulty) +1060        struct.pack('!b', 0) +1061        struct.pack('!h', 256) +1062        self.PackString(levelType)1063        )1064    self.Send(packet)1065  def SendPlayer(self, on_ground):1066    ''' Tell server whether player is on the ground '''1067    self.Send(1068        '\x0a' +1069        struct.pack('!b', on_ground)1070        )1071  def SendPlayerPosition(self, x, y, stance, z, on_ground):1072    self.Send(1073        '\x0b' +1074        struct.pack('!ddddb', x, y, stance, z, on_ground)1075        )1076  def SendPlayerLook(self, yaw, pitch, on_ground):1077    self.Send(1078        '\x0c' +1079        struct.pack('!ffb', yaw, pitch, on_ground)1080        )1081  def SendPlayerPositionAndLook(self, x, y, stance, z, yaw, pitch, on_ground):1082    self.Send(1083        '\x0d' +1084        struct.pack('!ddddffb', x, y, stance, z, yaw, pitch, on_ground)1085        )1086  def SendPlayerDigging(self, status, x, y, z, face):1087    self.Send(1088        '\x0e' +1089        struct.pack('!b', status) +1090        struct.pack('!i', x) +1091        struct.pack('!b', y) +1092        struct.pack('!i', z) +1093        struct.pack('!B', face) # trying unsigned 1094        )1095  def SendPlayerBlockPlacement(self, x, y, z, direction, held_item):1096    self.Send(1097        '\x0f' +1098        struct.pack('!i', x) +1099        struct.pack('!b', y) +1100        struct.pack('!i', z) +1101        struct.pack('!b', direction)+1102        self.PackSlot(held_item)1103        )1104  def SendHeldItemChange(self, slot_id):1105    #print 'SendHeldItemChange:', (slot_id)1106    packet = (1107        '\x10' +1108        struct.pack('!h', slot_id)1109        )1110    self.Send(packet)1111  def SendAnimation(self, eid, animation):1112    self.Send(1113        '\x12' +1114        struct.pack('!i', eid) +1115        struct.pack('!b', animation)1116        )1117  def SendEntityAction(self, eid, action_id):1118    self.Send(1119        '\x13' +1120        struct.pack('!i', eid) +1121        struct.pack('!b', action_id)1122        )1123  def SendCloseWindow(self, window_id):1124    self.Send(1125        '\x65' +1126        struct.pack('!b', window_id)1127        )1128  def SendClickWindow(self, window_id, slot_id, right_click, action_number, shift, slot_data):1129    #print 'SendClickWindow:', window_id, slot_id, right_click, action_number, shift, slot_data1130    packet = (1131        '\x66' +1132        struct.pack('!b', window_id) +1133        struct.pack('!h', slot_id) +1134        struct.pack('!b', right_click) +1135        struct.pack('!h', action_number) +1136        struct.pack('!b', shift) +1137        self.PackSlot(slot_data)1138        )1139    self.Send(packet)1140  def SendConfirmTransaction(self, window_id, action_number, accepted):1141    self.Send(1142        '\x6a' +1143        struct.pack('!b', window_id) +1144        struct.pack('!h', action_number) +1145        struct.pack('!b', accepted)1146        )1147  def SendCreativeInventoryAction(self, slot, clicked_item):1148    self.Send(1149        '\x6b' +1150        struct.pack('!h', slot) +1151        self.PackSlot(clicked_item)1152        )1153  def SendEnchantItem(self, window_id, enchantment):1154    self.Send(1155        '\x6c' +1156        struct.pack('!b', window_id) +1157        struct.pack('!b', enchantment)1158        )1159  def SendUpdateSign(self, x, y, z, text1, text2, text3, text4):1160    self.Send(1161        '\x82' +1162        struct.pack('!i', x) +1163        struct.pack('!h', y) +1164        struct.pack('!i', z) +1165        self.PackString(text1) +1166        self.PackString(text2) +1167        self.PackString(text3) +1168        self.PackString(text4)1169        )1170  def SendPlayerAbilities(self, invulnerability, is_flying, can_fly, instant_destroy):1171    self.Send(1172        '\xca' +1173        struct.pack('!b', invulnerability) +1174        struct.pack('!b', is_flying) +1175        struct.pack('!b', can_fly) +1176        struct.pack('!b', instant_destroy)1177        )1178  def SendListPing(self):1179    self.Send(1180        '\xfe'1181        )1182  def SendDisconnect(self, reason=''):1183    self.Send(1184        '\xff' +1185        self.PackString(reason)...

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.