fix: Add 'SPAM_DETECTION_BLOCKING_LEVEL' env var in BlockUsersJob

README.md

@@ -72,6 +72,9 @@ SPAM_DETECTION_EMAIL
 PERFORM_BLOCK_USER 
     default_value: false
     usage: Determine if the bot can perform blocking, default mode is just report
+SPAM_DETECTION_BLOCKING_LEVEL
+    default_value: 0.99
+    usage: Define which level of spam probability is considered as blocking in job Decidim::SpamDetection::BlockUsersJob (and task rake decidim:spam_detection:block_users)
 ```
 
 ## API usage

app/jobs/decidim/spam_detection/block_users_job.rb

@@ -5,27 +5,29 @@ module SpamDetection
     class BlockUsersJob < ApplicationJob
       queue_as :default
 
-      def perform
-        Rails.logger.info "Blocking users marked as spam"
-        users = reported_spams_users
+      def perform(**args)
+        level = spam_level(args[:spam_level]&.to_f)
+        Rails.logger.info "Blocking users marked as spam with spam level: #{level}..."
+        users = reported_spams_users(level)
         Rails.logger.info "Blocking users marked as spam: #{users.count} users found"
         users.find_each do |user|
-          Decidim::SpamDetection::BlockSpamUserCommand.call(user, spam_level).call
+          Decidim::SpamDetection::BlockSpamUserCommand.call(user, level).call
         end
         Rails.logger.info "Terminated..."
       end
 
       private
 
-      def reported_spams_users
+      def reported_spams_users(level)
         @reported_spams_users ||= Decidim::User.where(admin: false, blocked: false, deleted_at: nil)
                                                .where("(extended_data #> '{spam_detection, unreported_at}') is null")
                                                .where("(extended_data #> '{spam_detection, unblocked_at}') is null")
-                                               .where("(extended_data -> 'spam_detection' ->> 'spam_probability')::float >= ?", spam_level)
+                                               .where("(extended_data -> 'spam_detection' ->> 'spam_probability')::float >= ?", level)
       end
 
-      def spam_level
-        Decidim::SpamDetection::SpamUserCommandAdapter::SPAM_LEVEL[:very_sure]
+      def spam_level(spam_level = nil)
+        spam_level ||= ENV.fetch("SPAM_DETECTION_BLOCKING_LEVEL", nil)&.to_f
+        spam_level || Decidim::SpamDetection::SpamUserCommandAdapter::SPAM_LEVEL[:very_sure]
       end
     end
   end