Class: GovukSidekiq::APIHeaders::ClientMiddleware
- Inherits:
-
Object
- Object
- GovukSidekiq::APIHeaders::ClientMiddleware
- Defined in:
- lib/govuk_sidekiq/api_headers.rb
Overview
Client-side middleware runs before the pushing of the job to Redis and allows you to modify/stop the job before it gets pushed.
github.com/mperham/sidekiq/wiki/Middleware#client-side-middleware
Instance Method Summary collapse
- #call(_worker_class, job, _queue, _redis_pool) ⇒ Object
- #header_arguments ⇒ Object
- #is_header_hash(arg) ⇒ Object
Instance Method Details
#call(_worker_class, job, _queue, _redis_pool) ⇒ Object
11 12 13 14 15 16 17 18 19 20 |
# File 'lib/govuk_sidekiq/api_headers.rb', line 11 def call(_worker_class, job, _queue, _redis_pool) last_arg = job["args"].last if is_header_hash(last_arg) job["args"].pop job["args"] << header_arguments.merge(last_arg) else job["args"] << header_arguments end yield end |
#header_arguments ⇒ Object
22 23 24 25 26 27 |
# File 'lib/govuk_sidekiq/api_headers.rb', line 22 def header_arguments { "authenticated_user" => GdsApi::GovukHeaders.headers[:x_govuk_authenticated_user], "request_id" => GdsApi::GovukHeaders.headers[:govuk_request_id], } end |
#is_header_hash(arg) ⇒ Object
29 30 31 |
# File 'lib/govuk_sidekiq/api_headers.rb', line 29 def is_header_hash(arg) arg.is_a?(Hash) && (arg.symbolize_keys.keys.include?(:authenticated_user) || arg.symbolize_keys.keys.include?(:request_id)) end |