Class: Wurk::Encryption::ServerMiddleware

Inherits:

Object

• Object
• Wurk::Encryption::ServerMiddleware

Includes:

Middleware::ServerMiddleware

Defined in:

lib/wurk/encryption.rb

Overview

Server middleware — peels the envelope before perform runs. A decrypt failure (missing/rotated key, bad tag) is terminal and non-retryable, so rather than let it bubble into the 25× retry pipeline we route the job straight to the dead set tagged encryption_error and ACK it via JobRetry::Skip — see Wurk::Encryption.route_to_dead. Plaintext args remain visible for triage per §4.6.

Instance Attribute Summary

• #config ⇒ Object included from Middleware::ServerMiddleware

  Returns the value of attribute config.

Instance Method Summary

• #call(_worker, job, _queue) ⇒ Object
• #logger ⇒ Object included from Middleware::ServerMiddleware
• #redis ⇒ Object included from Middleware::ServerMiddleware
• #redis_pool ⇒ Object included from Middleware::ServerMiddleware

Instance Attribute Details

#config ⇒ Object Originally defined in module Middleware::ServerMiddleware

Returns the value of attribute config.

Instance Method Details

#call(_worker, job, _queue) ⇒ Object

# File 'lib/wurk/encryption.rb', line 251

def call(_worker, job, _queue)
  return yield unless Wurk::Encryption.enabled? && job['encrypt']

  decrypt_last_arg!(job)
  yield
end

#logger ⇒ Object Originally defined in module Middleware::ServerMiddleware

#redis ⇒ Object Originally defined in module Middleware::ServerMiddleware

#redis_pool ⇒ Object Originally defined in module Middleware::ServerMiddleware