Enhance inventory flow query to include AuditEvent handling and update related specs for accurate quantity calculations

Author: Olexii Kasianenko

app/queries/items_flow_query.rb

@@ -22,6 +22,7 @@ def call
               or (e.type = 'PurchaseEvent' and (item->>'to_storage_location')::int = :id)
               or (e.type = 'AdjustmentEvent' and (item->>'to_storage_location')::int = :id)
               or (e.type = 'TransferEvent' and (item->>'to_storage_location')::int = :id)
+              or (e.type = 'AuditEvent' and (item->>'to_storage_location')::int = :id)
               and e.organization_id = :organization_id
             then (item->>'quantity')::int
             else 0
@@ -31,6 +32,7 @@ def call
             when (e.type = 'DistributionEvent' and (item->>'from_storage_location')::int = :id)
               or (e.type = 'AdjustmentEvent' and (item->>'from_storage_location')::int = :id)      
               or (e.type = 'TransferEvent' and (item->>'from_storage_location')::int = :id)
+              or (e.type = 'AuditEvent' and (item->>'from_storage_location')::int = :id)
               and e.organization_id = :organization_id
             then case when (item->>'quantity')::int < 0 then -(item->>'quantity')::int else (item->>'quantity')::int end
             else 0

spec/queries/items_flow_query_spec.rb

@@ -14,19 +14,19 @@
         quantity_in: 10,
         quantity_out: 5,
         change: 5,
-        total_quantity_in: 16,
+        total_quantity_in: 19,
         total_quantity_out: 7,
-        total_change: 9
+        total_change: 12
       },
       {
         item_id: items[1].id,
         item_name: items[1].name,
-        quantity_in: 6,
+        quantity_in: 9,
         quantity_out: 2,
-        change: 4,
-        total_quantity_in: 16,
+        change: 7,
+        total_quantity_in: 19,
         total_quantity_out: 7,
-        total_change: 9
+        total_change: 12
       }
     ].map(&:with_indifferent_access)
   end
@@ -40,6 +40,8 @@
     AdjustmentEvent.publish(adjustment)
     transfer = create(:transfer, :with_items, item: items[1], item_quantity: 2, from: storage_location, to: create(:storage_location))
     TransferEvent.publish(transfer)
+    audit = create(:audit, :with_items, item: items[1], item_quantity: 3, adjustment: adjustment, storage_location: storage_location)
+    AuditEvent.publish(audit)
   end
 
   subject { described_class.new(organization: organization, storage_location: storage_location).call }