58 lines
1.6 KiB
Ruby
58 lines
1.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module InboxAgentAvailability
|
|
extend ActiveSupport::Concern
|
|
|
|
def available_agents(options = {})
|
|
# Get online agent IDs
|
|
online_agent_ids = fetch_online_agent_ids
|
|
return inbox_members.none if online_agent_ids.empty?
|
|
|
|
# Base query - only online agents
|
|
scope = build_online_agents_scope(online_agent_ids)
|
|
|
|
# Apply filters
|
|
apply_agent_filters(scope, options)
|
|
end
|
|
|
|
def member_ids_with_assignment_capacity
|
|
member_ids
|
|
end
|
|
|
|
private
|
|
|
|
def build_online_agents_scope(online_agent_ids)
|
|
inbox_members
|
|
.joins(:user)
|
|
.where(users: { id: online_agent_ids })
|
|
.includes(:user)
|
|
end
|
|
|
|
def apply_agent_filters(scope, options)
|
|
# Exclude specific users if requested
|
|
scope = scope.where.not(users: { id: options[:exclude_user_ids] }) if options[:exclude_user_ids].present?
|
|
|
|
# Apply rate limiting if assignment policy is enabled
|
|
scope = filter_by_rate_limits(scope) if options[:check_rate_limits] && defined?(AssignmentV2::RateLimiter)
|
|
|
|
scope
|
|
end
|
|
|
|
def fetch_online_agent_ids
|
|
OnlineStatusTracker.get_available_users(account_id)
|
|
.select { |_key, value| value.eql?('online') }
|
|
.keys
|
|
.map(&:to_i)
|
|
end
|
|
|
|
def filter_by_rate_limits(inbox_members_scope)
|
|
# Filter out agents who have exceeded rate limits
|
|
return inbox_members_scope unless assignment_policy&.enabled?
|
|
|
|
inbox_members_scope.select do |inbox_member|
|
|
rate_limiter = AssignmentV2::RateLimiter.new(inbox: self, user: inbox_member.user)
|
|
rate_limiter.within_limits?
|
|
end
|
|
end
|
|
end
|