[EK-964] Aktywacja rabatów w koszyku

.rubocop.yml

@@ -18,6 +18,10 @@ Style/Documentation:
 Metrics/ParameterLists:
   Max: 8
 
+Lint/MissingSuper:
+  Exclude:
+    - app/services/**/*
+
 Metrics/BlockLength:
   Exclude:
     - spec/**/*

.rubocop_todo.yml

@@ -1,6 +1,6 @@
 # This configuration was generated by
 # `rubocop --auto-gen-config`
-# on 2026-01-27 11:43:39 UTC using RuboCop version 1.84.0.
+# on 2026-01-27 12:23:34 UTC using RuboCop version 1.84.0.
 # The point is for the user to remove these configuration records
 # one by one as the offenses are removed from the code base.
 # Note that changes in the inspected code, or installation of new
@@ -13,15 +13,25 @@ Lint/RedundantCopDisableDirective:
     - 'app/jobs/update_sparta_state_job.rb'
     - 'app/services/spl/sparta_loyalty_service.rb'
 
-# Offense count: 8
+# Offense count: 3
+# Configuration parameters: AllowedMethods, AllowedPatterns, CountRepeatedAttributes.
+Metrics/AbcSize:
+  Max: 18
+
+# Offense count: 2
+# Configuration parameters: AllowedMethods, AllowedPatterns.
+Metrics/CyclomaticComplexity:
+  Max: 8
+
+# Offense count: 13
 # Configuration parameters: CountComments, CountAsOne, AllowedMethods, AllowedPatterns.
 Metrics/MethodLength:
   Max: 14
 
 # Offense count: 1
 # Configuration parameters: CountComments, CountAsOne.
 Metrics/ModuleLength:
-  Max: 125
+  Max: 156
 
 # Offense count: 2
 # Configuration parameters: MinNameLength, AllowNamesEndingInNumbers, AllowedNames, ForbiddenNames.
@@ -82,7 +92,7 @@ Style/IfUnlessModifier:
     - 'app/services/assign_sparta_card_number_service.rb'
     - 'app/services/spl/validate_card_service.rb'
 
-# Offense count: 4
+# Offense count: 5
 # This cop supports safe autocorrection (--autocorrect).
 # Configuration parameters: AllowHeredoc, AllowURI, AllowQualifiedName, URISchemes, AllowRBSInlineAnnotation, AllowCopDirectives, AllowedPatterns, SplitStrings.
 # URISchemes: http, https

app/controllers/spl/spree/storefront/checkout_controller_decorator.rb

@@ -4,20 +4,45 @@ module Spl
   module Spree
     module Storefront
       module CheckoutControllerDecorator
+        include ErrorHandlingHelper
         include BooleanHelper
 
         def self.prepended(base)
-          base.before_action :load_user_coupons
           base.before_action :promotion_switcher
+          base.before_action :load_user_coupons, except: %i[activate_coupon deactivate_coupon]
           base.after_action :perform_update_sparta_state_job, only: %i[confirm complete]
         end
 
-        private
+        def activate_coupon
+          Spl::Coupons::ActivateCouponService.new(@order.user, @order.store, params[:coupon_code]).call
+          load_user_coupons
+        rescue StandardError => e
+          handle_spl_error(e)
+          raise e
+        ensure
+          respond_to do |format|
+            format.turbo_stream
+            format.html { redirect_to checkout_path }
+          end
+        end
 
-        def load_user_coupons
-          @coupons = Spl::GetCouponsService.new(@order.user, @order.store).call
+        def deactivate_coupon
+          Spl::Coupons::DeactivateCouponService
+            .new(@order.user, @order.store, params[:coupon_code])
+            .call
+          load_user_coupons
+        rescue StandardError => e
+          handle_spl_error(e)
+          raise e
+        ensure
+          respond_to do |format|
+            format.turbo_stream
+            format.html { redirect_to checkout_path }
+          end
         end
 
+        private
+
         def promotion_switcher
           PromotionSwitcherService.new(@order, checkout_state_allowed?).call
         end
@@ -34,6 +59,13 @@ def perform_update_sparta_state_job
             UpdateSpartaStateJob.perform_later(@order.token, 'C', @order.number, @order.store)
           end
         end
+
+        def load_user_coupons
+          @coupons = Spl::Coupons::GetCouponsService.new(@order.user, @order.store).call
+        rescue StandardError => e
+          handle_spl_error(e)
+          raise e
+        end
       end
     end
   end

app/controllers/spl/spree/storefront/profile_controller_decorator.rb

@@ -6,6 +6,7 @@ module Storefront
       module ProfileControllerDecorator
         include BooleanHelper
         include ProfileControllerHelper
+        include ErrorHandlingHelper
 
         def self.prepended(base)
           base.before_action :validate_spl_no_card, only: :update
@@ -128,9 +129,37 @@ def clear_errors
           try_spree_current_user.errors.clear
         end
 
-        def assign_card_number(user, store, params)
-          Spl::LoginAccountService.new(user, store, params).call
-          AssignSpartaCardNumberService.new(user, store).call
+        def render_login_code_error
+          render turbo_stream: turbo_stream.replace(
+            'loyalty_connect_form',
+            partial: 'spl/loyalty_connect_form',
+            locals: { user: try_spree_current_user }
+          ),
+                 status: :unprocessable_content
+        end
+
+        def render_login_code_success(phone)
+          render turbo_stream: turbo_stream.replace(
+            'loyalty_connect_form',
+            partial: 'spl/otp_code_form',
+            locals: {
+              user: try_spree_current_user,
+              phone_e164: phone.respond_to?(:e164) ? phone.e164 : nil
+            }
+          ),
+                 status: :ok
+        end
+
+        def render_connect_loyalty_account_error(phone)
+          render turbo_stream: turbo_stream.replace(
+            'otp_code_form',
+            partial: 'spl/otp_code_form',
+            locals: {
+              user: try_spree_current_user,
+              phone_e164: phone.respond_to?(:e164) ? phone.e164 : nil
+            }
+          ),
+                 status: :unprocessable_content
         end
 
         def send_otp(phone, store)
@@ -152,6 +181,11 @@ def handle_spl_error(error)
           try_spree_current_user.errors.add(:base, msg)
         end
 
+        def assign_card_number(user, store, params)
+          Spl::LoginAccountService.new(user, store, params).call
+          AssignSpartaCardNumberService.new(user, store).call
+        end
+
         def login_code_params
           params.require(:user).permit(:phone, :accept_yc_terms)
         end

app/helpers/error_handling_helper.rb

@@ -0,0 +1,22 @@
+# frozen_string_literal: true
+
+module ErrorHandlingHelper
+  # Parses and translate occurred error, then adds it to user errors.
+  # Dedicated for storefront controllers.
+  # @param [StandardError]
+  def handle_spl_error(error)
+    payload = Spl::ErrorPayloadParser.parse(error.message) || error
+    msg = Spl::ErrorTranslator.translate(payload)
+
+    clear_errors
+    try_spree_current_user.errors.add(:base, msg)
+  end
+
+  def clear_errors
+    try_spree_current_user.errors.clear
+  end
+
+  def token_expired?(err_msg)
+    err_msg == 'TOKEN_EXPIRED'
+  end
+end

app/helpers/login_check_helper.rb

@@ -4,9 +4,7 @@ module LoginCheckHelper
   # Checks if user is logged to SPL basing on local information
   # @param user [Spree::User]
   # @return [true, false]
-  def self.logged?(user)
-    return false unless user&.private_metadata&.fetch('spl_access_token', nil)
-
-    true
+  def logged_user?(user)
+    user&.private_metadata&.fetch('spl_access_token', nil).present?
   end
 end

app/helpers/spl_service_helper.rb

@@ -0,0 +1,24 @@
+# frozen_string_literal: true
+
+module SplServiceHelper
+  def send_request(url, body)
+    Spl::SendRequestService.new(url, body).call
+  end
+
+  # Refreshes user private token to keep possible
+  # using customer oriented endpoints
+  # @param [user: Spree::User]
+  def refresh_user_token(user, store)
+    return if user.private_metadata.nil?
+    return if user.private_metadata['spl_refresh_token'].nil?
+
+    response = Spl::OauthTokenService.new(DateTime.current, store).refresh_token(user.private_metadata['spl_refresh_token'])
+
+    user.update!(private_metadata: { spl_access_token: response['access_token'],
+                                     spl_refresh_token: response['refresh_token'] })
+  end
+
+  def token_refresh_needed(response_body, retry_counter, user, store)
+    token_expired?(response_body['errorCode']) && retry_counter < 1 && refresh_user_token(user, store)
+  end
+end

app/services/apply_sparta_discount_service.rb

@@ -10,7 +10,7 @@ def initialize(response, order)
     @response = response
   end
 
-  def call # rubocop:disable Metrics/AbcSize,Metrics/CyclomaticComplexity
+  def call # rubocop:disable Metrics/AbcSize
     return unless response_valid?
 
     line_items.each do |line_item|

app/services/spl/coupons/activate_coupon_service.rb

@@ -0,0 +1,51 @@
+# frozen_string_literal: true
+
+require 'json'
+
+module Spl
+  module Coupons
+    class ActivateCouponService
+      class ActivateCouponServiceError < StandardError; end
+      include SplServiceHelper
+      include ErrorHandlingHelper
+      include LoginCheckHelper
+
+      def initialize(user, store, coupon_code)
+        @store = store
+        @activate_coupons_url = URI.parse(Spl::UrlCreatorService.new(store.private_metadata['spl_url']).coupon_activate)
+        @user = user
+        @coupon_code = coupon_code
+        @retry_counter = 0
+      end
+
+      def call
+        return unless @user.present? && @user.private_metadata.present?
+        return unless logged_user?(@user)
+
+        response = send_request(@activate_coupons_url, body)
+        response_body = JSON.parse(response.body)
+        Rails.logger.debug response_body
+        raise ActivateCouponServiceError, response_body['msg'] if response_body['errorCode'] != '0'
+
+        response_body['response']
+      rescue ActivateCouponServiceError => e
+        raise e unless token_refresh_needed(response_body, @retry_counter, @user, @store)
+
+        @retry_counter += 1
+        retry
+      end
+
+      private
+
+      def body
+        {
+          context: {
+            prgCode: @store.private_metadata['spl_prg_code'],
+            oauthToken: @user.private_metadata['spl_access_token']
+          },
+          couponCode: @coupon_code
+        }
+      end
+    end
+  end
+end

app/services/spl/coupons/deactivate_coupon_service.rb

@@ -0,0 +1,51 @@
+# frozen_string_literal: true
+
+require 'json'
+
+module Spl
+  module Coupons
+    class DeactivateCouponService
+      class DeactivateCouponServiceError < StandardError; end
+      include SplServiceHelper
+      include ErrorHandlingHelper
+      include LoginCheckHelper
+
+      def initialize(user, store, coupon_code)
+        @store = store
+        @deactivate_coupons_url = URI.parse(Spl::UrlCreatorService.new(store.private_metadata['spl_url']).coupon_deactivate)
+        @user = user
+        @coupon_code = coupon_code
+        @retry_counter = 0
+      end
+
+      def call
+        return unless @user.present? && @user.private_metadata.present?
+        return unless logged_user?(@user)
+
+        response = send_request(@deactivate_coupons_url, body)
+        response_body = JSON.parse(response.body)
+        Rails.logger.debug response_body
+        raise DeactivateCouponServiceError, response_body['msg'] if response_body['errorCode'] != '0'
+
+        response_body['response']
+      rescue DeactivateCouponServiceError => e
+        raise e unless token_refresh_needed(response_body, @retry_counter, @user, @store)
+
+        @retry_counter += 1
+        retry
+      end
+
+      private
+
+      def body
+        {
+          context: {
+            prgCode: @store.private_metadata['spl_prg_code'],
+            oauthToken: @user.private_metadata['spl_access_token']
+          },
+          couponCode: @coupon_code
+        }
+      end
+    end
+  end
+end