Method: FaaStRuby::Subscriber#call

Defined in:
lib/faastruby/server/subscriber.rb

#call(encoded_data) ⇒ Object 



9
10
11
12
13
14
 
# File 'lib/faastruby/server/subscriber.rb', line 9

def call(encoded_data)
  data = Base64.urlsafe_decode64(encoded_data)
  headers = {'X-Origin' => 'event_hub', 'Content-Transfer-Encoding' => 'base64'}
  event = Event.new(body: data, query_params: {}, headers: headers, context: nil)
  Runner.new.call(@workspace_name, @function_name, event, [])
end