Class: PublishingPlatformSidekiq::APIHeaders::ServerMiddleware

Inherits:
Object
  • Object
show all
Defined in:
lib/publishing_platform_sidekiq/api_headers.rb

Overview

Server-side middleware runs ‘around’ job processing.

github.com/mperham/sidekiq/wiki/Middleware#server-side-middleware

Instance Method Summary collapse

Instance Method Details

#call(_worker, message, _queue) ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/publishing_platform_sidekiq/api_headers.rb', line 38

def call(_worker, message, _queue)
  last_arg = message["args"].last

  if last_arg.is_a?(Hash) && last_arg.keys.include?("request_id")
    message["args"].pop
    request_id = last_arg["request_id"]
    authenticated_user = last_arg["authenticated_user"]
    PublishingPlatformApi::PublishingPlatformHeaders.set_header(:publishing_platform_request_id, request_id)
    PublishingPlatformApi::PublishingPlatformHeaders.set_header(:x_publishing_platform_authenticated_user, authenticated_user)
    Sidekiq::Context.add("publishing_platform_request_id", request_id)
  end

  yield
end