chore: Bump version to 1.3.133

VERSION

@@ -1 +1 @@
-1.3.132
+1.3.133

app/services/economic_service.py

@@ -470,33 +470,51 @@ class EconomicService:
                     logger.info(f"📋 Trying invoice endpoint: {endpoint}")
                     
                     try:
-                        async with session.get(
+                        # Pagination: Keep fetching until no more pages
-                            endpoint,
+                        page = 0
-                            params={"pagesize": 1000},
+                        while True:
-                            headers=self._get_headers()
+                            async with session.get(
-                        ) as response:
+                                endpoint,
-                            logger.info(f"🔍 [API] Response status from {endpoint}: {response.status}")
+                                params={"pagesize": 1000, "skippages": page},
+                                headers=self._get_headers()
+                            ) as response:
+                                logger.info(f"🔍 [API] Response status from {endpoint} (page {page}): {response.status}")
                                 
-                            if response.status == 200:
+                                if response.status == 200:
-                                data = await response.json()
+                                    data = await response.json()
-                                invoices_from_endpoint = data.get('collection', [])
+                                    invoices_from_endpoint = data.get('collection', [])
-                                logger.info(f"✅ Successfully fetched {len(invoices_from_endpoint)} invoices from {endpoint}")
+                                    logger.info(f"✅ Fetched {len(invoices_from_endpoint)} invoices from {endpoint} page {page}")
                                     
-                                # Add new invoices (avoid duplicates by tracking invoice numbers)
+                                    if not invoices_from_endpoint:
-                                existing_invoice_numbers = set()
+                                        # No more invoices on this page
-                                for inv in all_invoices:
+                                        break
-                                    inv_num = inv.get('draftInvoiceNumber') or inv.get('bookedInvoiceNumber')
-                                    if inv_num:
-                                        existing_invoice_numbers.add(inv_num)
                                     
-                                for inv in invoices_from_endpoint:
+                                    # Add new invoices (avoid duplicates by tracking invoice numbers)
-                                    inv_num = inv.get('draftInvoiceNumber') or inv.get('bookedInvoiceNumber')
+                                    existing_invoice_numbers = set()
-                                    if inv_num and inv_num not in existing_invoice_numbers:
+                                    for inv in all_invoices:
-                                        all_invoices.append(inv)
+                                        inv_num = inv.get('draftInvoiceNumber') or inv.get('bookedInvoiceNumber')
-                                        existing_invoice_numbers.add(inv_num)
+                                        if inv_num:
-                            else:
+                                            existing_invoice_numbers.add(inv_num)
-                                error_text = await response.text()
+                                    
-                                logger.warning(f"⚠️ Endpoint {endpoint} returned {response.status}: {error_text[:200]}")
+                                    new_invoices_count = 0
+                                    for inv in invoices_from_endpoint:
+                                        inv_num = inv.get('draftInvoiceNumber') or inv.get('bookedInvoiceNumber')
+                                        if inv_num and inv_num not in existing_invoice_numbers:
+                                            all_invoices.append(inv)
+                                            existing_invoice_numbers.add(inv_num)
+                                            new_invoices_count += 1
+                                    
+                                    logger.info(f"   Added {new_invoices_count} new unique invoices")
+                                    
+                                    # Check if we got full page (1000) - if so, there might be more pages
+                                    if len(invoices_from_endpoint) < 1000:
+                                        break  # Last page
+                                    
+                                    page += 1
+                                else:
+                                    error_text = await response.text()
+                                    logger.warning(f"⚠️ Endpoint {endpoint} returned {response.status}: {error_text[:200]}")
+                                    break
                     except Exception as e:
                         logger.warning(f"⚠️ Error trying endpoint {endpoint}: {e}")