[PAGOPA-959] test: fix

integration-test/src/config/.env.uat

@@ -11,7 +11,7 @@ nodo_host=https://api.uat.platform.pagopa.it/nodo
 creditor_institution_id=77777777777
 broker_id=15376371009
 station_id=15376371009_01
-psp_id=60000000001
-channel_id=60000000001_01
+psp_id=AGID_01
+channel_id=97735020584_03
 reporting_batch_wait_execution_sec=120
-include_debug_logs=true
+include_debug_logs=false

integration-test/src/features/01_reporting_batch.feature

@@ -8,16 +8,17 @@ Feature: All about flow report retrieving workflow - Reporting batch component
     * a paid debt position
 
   Scenario: Reporting - Reporting batch no computed flow
+    Given the current flows list size
     When the reporting batch analyzes the reporting flows for the organization
     And the client waits its execution
     Then the client asks the flow list for the organization
     * the client receives status code 200
-    * the client receives an empty list of flows
+    * the client receives an empty list of new flows
 
-  # Scenario: Reporting - Reporting batch Happy path
-  #   Given a report flow sent to Node 
-  #   When the reporting batch analyzes the reporting flows for the organization
-  #   And the client waits its execution
-  #   Then the client asks the flow list for the organization
-  #   * the client receives status code 200
-  #   * the client receives a non-empty list of flows
+  Scenario: Reporting - Reporting batch Happy path
+    Given a report flow sent to Node 
+    When the reporting batch analyzes the reporting flows for the organization
+    And the client waits its execution
+    Then the client asks the flow list for the organization
+    * the client receives status code 200
+    * the client receives a non-empty list of flows

integration-test/src/step_definitions/support/logic/common_logic.js

@@ -1,8 +1,8 @@
 const assert = require("assert");
 
-async function assertEmptyList(response) {
-    console.log(` - -> the client receives an empty list of flows..`);
-    assert.ok(response.data.length === 0);
+async function assertEmptyList(response, flows) {
+    console.log(` - -> the client receives an empty list of flows: ${(response.data.length - flows.size)} flows`);
+    assert.ok((response.data.length - flows.size) === 0);
 }
 
 async function assertNonEmptyList(response) {

integration-test/src/step_definitions/support/logic/gpd_logic.js

@@ -77,7 +77,8 @@ async function generateAndPayDebtPosition(bundle) {
 
     response = await payDebtPosition(bundle.creditorInstitution.id, bundle.debtPosition.paymentOption[0].iuv, buildPayRequest(bundle));
     debugLog(`Debt position payment sending API invocation returned HTTP status code: ${response.status} with body: ${JSON. stringify(response.data)}`);
-    assert.strictEqual(response.status, 200);
+    assert([200, 409].includes(response.status));
+    //assert.strictEqual(response.status, 200);
 
     /*
     response = await sendRT(buildSendRTRequest(bundle));

integration-test/src/step_definitions/support/logic/reporting_logic.js

@@ -40,6 +40,14 @@ async function sendReportFlowToNode(bundle) {
     assert.match(response.data, new RegExp(`<totRestituiti>.+</totRestituiti>`, "g")); 
 }
 
+async function getCurrentListSize(bundle, flows) {
+    console.log(` - Then the client asks the flow list for the organization with id [${bundle.creditorInstitution.id}]..`);
+    bundle.response = await getFlowList(bundle.creditorInstitution.id);
+    debugLog(`Report flow list retrieving API invocation returned HTTP status code: ${bundle.response.status} with body: ${JSON.stringify(bundle.response.data)}`);
+    flows.size = bundle.response.data.length;
+    console.log(` - -> the client receives a list of ${flows.size} flows`);
+}
+
 async function waitWholeReportingProcessExecution() {
     console.log(` - -> the client waits its execution for [${process.env.reporting_batch_wait_execution_sec}] seconds. Please wait..`);
     await new Promise(resolve => setTimeout(resolve, process.env.reporting_batch_wait_execution_sec * 1000));
@@ -52,5 +60,6 @@ module.exports = {
     retrieveReportFlow,
     retrieveReportFlowList,
     sendReportFlowToNode,
-    waitWholeReportingProcessExecution
+    waitWholeReportingProcessExecution,
+    getCurrentListSize
 }

integration-test/src/step_definitions/support/steps.js

@@ -20,8 +20,9 @@ const {
     retrieveReportFlow,
     sendReportFlowToNode, 
     waitWholeReportingProcessExecution,
+    getCurrentListSize
 } = require('./logic/reporting_logic');
-const { bundle } = require('./utility/data');
+const { bundle, flows } = require('./utility/data');
 
 /* Setting defaul timeout to 10s. */
 setDefaultTimeout(120 * 1000);
@@ -42,6 +43,7 @@ Given('reporting analysis service running', () => executeHealthCheckForReporting
 Given('a not paid debt position', () => generateDebtPosition(bundle, true));
 Given('a paid debt position', () => generateAndPayDebtPosition(bundle));
 Given('a report flow sent to Node', () => sendReportFlowToNode(bundle));
+Given('the current flows list size', () => getCurrentListSize(bundle, flows));
 
 
 /* 
@@ -63,7 +65,7 @@ Then('the client asks the detail for the analyzed debt positions', () => retriev
  */
 Then('the client receives status code {int}', (statusCode) => assertStatusCode(bundle.response, statusCode));
 Then('the client receives a non-empty list of flows', () => assertNonEmptyList(bundle.response));
-Then('the client receives an empty list of flows', () => assertEmptyList(bundle.response));
+Then('the client receives an empty list of new flows', () => assertEmptyList(bundle.response, flows));
 Then('the client receives the flow XML content', () => assertFlowXMLContent(bundle.response, bundle.flow.id));
 Then('the client receives the payment options with status {string}', (status) => assertPaymentOptionStatus(bundle.response, status));
 

integration-test/src/step_definitions/support/utility/data.js

@@ -95,6 +95,11 @@ let bundle = {
     response: undefined
 };
 
+let flows = {
+    size: 0
+}
+
 module.exports = {
-    bundle
+    bundle,
+    flows
 }