NovaBryan/EVE_Dump
Log | Files | 📦 下载最新源码 (.zip) | Refs | README

requestMessenger.py (3072B)

      1 #Embedded file name: C:\BuildAgent\work\20d73f1b24eed06e\eve\release\V24.01\packages\cosmetics\client\messengers\entitlements\character\ship\admin\requestMessenger.py
      2 from eveProto.generated.eve_public.entitlement.character.ship.admin import corplogo_pb2 as admin_corplogo_pb2
      3 from eveProto.generated.eve_public.entitlement.character.ship.admin import alliancelogo_pb2 as admin_alliancelogo_pb2
      4 from eveProto.generated.eve_public.entitlement.character.ship import corplogo_pb2
      5 from eveProto.generated.eve_public.entitlement.character.ship import alliancelogo_pb2
      6 from eveProto.generated.eve_public.character import character_pb2
      7 from eveProto.generated.eve_public.ship import ship_type_pb2
      8 from publicGateway.grpc import requestBroker
      9 TIMEOUT_SECONDS = 10
     10 
     11 class PublicEntitlementsAdministrativeRequestsMessenger(object):
     12     public_gateway = None
     13 
     14     def __init__(self, public_gateway):
     15         self.public_gateway = public_gateway
     16 
     17     def grant_corp_logo(self, character_id, ship_type_id):
     18         request = admin_corplogo_pb2.GrantRequest(entitlement=corplogo_pb2.Identifier(character=character_pb2.Identifier(sequential=character_id), ship_type=ship_type_pb2.Identifier(sequential=ship_type_id)))
     19         request_primitive, response_channel = self.send_async_request(request, admin_corplogo_pb2.GrantResponse)
     20         return requestBroker.ResponseChannel(request_primitive, response_channel)
     21 
     22     def grant_alliance_logo(self, character_id, ship_type_id):
     23         request = admin_alliancelogo_pb2.GrantRequest(entitlement=alliancelogo_pb2.Identifier(character=character_pb2.Identifier(sequential=character_id), ship_type=ship_type_pb2.Identifier(sequential=ship_type_id)))
     24         request_primitive, response_channel = self.send_async_request(request, admin_alliancelogo_pb2.GrantResponse)
     25         return requestBroker.ResponseChannel(request_primitive, response_channel)
     26 
     27     def revoke_corp_logo(self, character_id, ship_type_id):
     28         request = admin_corplogo_pb2.RevokeRequest(entitlement=corplogo_pb2.Identifier(character=character_pb2.Identifier(sequential=character_id), ship_type=ship_type_pb2.Identifier(sequential=ship_type_id)))
     29         request_primitive, response_channel = self.send_async_request(request, admin_corplogo_pb2.RevokeResponse)
     30         return requestBroker.ResponseChannel(request_primitive, response_channel)
     31 
     32     def revoke_alliance_logo(self, character_id, ship_type_id):
     33         request = admin_alliancelogo_pb2.RevokeRequest(entitlement=alliancelogo_pb2.Identifier(character=character_pb2.Identifier(sequential=character_id), ship_type=ship_type_pb2.Identifier(sequential=ship_type_id)))
     34         request_primitive, response_channel = self.send_async_request(request, admin_alliancelogo_pb2.RevokeResponse)
     35         return requestBroker.ResponseChannel(request_primitive, response_channel)
     36 
     37     def send_async_request(self, request, response_class):
     38         request_primitive, response_channel = self.public_gateway.send_character_request(request, response_class, TIMEOUT_SECONDS)
     39         return (request_primitive, response_channel)