From 9adddebc6deacd05e2de146ede640f690a17d7bf Mon Sep 17 00:00:00 2001
From: Adam Niedzielski <adamsunday@gmail.com>
Date: Thu, 4 Aug 2016 09:41:29 +0200
Subject: Add worker which removes expired members.

---
 app/workers/remove_expired_members_worker.rb | 13 +++++++++++++
 1 file changed, 13 insertions(+)
 create mode 100644 app/workers/remove_expired_members_worker.rb

(limited to 'app/workers/remove_expired_members_worker.rb')

diff --git a/app/workers/remove_expired_members_worker.rb b/app/workers/remove_expired_members_worker.rb
new file mode 100644
index 00000000000..30486b9e8a3
--- /dev/null
+++ b/app/workers/remove_expired_members_worker.rb
@@ -0,0 +1,13 @@
+class RemoveExpiredMembersWorker
+  include Sidekiq::Worker
+
+  def perform
+    Member.includes(:created_by).where("expires_at <= ?", Time.current).find_each do |member|
+      begin
+        Members::DestroyService.new(member, member.created_by).execute
+      rescue => ex
+        logger.error("Expired Member ID=#{member.id} cannot be removed - #{ex}")
+      end
+    end
+  end
+end
-- 
cgit v1.2.3