Method: SOULs::SOULsMutation#souls_worker_trigger

Defined in:
lib/souls/app/graphql/souls_mutation.rb

#souls_worker_trigger(worker_name:, query_file_name:, args: {}) ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/souls/app/graphql/souls_mutation.rb', line 8

def souls_worker_trigger(worker_name:, query_file_name:, args: {})
  query_file_name = query_file_name.gsub("_", "-")
  topic_name = "souls-#{worker_name}-#{query_file_name}"
  query = query_file_name.underscore.camelize(:lower)
  query_string = souls_make_graphql_query(query:, args:)
  case ENV["RACK_ENV"]
  when "production"
    souls_publish_pubsub_queue(topic_name:, message: query_string)
  when "development"
    puts(souls_post_to_dev(worker_name:, query_string:))
  end
end