release 3.0.15

Author: AK47454453

RELEASE_NOTES.md

@@ -1763,3 +1763,41 @@
 | 🔧 zmienione | 3             |
 | ➖ usunięte  | 0             |
 
+
+# Changelog zmian - `## 3.0.15 (2026-02-12)`- `API: 2.0.1`
+
+## 1. ksef-client
+
+### 1.1 api
+- **DefaultKsefClient.java**: 🔧 dodanie obsługi parsowania odpowiedzi dla status http 429 (Too Many Requests)  
+
+### 1.2 client
+- **ExceptionDetails.java**: 🔧 dodanie opisów pól i metody `toString`
+- **Headers.java**: 🔧 dodanie pola `String RETRY_AFTER = "Retry-After"`
+
+### 1.3 client.model
+- **ApiException.java**: 🔧 dodanie metody `toString`
+- **ExceptionObject.java**: 🔧 dodanie opisów pól i metody `toString`
+- **ExceptionResponse.java**: 🔧 dodanie opisów pól i metody `toString`, dodatkowo dodano pole dla obiektu z http status 429 `TooManyRequestsResponse status`
+- **HttpStatus.java**: 🔧 dodanie enuma `TOO_MANY_REQUESTS(429)`
+- **TooManyRequestsResponse.java**: ➕ dodanie klasy z modelem dla status http 429
+- **lighthouse/Categories.java**: 🔧 zmiana klasy na enuma
+- **lighthouse/Statuses.java**: 🔧 zmiana klasy na enuma
+
+## 2. demo-web-app
+
+### 2.1 integrationTest
+- **BaseIntegrationTest.java**: 🔧 wydłużenie timeoutu przy oczekiwanie na konkretny status/proces
+- **KsefTokenIntegrationTest.java**: 🔧 wydłużenie timeoutu przy oczekiwanie na konkretny status/proces
+- **DuplicateInvoiceIntegrationTest.java**: 🔧 użycie `getContinuationToken` w scenariuszu przy pobieraniu błednie przetworzonych faktur 
+- **TechnicalCorrectionIntegrationTest.java**: ➕ dodanie scenariuszy testowych dla funkcjonalności korekty technicznej faktur 
+
+---
+## 3. Podsumowanie
+
+| Typ zmiany  | Liczba plików |
+|-------------|---------------|
+| ➕ dodane    | 2             |
+| 🔧 zmienione | 12            |
+| ➖ usunięte  | 0             |
+

demo-web-app/build.gradle.kts

@@ -8,7 +8,7 @@ plugins {
 }
 
 group = "pl.akmf.ksef"
-version = "3.0.14"
+version = "3.0.15"
 
 java {
     toolchain {

demo-web-app/src/integrationTest/java/pl/akmf/ksef/sdk/DuplicateInvoiceIntegrationTest.java

@@ -1,6 +1,7 @@
 package pl.akmf.ksef.sdk;
 
 import jakarta.xml.bind.JAXBException;
+import org.apache.logging.log4j.util.Strings;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.Arguments;
@@ -37,13 +38,13 @@
 import java.io.InputStream;
 import java.nio.charset.StandardCharsets;
 import java.time.LocalDate;
+import java.util.ArrayList;
 import java.util.Base64;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.UUID;
-import java.util.concurrent.atomic.AtomicReference;
 import java.util.stream.Stream;
 
 import static java.util.concurrent.TimeUnit.SECONDS;
@@ -89,9 +90,9 @@ void duplicateInvoiceEndToEndFailedListContainsDuplicate(SystemCode systemCode,
         checkSessionStatus(onlineSessionRef, accessToken, 100, null, 1);
 
         // 5. Pobranie nieudanych faktur /invoices/failed (duplikat)
-        SessionInvoicesResponse failedInvoices = getFailedInvoices(onlineSessionRef, accessToken);
+        List<SessionInvoiceStatusResponse> failedInvoices = getFailedInvoicesList(onlineSessionRef, accessToken);
 
-        SessionInvoiceStatusResponse failed = failedInvoices.getInvoices().getFirst();
+        SessionInvoiceStatusResponse failed = failedInvoices.getFirst();
         Assertions.assertNotNull(failed.getStatus());
         Assertions.assertNotNull(failed.getStatus().getCode());
         int duplicateInvoice = 440;
@@ -122,9 +123,9 @@ void duplicateInvoiceOnlineFirstBatchFailedListContainsDuplicate(SystemCode syst
         checkSessionStatus(batchSessionRef, accessToken, 445, 0, 1);
 
         // 3. Pobranie nieudanych faktur sesji wsadowej (polling aż dostępne)
-        SessionInvoicesResponse failedBatchInvoices = getFailedInvoices(batchSessionRef, accessToken);
+        List<SessionInvoiceStatusResponse> failedBatchInvoices = getFailedInvoicesList(batchSessionRef, accessToken);
 
-        SessionInvoiceStatusResponse failed = failedBatchInvoices.getInvoices().getFirst();
+        SessionInvoiceStatusResponse failed = failedBatchInvoices.getFirst();
         Assertions.assertNotNull(failed.getStatus());
         Assertions.assertNotNull(failed.getStatus().getCode());
         int duplicateInvoice = 440;
@@ -197,9 +198,9 @@ private void checkSessionStatus(String sessionReferenceNumber, String accessToke
                 .until(() -> {
                     SessionStatusResponse statusResponse = ksefClient.getSessionStatus(sessionReferenceNumber, accessToken);
                     return statusResponse.getStatus() != null
-                           && statusResponse.getStatus().getCode() == expectedStatus
-                           && Objects.equals(statusResponse.getSuccessfulInvoiceCount(), expectedSuccessfulInvoice)
-                           && Objects.equals(statusResponse.getFailedInvoiceCount(), expectedFailedInvoice);
+                            && statusResponse.getStatus().getCode() == expectedStatus
+                            && Objects.equals(statusResponse.getSuccessfulInvoiceCount(), expectedSuccessfulInvoice)
+                            && Objects.equals(statusResponse.getFailedInvoiceCount(), expectedFailedInvoice);
                 });
     }
 
@@ -242,17 +243,25 @@ private String openOnlineSessionAndSendInvoice(EncryptionData encryptionData, St
         return openOnlineSessionResponse.getReferenceNumber();
     }
 
-    private SessionInvoicesResponse getFailedInvoices(String sessionRef, String accessToken) {
-        AtomicReference<SessionInvoicesResponse> failedInvoicesResponse = new AtomicReference<>();
+    private List<SessionInvoiceStatusResponse> getFailedInvoicesList(String sessionRef, String accessToken) {
+        List<SessionInvoiceStatusResponse> failedInvoicesList = new ArrayList<>();
+
         await().atMost(120, SECONDS)
                 .pollInterval(2, SECONDS)
                 .until(() -> {
-                    SessionInvoicesResponse failedBatchInvoices = ksefClient.getSessionFailedInvoices(sessionRef, null, 10, accessToken);
-                    failedInvoicesResponse.set(failedBatchInvoices);
-                    return failedBatchInvoices.getInvoices() != null
-                           && !failedBatchInvoices.getInvoices().isEmpty();
+                    SessionInvoicesResponse failedInvoices = ksefClient.getSessionFailedInvoices(sessionRef, null, 10, accessToken);
+                    if (failedInvoices.getInvoices() != null && !failedInvoices.getInvoices().isEmpty()) {
+                        failedInvoicesList.addAll(failedInvoices.getInvoices());
+                    }
+                    while (Strings.isNotBlank(failedInvoices.getContinuationToken())) {
+                        failedInvoices = ksefClient.getSessionFailedInvoices(sessionRef, failedInvoices.getContinuationToken(), 10, accessToken);
+                        if (failedInvoices.getInvoices() != null && !failedInvoices.getInvoices().isEmpty()) {
+                            failedInvoicesList.addAll(failedInvoices.getInvoices());
+                        }
+                    }
+                    return !failedInvoicesList.isEmpty();
                 });
 
-        return failedInvoicesResponse.get();
+        return failedInvoicesList;
     }
 }

demo-web-app/src/integrationTest/java/pl/akmf/ksef/sdk/KsefTokenIntegrationTest.java

@@ -136,7 +136,7 @@ public void tokenTest(EncryptionMethod encryptionMethod) throws JAXBException, I
 
         SignatureResponse response = ksefClient.authenticateByKSeFToken(authTokenRequest);
 
-        await().atMost(30, SECONDS)
+        await().atMost(60, SECONDS)
                 .pollInterval(2, SECONDS)
                 .until(() -> isAuthStatusReady(response.getReferenceNumber(), response.getAuthenticationToken().getToken()));