Class: DiscourseSubscriptionClient::Subscriptions::UpdateResult
- Inherits:
-
Object
- Object
- DiscourseSubscriptionClient::Subscriptions::UpdateResult
- Defined in:
- lib/discourse_subscription_client/subscriptions/update_result.rb
Constant Summary collapse
- KEYS =
REQUIRED_KEYS + OPTIONAL_KEYS
Instance Attribute Summary collapse
-
#errored_suppliers ⇒ Object
readonly
Returns the value of attribute errored_suppliers.
-
#errors ⇒ Object
readonly
Returns the value of attribute errors.
-
#infos ⇒ Object
readonly
Returns the value of attribute infos.
Instance Method Summary collapse
- #connection_error(supplier) ⇒ Object
- #created_subscription(supplier, subscription_ids: nil) ⇒ Object
- #error(key, supplier) ⇒ Object
- #failed_to_create_subscription(supplier, subscription_ids: nil) ⇒ Object
- #info(key, supplier = nil, subscription_ids: nil, resource: nil) ⇒ Object
-
#initialize ⇒ UpdateResult
constructor
A new instance of UpdateResult.
- #no_subscriptions(supplier) ⇒ Object
- #no_suppliers ⇒ Object
- #not_authorized(supplier) ⇒ Object
- #retrieve_subscriptions(supplier, raw_data) ⇒ Object
- #updated_subscription(supplier, subscription_ids: nil) ⇒ Object
Constructor Details
#initialize ⇒ UpdateResult
Returns a new instance of UpdateResult.
21 22 23 24 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 21 def initialize @errors = [] @infos = [] end |
Instance Attribute Details
#errored_suppliers ⇒ Object (readonly)
Returns the value of attribute errored_suppliers.
17 18 19 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 17 def errored_suppliers @errored_suppliers end |
#errors ⇒ Object (readonly)
Returns the value of attribute errors.
17 18 19 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 17 def errors @errors end |
#infos ⇒ Object (readonly)
Returns the value of attribute infos.
17 18 19 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 17 def infos @infos end |
Instance Method Details
#connection_error(supplier) ⇒ Object
69 70 71 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 69 def connection_error(supplier) error("supplier_connection", supplier) end |
#created_subscription(supplier, subscription_ids: nil) ⇒ Object
85 86 87 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 85 def created_subscription(supplier, subscription_ids: nil) info("created_subscription", supplier, subscription_ids: subscription_ids) end |
#error(key, supplier) ⇒ Object
112 113 114 115 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 112 def error(key, supplier) @errors << I18n.t("subscription_client.subscriptions.error.#{key}", supplier: supplier.name, supplier_url: supplier.url) end |
#failed_to_create_subscription(supplier, subscription_ids: nil) ⇒ Object
89 90 91 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 89 def failed_to_create_subscription(supplier, subscription_ids: nil) info("failed_to_create_subscription", supplier, subscription_ids: subscription_ids) end |
#info(key, supplier = nil, subscription_ids: nil, resource: nil) ⇒ Object
93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 93 def info(key, supplier = nil, subscription_ids: nil, resource: nil) attrs = {} if supplier attrs = { supplier: supplier.name, supplier_url: supplier.url, deep_interpolation: true, price: "", resource_name: "" } end attrs.merge!(subscription_ids) if subscription_ids.present? attrs[:resource] if resource.present? @infos << I18n.t("subscription_client.subscriptions.info.#{key}", **attrs) end |
#no_subscriptions(supplier) ⇒ Object
77 78 79 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 77 def no_subscriptions(supplier) info("no_subscriptions", supplier) end |
#no_suppliers ⇒ Object
73 74 75 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 73 def no_suppliers info("no_suppliers") end |
#not_authorized(supplier) ⇒ Object
26 27 28 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 26 def (supplier) error("not_authorized", supplier) end |
#retrieve_subscriptions(supplier, raw_data) ⇒ Object
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 30 def retrieve_subscriptions(supplier, raw_data) subscriptions_data = raw_data[:subscriptions].compact unless subscriptions_data.present? && subscriptions_data.is_a?(Array) error("invalid_response", supplier) return [] end # subscriptions must be properly formed subscriptions_data = subscriptions_data .map(&:symbolize_keys) .each { |data| data[:resource_id] = data[:resource] } .select { |data| REQUIRED_KEYS.all? { |key| data.key?(key) } } # we only care about subscriptions for resources on this instance resources = SubscriptionClientResource.where( supplier_id: supplier.id, name: subscriptions_data.map { |data| data[:resource] } ) subscriptions_data.each_with_object([]) do |data, result| resource = resources.select { |r| r.name === data[:resource] }.first if resource.present? data[:resource_id] = resource.id result << OpenStruct.new( required: data.slice(*REQUIRED_KEYS), create: data.slice(*KEYS), subscription: nil ) else info("no_resource", supplier, resource: data[:resource]) end end end |
#updated_subscription(supplier, subscription_ids: nil) ⇒ Object
81 82 83 |
# File 'lib/discourse_subscription_client/subscriptions/update_result.rb', line 81 def updated_subscription(supplier, subscription_ids: nil) info("updated_subscription", supplier, subscription_ids: subscription_ids) end |