Merge pull request #36 from fractaledmind/verification-job

Add a verification job

Gemfile.lock

@@ -2,6 +2,7 @@ PATH
   remote: .
   specs:
     litestream (0.10.5)
+      activejob
       logfmt (>= 0.0.10)
       sqlite3
 

app/jobs/litestream/verification_job.rb

@@ -0,0 +1,13 @@
+require "active_job"
+
+module Litestream
+  class VerificationJob < ActiveJob::Base
+    queue_as Litestream.queue
+
+    def perform
+      Litestream::Commands.databases.each do |db_hash|
+        Litestream.verify!(db_hash["path"])
+      end
+    end
+  end
+end

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?

litestream.gemspec

@@ -27,6 +27,7 @@ Gem::Specification.new do |spec|
   # Uncomment to register a new dependency of your gem
   spec.add_dependency "logfmt", ">= 0.0.10"
   spec.add_dependency "sqlite3"
+  spec.add_dependency "activejob"
   spec.add_development_dependency "rubyzip"
   spec.add_development_dependency "rails"
   spec.add_development_dependency "sqlite3"