Nevillealee/cs_prepaid_app

require Rails.root.join('app', 'helpers','resque_helper.rb')
 
# Class for  updating Subscription and attached QUEUED Order sizes
# @param arg [Hash] nested hash (prop_params and  line_items) of form data
class LineItemUpdate
  include ResqueHelper
 
  def initialize(arg)
    @form_data = arg
    recharge_token = arg["recharge_token"]
    @recharge_change_header = {
      'X-Recharge-Access-Token' => recharge_token,
      'Accept' => 'application/json',
      'Content-Type' => 'application/json'
    }
    @my_user_id = arg["current_user_id"]
  end
 
Method `run` has 50 lines of code (exceeds 25 allowed). Consider refactoring.
  def run
    stream_pre_update
    Resque.logger = Logger.new("#{Rails.root}/log/order_updates.log", 5, 10024000)
    Resque.logger.level = Logger::INFO
    Resque.logger.info "received params: #{@form_data}"
 
    order_id = @form_data["order_id"].to_i
    my_order = Order.find(order_id)
    new_line_items = format_params(@form_data)
    item_array = []
 
Similar blocks of code found in 2 locations. Consider refactoring.
    formatted_line_item = {
      "properties" => new_line_items['properties'].reduce({}, :update).map{|k, v| {'name' => k, 'value' => v}},
      "quantity" => new_line_items['quantity'].to_i,
      "sku" => new_line_items['sku'],
      "product_title" => new_line_items['product_title'],
      "variant_title" => new_line_items['variant_title'],
      "product_id" => new_line_items['shopify_product_id'].to_i,
      "variant_id" => new_line_items['shopify_variant_id'].to_i,
      "subscription_id" => new_line_items['subscription_id'].to_i,
      "price" => new_line_items['price'].to_i
    }
 
Similar blocks of code found in 2 locations. Consider refactoring.
    new_local_line_item = {
      "properties" => new_line_items['properties'].reduce({}, :update).map{|k, v| {'name' => k, 'value' => v}},
      "quantity" => new_line_items['quantity'].to_i,
      "sku" => new_line_items['sku'],
      "product_title" => new_line_items['product_title'],
      "variant_title" => new_line_items['variant_title'],
      "shopify_product_id" => new_line_items['shopify_product_id'].to_i,
      "shopify_variant_id" => new_line_items['shopify_variant_id'].to_i,
      "subscription_id" => new_line_items['subscription_id'].to_i,
      "price" => new_line_items['price'].to_i
    }
 
    item_array.push(formatted_line_item)
    Resque.logger.warn "LINE_ITEMS BEFORE UPDATE: #{my_order.line_items}"
    my_hash = { "line_items" => item_array }
    body = my_hash.to_json
    Resque.logger.warn "JSON SENT TO RECHARGE: #{body}"
    # When updating line_items, you need to provide all the data that was in
    # line_items before, otherwise only new parameters will remain! (from Recharge docs)
    recharge_response = HTTParty.put("https://api.rechargeapps.com/orders/#{order_id}",
      :headers => @recharge_change_header,
      :body => body,
      :timeout => 80
    )
    if recharge_response.code == 200
      my_order.line_items = [new_local_line_item]
      my_order.save!
      Resque.logger.warn "LINE_ITEMS AFTER UPDATE: #{my_order.line_items}"
      puts "Line_item update Done"
      stream_complete_update(recharge_response)
    else
      Resque.logger.error "SOMETHING WENT WRONG#{recharge_response}"
      stream_failure(recharge_response)
    end
  end
 
  def stream_pre_update
    ActionCable.server.broadcast "notifications:#{@my_user_id}", {html:
      "<div class='alert alert-primary alert-block text-center'>
          Sending Subscription switch request to Recharge API....
      </div>"
      }
  end
 
  def stream_complete_update(res)
    results = res['order']['line_items'][0]['properties'].select do |hash|
      hash['name'] == 'product_collection'
    end
 
    ActionCable.server.broadcast "notifications:#{@my_user_id}", {html:
    "<div class='alert alert-success alert-block text-center'>
      Subscription switched to #{results} in Recharge successfully!
      *<a href='/customer/orders/#{@form_data['order_id']}'>Order</a> page may require refresh to show updated values
     </div>"
    }
  end
 
  def stream_failure(res)
    ActionCable.server.broadcast "notifications:#{@my_user_id}", {html:
    "<div class='alert alert-danger alert-block text-center'>
        Recharge API Error: #{res["errors"]}
        <p>Please correct error & resubmit switch request <a href='/customer/orders/#{@form_data['order_id']}'>here</a></p>
     </div>"
    }
  end
 
end