Class: Azure::Push::Message

Inherits:
Object
  • Object
show all
Includes:
Sas
Defined in:
lib/azure/push/message.rb

Instance Method Summary collapse

Methods included from Sas

sas_token

Constructor Details

#initialize(namespace, hub, access_key, key_name: 'DefaultFullSharedAccessSignature', sig_lifetime: 10) ⇒ Message

Returns a new instance of Message.



11
12
13
14
15
16
17
18
19
 
# File 'lib/azure/push/message.rb', line 11

def initialize(namespace, hub, access_key,
    key_name: 'DefaultFullSharedAccessSignature',
    sig_lifetime: 10)
  @access_key = access_key
  @key_name = key_name
  @namespace = namespace
  @hub = hub
  @sig_lifetime = sig_lifetime
end

Instance Method Details

#send(payload, tags = nil, format: 'apple', additional_headers: {}) ⇒ Object

Raises:

  • (ArgumentError) 


21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/azure/push/message.rb', line 21

def send(payload, tags = nil, format: 'apple', additional_headers: {})
  raise ArgumentError unless ['apple', 'gcm', 'template', 'windows', 'windowsphone'].include? format
  raise ArgumentError unless additional_headers.instance_of?(Hash)
  if tags.instance_of?(Array)
    tags = tags.join(' || ')
  end
  uri = URI(url)
  content_type = ['apple', 'gcm', 'template'].include?(format) ? 'application/json' : 'application/xml;charset=utf-8'
  headers = {
    'Content-Type' => content_type,
    'Authorization' => Azure::Push::Sas.sas_token(url, @key_name, @access_key, lifetime: @sig_lifetime),
    'ServiceBusNotification-Format' => format
  }.merge(additional_headers)

  headers['ServiceBusNotification-Tags'] = tags if tags

  http = Net::HTTP.new(uri.host,uri.port)
  http.use_ssl = true
  req = Net::HTTP::Post.new(uri.path, initheader = headers)
  req.body = payload.to_json
  res = http.request(req)
  res.is_a?(Net::HTTPSuccess) ? true : res
end