From b06d95a20d2a146f75038de7a90ff87a7fe6b3c5 Mon Sep 17 00:00:00 2001
From: "Stanko K.R." <stanko@stanko.io>
Date: Mon, 2 Feb 2026 16:24:10 +0100
Subject: [PATCH] Delete accounts for failed imports

---
 app/models/account/import.rb       |  7 ++++++-
 test/models/account/import_test.rb | 26 ++++++++++++++++++++++++++
 2 files changed, 32 insertions(+), 1 deletion(-)

diff --git a/app/models/account/import.rb b/app/models/account/import.rb
index 1ee65b760..4e3edc0ec 100644
--- a/app/models/account/import.rb
+++ b/app/models/account/import.rb
@@ -11,7 +11,7 @@ class Account::Import < ApplicationRecord
   scope :expired, -> { where(completed_at: ...24.hours.ago).or(where(status: :failed, created_at: ...7.days.ago)) }
 
   def self.cleanup
-    expired.destroy_all
+    expired.each(&:cleanup)
   end
 
   def process_later
@@ -49,6 +49,11 @@ class Account::Import < ApplicationRecord
     raise e
   end
 
+  def cleanup
+    destroy
+    account.destroy if failed?
+  end
+
   private
     def mark_completed
       update!(status: :completed, completed_at: Time.current)
diff --git a/test/models/account/import_test.rb b/test/models/account/import_test.rb
index 31ce8f785..dfce60cf3 100644
--- a/test/models/account/import_test.rb
+++ b/test/models/account/import_test.rb
@@ -1,6 +1,32 @@
 require "test_helper"
 
 class Account::ImportTest < ActiveSupport::TestCase
+  test "cleanup deletes completed imports older than 24 hours" do
+    identity = identities(:david)
+    old_completed = Account::Import.create!(account: Current.account, identity: identity, status: :completed, completed_at: 25.hours.ago)
+    recent_completed = Account::Import.create!(account: Current.account, identity: identity, status: :completed, completed_at: 23.hours.ago)
+
+    Account::Import.cleanup
+
+    assert_not Account::Import.exists?(old_completed.id)
+    assert Account::Import.exists?(recent_completed.id)
+  end
+
+  test "cleanup destroys accounts for failed imports older than 7 days" do
+    identity = identities(:david)
+    old_failed_account = Account.create!(name: "Old Failed Import")
+    old_failed = Account::Import.create!(account: old_failed_account, identity: identity, status: :failed, created_at: 8.days.ago)
+    recent_failed_account = Account.create!(name: "Recent Failed Import")
+    recent_failed = Account::Import.create!(account: recent_failed_account, identity: identity, status: :failed, created_at: 6.days.ago)
+
+    Account::Import.cleanup
+
+    assert_not Account::Import.exists?(old_failed.id)
+    assert_not Account.exists?(old_failed_account.id)
+    assert Account::Import.exists?(recent_failed.id)
+    assert Account.exists?(recent_failed_account.id)
+  end
+
   test "export and import round-trip preserves account data" do
     source_account = accounts("37s")
     exporter = users(:david)