Governace rules support (#78)

Governance Rules Support

Author: xinghengwang

dist/dataUtils.d.ts

@@ -29,5 +29,6 @@ export function isJsonHeader(msg: any): boolean;
 export function appendChunk(buf: any, chunk: any): any;
 export function computeBodySize(body: any): number;
 export function totalChunkLength(chunk1: any, chunk2: any): any;
+export function ensureToString(id: any): any;
 export { _getUrlFromRequestOptions as getUrlFromRequestOptions, _getEventModelFromRequestAndResponse as getEventModelFromRequestAndResponse, _safeJsonParse as safeJsonParse, _startWithJson as startWithJson, _bodyToBase64 as bodyToBase64, _hashSensitive as hashSensitive };
 //# sourceMappingURL=dataUtils.d.ts.map

dist/dataUtils.d.ts.map

@@ -0,0 +1,38 @@
+declare const _exports: GovernanceRulesManager;
+export = _exports;
+/**
+ *
+ * @type Class
+ *
+ * */
+declare function GovernanceRulesManager(): void;
+declare class GovernanceRulesManager {
+    _lastUpdate: number;
+    setLogger(logger: any): void;
+    _logger: any;
+    log(message: any, details: any): void;
+    hasRules(): boolean;
+    shouldFetch(): boolean;
+    tryGetRules(): Promise<any>;
+    _cacheRules(rules: any): void;
+    regexRules: any;
+    userRulesHashByRuleId: {};
+    companyRulesHashByRuleId: {};
+    unidentifiedUserRules: any;
+    unidentifiedCompanyRules: any;
+    _getApplicableRegexRules(requestFields: any, requestBody: any): any;
+    _getApplicableUnidentifiedUserRules(requestFields: any, requestBody: any): any;
+    _getApplicableUnidentifiedCompanyRules(requestFields: any, requestBody: any): any;
+    _getApplicableUserRules(configUserRulesValues: any, requestFields: any, requestBody: any): any[];
+    _getApplicableCompanyRules(configCompanyRulesValues: any, requestFields: any, requestBody: any): any[];
+    applyRuleList(applicableRules: any, responseHolder: any, configRuleValues: any): any;
+    governRequest(config: any, userId: any, companyId: any, request: any): {
+        status: any;
+        headers: {};
+        body: any;
+        blocked_by: any;
+    };
+    tryUpdateHash(response: any): void;
+    _lastSeenHash: any;
+}
+//# sourceMappingURL=governanceRulesManager.d.ts.map

dist/formatEventDataAndSave.d.ts.map

@@ -276,7 +276,7 @@ function _getEventModelFromRequestAndResponse(
 
   logData.response = {};
   logData.response.time = responseTime;
-  logData.response.status = (response && response.statusCode) || 599;
+  logData.response.status = (response && (response.statusCode || response.status)) || 599;
   logData.response.headers = assign({}, (response && response.headers) || {});
 
   if (responseBody) {
@@ -375,6 +375,22 @@ function totalChunkLength(chunk1, chunk2) {
   return length1 + length2;
 }
 
+function ensureToString(id) {
+  if (typeof id === 'number') {
+    return String(id);
+  }
+  if (typeof id === 'string') {
+    return id;
+  }
+  if (id === null || id === undefined) {
+    return id;
+  }
+  if (typeof id === 'object') {
+    return String(id);
+  }
+  return id;
+}
+
 module.exports = {
   getUrlFromRequestOptions: _getUrlFromRequestOptions,
   getEventModelFromRequestAndResponse: _getEventModelFromRequestAndResponse,
@@ -388,4 +404,5 @@ module.exports = {
   appendChunk: appendChunk,
   computeBodySize: computeBodySize,
   totalChunkLength: totalChunkLength,
+  ensureToString: ensureToString,
 };

dist/governanceRulesManager.d.ts

@@ -10,28 +10,12 @@ var timeTookInSeconds = dataUtils.timeTookInSeconds;
 var safeJsonParse = dataUtils.safeJsonParse;
 var isJsonHeader = dataUtils.isJsonHeader;
 var computeBodySize = dataUtils.computeBodySize;
+var ensureToString = dataUtils.ensureToString;
 
 const TRANSACTION_ID_HEADER = 'x-moesif-transaction-id';
 
 var ensureValidLogData = ensureValidUtils.ensureValidLogData;
 
-function ensureToString(id) {
-  if (typeof id === 'number') {
-    return String(id);
-  }
-  if (typeof id === 'string') {
-    return id;
-  }
-  if (id === null || id === undefined) {
-    return id;
-  }
-  if (typeof id === 'object') {
-    return String(id);
-  }
-  return id;
-}
-
-
 function decodeHeaders(header) {
   try {
     var keyVal = header.split('\r\n');
@@ -159,9 +143,14 @@ function formatEventDataAndSave(responseBodyBuffer, req, res, options, saveEvent
   res._moHeaders = safeGetResponseHeaders(res);
   logData.response.headers = res._moHeaders;
   logData.response.time = res._endTime;
+  // if _mo_blocked_by not exist, it will be undefined anyways.
+  logData.blockedBy = res._mo_blocked_by;
 
   if (options.logBody) {
-    if (responseBodyBuffer) {
+    if (res._mo_blocked_by) {
+      // blocked body is always json
+      logData.body = res._mo_blocked_body;
+    } else if (responseBodyBuffer) {
       logMessage(options.debug, 'formatEventDataAndSave', 'processing responseBodyBuffer');
       if (responseBodyBuffer.length < options.responseMaxBodySize) {
         if (isJsonHeader(res) || startWithJson(responseBodyBuffer)) {