Module: ActivityNotification::SubscriptionApi

Extended by:
ActiveSupport::Concern
Included in:
ORM::ActiveRecord::Subscription, ORM::Dynamoid::Subscription, ORM::Mongoid::Subscription
Defined in:
lib/activity_notification/apis/subscription_api.rb

Overview

Defines API for subscription included in Subscription model.

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.convert_time_as_hash(time) ⇒ Time, Object

Convert Time value to store in database as Hash value.

Parameters:

  • time (Time) —

    Time value to store in database as Hash value

Returns:

  • (Time, Object) —

    Converted Time value



76
77
78
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 76

def self.convert_time_as_hash(time)
  time
end

.filtered_by_key ⇒ ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>

Selects filtered subscriptions by key.

Examples:

Get filtered subscriptions of the @user with key 'comment.reply'

@subscriptions = @user.subscriptions.filtered_by_key('comment.reply')

Parameters:

  • key (String) —

    Key of the subscription for filter

Returns:

  • (ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>) —

    Database query of filtered subscriptions



18
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 18

scope :filtered_by_key,     ->(key) { where(key: key) }

.filtered_by_options ⇒ ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>

Selects filtered subscriptions by key with filter options.

Examples:

Get filtered subscriptions of the @user with key 'comment.reply'

@subscriptions = @user.subscriptions.filtered_by_key('comment.reply')

Get custom filtered subscriptions of the @user

@subscriptions = @user.subscriptions.filtered_by_options({ custom_filter: ["created_at >= ?", time.hour.ago] })

Parameters:

  • options (Hash) —

    Options for filter

Returns:

  • (ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>) —

    Database query of filtered subscriptions



30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 30

scope :filtered_by_options, ->(options = {}) {
  options = ActivityNotification.cast_to_indifferent_hash(options)
  filtered_subscriptions = all
  if options.has_key?(:filtered_by_key)
    filtered_subscriptions = filtered_subscriptions.filtered_by_key(options[:filtered_by_key])
  end
  if options.has_key?(:custom_filter)
    filtered_subscriptions = filtered_subscriptions.where(options[:custom_filter])
  end
  filtered_subscriptions
}

.to_optional_target_key(optional_target_name) ⇒ Symbol

Returns key of optional_targets hash from symbol class name of the optional target implementation.

Parameters:

  • optional_target_name (String, Symbol) —

    Class name of the optional target implementation (e.g. :amazon_sns, :slack)

Returns:

  • (Symbol) —

    Key of optional_targets hash



90
91
92
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 90

def to_optional_target_key(optional_target_name)
  ("subscribing_to_" + optional_target_name.to_s).to_sym
end

.to_optional_target_subscribed_at_key(optional_target_name) ⇒ Symbol

Returns subscribed_at parameter key of optional_targets hash from symbol class name of the optional target implementation.

Parameters:

  • optional_target_name (String, Symbol) —

    Class name of the optional target implementation (e.g. :amazon_sns, :slack)

Returns:

  • (Symbol) —

    Subscribed_at parameter key of optional_targets hash



97
98
99
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 97

def to_optional_target_subscribed_at_key(optional_target_name)
  ("subscribed_to_" + optional_target_name.to_s + "_at").to_sym
end

.to_optional_target_unsubscribed_at_key(optional_target_name) ⇒ Symbol

Returns unsubscribed_at parameter key of optional_targets hash from symbol class name of the optional target implementation.

Parameters:

  • optional_target_name (String, Symbol) —

    Class name of the optional target implementation (e.g. :amazon_sns, :slack)

Returns:

  • (Symbol) —

    Unsubscribed_at parameter key of optional_targets hash



104
105
106
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 104

def to_optional_target_unsubscribed_at_key(optional_target_name)
  ("unsubscribed_to_" + optional_target_name.to_s + "_at").to_sym
end

Instance Method Details

#earliest_order ⇒ ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>

Orders by earliest (older) first as created_at: :asc.

Returns:

  • (ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>) —

    Database query of subscriptions ordered by earliest first



48
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 48

scope :earliest_order,            -> { order(created_at: :asc) }

#earliest_order! ⇒ ActiveRecord_AssociationRelation<Notificaion>, Mongoid::Criteria<Notificaion>

Orders by earliest (older) first as created_at: :asc. This method is to be overridden in implementation for each ORM.

Returns:

  • (ActiveRecord_AssociationRelation<Notificaion>, Mongoid::Criteria<Notificaion>) —

    Database query of subscriptions ordered by earliest first



59
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 59

scope :earliest_order!,           -> { earliest_order }

#earliest_subscribed_order ⇒ ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>

Orders by earliest (older) first as subscribed_at: :asc.

Returns:

  • (ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>) —

    Database query of subscriptions ordered by earliest subscribed_at first



67
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 67

scope :earliest_subscribed_order, -> { order(subscribed_at: :asc) }

#key_order ⇒ ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>

Orders by key name as key: :asc.

Returns:

  • (ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>) —

    Database query of subscriptions ordered by key name



71
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 71

scope :key_order,                 -> { order(key: :asc) }

#latest_order ⇒ ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>

Orders by latest (newest) first as created_at: :desc.

Returns:

  • (ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>) —

    Database query of subscriptions ordered by latest first



44
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 44

scope :latest_order,              -> { order(created_at: :desc) }

#latest_order! ⇒ ActiveRecord_AssociationRelation<Notificaion>, Mongoid::Criteria<Notificaion>

Orders by latest (newest) first as created_at: :desc. This method is to be overridden in implementation for each ORM.

Parameters:

  • reverse (Boolean) —

    If subscriptions will be ordered as earliest first

Returns:

  • (ActiveRecord_AssociationRelation<Notificaion>, Mongoid::Criteria<Notificaion>) —

    Database query of ordered subscriptions



54
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 54

scope :latest_order!,             ->(reverse = false) { reverse ? earliest_order : latest_order }

#latest_subscribed_order ⇒ ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>

Orders by latest (newest) first as subscribed_at: :desc.

Returns:

  • (ActiveRecord_AssociationRelation<Subscription>, Mongoid::Criteria<Notificaion>) —

    Database query of subscriptions ordered by latest subscribed_at first



63
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 63

scope :latest_subscribed_order,   -> { order(subscribed_at: :desc) }

#optional_target_names ⇒ Array<Symbol>

Returns optional_target names of the subscription from optional_targets field.

Returns:

  • (Array<Symbol>) —

    Array of optional target names



212
213
214
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 212

def optional_target_names
  optional_targets.keys.select { |key| key.to_s.start_with?("subscribing_to_") }.map { |key| key.slice(15..-1) }
end

#subscribe(options = {}) ⇒ Boolean

Subscribes to the notification and notification email.

Parameters:

  • options (Hash) (defaults to: {}) —

    Options for subscribing to the notification

Options Hash (options):

  • :subscribed_at (DateTime) — default: Time.current —

    Time to set to subscribed_at and subscribed_to_email_at of the subscription record

  • :with_email_subscription (Boolean) — default: true —

    If the subscriber also subscribes notification email

  • :with_optional_targets (Boolean) — default: true —

    If the subscriber also subscribes optional_targets

Returns:

  • (Boolean) —

    If successfully updated subscription instance



116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 116

def subscribe(options = {})
  subscribed_at = options[:subscribed_at] || Time.current
  with_email_subscription = options.has_key?(:with_email_subscription) ? options[:with_email_subscription] : true
  with_optional_targets   = options.has_key?(:with_optional_targets) ? options[:with_optional_targets] : true
  new_attributes = { subscribing: true, subscribed_at: subscribed_at, optional_targets: optional_targets }
  new_attributes = new_attributes.merge(subscribing_to_email: true, subscribed_to_email_at: subscribed_at) if with_email_subscription
  if with_optional_targets
    optional_target_names.each do |optional_target_name|
      new_attributes[:optional_targets] = new_attributes[:optional_targets].merge(
        Subscription.to_optional_target_key(optional_target_name) => true,
        Subscription.to_optional_target_subscribed_at_key(optional_target_name) => Subscription.convert_time_as_hash(subscribed_at))
    end
  end
  update(new_attributes)
end

#subscribe_to_email(options = {}) ⇒ Boolean

Subscribes to the notification email.

Parameters:

  • options (Hash) (defaults to: {}) —

    Options for subscribing to the notification email

Options Hash (options):

  • :subscribed_to_email_at (DateTime) — default: Time.current —

    Time to set to subscribed_to_email_at of the subscription record

Returns:

  • (Boolean) —

    If successfully updated subscription instance



155
156
157
158
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 155

def subscribe_to_email(options = {})
  subscribed_to_email_at = options[:subscribed_to_email_at] || Time.current
  update(subscribing_to_email: true, subscribed_to_email_at: subscribed_to_email_at)
end

#subscribe_to_optional_target(optional_target_name, options = {}) ⇒ Boolean

Subscribes to the specified optional target.

Parameters:

  • optional_target_name (String, Symbol) —

    Symbol class name of the optional target implementation (e.g. :amazon_sns, :slack)

  • options (Hash) (defaults to: {}) —

    Options for unsubscribing to the specified optional target

Options Hash (options):

  • :subscribed_at (DateTime) — default: Time.current —

    Time to set to subscribed_[optional_target_name]_at in optional_targets hash of the subscription record

Returns:

  • (Boolean) —

    If successfully updated subscription instance



188
189
190
191
192
193
194
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 188

def subscribe_to_optional_target(optional_target_name, options = {})
  subscribed_at = options[:subscribed_at] || Time.current
  update(optional_targets: optional_targets.merge(
    Subscription.to_optional_target_key(optional_target_name) => true,
    Subscription.to_optional_target_subscribed_at_key(optional_target_name) => Subscription.convert_time_as_hash(subscribed_at))
  )
end

#subscribing_to_optional_target?(optional_target_name, subscribe_as_default = ActivityNotification.config.subscribe_as_default) ⇒ Boolean

Returns if the target subscribes to the specified optional target.

Parameters:

  • optional_target_name (Symbol) —

    Symbol class name of the optional target implementation (e.g. :amazon_sns, :slack)

  • subscribe_as_default (Boolean) (defaults to: ActivityNotification.config.subscribe_as_default) —

    Default subscription value to use when the subscription record does not configured

Returns:

  • (Boolean) —

    If the target subscribes to the specified optional target



175
176
177
178
179
180
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 175

def subscribing_to_optional_target?(optional_target_name, subscribe_as_default = ActivityNotification.config.subscribe_as_default)
  optional_target_key = Subscription.to_optional_target_key(optional_target_name)
  subscribe_as_default ?
    !optional_targets.has_key?(optional_target_key) || optional_targets[optional_target_key] :
     optional_targets.has_key?(optional_target_key) && optional_targets[optional_target_key]
end

#unsubscribe(options = {}) ⇒ Boolean

Unsubscribes to the notification and notification email.

Parameters:

  • options (Hash) (defaults to: {}) —

    Options for unsubscribing to the notification

Options Hash (options):

  • :unsubscribed_at (DateTime) — default: Time.current —

    Time to set to unsubscribed_at and unsubscribed_to_email_at of the subscription record

Returns:

  • (Boolean) —

    If successfully updated subscription instance



137
138
139
140
141
142
143
144
145
146
147
148
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 137

def unsubscribe(options = {})
  unsubscribed_at = options[:unsubscribed_at] || Time.current
  new_attributes = { subscribing:          false, unsubscribed_at:          unsubscribed_at,
                     subscribing_to_email: false, unsubscribed_to_email_at: unsubscribed_at,
                     optional_targets: optional_targets }
  optional_target_names.each do |optional_target_name|
    new_attributes[:optional_targets] = new_attributes[:optional_targets].merge(
      Subscription.to_optional_target_key(optional_target_name) => false,
      Subscription.to_optional_target_unsubscribed_at_key(optional_target_name) => Subscription.convert_time_as_hash(subscribed_at))
  end
  update(new_attributes)
end

#unsubscribe_to_email(options = {}) ⇒ Boolean

Unsubscribes to the notification email.

Parameters:

  • options (Hash) (defaults to: {}) —

    Options for unsubscribing the notification email

Options Hash (options):

  • :subscribed_to_email_at (DateTime) — default: Time.current —

    Time to set to subscribed_to_email_at of the subscription record

Returns:

  • (Boolean) —

    If successfully updated subscription instance



165
166
167
168
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 165

def unsubscribe_to_email(options = {})
  unsubscribed_to_email_at = options[:unsubscribed_to_email_at] || Time.current
  update(subscribing_to_email: false, unsubscribed_to_email_at: unsubscribed_to_email_at)
end

#unsubscribe_to_optional_target(optional_target_name, options = {}) ⇒ Boolean

Unsubscribes to the specified optional target.

Parameters:

  • optional_target_name (String, Symbol) —

    Class name of the optional target implementation (e.g. :amazon_sns, :slack)

  • options (Hash) (defaults to: {}) —

    Options for unsubscribing to the specified optional target

Options Hash (options):

  • :unsubscribed_at (DateTime) — default: Time.current —

    Time to set to unsubscribed_[optional_target_name]_at in optional_targets hash of the subscription record

Returns:

  • (Boolean) —

    If successfully updated subscription instance



202
203
204
205
206
207
208
 
# File 'lib/activity_notification/apis/subscription_api.rb', line 202

def unsubscribe_to_optional_target(optional_target_name, options = {})
  unsubscribed_at = options[:unsubscribed_at] || Time.current
  update(optional_targets: optional_targets.merge(
    Subscription.to_optional_target_key(optional_target_name) => false,
    Subscription.to_optional_target_unsubscribed_at_key(optional_target_name) => Subscription.convert_time_as_hash(unsubscribed_at))
  )
end