Merge pull request #506 from codeforjapan/destroy-all

`delete:destroy_all`の修正

Author: ayuki-joto

app/commands/decidim/comments/destroy_all_comments.rb

@@ -17,11 +17,27 @@ def initialize(organization)
       #
       # Returns nothing.
       def call
-        Decidim::Comments::Comment.find_each do |comment|
-          if comment.organization == organization
-            puts "destroy comment id: #{comment.id}, for #{comment.decidim_root_commentable_type}:#{comment.decidim_root_commentable_id}"
-            comment.destroy!
+        begin
+          deletable_ids = []
+          Decidim::Comments::Comment.find_each(batch_size: 100) do |comment|
+            if comment&.organization == organization # rubocop:disable Style/IfUnlessModifier
+              deletable_ids << comment.id
+            end
+          rescue Module::DelegationError
+            # If commentable of comment is nil, the comment should be removed
+            deletable_ids << comment.id
           end
+
+          deletable_ids.reverse.each_slice(30) do |ids|
+            Decidim::Comments::Comment.where(id: ids).order(id: :desc).each do |comment|
+              puts "destroy comment id: #{comment.id}, for #{comment.decidim_root_commentable_type}:#{comment.decidim_root_commentable_id}"
+              # force to delete (ignore validation)
+              Decidim::Comments::CommentVote.where(comment: comment).delete_all
+              comment.delete
+            end
+          end
+        rescue Exception => e # rubocop:disable Lint/RescueException
+          pp "error?: #{e.inspect}"
         end
 
         broadcast(:ok)

app/commands/decidim/organizations/destroy_organization.rb

@@ -24,8 +24,19 @@ def call
           end
         end
 
+        Decidim::Verifications::Conflict.find_each do |conflict|
+          if conflict.current_user.organization == organization || conflict.managed_user.organization == organization
+            puts "destroy verifications_conflict id: #{conflict.id}"
+            conflict.destroy!
+          end
+        end
+
+        Decidim::DecidimAwesome::EditorImage.where(organization: organization).delete_all
+
         Decidim::ActionLog.where(organization: organization).delete_all
 
+        Decidim::AssembliesSetting.where(organization: organization).delete_all
+
         organization.destroy!
 
         broadcast(:ok)

lib/tasks/delete.rake

@@ -13,10 +13,11 @@ namespace :delete do
     :destroy_all_meetings,
     :destroy_all_pages,
     :destroy_all_surveys,
+    :destroy_all_users,
     :destroy_all_assemblies,
     :destroy_all_participatory_processes,
     :destroy_all_areas,
-    :destroy_all_users,
+    :destroy_all_newsletters,
     :destroy_organization,
     :destroy_all_messages
   ]
@@ -203,23 +204,43 @@ namespace :delete do
     puts "Finish destroy_all_areas of #{ENV["DECIDIM_ORGANIZATION_NAME"]}"
   end
 
+  desc "Destroy all newsletters for a given organization"
+  task destroy_all_newsletters: :environment do
+    puts "Start destroy_all_newsletters of #{ENV["DECIDIM_ORGANIZATION_NAME"]}"
+
+    organization = decidim_find_organization
+    return unless organization
+
+    Decidim::Newsletter.transaction do
+      Decidim::Newsletter.where(organization: organization).destroy_all
+    end
+
+    puts "Finish destroy_all_newsletters of #{ENV["DECIDIM_ORGANIZATION_NAME"]}"
+  end
+
   desc "Destroy all users for a given organization"
   task destroy_all_users: :environment do
     puts "Start destroy_all_users of #{ENV["DECIDIM_ORGANIZATION_NAME"]}"
 
     organization = decidim_find_organization
     return unless organization
 
+    form = OpenStruct.new(valid?: true, delete_reason: "Testing")
     Decidim::User.transaction do
-      form = OpenStruct.new(valid?: true, delete_reason: "Testing")
-      Decidim::User.where(organization: organization).find_each do |user|
+      Decidim::User.where(organization: organization).find_each(batch_size: 100) do |user|
         Decidim::Gamifications::DestroyAllBadges.call(organization, user)
         Decidim::Authorization.where(user: user).destroy_all
-        puts "destroy user id: #{user.id}"
-        Decidim::DestroyAccount.call(user, form)
       end
     end
 
+    # Use tranzaction in Decidim::DestroyAccount
+    Decidim::User.where(organization: organization).find_each(batch_size: 100) do |user|
+      puts "destroy user id: #{user.id}"
+      Decidim::DestroyAccount.call(user, form)
+    rescue StandardError => e
+      puts "Decidim::DestroyAccount failed: #{e.inspect}"
+    end
+
     puts "Finish destroy_all_users of #{ENV["DECIDIM_ORGANIZATION_NAME"]}"
   end
 
@@ -256,9 +277,11 @@ def decidim_find_organization
 
   unless organization
     puts "Organization not found: '#{ENV["DECIDIM_ORGANIZATION_NAME"]}'"
-    puts "Usage: DECIDIM_ORGANIZATION_NAME=<organization name> rails delete::destroy_all_pages"
+    puts "Usage: DECIDIM_ORGANIZATION_NAME=<organization name> rails delete::destroy_all"
     return
   end
 
+  puts "Organization found: '#{ENV["DECIDIM_ORGANIZATION_NAME"]}' as '#{organization.id}'"
+
   organization
 end