"""Project Participant Handler.""" from switchboard_consumer.constants import system from switchboard_consumer.logic.participant.base_participant_handler \ import BaseParticipantHandler from switchboard_consumer.utils.message import get_system_local_id class ProjectParticipantHandler(BaseParticipantHandler): def __init__( self, logger, orchard_client, message, vendor_id, subaccount_id): """Create a ProductParticipantHandler instance. Args: logger: Logger instance orchard_client: OrchardClient instance message: Incoming KafkaMessage vendor_id: target vendor id subaccount_id: target subaccount id """ super().__init__(logger, orchard_client, message, vendor_id, subaccount_id) def process(self, project_data): """Process Project participant. Args: project_data: SWB project data """ participant = project_data['artist'] role = 'primary_artist' source_mapping = get_system_local_id( participant, system.SONY) target_mapping = get_system_local_id( participant) return self.handle_participant(participant, role, source_mapping, target_mapping)