2016-10-19 03:11:36 +00:00
|
|
|
# Copyright (C) 2012-2016 Zammad Foundation, http://zammad-foundation.org/
|
2013-06-12 15:59:58 +00:00
|
|
|
|
2013-05-21 22:30:09 +00:00
|
|
|
class SearchController < ApplicationController
|
2017-02-15 12:29:25 +00:00
|
|
|
prepend_before_action :authentication_check
|
2013-05-21 22:30:09 +00:00
|
|
|
|
2015-08-15 23:27:11 +00:00
|
|
|
# GET|POST /api/v1/search
|
2015-08-05 09:47:00 +00:00
|
|
|
# GET|POST /api/v1/search/:objects
|
|
|
|
|
|
|
|
def search_generic
|
2014-09-19 21:35:40 +00:00
|
|
|
|
2015-08-15 23:27:11 +00:00
|
|
|
# enable search only for users with valid session
|
|
|
|
if !current_user
|
2014-09-19 21:35:40 +00:00
|
|
|
response_access_deny
|
|
|
|
return true
|
|
|
|
end
|
|
|
|
|
|
|
|
# get params
|
|
|
|
query = params[:query]
|
|
|
|
limit = params[:limit] || 10
|
|
|
|
|
2015-08-05 09:47:00 +00:00
|
|
|
# convert objects string into array of class names
|
|
|
|
# e.g. user-ticket-another_object = %w( User Ticket AnotherObject )
|
2016-01-15 17:22:57 +00:00
|
|
|
objects = if !params[:objects]
|
|
|
|
Setting.get('models_searchable')
|
|
|
|
else
|
|
|
|
params[:objects].split('-').map(&:camelize)
|
|
|
|
end
|
2015-08-16 00:53:27 +00:00
|
|
|
|
|
|
|
# get priorities of result
|
|
|
|
objects_in_order = []
|
|
|
|
objects_in_order_hash = {}
|
|
|
|
objects.each { |object|
|
|
|
|
preferences = object.constantize.search_preferences(current_user)
|
|
|
|
next if !preferences
|
|
|
|
objects_in_order_hash[preferences[:prio]] = object
|
|
|
|
}
|
2016-06-30 20:04:48 +00:00
|
|
|
objects_in_order_hash.keys.sort.reverse_each { |prio|
|
2015-08-16 00:53:27 +00:00
|
|
|
objects_in_order.push objects_in_order_hash[prio]
|
|
|
|
}
|
|
|
|
|
2014-09-19 21:35:40 +00:00
|
|
|
# try search index backend
|
|
|
|
assets = {}
|
|
|
|
result = []
|
|
|
|
if SearchIndexBackend.enabled?
|
2015-08-16 00:53:27 +00:00
|
|
|
|
|
|
|
# get direct search index based objects
|
|
|
|
objects_with_direct_search_index = []
|
|
|
|
objects_without_direct_search_index = []
|
|
|
|
objects.each { |object|
|
|
|
|
preferences = object.constantize.search_preferences(current_user)
|
|
|
|
next if !preferences
|
|
|
|
if preferences[:direct_search_index]
|
|
|
|
objects_with_direct_search_index.push object
|
|
|
|
else
|
|
|
|
objects_without_direct_search_index.push object
|
|
|
|
end
|
2014-09-19 21:35:40 +00:00
|
|
|
}
|
2015-08-05 11:58:53 +00:00
|
|
|
|
2015-08-16 00:53:27 +00:00
|
|
|
# do only one query to index search backend
|
|
|
|
if !objects_with_direct_search_index.empty?
|
2016-01-15 19:08:51 +00:00
|
|
|
items = SearchIndexBackend.search(query, limit, objects_with_direct_search_index)
|
2015-08-16 00:53:27 +00:00
|
|
|
items.each { |item|
|
|
|
|
require item[:type].to_filename
|
2016-01-15 19:08:51 +00:00
|
|
|
record = Kernel.const_get(item[:type]).lookup(id: item[:id])
|
2017-07-24 07:06:15 +00:00
|
|
|
next if !record
|
2015-08-16 00:53:27 +00:00
|
|
|
assets = record.assets(assets)
|
2015-08-05 11:58:53 +00:00
|
|
|
result.push item
|
2015-08-16 00:53:27 +00:00
|
|
|
}
|
2015-08-05 11:58:53 +00:00
|
|
|
end
|
2015-08-16 00:53:27 +00:00
|
|
|
|
|
|
|
# e. g. do ticket query by Ticket class to handle ticket permissions
|
|
|
|
objects_without_direct_search_index.each { |object|
|
|
|
|
object_result = search_generic_backend(object, query, limit, current_user, assets)
|
|
|
|
if !object_result.empty?
|
|
|
|
result = result.concat(object_result)
|
|
|
|
end
|
|
|
|
}
|
|
|
|
|
|
|
|
# sort order by object priority
|
|
|
|
result_in_order = []
|
|
|
|
objects_in_order.each { |object|
|
2016-06-30 20:04:48 +00:00
|
|
|
result.each { |item|
|
2015-08-16 00:53:27 +00:00
|
|
|
next if item[:type] != object
|
|
|
|
item[:id] = item[:id].to_i
|
|
|
|
result_in_order.push item
|
|
|
|
}
|
|
|
|
}
|
|
|
|
result = result_in_order
|
|
|
|
|
2014-09-19 21:35:40 +00:00
|
|
|
else
|
2015-08-05 11:58:53 +00:00
|
|
|
|
2014-09-19 21:35:40 +00:00
|
|
|
# do query
|
2015-08-16 00:53:27 +00:00
|
|
|
objects_in_order.each { |object|
|
|
|
|
object_result = search_generic_backend(object, query, limit, current_user, assets)
|
|
|
|
if !object_result.empty?
|
|
|
|
result = result.concat(object_result)
|
2015-08-05 09:47:00 +00:00
|
|
|
end
|
|
|
|
}
|
2014-09-19 21:35:40 +00:00
|
|
|
end
|
|
|
|
|
2015-04-27 13:42:53 +00:00
|
|
|
render json: {
|
|
|
|
assets: assets,
|
|
|
|
result: result,
|
2014-09-19 21:35:40 +00:00
|
|
|
}
|
|
|
|
end
|
|
|
|
|
2015-08-16 00:53:27 +00:00
|
|
|
private
|
|
|
|
|
|
|
|
def search_generic_backend(object, query, limit, current_user, assets)
|
|
|
|
found_objects = object.constantize.search(
|
|
|
|
query: query,
|
|
|
|
limit: limit,
|
|
|
|
current_user: current_user,
|
|
|
|
)
|
|
|
|
result = []
|
|
|
|
found_objects.each do |found_object|
|
|
|
|
item = {
|
|
|
|
id: found_object.id,
|
|
|
|
type: found_object.class.to_s
|
|
|
|
}
|
|
|
|
result.push item
|
|
|
|
assets = found_object.assets(assets)
|
|
|
|
end
|
|
|
|
result
|
|
|
|
end
|
2013-05-21 22:30:09 +00:00
|
|
|
end
|