event_matcher_messenger.py (2544B)

---

 #Embedded file name: C:\BuildAgent\work\20d73f1b24eed06e\eve\release\V24.01\packages\campaigns\client\v2\messengers\event_matcher_messenger.py
 from __future__ import absolute_import, division, print_function
 import logging
 from campaigns.client.errors import EventMatcherRequestError, EventMatcherNotFoundError, EventMatcherBadRequestError
 from campaigns.client.v2.data_model.event_matcher_definition import EventMatcherDefinition
 from eveProto.generated.eve_public.campaign.trigger.eventmatch.definition.api.requests_pb2 import GetAllRequest, GetAllResponse
 from six.moves.http_client import NOT_FOUND, BAD_REQUEST, OK
 from semantic_version import SemanticVersion
 from stackless_response_router.exceptions import TimeoutException, UnpackException
 logger = logging.getLogger('campaigns_v2')
 
 class CampaignEventMatcherMessenger(object):
 
     def __init__(self, public_gateway):
         self.public_gateway = public_gateway
 
     def override_gateway(self, public_gateway):
         self.public_gateway = public_gateway
 
     def get_all_request(self, semantic_version):
         request = GetAllRequest(version=semantic_version.to_eve_public_proto())
         info_log = 'Request: CampaignEventMatcherMessenger: GetAllRequest: {request}\n'.format(request=request)
         try:
             response_primitive, response = self.public_gateway.send_blocking_character_request_and_receive_response(request_payload=request, expected_response_class=GetAllResponse, timeout_seconds=4, max_attempts=2, retry_delay_in_seconds=1)
         except (TimeoutException, UnpackException) as exc:
             info_log += 'ERROR: %s' % exc.__class__.__name__
             logger.info(info_log)
             raise EventMatcherRequestError('Failed to receive response from GetAllRequest: %s' % exc)
 
         status_code = response_primitive.status_code
         if status_code == NOT_FOUND:
             raise EventMatcherNotFoundError('Could not find requested version in GetAllRequest: %s' % semantic_version)
         if status_code == BAD_REQUEST:
             raise EventMatcherBadRequestError('Bad request in GetAllRequest: %s' % semantic_version)
         if status_code != OK:
             raise EventMatcherRequestError('Received error status code for GetAllResponse: %s' % status_code)
         info_log += 'Response: CampaignContributionMethodsMessenger: GetAllResponse: {response}'.format(response=response)
         logger.info(info_log)
         results = [ EventMatcherDefinition.from_proto(definition) for definition in response.definitions ]
         return results