o Ín~bÍã@s€dZddlZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl mZmZmZddlmZGd d „d eƒZdS) a- :class:`GameCoordinator` is used to proxy messages from/to GC. It takes care of the encapsulation details, but on its own is not enough to communicate with a given GC. Example implementation of Dota 2 GC client with inheritance. .. code:: python import myDotaModule from steam.client import SteamClient from steam.core.msg import GCMsgHdrProto from steam.client.gc import GameCoordinator class ExampleDotaClient(GameCoordinator): def __init__(self, steam): GameCoordinator.__init__(self, steam, 570) def _process_gc_message(self, emsg, header, body): if emsg == 4004: # EMsgGCClientWelcome message = myDotaModule.gcsdk_gcmessages_pb2.CMsgClientWelcome() message.ParseFromString(body) print message def send_hello(self): header = GCMsgHdrProto(4006) # EMsgGCClientHello body = myDotaModule.gcsdk_gcmessages_pb2.CMsgClientHello() self.send(header, body.SerializeToString()) client = SteamClient() dota = ExampleDotaClient(client) client.login() client.games_played([570]) dota.send_hello() The above code assumes that we have a ``myDotaModule`` that contains the appropriate protobufs needed to (de)serialize message for communication with GC. éN)Ú EventEmitter)Ú set_proto_bitÚclear_proto_bitÚis_proto)ÚEMsg)ÚEResult)ÚGCMsgHdrÚ GCMsgHdrProtoÚMsgProto)Ú SteamClientc@s8eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd S) ÚGameCoordinatoraé ``GameCoordinator`` is used to proxy messages from/to GC :param steam_client: steam client instance :type steam_client: :class:`steam.client.SteamClient` :param app_id: app id of the application :type app_id: :class:`int` Incoming messages are emitted as events using their ``EMsg`` as an event identifier. :param header: message header :type header: :class:`steam.core.msg.GCMsgHdr` :param body: raw message body :type body: :class:`bytes` cCsDt|tƒs tdƒ‚||_||_t d|¡|_|j t j |j ¡dS)Nz5Expected an instance of SteamClient as first argumentz GC(appid:%d)) Ú isinstancer Ú ValueErrorÚsteamÚapp_idÚloggingÚ getLoggerÚ_LOGÚonrZ ClientFromGCÚ_handle_from_gc)ÚselfZ steam_clientr©rú:/usr/local/lib/python3.10/dist-packages/steam/client/gc.pyÚ__init__Cs zGameCoordinator.__init__cGs4|dur|j dt|ƒ¡tj||g|¢RŽdS)NzEmit event: %s)rÚdebugÚreprrÚemit)rÚeventÚargsrrrrNszGameCoordinator.emitcCsXttjƒ}|j|j_|j|j_|jrt |j ƒn|j |j_ |  ¡||j_ |j |¡dS)zÛ Send a message to GC :param header: message header :type header: :class:`steam.core.msg.GCMsgHdr` :param body: serialized body of the message :type body: :class:`bytes` N)r rZ ClientToGCrÚheaderZ routing_appidÚbodyÚappidÚprotorÚmsgÚmsgtypeÚ serializeÚpayloadrÚsend)rrr Úmessagerrrr'Ss   ÿþzGameCoordinator.sendcCsx|jj|jkr dS|jj}t|ƒrt||jjƒ}tj|j}n t ||jjƒ}t j}|jj|d…}|  t |ƒ||¡dS©N) r r!rr$rr r&Ú_sizeZ headerLengthrÚ_process_gc_messager)rr#ÚemsgrÚ header_sizer rrrrfszGameCoordinator._handle_from_gccCs| |||¡dSr))r)rr,rr rrrr+wsz#GameCoordinator._process_gc_messageN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrr'rr+rrrrr 2s  r )r1rZgeventZ eventemitterrZsteam.utils.protorrrZsteam.enums.emsgrZ steam.enumsrZsteam.core.msgrr r Z steam.clientr r rrrrÚs'