Merge pull request #21 from Purple-Stock/feat/canceled-alteration-date-filter

Feat/canceled alteration date filter

Author: Pauloparakleto

app/jobs/daily_canceled_order_job.rb

@@ -0,0 +1,34 @@
+# frozen_string_literal: true
+
+# DailyCanceledOrderJob perform against created orders set previously
+# with another status.
+# For this reason, we should call this job as an updater job.
+# The crucial difference here is the absence of the alteration date in the bling API response.
+# It is possible to filter by alteration date, however the alteration date (dataAlteraçãoInicial) is not
+# present in the response. Our solution is querying by alteration date assuming it is the same in bling API
+# setting this assumed value directly on our database.
+# Motives to run this job:
+# There are orders status over counted. There are possibilities they became canceled on bling API
+class DailyCanceledOrderJob < BlingOrderItemCreatorBaseJob
+  STATUS = BlingOrderItem::Status::CANCELED.freeze
+
+  attr_accessor :account_id
+
+  def perform(account_id, initial_alteration_date = nil)
+    @status = STATUS
+    @account_id = account_id
+    @initial_date = initial_alteration_date || Date.today
+    @final_date = Date.today
+    date_range = (@initial_date..@final_date)
+    date_range.each do |alteration_date|
+      @alteration_date = alteration_date
+      final_alteration_date = (alteration_date + 1.day).strftime
+      options = { dataAlteracaoInicial: @alteration_date.strftime, dataAlteracaoFinal: final_alteration_date }
+      orders = Services::Bling::Order.call(order_command: 'find_orders', tenant: account_id,
+                                           situation: STATUS, options: options)
+      orders = orders['data']
+
+      create_orders(orders)
+    end
+  end
+end

config/environments/development.rb

@@ -131,6 +131,14 @@
                                         description: "Create Order Items statuses are canceled" # optional description that appears in Dashboard
     },
 
+    daily_canceled_order_task: {
+                                        cron: "*/10 * * * *",
+                                        class: "DailyCanceledOrderJob",
+                                        args: [1, Date.today],
+                                        set: { priority: 1 },
+                                        description: "Create Order Items statuses are canceled at current day"
+    },
+
     checked_order_items_task: {
       cron: "@weekly",
       class: "CheckedBlingOrderItemsJob",

config/environments/production.rb

@@ -157,6 +157,14 @@
                                         description: "Create Order Items statuses are canceled" # optional description that appears in Dashboard
     },
 
+    daily_canceled_order_task: {
+      cron: "*/10 * * * *",
+      class: "DailyCanceledOrderJob",
+      args: [1, Date.today],
+      set: { priority: 1 },
+      description: "Create Order Items statuses are canceled at current day"
+    },
+
     checked_order_items_task: {
       cron: "@weekly",
       class: "CheckedBlingOrderItemsJob",

spec/jobs/daily_canceled_order_job_spec.rb

@@ -0,0 +1,35 @@
+# frozen_string_literal: true
+
+require 'rails_helper'
+
+RSpec.describe DailyCanceledOrderJob, type: :job do
+  let(:user) { FactoryBot.create(:user) }
+  let(:date) { Date.new(2023, 11, 22) }
+  let(:alteration_date) { Date.new(2023, 12, 14) }
+  let(:situation_id) { BlingOrderItem::Status::PENDING }
+  let(:bling_order_id) { '19341921284' }
+
+  describe '#perform' do
+    before do
+      allow(Date).to receive(:today).and_return Date.new(2023, 12, 14)
+      FactoryBot.create(:bling_datum, account_id: user.account.id, expires_at: Time.zone.now + 2.days)
+      FactoryBot.create(:bling_order_item, bling_order_id:, date:, situation_id:)
+    end
+
+    it 'has status canceled' do
+      VCR.use_cassette('canceled_by_initial_alteration_date', erb: true) do
+        subject.perform(user.account.id)
+        expect(BlingOrderItem.find_by(bling_order_id:).situation_id.to_i)
+          .to eq(BlingOrderItem::Status::CANCELED)
+      end
+    end
+
+    it 'is equal to alteration_date' do
+      VCR.use_cassette('canceled_by_initial_alteration_date', erb: true) do
+        subject.perform(user.account.id)
+        expect(BlingOrderItem.find_by(bling_order_id:).alteration_date.to_date)
+          .to eq(alteration_date)
+      end
+    end
+  end
+end

spec/spec_helper.rb

@@ -12,6 +12,14 @@
     # https://github.com/vcr/vcr/discussions/887 ways to hide sensitive data.
     interaction.request.headers['Authorization'][0] = "Bearer <%= ENV['ACCESS_TOKEN'] %>"
     interaction.response.body.gsub!(/\d{3}[.]\d{3}[.]\d{3}[-]\d{2}/, '999.999.999-99')
+    # Some names with latin punctuation had escaped
+    interaction.response.body.gsub!(/\\u00ed/, '')
+    interaction.response.body.gsub!(/\\u00f3/, '')
+    interaction.response.body.gsub!(/\\u00fa/, '')
+    interaction.response.body.gsub!(/\\u00e3/, '')
+    interaction.response.body.gsub!(/\\u00e7/, '')
+    interaction.response.body.gsub!('******', 'Aa Bb')
+    interaction.response.body.gsub!('****', 'Aa Bb')
     interaction.response.body.gsub!(/"nome\":["^\"][a-z-A-Z]+[\s][a-z-A-Z | \s]+/, "\"nome\":\"Faker Name Souza")
   end
 end