Updated monitor example

RomanBachaloSigmaSoftware · RomanBachaloSigmaSoftware · commit 0e208b7a32a0 · 2021-05-20T13:27:32.000+03:00
diff --git a/lib/monitor/controllers/eg001GetMonitoringData.js b/lib/monitor/controllers/eg001GetMonitoringData.js
@@ -32,7 +32,12 @@ eg001GetMonitoringData.createController = async(req, res) => {
 
     const args = {
       accessToken: req.user.accessToken,
-      requestUrl: 'https://lens-d.docusign.net/api/v2.0/datasets/monitor/stream?'
+      basePath: dsConfig.monitorApiUrl,
+      accountId: req.session.accountId,
+      version: '2.0',
+      dataset: 'monitor',
+      cursor: '',
+      limit: 2,
     };
     let results = null;
 
diff --git a/lib/monitor/examples/getMonitoringData.js b/lib/monitor/examples/getMonitoringData.js
@@ -4,76 +4,25 @@
  * @author DocuSign
  */
 
-const request = require("request");
+const docusign = require('docusign-monitor');
 
 /**
  * This function does the work of getting the monitoring data
  */
 const getMonitoringData = async (args) => {
-  // Data for this method
-  // args.requestUrl
-  // args.accessToken
-
-  const requestOptions = {
-    method: "GET",
-    // step 2 start
-    headers: {
-      Authorization: `Bearer ${args.accessToken}`,
-      "Content-Type": "application/json",
-    },
-    // step 2 end
-    json: true,
+  let dsApiClient = new docusign.ApiClient();
+  dsApiClient.setBasePath(args.basePath);
+  dsApiClient.addDefaultHeader("Authorization", "Bearer " + args.accessToken);
+  const datasetApi = new docusign.DataSetApi(dsApiClient);
+
+  const options = {
+    cursor: args.cursor,
+    limit: args.limit
   };
 
-  // step 3 start
-  const limit = 2;
-  let cursorValue = "";
-  let complete = false;
-  let results = [];
-  do {
-    const requestParams = `cursor=${cursorValue}&limit=${limit}`;
-
-    let endCursor = "";
-    let responseResult = null;
-
-    await doRequest(args.requestUrl + requestParams, requestOptions)
-      .then((body) => {
-        endCursor = body.endCursor;
-        responseResult = body;
-      })
-      .catch((error) => {
-        throw error;
-      });
+  const result = await datasetApi.getStreamForDataset(args.version, args.dataset, options);
 
-    if (endCursor === cursorValue) {
-      complete = true;
-    } else {
-      cursorValue = endCursor;
-      results.push(responseResult);
-    }
-  } while (!complete);
-  // step 3 end
-  return results;
-};
-
-/**
- * Does the request
- * @function
- * @private
- * @param {string} url request url
- * @param {Object} options request options
- * @returns {Promise} A promise with request results
- */
-function doRequest(url, options) {
-  return new Promise(function (resolve, reject) {
-    request(url, options, function (error, res, body) {
-      if (!error) {
-        resolve(body);
-      } else {
-        reject(error);
-      }
-    });
-  });
+  return result;
 }
 
 module.exports = { getMonitoringData };
