class Object

# File services-legacy.rb, line 122
def __legacy_load_item primary_key, *cache_or_opts, &load_block

  named_arguments = {}

  # Deal with compatibility: 'cache_or_opts' could be a cache or load options or both
  case cache_or_opts.size
  when 1

    cache_or_opts = cache_or_opts[0]

    # FIXME: For Ruby <= 2.5 we cannot simply "convert" a Hash to named arguments using "**",
    # so instead we ensure that only Symbol keys are used!
    if cache_or_opts.is_a?(Hash) and cache_or_opts.keys.all? { |k| k.is_a?(Symbol) }

      # Use complete first part as named argument
      named_arguments.merge!(cache_or_opts)

    elsif cache_or_opts.is_a?(PIM::LRUCache)

      # Set first part as item_cache, if it actually is one
      named_arguments[:item_cache] = cache_or_opts

    end

  when 2

    # Set first part as item_cache
    named_arguments[:item_cache] = cache_or_opts[0]

    # Add second part as load options
    named_arguments.merge!(cache_or_opts[1])

  end

  load_block.call(named_arguments)

end

# File services-legacy.rb, line 599
def __service name
  return PIM::Services.__proxy_service(name)
end

# File services-legacy.rb, line 373
def add_comment_to_task(task_id, comment)
  PIM::Services::TaskService.add_comment_to_task(task_id, comment)
end

# File services-legacy.rb, line 29
def broadcast_message(message, severity = :success, opts = {})
  PIM::Services::AccountService.broadcast_message(message, severity, opts)
end

# File services-legacy.rb, line 37
def complete_order(order_reference)
  __service(:shoppingCartService).completeCurrentOrder(order_reference)
end

# File services-legacy.rb, line 503
def create_email_invitation(email_address, invitation_type, language = nil, custom_values = {})
  PIM::Services::InvitationService.invite_organization(email_address, invitation_type, language: language, custom_values: custom_values)
end

# File services-legacy.rb, line 579
def create_selection query_string
  selection = com.lansa.lax.pim.model::Selection.new
  item_query = com.lansa.lax.pim::ItemQuery.new

  item_query.keyword = query_string
  selection.items_query = item_query

  return __service(:selectionService).createSelection(selection)
end

# File services-legacy.rb, line 358
def create_task(task_hash)
  PIM::Services::TaskService.create_task(task_hash)
end

# File services-legacy.rb, line 363
def create_todo(task_hash)
  create_task(task_hash)
end

# File services-legacy.rb, line 556
def delete_item primary_key
   __service(:itemService).deleteItem(primary_key)
end

# File services-legacy.rb, line 560
def delete_items primary_keys
   __service(:itemService).deleteItems(primary_keys)
end

# File services-legacy.rb, line 564
def delete_items_by_selection selection_id
  __service(:itemService).deleteItemsBySelection(selection_id)
end

# File services-legacy.rb, line 435
def depublish_items(item_ids, destination_type, destination_id, destination_sub_id = nil, publication_values = {})
  queue_publication(item_ids, "DELETE", destination_type, destination_id, destination_sub_id, publication_values)
end

# File services-legacy.rb, line 232
def fill_store_options_from_options(store_options, options)

  # Set default values
  set_store_option(store_options, :setBroadcastUpdateEvent, true)

  # Set values from ruby options
  return nil if not options.respond_to?(:has_key?)
  set_store_option(store_options, :setAllowAudit, options[:allowAudit])
  set_store_option(store_options, :setBroadcastUpdateEvent, options[:broadcastUpdateEvent])
  set_store_option(store_options, :setCallAfterStore, options[:callAfterStore])
  set_store_option(store_options, :setCallBeforeStore, options[:callBeforeStore])
  set_store_option(store_options, :setDirty, options[:dirty])
  set_store_option(store_options, :setMerge, options[:merge])
  set_store_option(store_options, :setRecalculateStatistics, options[:recalculateStatistics])
  set_store_option(store_options, :setUnique, options[:unique])
  set_store_option(store_options, :setValidate, options[:validate])

end

# File services-legacy.rb, line 333
def get_active_communication_channels type = nil
  PIM::Services::CommunicationChannelService.get_active_communication_channels type
end

# File services-legacy.rb, line 14
def get_base_url
  PIM::Services::OrganizationService.get_base_url
end

# File services-legacy.rb, line 328
def get_communication_channel *args
  PIM::Services::CommunicationChannelService.get_communication_channel *args
end

# File services-legacy.rb, line 338
def get_communication_channel_template name
  PIM::Services::CommunicationChannelService.get_communication_channel_template name
end

# File services-legacy.rb, line 478
def get_contact(organization_id)
  PIM::Services::ContactService.get_contact(organization_id)
end

# File services-legacy.rb, line 483
def get_contact_by_id(contact_id)
  PIM::Services::ContactService.get_contact_by_id(contact_id)
end

# File services-legacy.rb, line 488
def get_contact_by_organization_id(organization_id)
  PIM::Services::ContactService.get_contact_by_organization_id(organization_id)
end

# File services-legacy.rb, line 552
def get_item_primary_keys_by_tags *tags
  __service(:itemService).findPrimaryKeysByTags(*tags)
end

# File services-legacy.rb, line 343
def get_item_review_as_reviewer(primary_key)
  PIM::Services::ReviewService.get_item_review_as_reviewer(primary_key)
end

# File services-legacy.rb, line 348
def get_item_review_as_supplier(primary_key, reviewer)
  PIM::Services::ReviewService.get_item_review_as_supplier(primary_key, reviewer)
end

# File services-legacy.rb, line 547
def get_items_by_export_task_id export_task_id
  return [] if export_task_id.nil?
  __service(:exportService).getExportedItems(export_task_id)
end

# File services-legacy.rb, line 574
def get_items_by_selection_id selection_id
  return [] if selection_id.nil?
  __service(:selectionService).getItems(selection_id)
end

# File services-legacy.rb, line 537
def get_items_by_tag tag
  __service(:itemService).findByTag(tag)
end

# File services-legacy.rb, line 402
def get_messaging_asset_content messaging_asset_id
  return PIM::Services::MessagingService.get_messaging_asset_content(messaging_asset_id)
end

# File services-legacy.rb, line 412
def get_messaging_asset_content_stream messaging_asset_id
  return PIM::Services::MessagingService.get_messaging_asset_content_stream(messaging_asset_id)
end

# File services-legacy.rb, line 378
def get_open_tasks_for_item(item_primary_key, tag)
  PIM::Services::TaskService.get_open_tasks_for_item(item_primary_key, tag)
end

# File services-legacy.rb, line 9
def get_organization
  PIM::Services::OrganizationService.get_organization
end

# File services-legacy.rb, line 527
def get_publication_tasks publication_group_id
  __service(:publicationService).getPublicationTasks(publication_group_id)
end

# File services-legacy.rb, line 24
def get_roles_for_user(user_id_or_email = nil)
  PIM::Services::AccountService.get_roles_for_user(user_id_or_email)
end

# File services-legacy.rb, line 33
def get_shopping_card
  __service(:shoppingCartService).getCurrentShoppingCart
end

# File services-legacy.rb, line 383
def get_translations(locale)
  PIM::Services::TranslationService.get_translations(locale)
end

# File services-legacy.rb, line 19
def get_user(user_id_or_email = nil)
  PIM::Services::AccountService.get_user(user_id_or_email)
end

# File services-legacy.rb, line 518
def handle_task_retry_exception exception, &block
  PIM::Services::ProcessTaskService.handle_task_retry_exception(exception, &block)
end

# File services-legacy.rb, line 595
def has_data_model_license? data_model
  return __service(:rubyUtilsService).hasDataModelLicense(data_model)
end

# File services-legacy.rb, line 508
def invite_colleague(email_address, opts = {})
  PIM::Services::InvitationService.invite_colleague(email_address, opts)
end

# File services-legacy.rb, line 513
def is_task_retry_exception exception
  PIM::Services::ProcessTaskService.is_task_retry_exception(exception)
end

# File services-legacy.rb, line 162
def item_as_json(item)
  PIM::Services::ItemService.convert_item_to_json(item)
end

# File services-legacy.rb, line 182
def item_as_map(item)
  item_as_json(item)
end

# File services-legacy.rb, line 167
def item_as_xml(item)
  PIM::Services::ItemService.convert_item_to_xml(item)
end

# File services-legacy.rb, line 172
def items_as_xml(items)
  PIM::Services::ItemService.convert_items_to_xml(items)
end

# File services-legacy.rb, line 589
def license_require data_model, name
  path_prefix = __service(:rubyUtilsService).getLicensedDataModelPathPrefix()
  name = "#{path_prefix}#{data_model}/#{name}"
  require name
end

# File services-legacy.rb, line 287
def load_file(path, gathering_key = nil)
  digital_asset = __service(:digitalAssetService).getContent(gathering_key, path)
  input_stream = digital_asset ? digital_asset.getContentStream() : nil
  input_stream ? input_stream.to_io : nil
end

# File services-legacy.rb, line 55
def load_item primary_key, *cache_or_opts
  __legacy_load_item(primary_key, *cache_or_opts) do |named_arguments|
    PIM::Services::ItemService.get_item_as_java(primary_key, **named_arguments)
  end
end

# File services-legacy.rb, line 75
def load_item_as_json primary_key, *cache_or_opts
  __legacy_load_item(primary_key, *cache_or_opts) do |named_arguments|
    PIM::Services::ItemService.get_item_as_json(primary_key, **named_arguments)
  end
end

# File services-legacy.rb, line 95
def load_item_as_ruby primary_key, *cache_or_opts
  __legacy_load_item(primary_key, *cache_or_opts) do |named_arguments|
    PIM::Services::ItemService.get_item_as_ruby(primary_key, **named_arguments)
  end
end

# File services-legacy.rb, line 115
def load_item_as_xml primary_key, *cache_or_opts
  __legacy_load_item(primary_key, *cache_or_opts) do |named_arguments|
    PIM::Services::ItemService.get_item_as_xml(primary_key, **named_arguments)
  end
end

# File services-legacy.rb, line 265
def load_item_event_history(primary_key, opts = {})
  newest_first = PIM.get_value(opts, 'newest_first') || false
  event_type = PIM.get_value(opts, 'event_type') || PIM.get_value(opts, 'event')
  PIM::Services::ItemService.get_item_event_history(primary_key, newest_first:newest_first, event_type: event_type)
end

# File services-legacy.rb, line 177
def load_item_with_publication primary_key, destination_id, sub_destination, item_cache = nil
  load_item(primary_key, item_cache, :destinationId => destination_id, :subDestination => sub_destination)
end

# File services-legacy.rb, line 431
def publish_items(item_ids, destination_type, destination_id, destination_sub_id = nil, publication_values = {})
  queue_publication(item_ids, "ADD", destination_type, destination_id, destination_sub_id, publication_values)
end

# File services-legacy.rb, line 439
def queue_publication(item_ids, publication_type, destination_type, destination_id, destination_sub_id = nil, publication_values = {})

  publication_destination = com.lansa.lax.pim.PublicationDestination.new
  if destination_type == 'CHANNEL'
    publication_destination.destination_type = com.lansa.lax.pim.DestinationType::COMMUNICATION_CHANNEL
  elsif destination_type == 'PLATFORM'
    publication_destination.destination_type = com.lansa.lax.pim.DestinationType::IN_PLATFORM
  else
    raise "'#{destination_type}' is not a valid destination type."
  end
  publication_destination.destination_id = destination_id
  publication_destination.sub_destination = destination_sub_id

  transition_hash = {}
  if publication_values
    publication_values.each do |key, value|
      transition_hash[key.to_s] = value
    end
  end

  if publication_type == 'ADD'
    __service(:publicationService).queuePublications(
      java.util.ArrayList.new(item_ids),
      publication_destination,
      java.util.LinkedHashMap.new(transition_hash)
    )
  elsif publication_type == 'DELETE'
    __service(:publicationService).queueDePublications(
      java.util.ArrayList.new(item_ids),
      publication_destination,
      java.util.LinkedHashMap.new(transition_hash)
    )
  else
    raise "'#{publication_type}' is not a valid publication type."
  end

end

# File services-legacy.rb, line 523
def queue_workflow_task event_name, parameters = {}
  PIM::Services::WorkflowService.queue_workflow_task(event_name, parameters)
end

# File services-legacy.rb, line 319
def recalculate_statistics(primaryKeys = nil)
  if primaryKeys
    __service(:statisticsService).queueStatisticCalculation(primaryKeys)
  else
    __service(:statisticsService).queueRecalculation()
  end
end

# File services-legacy.rb, line 311
def revalidate_items(primaryKeys = nil)
  if primaryKeys
    __service(:itemService).queueRevalidateItems(primaryKeys)
  else
    __service(:itemService).queueRevalidateAllItems()
  end
end

# File services-legacy.rb, line 493
def search_contacts_by_custom_value(key, value)
  PIM::Services::ContactService.search_contacts_by_custom_value(key, value)
end

# File services-legacy.rb, line 417
def search_item keyword
  search_items_by_keyword keyword
end

# File services-legacy.rb, line 422
def search_items_by_keyword keyword, opts = {}
  PIM::Services::ItemService.search_items(keyword: keyword, **opts)
end

# File services-legacy.rb, line 427
def search_items_by_tag tag, opts = {}
  PIM::Services::ItemService.search_items(tag: tag, **opts)
end

# File services-legacy.rb, line 392
def send_email(email, locale = nil)
   __service(:emailService).send_mail(email[:subject], email[:message], email[:from], email[:to], locale)
end

# File services-legacy.rb, line 353
def send_review(review_hash)
  PIM::Services::ReviewService.send_review(review_hash)
end

# File services-legacy.rb, line 293
def send_webservice_request(webservice_name, req)
  __service(:webserviceCommunicationService).request(webservice_name, req)
end

# File services-legacy.rb, line 252
def set_store_option store_options, store_method, value
  if not value.nil?
    store_options.send(store_method, value)
  end
end

# File services-legacy.rb, line 271
def store_file(path, content)

  content = case
    when content.is_a?(String)
      java.io.ByteArrayInputStream.new(content.to_java.get_bytes("UTF-8"))
    when content.is_a?(IO)
      content.to_inputstream
    else
      java.io.ByteArrayInputStream.new(content.to_s.to_java_bytes)
  end

  gathering = __service(:digitalAssetService).createGathering()
  __service(:digitalAssetService).createDigitalAsset(nil, gathering, path, content, "ruby")

end

# File services-legacy.rb, line 204
def store_item(item, tags = nil, options = nil)

  return nil if item.nil?

  # Convert Ruby item and Hash item to JSON string to prevent problems with Ruby objects being used in different runtimes
  if !item.is_a?(com.lansa.lax.pim::Item)

    if item.is_a?(PIM::Item)
      item = PIM.return_json(item.as_json)
    elsif PIM.is_hash?(item)
      item = PIM.return_json(item)
    end

    return nil if PIM.is_empty?(item)

    if !PIM.is_string?(item)
      raise "Cannot store item of class #{item.class}"
    end

  end

  store_options = com.lansa.lax.pim::ItemStoreOptions.getDefaultOptions
  fill_store_options_from_options(store_options, options)

  __service(:itemService).store(item, tags, nil, store_options)

end

# File services-legacy.rb, line 388
def translate(locale, key, params = {})
  PIM::Services::TranslationService.translate(locale, key, params)
end

# File services-legacy.rb, line 498
def update_managed_organization managed_organization_id, params = {}
  PIM::Services::OrganizationService.update_managed_organization(managed_organization_id, params)
end

# File services-legacy.rb, line 397
def update_message reference_message_id, new_status, status_message, response_id
  PIM::Services::MessagingService.update_message(reference_message_id, new_status, status_message, response_id)
end

# File services-legacy.rb, line 368
def update_task(task)
  PIM::Services::TaskService.update_task(task)
end

# File services-legacy.rb, line 407
def upload_inbound_message_from_stream stream, filename, content_type, channel_id
  PIM::Services::MessagingService.upload_inbound_message_from_stream(stream, filename, content_type, channel_id)
end

# File services-legacy.rb, line 307
def write_activity(message)
   __service(:monitoringService).write("ACTIVITY", message)
end

# File services-legacy.rb, line 297
def write_log(message, log_level = nil, exception = nil)
  monitoring_module = log_level ? "RUBY_#{log_level.to_s.upcase}" : "RUBY"
  exception = PIM.to_java_exception(exception)
  if __service(:monitoringService)
    __service(:monitoringService).write(monitoring_module, message, nil, exception)
  else
    $stderr.puts "#{monitoring_module}: #{message}"
  end
end