Add a verification job

fractaledmind · Aug 22, 2024 · 8dd2f0b · 8dd2f0b
1 parent 10677a1
commit 8dd2f0b
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/app/jobs/litestream/verification_job.rb b/app/jobs/litestream/verification_job.rb
@@ -0,0 +1,11 @@
+module Litestream
+  class VerificationJob < ApplicationJob
+    queue_as Litestream.queue
+
+    def perform
+      Litestream::Commands.databases.each do |db_hash|
+        Litestream.verify!(db_hash["path"])
+      end
+    end
+  end
+end
diff --git a/lib/litestream.rb b/lib/litestream.rb
@@ -23,6 +23,7 @@ def initialize
 
   mattr_writer :username
   mattr_writer :password
+  mattr_writer :queue
 
   class << self
     def verify!(database_path)
@@ -60,6 +61,10 @@ def password
       @password ||= ENV["LITESTREAM_PASSWORD"] || @@password
     end
 
+    def queue
+      @queue ||= ENV["LITESTREAM_QUEUE"] || @@queue || "default"
+    end
+
     def replicate_process
       info = {}
       if !`which systemctl`.empty?