Class: PipelineService::Endpoints::Pipeline

Inherits:
Object
  • Object
show all
Defined in:
app/services/pipeline_service/endpoints/pipeline.rb,
app/services/pipeline_service/endpoints/pipeline/message_builder.rb

Defined Under Namespace

Classes: MessageBuilder

Instance Method Summary collapse

Constructor Details

#initialize(args = {}) ⇒ Pipeline

Returns a new instance of Pipeline.



4
5
6
7
8
 
# File 'app/services/pipeline_service/endpoints/pipeline.rb', line 4

def initialize(args={})
  @args = args
  configure_dependencies
  raise 'Missing config' if missing_config?
end

Instance Method Details

#call ⇒ Object 



10
11
12
13
14
15
16
17
18
 
# File 'app/services/pipeline_service/endpoints/pipeline.rb', line 10

def call
  return if SettingsService.get_settings(object: :school, id: 1)['disable_pipeline']
  if PipelineService.perform_synchronously?
    perform
  else
    Delayed::Job.enqueue(self, priority: 1000000)
  end
  self
end

#perform ⇒ Object 



20
21
22
23
24
 
# File 'app/services/pipeline_service/endpoints/pipeline.rb', line 20

def perform
  configure_publisher
  build_payload
  post
end