class PIM::CommunicationPlan::ActionExecutor

# File pim.rb, line 9169
def initialize plan, action_type, action_creator, action_tags, action_date, channel, organization, data
  @plan = plan
  @action_type = action_type
  @action_creator = action_creator
  @action_tags = action_tags
  @action_date = action_date
  @channel = channel
  @channel_type = channel.type
  @organization = organization
  @data = data || {}
end

# File pim.rb, line 9435
def add_action_result item, status, status_message = nil, *tags
  set_item_publication_result item, status, status_message, tags
end

# File pim.rb, line 9440
def add_action_results items, status, status_message = nil, *tags
  set_item_publication_results items, status, status_message, tags
end

# File pim.rb, line 9228
def create_content_message content_type, prefix = nil, suffix = nil, &block

  message_creation_parameters = service.create_message_creation_parameters
  message_content = PIM::Services::CommunicationPlanService.create_content(message_creation_parameters, &block)
  message = service.create_content_messaging_asset(@action_creator,
                                                   @channel,
                                                   message_creation_parameters,
                                                   message_content,
                                                   content_type,
                                                   prefix,
                                                   suffix,
                                                   true)
  set_message_update_result message, 'PENDING'

  message

end

# File pim.rb, line 9430
def create_publication_message_tag reference_message
  reference_message.reference_message_id if reference_message
end

# File pim.rb, line 9287
def create_trafo_digital_asset items, content_type, prefix = nil, suffix = nil, params = {}
  params = unsymbolized_hash(params)
  service.create_trafo_digital_asset(@action_creator,
                                     items,
                                     content_type,
                                     prefix,
                                     suffix,
                                     params)
end

# File pim.rb, line 9246
def create_trafo_message items, content_type, prefix = nil, suffix = nil, trafo_params = {}, *message_params

  blocked_by_id = nil
  blocked_by_delay = nil
  expecting_response = nil
  tags = Set.new
  tags.merge @action_tags

  if message_params.length == 1 and is_hash?(message_params[0])
    message_params = message_params[0]
    blocked_by_id = message_params[:blocked_by_id]
    blocked_by_delay = message_params[:blocked_by_delay]
    expecting_response = message_params[:expecting_response]
    tags.merge(message_params[:tags]) unless message_params[:tags].nil?
  else
    blocked_by_id = message_params[0] if message_params.length >= 1
    blocked_by_delay = message_params[1] if message_params.length >= 2
  end

  trafo_params = unsymbolized_hash(trafo_params)
  message = service.create_trafo_messaging_asset(@action_creator,
                                                 tags,
                                                 @channel,
                                                 items,
                                                 content_type,
                                                 prefix,
                                                 suffix,
                                                 trafo_params,
                                                 blocked_by_id,
                                                 blocked_by_delay,
                                                 expecting_response)

  # Message will be created with state 'DEFERRED', if not blocked, so add an update result to make it 'PENDING'
  if message and blocked_by_id.nil?
    set_message_update_result message, 'PENDING'
  end

  message

end

# File pim.rb, line 9297
def create_trafo_public_asset items, content_type, prefix = nil, suffix = nil, params = {}
  params = unsymbolized_hash(params)
  service.create_trafo_public_asset(@action_creator,
                                    items,
                                    content_type,
                                    prefix,
                                    suffix,
                                    params)
end

# File pim.rb, line 9181
def execute &action
  @action_result = {}
  self.instance_exec(&action)
  @action_result.values
end

# File pim.rb, line 9307
def get_asset_content_stream asset
  service.get_asset_content_stream(asset)
end

# File pim.rb, line 9369
def get_item_primary_key item

  # Determine primary key
  if item.respond_to?(:primary_key)
    primary_key = item.primary_key
  elsif is_hash?(item)
    primary_key = item['primaryKey__']
  else
    primary_key = item.to_s
  end
  if is_empty?(primary_key)
    PIM.log_warn "No or empty primary key specified in action result"
    primary_key = nil
  end

  return primary_key
end

# File pim.rb, line 9387
def get_item_publication_result item
  primary_key = get_item_primary_key(item)
  return nil if !primary_key
  get_result REFERENCED_TYPE_PRIMARY_KEY, primary_key
end

# File pim.rb, line 9405
def get_message_id message

  # Determine message id
  if message.respond_to?(:reference_message_id)
    message_id = message.reference_message_id
  elsif is_hash?(message)
    message_id = message['reference_message_id']
  else
    message_id = message.to_s
  end
  if is_empty?(message_id)
    PIM.log_warn "No or empty message id specified in action result"
    message_id = nil
  end

  return message_id
end

# File pim.rb, line 9423
def get_message_update_result message
  message_id = get_message_id(message)
  return nil if !message_id
  get_result REFERENCED_TYPE_MESSAGE_ID, message_id
end

# File pim.rb, line 9343
def get_tag_publication_result tag
  get_result REFERENCED_TYPE_TAG, tag
end

# File pim.rb, line 9191
def item_hierarchies
  @data['item_hierarchies']
end

# File pim.rb, line 9187
def items
  @data['items']
end

# File pim.rb, line 9316
def load_item_with_publication primary_key
  return nil if publication.nil?
  __service(:itemService).load_with_publication primary_key, publication.destination_id, publication.sub_destination
end

# File pim.rb, line 9311
def load_items_with_publications *primary_keys
  return nil if publication.nil?
  __service(:itemService).load_with_publications primary_keys, publication.destination_id, publication.sub_destination
end

# File pim.rb, line 9207
def publication
  return action_creator if !action_creator.nil? and action_creator.messaging_creator_type.to_s == 'PUBLICATION'
end

# File pim.rb, line 9219
def publication_name
  if !publication.nil? and !publication.job_id.nil?
    job = PIM::Services::JobService.get_job(publication.job_id)
    return job.name unless job.nil?
  end

  nil
end

# File pim.rb, line 9195
def reference_message
  @data['reference_message']
end

# File pim.rb, line 9199
def response_message
  @data['response_message']
end

# File pim.rb, line 9203
def responses
  @data['responses']
end

# File pim.rb, line 9215
def review
  return action_creator if !action_creator.nil? and action_creator.messaging_creator_type.to_s == 'REVIEW'
end

# File pim.rb, line 9321
def send_publication_email public_asset
  service.send_publication_email(@channel, public_asset)
end

# File pim.rb, line 9347
def set_item_publication_result item, status, status_message = nil, tags = nil, custom_values = nil

  primary_key = get_item_primary_key(item)
  return if !primary_key

  result_values = {}
  if !tags.nil?
    tags = is_array?(tags) ? tags : [tags.to_s]
    result_values[RESULT_ADDITIONAL_TAGS] = tags
  end
  result_values[RESULT_CUSTOM_VALUES] = custom_values if !custom_values.nil?

  add_result REFERENCED_TYPE_PRIMARY_KEY, primary_key, status, status_message, result_values

end

# File pim.rb, line 9363
def set_item_publication_results items, status, status_message = nil, tags = nil, custom_values = nil
  items.each do |item|
    set_item_publication_result item, status, status_message, tags, custom_values
  end
end

# File pim.rb, line 9393
def set_message_update_result message, status, status_message = nil, response_id = nil

  message_id = get_message_id(message)
  return if !message_id

  result_values = {}
  result_values[RESULT_RESPONSE_ID] = response_id if !response_id.nil?

  add_result REFERENCED_TYPE_MESSAGE_ID, message_id, status, status_message, result_values

end

# File pim.rb, line 9325
def set_tag_publication_result tag, status, status_message = nil, tags = nil, custom_values = nil

  if is_empty?(tag)
    PIM.log_warn "No or empty tag key specified in action result"
    return
  end

  result_values = {}
  if !tags.nil?
    tags = is_array?(tags) ? tags : [tags.to_s]
    result_values[RESULT_ADDITIONAL_TAGS] = tags
  end
  result_values[RESULT_CUSTOM_VALUES] = custom_values if !custom_values.nil?

  add_result REFERENCED_TYPE_TAG, tag, status, status_message, result_values

end

# File pim.rb, line 9211
def subscription
  return action_creator if !action_creator.nil? and action_creator.messaging_creator_type.to_s == 'SUBSCRIPTION'
end