schedule visitor cleaner job

app/jobs/visitor_cleaner_job.rb

@@ -0,0 +1,9 @@
+class VisitorCleanerJob < ApplicationJob
+ queue_as :default
+
+ def perform(*args)
+ days_to_remove = 5.days.ago
+ Visitor.where(last_visited_at: nil).where('updated_at <=?', days_to_remove).delete_all
+ Visitor.where('last_visited_at <=?', days_to_remove).delete_all
+ end
+end

app/policies/app_policy.rb

@@ -47,8 +47,8 @@ def update_agent_role?
 
  def update_agent_role?
  role.app.owner_id == user.id ||
- role.access_list.include?("manage") || 
- role.access_list.include?("admin")
+  role.access_list.include?('manage') ||
+  role.access_list.include?('admin')
  end
 
  def update?

config/initializers/sidekiq.rb

@@ -0,0 +1,5 @@
+schedule_file = "config/schedule.yml"
+
+if File.exist?(schedule_file) && Sidekiq.server?
+ Sidekiq::Cron::Job.load_from_hash YAML.load_file(schedule_file)
+end

config/schedule.yml

@@ -0,0 +1,5 @@
+my_first_job:
+ cron: "0 */72 * * *"
+ # cron: "*/5 * * * *"
+ class: "VisitorCleanerJob"
+ queue: cron_tasks

config/sidekiq.yml

@@ -7,5 +7,6 @@
  :queues:
  - [mailers, 2]
  - [default, 1]
+ - [cron_tasks, 3]
  - [active_storage_analysis, 2]
  - [active_storage_purge, 2]

spec/jobs/email_chat_notifier_job_spec.rb

@@ -3,5 +3,10 @@
 require 'rails_helper'
 
 RSpec.describe EmailChatNotifierJob, type: :job do
- pending "add some examples to (or delete) #{__FILE__}"
+ it "enqueue job" do
+ ActiveJob::Base.queue_adapter = :test
+ expect {
+ EmailChatNotifierJob.perform_later({})
+ }.to have_enqueued_job
+ end
 end

spec/jobs/list_importer_job_spec.rb

@@ -3,5 +3,10 @@
 require 'rails_helper'
 
 RSpec.describe ListImporterJob, type: :job do
- pending "add some examples to (or delete) #{__FILE__}"
+ it "enqueue job" do
+ ActiveJob::Base.queue_adapter = :test
+ expect {
+ ListImporterJob.perform_later({})
+ }.to have_enqueued_job
+ end
 end

spec/jobs/mail_importer_job_spec.rb

@@ -3,5 +3,10 @@
 require 'rails_helper'
 
 RSpec.describe MailImporterJob, type: :job do
- pending "add some examples to (or delete) #{__FILE__}"
+ it "enqueue job" do
+ ActiveJob::Base.queue_adapter = :test
+ expect {
+ MailImporterJob.perform_later({})
+ }.to have_enqueued_job
+ end
 end

spec/jobs/offline_checker_job_spec.rb

@@ -1,5 +1,10 @@
 require 'rails_helper'
 
 RSpec.describe OfflineCheckerJob, type: :job do
- pending "add some examples to (or delete) #{__FILE__}"
+ it "enqueue job" do
+ ActiveJob::Base.queue_adapter = :test
+ expect {
+ OfflineCheckerJob.perform_later({})
+ }.to have_enqueued_job
+ end
 end

spec/jobs/ses_sender_job_spec.rb

@@ -3,5 +3,10 @@
 require 'rails_helper'
 
 RSpec.describe SesSenderJob, type: :job do
- pending "add some examples to (or delete) #{__FILE__}"
+ it "enqueue job" do
+ ActiveJob::Base.queue_adapter = :test
+ expect {
+ SesSenderJob.perform_later({})
+ }.to have_enqueued_job
+ end
 end

spec/jobs/sns_receiver_job_spec.rb

@@ -3,5 +3,10 @@
 require 'rails_helper'
 
 RSpec.describe SnsReceiverJob, type: :job do
- pending "add some examples to (or delete) #{__FILE__}"
+ it "enqueue job" do
+ ActiveJob::Base.queue_adapter = :test
+ expect {
+ SnsReceiverJob.perform_later({})
+ }.to have_enqueued_job
+ end
 end

spec/jobs/visitor_cleaner_job_spec.rb

@@ -0,0 +1,10 @@
+require 'rails_helper'
+
+RSpec.describe VisitorCleanerJob, type: :job do
+ it "enqueue job" do
+ ActiveJob::Base.queue_adapter = :test
+ expect {
+ VisitorCleanerJob.perform_later({})
+ }.to have_enqueued_job
+ end
+end