Don't forget to lycansubscribe

option to skip processing posts already in the queue

Changed files
+5 -4
lib
tasks
+5 -4
lib/tasks/import.rake
··· 12 12 end 13 13 14 14 user = User.find_or_create_by!(did: ENV['USER']) 15 + pending = !ENV['SKIP_PENDING'] 15 16 16 17 case ENV['COLLECTION'] 17 18 when 'likes' 18 - queue = ItemQueue.new(user.likes.pending.to_a) 19 + queue = ItemQueue.new(pending ? user.likes.pending.to_a : []) 19 20 importer = LikesImporter.new(ENV['USER']) 20 21 when 'reposts' 21 - queue = ItemQueue.new(user.reposts.pending.to_a) 22 + queue = ItemQueue.new(pending ? user.reposts.pending.to_a : []) 22 23 importer = RepostsImporter.new(ENV['USER']) 23 24 when 'posts' 24 - queue = ItemQueue.new(user.quotes.pending.to_a + user.pins.pending.to_a) 25 + queue = ItemQueue.new(pending ? user.quotes.pending.to_a + user.pins.pending.to_a : []) 25 26 importer = PostsImporter.new(ENV['USER']) 26 27 when nil 27 28 raise "Required COLLECTION parameter missing" 28 29 else 29 30 raise "Invalid collection: #{ENV['COLLECTION']}" 30 - end 31 + end 31 32 32 33 report = ImportReport.new 33 34