Source: utils.js

  1. /**
  2.  * @namespace utils
  3.  * @description Common utils module
  4.  * @author Andrew D.Laptev <a.d.laptev@gmail.com>
  5.  * @licence MIT
  6.  */
  8. const xml2js = require('xml2js'),
  9. 	numberRE = /^-?([1-9]\d*|0)(\.\d*)?$/,
  10. 	dateRE = /^\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}(.\d+)?Z$/,
  11. 	prefixMatch = /(?!xmlns)^.*:/;
  13. /**
  14.  * Parse SOAP object to pretty JS-object
  15.  * @param {object} xml
  16.  * @returns {object}
  17.  */
  18. const linerase = function(xml) {
  19. 	if (Array.isArray(xml)) {
  20. 		if (xml.length > 1) {
  21. 			return xml.map(linerase);
  22. 		} else {
  23. 			xml = xml[0];
  24. 		}
  25. 	}
  26. 	if (typeof xml === 'object') {
  27. 		var obj = {};
  28. 		Object.keys(xml).forEach(function(key) {
  29. 			obj[key] = linerase(xml[key]);
  30. 		});
  31. 		return obj;
  32. 	} else {
  33. 		if (xml === 'true') { return true; }
  34. 		if (xml === 'false') { return false; }
  35. 		if (numberRE.test(xml)) { return parseFloat(xml); }
  36. 		if (dateRE.test(xml)) { return new Date(xml); }
  37. 		return xml;
  38. 	}
  39. };
  41. /**
  42.  * @callback ParseSOAPStringCallback
  43.  * @property {?Error} error
  44.  * @property {object} SOAP response
  45.  * @property {string} raw XML
  46.  * @property {number} HTTP Status Code
  47.  */
  49. /**
  50.  * Parse SOAP response
  51.  * @param {string} xml
  52.  * @param {ParseSOAPStringCallback} callback
  53.  * @param {number} statusCode. This is passed in so it can be passed back out to the callback
  54.  */
  55. const parseSOAPString = function(xml, callback, statusCode) {
  56. 	/* Filter out xml name spaces */
  57. 	xml = xml.replace(/xmlns([^=]*?)=(".*?")/g, '');
  59. 	try {
  60. 		xml2js.parseString(
  61. 			xml, {
  62. 				tagNameProcessors: [function(str) {
  63. 					str = str.replace(prefixMatch, '');
  64. 					var secondLetter = str.charAt(1);
  65. 					if (secondLetter && secondLetter.toUpperCase() !== secondLetter) {
  66. 						return str.charAt(0).toLowerCase() + str.slice(1);
  67. 					} else {
  68. 						return str;
  69. 					}
  70. 				}]
  71. 			},
  72. 			function(err, result) {
  73. 				if (!result || !result['envelope'] || !result['envelope']['body']) {
  74. 					callback(new Error('Wrong ONVIF SOAP response'), null, xml, statusCode);
  75. 				} else {
  76. 					if (!err && result['envelope']['body'][0]['fault']) {
  77. 						var fault = result['envelope']['body'][0]['fault'][0];
  78. 						var reason;
  79. 						try {
  80. 							if (fault.reason[0].text[0]._) {
  81. 								reason = fault.reason[0].text[0]._;
  82. 							}
  83. 						} catch (e) {
  84. 							reason = '';
  85. 						}
  86. 						if (!reason) {
  87. 							try {
  88. 								reason = JSON.stringify(linerase(fault.code[0]));
  89. 							} catch (e) {
  90. 								reason = '';
  91. 							}
  92. 						}
  93. 						var detail = '';
  94. 						try {
  95. 							detail = fault.detail[0].text[0];
  96. 						} catch (e) {
  97. 							detail = '';
  98. 						}
  100. 						// console.error('Fault:', reason, detail);
  101. 						err = new Error('ONVIF SOAP Fault: ' + (reason) + (detail));
  102. 					}
  103. 					callback(err, result['envelope']['body'], xml, statusCode);
  104. 				}
  105. 			}
  106. 		);
  107. 	} catch (err) {
  108. 		callback(err, '', xml, statusCode);
  109. 	}
  110. };
  112. const s4 = function() {
  113. 	return (((1 + Math.random()) * 0x10000) | 0).toString(16).substring(1);
  114. };
  116. /**
  117.  * Generate GUID
  118.  * @returns {string}
  119.  */
  120. const guid = function() {
  121. 	return (s4() + s4() + '-' + s4() + '-' + s4() + '-' + s4() + '-' + s4() + s4() + s4());
  122. };
  124. module.exports = {
  125. 	linerase: linerase,
  126. 	parseSOAPString: parseSOAPString,
  127. 	guid: guid
  128. };