Merge pull request #148 from docusign/bugfix/fixes-for-monitor

Added the limits to the monitor example

Author: meihDS

lib/monitor/examples/getMonitoringData.js

@@ -4,7 +4,7 @@
  * @author DocuSign
  */
 
-const docusign = require('docusign-monitor');
+const docusign = require("docusign-monitor");
 
 /**
  * This function does the work of getting the monitoring data
@@ -13,15 +13,41 @@ const getMonitoringData = async (args) => {
   //ds-snippet-start:Monitor1Step2
   let dsApiClient = new docusign.ApiClient();
   dsApiClient.setBasePath(args.basePath);
-  dsApiClient.addDefaultHeader('Authorization', 'Bearer ' + args.accessToken);
+  dsApiClient.addDefaultHeader("Authorization", "Bearer " + args.accessToken);
   //ds-snippet-end:Monitor1Step2
 
   //ds-snippet-start:Monitor1Step3
+  const limit = 100; // Amount of records you want to read in one request
+  let functionResult = [];
+
+  let complete = false;
+  let cursorValue, cursoredResult;
   const datasetApi = new docusign.DataSetApi(dsApiClient);
-  const result = await datasetApi.getStream(args.version, args.dataset);
-  //ds-snippet-end:Monitor1Step3
 
-  return result;
+  let options = {
+    limit: limit,
+  };
+
+  // Get monitoring data
+  do {
+    if (cursorValue != null) {
+      options.cursor = cursorValue;
+    }
+    cursoredResult = await datasetApi.getStream("2.0", "monitor", options);
+    let endCursor = cursoredResult.endCursor;
+
+    // If the endCursor from the response is the same as the one that you already have,
+    // it means that you have reached the end of the records
+    if (endCursor === cursorValue) {
+      complete = true;
+    } else {
+      cursorValue = endCursor;
+      functionResult.push(cursoredResult.data);
+    }
+  } while (!complete);
+
+  //ds-snippet-end:Monitor1Step3
+  return functionResult;
 };
 
 module.exports = { getMonitoringData };