Chore prod test script

performance-test/src/scripts/prod_test_script.js

@@ -0,0 +1,67 @@
+import { CosmosClient } from '@azure/cosmos';
+
+//ENVIRONMENTAL VARIABLES
+const bizEventCosmosDBConnString = ""; //bizEvent cosmos connection string
+const bizEventDatabaseID = "db";
+const bizEventContainerID = "biz-events";
+
+const receiptCosmosDBConnString = ""; //receipt cosmos connection string
+const receiptDatabaseID = "db";
+const receiptContainerID = "receipts";
+
+const apiRetryFailedURI = ""; //Retry failed function apim uri
+const ocpApimKey = ""; //APIM ocp key
+
+//CLIENTS
+const bizeventClient = new CosmosClient(bizEventCosmosDBConnString);
+const bizeventContainer = bizeventClient.database(bizEventDatabaseID).container(bizEventContainerID);
+
+const receiptClient = new CosmosClient(receiptCosmosDBConnString);
+const receiptContainer = receiptClient.database(receiptDatabaseID).container(receiptContainerID);
+
+//INPUTS
+const minDate = new Date("04/01/2023").getTime(); //mm/dd/yyyy
+const FISCAL_CODES_TO_TEST = [
+    ""
+];
+
+const updateBizEvents = async () => {
+    for (const fiscalCode of FISCAL_CODES_TO_TEST) {
+        let { resources } = await bizeventContainer.items.query({
+            query: "SELECT * from c WHERE c.debtor.entityUniqueIdentifierValue = @fiscalCode and c.timestamp >= @minDate and c.eventStatus = 'DONE'",
+            parameters: [{ name: "@fiscalCode", value: fiscalCode }, { name: "@minDate", value: minDate }]
+        }).fetchAll();
+
+        for (let j = 0; j < resources.length; j++) {
+            let bizEvent = resources[j];
+
+            let exist = await bizeventContainer.item(bizEvent.id, bizEvent.id).read();
+
+            if (exist.statusCode === 200) {
+                let receipt = {
+                    eventId: bizEvent.id,
+                    status: "FAILED"
+                };
+                let { resource } = await receiptContainer.items.create(receipt);
+                console.log("SAVED receipt with id: " + resource.id);
+
+                fetch(apiRetryFailedURI, {
+                    method: "PUT",
+                    headers: {
+                        'Content-Type': 'application/json',
+                        "Ocp-Apim-Subscription-Key": ocpApimKey
+                    },
+                    body: {
+                        "eventId": bizEvent.id
+                    }
+                })
+                .then(() => console.log("RETRIED receipt with id: " + resource.id))
+                .catch(() => console.log("FAILED RETRY for receipt with id: " + resource.id))
+            }
+
+        }
+
+    }
+}
+
+updateBizEvents();