diff --git a/src/api/app/jobs/measurements_job.rb b/src/api/app/jobs/measurements_job.rb index 72599714719..8ca643be472 100644 --- a/src/api/app/jobs/measurements_job.rb +++ b/src/api/app/jobs/measurements_job.rb @@ -3,11 +3,15 @@ class MeasurementsJob < ApplicationJob def perform RabbitmqBus.send_to_bus('metrics', "group count=#{Group.count}") - RabbitmqBus.send_to_bus('metrics', "user in_beta=#{User.in_beta.count},in_rollout=#{User.in_rollout.count},count=#{User.count},#{state_fields}") + RabbitmqBus.send_to_bus('metrics', "user in_beta=#{User.in_beta.count},in_rollout=#{User.in_rollout.count},count=#{User.count},#{role_fields},#{state_fields}") end private + def role_fields + Role.global.pluck(:title).map { |role_title| "#{role_title.downcase}=#{Role.find_by(title: role_title).users.count}" }.join(',') + end + def state_fields User::STATES.map { |state| "#{state}=#{User.where(state: state).count}" }.join(',') end