|
module Hostext
|
|
module Search
|
|
extend ActiveSupport::Concern
|
|
|
|
included do
|
|
include ScopedSearchExtensions
|
|
include ConfigurationStatusScopedSearch
|
|
include SmartProxyHostExtensions
|
|
|
|
has_many :search_parameters, :class_name => 'Parameter', :foreign_key => :reference_id
|
|
belongs_to :search_users, :class_name => 'User', :foreign_key => :owner_id
|
|
belongs_to :usergroups, :class_name => 'Usergroup', :foreign_key => :owner_id
|
|
|
|
scoped_search :on => :name, :complete_value => true, :default_order => true
|
|
scoped_search :on => :last_report, :complete_value => true, :only_explicit => true
|
|
scoped_search :on => :comment, :complete_value => true
|
|
scoped_search :on => :enabled, :complete_value => {:true => true, :false => false}, :rename => :'status.enabled'
|
|
scoped_search :on => :managed, :complete_value => {:true => true, :false => false}
|
|
scoped_search :on => :owner_type, :complete_value => true, :only_explicit => true
|
|
scoped_search :on => :owner_id, :complete_enabled => false, :only_explicit => true, :validator => ScopedSearch::Validators::INTEGER
|
|
|
|
scoped_search :relation => :last_report_object, :on => :origin
|
|
|
|
scoped_search :relation => :configuration_status_object, :on => :status, :offset => 0, :word_size => ConfigReport::BIT_NUM * 4, :rename => :'status.interesting', :complete_value => {:true => true, :false => false}, :only_explicit => true
|
|
scoped_search_status "applied", :relation => :configuration_status_object, :on => :status, :rename => :'status.applied'
|
|
scoped_search_status "restarted", :relation => :configuration_status_object, :on => :status, :rename => :'status.restarted'
|
|
scoped_search_status "failed", :relation => :configuration_status_object, :on => :status, :rename => :'status.failed'
|
|
scoped_search_status "failed_restarts", :relation => :configuration_status_object, :on => :status, :rename => :'status.failed_restarts'
|
|
scoped_search_status "skipped", :relation => :configuration_status_object, :on => :status, :rename => :'status.skipped'
|
|
scoped_search_status "pending", :relation => :configuration_status_object, :on => :status, :rename => :'status.pending'
|
|
|
|
scoped_search :on => :global_status, :complete_value => { :ok => HostStatus::Global::OK, :warning => HostStatus::Global::WARN, :error => HostStatus::Global::ERROR }, :only_explicit => true
|
|
|
|
scoped_search :relation => :model, :on => :name, :complete_value => true, :rename => :model
|
|
scoped_search :relation => :hostgroup, :on => :name, :complete_value => true, :rename => :hostgroup
|
|
scoped_search :relation => :hostgroup, :on => :name, :complete_enabled => false, :rename => :hostgroup_name, :only_explicit => true
|
|
scoped_search :relation => :hostgroup, :on => :title, :complete_value => true, :rename => :hostgroup_fullname
|
|
scoped_search :relation => :hostgroup, :on => :title, :complete_value => true, :rename => :hostgroup_title, :only_explicit => true
|
|
scoped_search :relation => :hostgroup, :on => :id, :complete_enabled => false, :rename => :hostgroup_id, :only_explicit => true, :validator => ScopedSearch::Validators::INTEGER
|
|
scoped_search :relation => :hostgroup, :on => :title, :complete_value => true, :rename => :parent_hostgroup, :only_explicit => true, :ext_method => :search_by_hostgroup_and_descendants
|
|
scoped_search :relation => :domain, :on => :name, :complete_value => true, :rename => :domain
|
|
scoped_search :relation => :domain, :on => :id, :complete_enabled => false, :rename => :domain_id, :only_explicit => true, :validator => ScopedSearch::Validators::INTEGER
|
|
scoped_search :relation => :realm, :on => :name, :complete_value => true, :rename => :realm
|
|
scoped_search :relation => :realm, :on => :id, :complete_enabled => false, :rename => :realm_id, :only_explicit => true, :validator => ScopedSearch::Validators::INTEGER
|
|
scoped_search :relation => :environment, :on => :name, :complete_value => true, :rename => :environment
|
|
scoped_search :relation => :architecture, :on => :name, :complete_value => true, :rename => :architecture
|
|
scoped_search :relation => :puppet_proxy, :on => :name, :complete_value => true, :rename => :puppetmaster, :only_explicit => true
|
|
scoped_search :on => :puppet_proxy_id, :complete_value => false, :only_explicit => true, :validator => ScopedSearch::Validators::INTEGER
|
|
scoped_search :relation => :puppet_ca_proxy, :on => :name, :complete_value => true, :rename => :puppet_ca, :only_explicit => true
|
|
scoped_search :relation => :puppet_proxy, :on => :name, :complete_value => true, :rename => :smart_proxy, :ext_method => :search_by_proxy, :only_explicit => true
|
|
scoped_search :relation => :compute_resource, :on => :name, :complete_value => true, :rename => :compute_resource
|
|
scoped_search :relation => :compute_resource, :on => :id, :complete_enabled => false, :rename => :compute_resource_id, :only_explicit => true, :validator => ScopedSearch::Validators::INTEGER
|
|
scoped_search :relation => :image, :on => :name, :complete_value => true, :rename => :image
|
|
|
|
scoped_search :relation => :operatingsystem, :on => :name, :complete_value => true, :rename => :os
|
|
scoped_search :relation => :operatingsystem, :on => :description, :complete_value => true, :rename => :os_description
|
|
scoped_search :relation => :operatingsystem, :on => :title, :complete_value => true, :rename => :os_title
|
|
scoped_search :relation => :operatingsystem, :on => :major, :complete_value => true, :rename => :os_major, :only_explicit => true
|
|
scoped_search :relation => :operatingsystem, :on => :minor, :complete_value => true, :rename => :os_minor, :only_explicit => true
|
|
scoped_search :relation => :operatingsystem, :on => :id, :complete_enabled => false, :rename => :os_id, :only_explicit => true, :validator => ScopedSearch::Validators::INTEGER
|
|
|
|
scoped_search :relation => :primary_interface, :on => :ip, :complete_value => true
|
|
scoped_search :relation => :interfaces, :on => :ip, :complete_value => true, :rename => :has_ip, :only_explicit => true
|
|
scoped_search :relation => :interfaces, :on => :mac, :complete_value => true, :rename => :has_mac, :only_explicit => true
|
|
|
|
scoped_search :relation => :puppetclasses, :on => :name, :complete_value => true, :rename => :class, :only_explicit => true, :operators => ['= ', '~ '], :ext_method => :search_by_puppetclass
|
|
scoped_search :relation => :fact_values, :on => :value, :in_key => :fact_names, :on_key => :name, :rename => :facts, :complete_value => true, :only_explicit => true, :ext_method => :search_cast_facts
|
|
scoped_search :relation => :search_parameters, :on => :value, :on_key => :name, :complete_value => true, :rename => :params, :ext_method => :search_by_params, :only_explicit => true
|
|
|
|
if SETTINGS[:locations_enabled]
|
|
scoped_search :relation => :location, :on => :title, :rename => :location, :complete_value => true, :only_explicit => true
|
|
scoped_search :on => :location_id, :complete_enabled => false, :only_explicit => true, :validator => ScopedSearch::Validators::INTEGER
|
|
end
|
|
if SETTINGS[:organizations_enabled]
|
|
scoped_search :relation => :organization, :on => :title, :rename => :organization, :complete_value => true, :only_explicit => true
|
|
scoped_search :on => :organization_id, :complete_enabled => false, :only_explicit => true, :validator => ScopedSearch::Validators::INTEGER
|
|
end
|
|
scoped_search :relation => :config_groups, :on => :name, :complete_value => true, :rename => :config_group, :only_explicit => true, :operators => ['= ', '~ '], :ext_method => :search_by_config_group
|
|
|
|
if SETTINGS[:unattended]
|
|
scoped_search :relation => :subnet, :on => :network, :complete_value => false, :rename => :subnet
|
|
scoped_search :relation => :subnet, :on => :name, :complete_value => false, :rename => 'subnet.name'
|
|
scoped_search :relation => :subnet6, :on => :network, :complete_value => false, :rename => :subnet6
|
|
scoped_search :relation => :subnet6, :on => :name, :complete_value => false, :rename => 'subnet6.name'
|
|
scoped_search :on => :uuid, :complete_value => true
|
|
scoped_search :on => :build, :complete_value => {:true => true, :false => false}
|
|
scoped_search :on => :installed_at, :complete_value => true, :only_explicit => true
|
|
|
|
scoped_search :relation => :provision_interface, :on => :mac, :complete_value => true
|
|
end
|
|
|
|
if SETTINGS[:login]
|
|
scoped_search :relation => :search_users, :on => :login, :complete_value => true, :only_explicit => true, :rename => :'user.login', :operators => ['= ', '~ '], :ext_method => :search_by_user, :aliases => [:owner]
|
|
scoped_search :relation => :search_users, :on => :firstname, :complete_value => true, :only_explicit => true, :rename => :'user.firstname', :operators => ['= ', '~ '], :ext_method => :search_by_user
|
|
scoped_search :relation => :search_users, :on => :lastname, :complete_value => true, :only_explicit => true, :rename => :'user.lastname', :operators => ['= ', '~ '], :ext_method => :search_by_user
|
|
scoped_search :relation => :search_users, :on => :mail, :complete_value => true, :only_explicit => true, :rename => :'user.mail', :operators => ['= ', '~ '], :ext_method => :search_by_user
|
|
scoped_search :relation => :usergroups, :on => :name, :complete_value => true, :only_explicit => true, :rename => :'usergroup.name', :aliases => [:usergroup]
|
|
end
|
|
|
|
cattr_accessor :fact_values_table_counter
|
|
end
|
|
|
|
module ClassMethods
|
|
def search_by_user(key, operator, value)
|
|
clean_key = key.sub(/^.*\./, '')
|
|
if value == "current_user"
|
|
value = User.current.id
|
|
clean_key = "id"
|
|
elsif key == "owner"
|
|
clean_key = "login"
|
|
end
|
|
key_name = User.connection.quote_column_name(clean_key)
|
|
condition = sanitize_sql_for_conditions(["#{key_name} #{operator} ?", value_to_sql(operator, value)])
|
|
users = User.where(condition)
|
|
hosts = users.map(&:hosts).flatten
|
|
opts = hosts.empty? ? "< 0" : "IN (#{hosts.map(&:id).join(',')})"
|
|
|
|
{:conditions => " hosts.id #{opts} " }
|
|
end
|
|
|
|
def search_by_puppetclass(key, operator, value)
|
|
conditions = sanitize_sql_for_conditions(["puppetclasses.name #{operator} ?", value_to_sql(operator, value)])
|
|
config_group_ids = ConfigGroup.where(conditions).joins(:puppetclasses).pluck('config_groups.id')
|
|
host_ids = Host.authorized(:view_hosts, Host).where(conditions).joins(:puppetclasses).distinct.pluck('hosts.id')
|
|
host_ids += HostConfigGroup.where(:host_type => 'Host::Base').where(:config_group_id => config_group_ids).pluck(:host_id)
|
|
hostgroups = Hostgroup.unscoped.with_taxonomy_scope.where(conditions).joins(:puppetclasses)
|
|
hostgroups += Hostgroup.unscoped.with_taxonomy_scope.joins(:host_config_groups).where("host_config_groups.config_group_id IN (#{config_group_ids.join(',')})") if config_group_ids.any?
|
|
hostgroup_ids = hostgroups.map(&:subtree_ids).flatten.uniq
|
|
|
|
opts = ''
|
|
opts += "hosts.id IN(#{host_ids.join(',')})" if host_ids.present?
|
|
opts += " OR " unless host_ids.blank? || hostgroup_ids.blank?
|
|
opts += "hostgroups.id IN(#{hostgroup_ids.join(',')})" if hostgroup_ids.present?
|
|
opts = "hosts.id < 0" if host_ids.blank? && hostgroup_ids.blank?
|
|
{:conditions => opts, :include => :hostgroup}
|
|
end
|
|
|
|
def search_by_hostgroup_and_descendants(key, operator, value)
|
|
conditions = sanitize_sql_for_conditions(["hostgroups.title #{operator} ?", value_to_sql(operator, value)])
|
|
# Only one hostgroup (first) is used to determined descendants. Future TODO - alert if result results more than one hostgroup
|
|
hostgroup = Hostgroup.unscoped.with_taxonomy_scope.find_by(conditions)
|
|
if hostgroup.present?
|
|
hostgroup_ids = hostgroup.subtree_ids
|
|
opts = "hosts.hostgroup_id IN (#{hostgroup_ids.join(',')})"
|
|
else
|
|
opts = "hosts.id < 0"
|
|
end
|
|
{:conditions => opts}
|
|
end
|
|
|
|
def search_by_params(key, operator, value)
|
|
key_name = key.sub(/^.*\./, '')
|
|
condition = sanitize_sql_for_conditions(["name = ? and value #{operator} ?", key_name, value_to_sql(operator, value)])
|
|
p = Parameter.where(condition).reorder(:priority)
|
|
return {:conditions => '1 = 0'} if p.blank?
|
|
|
|
max = p.first.priority
|
|
condition = sanitize_sql_for_conditions(["name = ? and NOT(value #{operator} ?) and priority > ?", key_name, value_to_sql(operator, value), max])
|
|
n = Parameter.where(condition).reorder(:priority)
|
|
|
|
conditions = param_conditions(p)
|
|
negate = param_conditions(n)
|
|
|
|
conditions += " AND " unless conditions.blank? || negate.blank?
|
|
conditions += " NOT(#{negate})" if negate.present?
|
|
{
|
|
:joins => :primary_interface,
|
|
:conditions => conditions
|
|
}
|
|
end
|
|
|
|
def search_by_config_group(key, operator, value)
|
|
conditions = sanitize_sql_for_conditions(["config_groups.name #{operator} ?", value_to_sql(operator, value)])
|
|
host_ids = Host::Managed.where(conditions).joins(:config_groups).distinct.pluck('hosts.id')
|
|
hostgroup_ids = Hostgroup.unscoped.with_taxonomy_scope.where(conditions).joins(:config_groups).distinct.map(&:subtree_ids).flatten.uniq
|
|
|
|
opts = ''
|
|
opts += "hosts.id IN(#{host_ids.join(',')})" if host_ids.present?
|
|
opts += " OR " unless host_ids.blank? || hostgroup_ids.blank?
|
|
opts += "hostgroup_id IN(#{hostgroup_ids.join(',')})" if hostgroup_ids.present?
|
|
opts = "hosts.id < 0" if host_ids.blank? && hostgroup_ids.blank?
|
|
{:conditions => opts}
|
|
end
|
|
|
|
def search_by_proxy(key, operator, value)
|
|
proxy_cond = sanitize_sql_for_conditions(["smart_proxies.name #{operator} ?", value_to_sql(operator, value)])
|
|
host_ids = Host::Managed.reorder('')
|
|
.authorized(:view_hosts, Host)
|
|
.eager_load(proxy_join_tables)
|
|
.joins("LEFT JOIN smart_proxies ON smart_proxies.id IN (#{proxy_column_list})")
|
|
.where(proxy_cond)
|
|
.distinct
|
|
.pluck('hosts.id')
|
|
.join(',')
|
|
host_ids = '-1' if host_ids.empty?
|
|
{:conditions => "hosts.id IN (#{host_ids})"}
|
|
end
|
|
|
|
def search_cast_facts(key, operator, value)
|
|
table_id = self.fact_values_table_counter = (self.fact_values_table_counter || 0) + 1
|
|
{
|
|
:joins => %{ INNER JOIN fact_values fact_values_#{table_id} ON (hosts.id = fact_values_#{table_id}.host_id) INNER JOIN fact_names fact_names_#{table_id} ON (fact_names_#{table_id}.id = fact_values_#{table_id}.fact_name_id)},
|
|
:conditions => "#{sanitize_sql_for_conditions(["fact_names_#{table_id}.name = ?", key.split('.')[1]])} AND #{cast_facts("fact_values_#{table_id}", key, operator, value)}"
|
|
}
|
|
end
|
|
|
|
private
|
|
|
|
def param_conditions(p)
|
|
conditions = []
|
|
p.each do |param|
|
|
case param.class.to_s
|
|
when 'CommonParameter'
|
|
conditions << "1 = 1" # include all Global parameters
|
|
when 'DomainParameter'
|
|
conditions << "nics.domain_id = #{param.reference_id}"
|
|
when 'OsParameter'
|
|
conditions << "hosts.operatingsystem_id = #{param.reference_id}"
|
|
when 'GroupParameter'
|
|
conditions << "hosts.hostgroup_id IN (#{param.hostgroup.subtree_ids.join(', ')})"
|
|
when 'HostParameter'
|
|
conditions << "hosts.id = #{param.reference_id}"
|
|
when 'SubnetParameter'
|
|
conditions << "nics.subnet_id = #{param.reference_id} OR nics.subnet6_id = #{param.reference_id}"
|
|
end
|
|
end
|
|
conditions.empty? ? "" : "( #{conditions.join(' OR ')} )"
|
|
end
|
|
end
|
|
end
|
|
end
|
