Added whenever to update slug tags every day and sync user names with Accounts

Author: Dantemss

Gemfile

@@ -154,6 +154,9 @@ gem 'activerecord-import'
 # Get env variables from .env file
 gem 'dotenv-rails'
 
+# Cron job scheduling
+gem 'whenever'
+
 group :development, :test do
   # Run specs in parallel
   gem 'parallel_tests'

Gemfile.lock

@@ -119,6 +119,7 @@ GEM
     cheat (1.3.3)
       pager (~> 1.0)
     choice (0.2.0)
+    chronic (0.10.2)
     codecov (0.2.12)
       json
       simplecov
@@ -524,6 +525,8 @@ GEM
     websocket-driver (0.7.5)
       websocket-extensions (>= 0.1.0)
     websocket-extensions (0.1.5)
+    whenever (1.0.0)
+      chronic (>= 0.6.3)
     zeitwerk (2.5.1)
 
 PLATFORMS
@@ -607,6 +610,7 @@ DEPENDENCIES
   vcr
   web-console
   webmock
+  whenever
 
 BUNDLED WITH
    2.3.7

app/models/exercise.rb

@@ -96,7 +96,7 @@ class Exercise < ApplicationRecord
   scope :can_release_to_a15k, -> { where(release_to_a15k: true) }
   scope :not_released_to_a15k, -> { where(a15k_identifier: nil) }
 
-  before_validation :set_context, :set_slug_tags
+  before_validation :set_context, :set_slug_tags!
 
   def content_equals?(other_exercise)
     return false unless other_exercise.is_a? ActiveRecord::Base
@@ -247,7 +247,7 @@ def set_context(archive_version: nil)
     return
   end
 
-  def set_slug_tags
+  def set_slug_tags!
     existing_book_slug_tags, other_tags = tags.partition do |tag|
       tag.name.starts_with? 'book-slug:'
     end
@@ -268,10 +268,10 @@ def set_slug_tags
       "module-slug:#{slug[:book]}:#{slug[:page]}"
     end
 
-    kept_book_slug_tags = existing_book_slug_tags.filter do |tag|
+    kept_book_slug_tags, removed_book_slug_tags = existing_book_slug_tags.partition do |tag|
       desired_book_slugs.include? tag.name
     end
-    kept_page_slug_tags = existing_page_slug_tags.filter do |tag|
+    kept_page_slug_tags, removed_page_slug_tags = existing_page_slug_tags.partition do |tag|
       desired_page_slugs.include? tag.name
     end
 
@@ -284,5 +284,11 @@ def set_slug_tags
     self.tags = non_slug_tags +
                 kept_book_slug_tags + kept_page_slug_tags +
                 new_book_slugs + new_page_slugs
+
+    # Return whether or not any tags changed
+    !removed_book_slug_tags.empty? ||
+    !removed_page_slug_tags.empty? ||
+    !new_book_slugs.empty? ||
+    !new_page_slugs.empty?
   end
 end

app/routines/update_slugs.rb

@@ -0,0 +1,16 @@
+class UpdateSlugs
+  lev_routine transaction: :no_transaction
+
+  protected
+
+  def exec
+    Exercise.preload(:publication).in_batches(of: 100, load: true) do |exercises|
+      Exercise.transaction do
+        updated_exercise_ids = exercises.filter(&:set_slug_tags!).map(&:id)
+        next if updated_exercise_ids.empty?
+
+        Exercise.where(id: updated_exercise_ids).update_all updated_at: Time.current
+      end
+    end
+  end
+end

config/schedule.rb

@@ -0,0 +1,5 @@
+# Server time is UTC
+# Times below are interpreted that way
+
+every(1.minute)          { rake 'cron:minute' }
+every(1.day, at: '8 AM') { rake 'cron:day'    }  # Midnight-1AM Pacific/2-3AM Central/3-4AM Eastern

db/migrate/20220302162344_create_slug_tags.rb

@@ -4,7 +4,7 @@ class CreateSlugTags < ActiveRecord::Migration[6.1]
   def up
     Exercise.preload(:publication).in_batches(of: 100, load: true) do |exercises|
       Exercise.transaction do
-        exercises.each(&:set_slug_tags)
+        exercises.each(&:set_slug_tags!)
         exercises.update_all updated_at: Time.current
       end
     end

lib/tasks/cron/day.rake

@@ -0,0 +1,10 @@
+namespace :cron do
+  task day: :log_to_stdout do
+    Rails.logger.debug 'Starting daily cron'
+
+    Rails.logger.info 'UpdateSlugs.call'
+    OpenStax::RescueFrom.this { UpdateSlugs.call }
+
+    Rails.logger.debug 'Finished daily cron'
+  end
+end

lib/tasks/cron/minute.rake

@@ -0,0 +1,10 @@
+namespace :cron do
+  task minute: :log_to_stdout do
+    Rails.logger.debug 'Starting minute cron'
+
+    Rails.logger.info 'rake openstax:accounts:sync:accounts'
+    OpenStax::RescueFrom.this { Rake::Task['openstax:accounts:sync:accounts'].invoke }
+
+    Rails.logger.debug 'Finished minute cron'
+  end
+end

spec/models/exercise_spec.rb

@@ -8,7 +8,8 @@
   it { is_expected.to have_many(:exercise_tags).dependent(:destroy) }
 
   it 'automatically sets the context based on tags and rewrites image links' do
-    expect_any_instance_of(Exercise).to receive(:set_slug_tags).twice
+    # Disable set_slug_tags!
+    expect_any_instance_of(Exercise).to receive(:set_slug_tags!).twice
 
     exercise.tags = [
       'context-cnxmod:4ee317f2-cc23-4075-b377-51ee4d11bb61',

spec/routines/exercises/tag/xlsx_spec.rb

@@ -20,8 +20,8 @@
 
   let!(:exercises) { (1..6).map { |ii| FactoryBot.create(:publication, number: ii).publishable } }
 
-  # Disable set_slug_tags
-  before { allow_any_instance_of(Exercise).to receive(:set_slug_tags) }
+  # Disable set_slug_tags!
+  before { allow_any_instance_of(Exercise).to receive(:set_slug_tags!) }
 
   it 'tags exercises with the sample spreadsheet' do
     expect { described_class.call(filename: fixture_path) }.to change { ExerciseTag.count }.by(20)