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

event_messenger.py (2007B)

      1 #Embedded file name: C:\BuildAgent\work\20d73f1b24eed06e\eve\release\V24.01\packages\careergoals\client\messenger\event_messenger.py
      2 import logging
      3 from eveProto.generated.eve_public.app.eveonline.career.career_pb2 import Selected as CareerSelected
      4 from eveProto.generated.eve_public.app.eveonline.career.goal_pb2 import Tracked, Selected
      5 from eveProto.generated.eve_public.app.eveonline.career.group_pb2 import Selected as GroupSelected
      6 from eveexceptions import EatsExceptions
      7 logger = logging.getLogger(__name__)
      8 UPDATE_TIMEOUT_SECONDS = 10
      9 
     10 class PublicCareerGoalEventMessenger(object):
     11     public_gateway = None
     12 
     13     def __init__(self, public_gateway):
     14         self.public_gateway = public_gateway
     15 
     16     @EatsExceptions('protoClientLogs')
     17     def goal_tracked(self, goal_id):
     18         tracked = Tracked()
     19         tracked.goal.uuid = goal_id.bytes
     20         self.public_gateway.publish_event_payload(tracked)
     21         logger.info('CAREER GOALS - Tracked event published, payload: %s' % tracked)
     22 
     23     @EatsExceptions('protoClientLogs')
     24     def career_selected(self, goal_id):
     25         if not goal_id:
     26             return
     27         selected = CareerSelected()
     28         selected.goal.uuid = goal_id.bytes
     29         self.public_gateway.publish_event_payload(selected)
     30         logger.info('CAREER GOALS - CareerSelected event published, payload: %s' % selected)
     31 
     32     @EatsExceptions('protoClientLogs')
     33     def group_selected(self, group_name, career_name):
     34         selected = GroupSelected()
     35         selected.group = group_name
     36         selected.career = career_name
     37         self.public_gateway.publish_event_payload(selected)
     38         logger.info('CAREER GOALS - GroupSelected event published, payload: %s' % selected)
     39 
     40     @EatsExceptions('protoClientLogs')
     41     def goal_selected(self, goal_id):
     42         selected = Selected()
     43         selected.goal.uuid = goal_id.bytes
     44         self.public_gateway.publish_event_payload(selected)
     45         logger.info('CAREER GOALS - GoalSelected event published, payload: %s' % selected)