Sha256: 0039ff105fa7822f83c9d8e39eb14bea5edc9fa7dec6e14577ac231807bf00b9
Contents?: true
Size: 502 Bytes
Versions: 35
Compression:
Stored size: 502 Bytes
Contents
module FaaStRuby
class Subscriber
attr_accessor :path
def initialize(path)
@path = path
@workspace_name, @function_name = @path.split("/")
end
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
end
end
Version data entries
35 entries across 35 versions & 1 rubygems