Module: Contentful::Scheduler

Defined in:

lib/contentful/scheduler.rb,
lib/contentful/scheduler/auth.rb,
lib/contentful/scheduler/queue.rb,
lib/contentful/scheduler/version.rb,
lib/contentful/scheduler/controller.rb,
lib/contentful/scheduler/taskshelper.rb,
lib/contentful/scheduler/tasks/publish.rb,
lib/contentful/scheduler/tasks/unpublish.rb

Defined Under Namespace

Modules: Tasks, Taskshelper Classes: Auth, Controller, Queue

Constant Summary

DEFAULT_PORT =

32123

DEFAULT_ENDPOINT =

'/scheduler'

DEFAULT_LOGGER =

::Contentful::Webhook::Listener::Support::NullLogger.new

VERSION =

"1.7.4"

@@config =

nil

Class Method Summary

• .config ⇒ Object
• .config=(config) ⇒ Object
• .start(config = {}) ⇒ Object

Class Method Details

.config ⇒ Object

# File 'lib/contentful/scheduler.rb', line 33

def self.config
  @@config
end

.config=(config) ⇒ Object

# File 'lib/contentful/scheduler.rb', line 17

def self.config=(config)
  fail ':redis configuration missing' unless config.key?(:redis)
  fail ':spaces configuration missing' unless config.key?(:spaces)
  config[:spaces].each do |space, data|
    fail ":management_token missing for space: #{space}" unless data.key?(:management_token)
    fail ":delivery_token missing for space: #{space}" unless data.key?(:delivery_token)
  end

  config[:port] = (ENV.key?('PORT') ? ENV['PORT'].to_i : DEFAULT_PORT) unless config.key?(:port)
  config[:logger] = DEFAULT_LOGGER unless config.key?(:logger)
  config[:endpoint] = DEFAULT_ENDPOINT unless config.key?(:endpoint)

  ::Resque.redis = config[:redis].dup
  @@config ||= config
end

.start(config = {}) ⇒ Object

# File 'lib/contentful/scheduler.rb', line 37

def self.start(config = {})
  fail "Scheduler not configured" if self.config.nil? && !block_given?

  if block_given?
    yield(config) if block_given?
    self.config = config
  end

  ::Contentful::Webhook::Listener::Server.start do |config|
    config[:port] = self.config[:port]
    config[:logger] = self.config[:logger]
    config[:endpoints] = [
      {
        endpoint: self.config[:endpoint],
        controller: ::Contentful::Scheduler::Controller,
        timeout: 0
      }
    ]
  end.join
end