Class: Noticed::DeliveryMethods::Fcm

Inherits:
Noticed::DeliveryMethod show all
Defined in:
lib/noticed/delivery_methods/fcm.rb

Instance Attribute Summary

Attributes inherited from Noticed::DeliveryMethod

#config, #event, #notification

Instance Method Summary collapse

Methods inherited from Noticed::DeliveryMethod

#evaluate_option, #fetch_constant, #perform

Methods included from ApiClient

#post_request

Instance Method Details

#access_token ⇒ Object 



61
62
63
64
65
66
67
 
# File 'lib/noticed/delivery_methods/fcm.rb', line 61

def access_token
  @authorizer ||= (evaluate_option(:authorizer) || Google::Auth::ServiceAccountCredentials).make_creds(
    json_key_io: StringIO.new(credentials.to_json),
    scope: "https://www.googleapis.com/auth/firebase.messaging"
  )
  @authorizer.fetch_access_token!["access_token"]
end

#bad_token?(response) ⇒ Boolean

Returns:

  • (Boolean) 


37
38
39
 
# File 'lib/noticed/delivery_methods/fcm.rb', line 37

def bad_token?(response)
  response.code == "404" || response.code == "400"
end

#credentials ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/noticed/delivery_methods/fcm.rb', line 41

def credentials
  @credentials ||= begin
    value = evaluate_option(:credentials)
    case value
    when Hash
      value
    when Pathname
      load_json(value)
    when String
      load_json(Rails.root.join(value))
    else
      raise ArgumentError, "FCM credentials must be a Hash, String, Pathname, or Symbol"
    end
  end
end

#deliver ⇒ Object 



8
9
10
11
12
 
# File 'lib/noticed/delivery_methods/fcm.rb', line 8

def deliver
  evaluate_option(:device_tokens).each do |device_token|
    send_notification device_token
  end
end

#format_notification(device_token) ⇒ Object 



28
29
30
31
32
33
34
35
 
# File 'lib/noticed/delivery_methods/fcm.rb', line 28

def format_notification(device_token)
  method = config[:json]
  if method.is_a?(Symbol) && event.respond_to?(method, true)
    event.send(method, device_token)
  else
    notification.instance_exec(device_token, &method)
  end
end

#load_json(path) ⇒ Object 



57
58
59
 
# File 'lib/noticed/delivery_methods/fcm.rb', line 57

def load_json(path)
  JSON.parse(File.read(path), symbolize_names: true)
end

#send_notification(device_token) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/noticed/delivery_methods/fcm.rb', line 14

def send_notification(device_token)
  post_request("https://fcm.googleapis.com/v1/projects/#{credentials[:project_id]}/messages:send",
    headers: {authorization: "Bearer #{access_token}"},
    json: format_notification(device_token))
rescue Noticed::ResponseUnsuccessful => exception
  if bad_token?(exception.response) && config[:invalid_token]
    notification.instance_exec(device_token, &config[:invalid_token])
  elsif config[:error_handler]
    notification.instance_exec(exception.response, &config[:error_handler])
  else
    raise
  end
end