Contents

require 'routemaster/cache'
require 'routemaster/config'
require 'routemaster/jobs/client'
require 'routemaster/jobs/cache_and_sweep'
require 'routemaster/event_index'

module Routemaster
  module Middleware
    class Cache
      def initialize(app, options = {})
        @app    = app
        @cache  = options.fetch(:cache) { Routemaster::Cache.new }
        @client = options.fetch(:client) { Routemaster::Jobs::Client.new }
        @queue  = options.fetch(:queue) { Config.queue_name }
      end

      def call(env)
        env.fetch('routemaster.dirty', []).each do |url|
          @client.enqueue(@queue, Routemaster::Jobs::CacheAndSweep, url)
        end
        @app.call(env)
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
routemaster-drain-3.7.1	lib/routemaster/middleware/cache.rb
routemaster-drain-3.7.0	lib/routemaster/middleware/cache.rb
routemaster-drain-3.6.8	lib/routemaster/middleware/cache.rb
routemaster-drain-3.6.7	lib/routemaster/middleware/cache.rb
routemaster-drain-3.6.6	lib/routemaster/middleware/cache.rb
routemaster-drain-3.6.5	lib/routemaster/middleware/cache.rb
routemaster-drain-3.6.4	lib/routemaster/middleware/cache.rb
routemaster-drain-3.6.3	lib/routemaster/middleware/cache.rb