2018-01-04 23:15:21 +03:00
/ * *
* @ description MeshCentral Common Library
* @ author Ylian Saint - Hilaire
2022-01-24 10:21:24 +03:00
* @ copyright Intel Corporation 2018 - 2022
2018-01-04 23:15:21 +03:00
* @ license Apache - 2.0
* @ version v0 . 0.1
* /
2018-08-30 03:40:30 +03:00
/*xjslint node: true */
/*xjslint plusplus: true */
/*xjslint maxlen: 256 */
/*jshint node: true */
/*jshint strict: false */
/*jshint esversion: 6 */
2020-07-31 03:34:15 +03:00
'use strict' ;
2018-08-27 22:24:15 +03:00
2020-07-31 03:34:15 +03:00
const fs = require ( 'fs' ) ;
const crypto = require ( 'crypto' ) ;
2021-07-29 17:38:44 +03:00
const path = require ( 'path' ) ;
2017-08-28 19:27:45 +03:00
// Binary encoding and decoding functions
2018-08-30 03:40:30 +03:00
module . exports . ReadShort = function ( v , p ) { return ( v . charCodeAt ( p ) << 8 ) + v . charCodeAt ( p + 1 ) ; } ;
module . exports . ReadShortX = function ( v , p ) { return ( v . charCodeAt ( p + 1 ) << 8 ) + v . charCodeAt ( p ) ; } ;
module . exports . ReadInt = function ( v , p ) { return ( v . charCodeAt ( p ) * 0x1000000 ) + ( v . charCodeAt ( p + 1 ) << 16 ) + ( v . charCodeAt ( p + 2 ) << 8 ) + v . charCodeAt ( p + 3 ) ; } ; // We use "*0x1000000" instead of "<<24" because the shift converts the number to signed int32.
module . exports . ReadIntX = function ( v , p ) { return ( v . charCodeAt ( p + 3 ) * 0x1000000 ) + ( v . charCodeAt ( p + 2 ) << 16 ) + ( v . charCodeAt ( p + 1 ) << 8 ) + v . charCodeAt ( p ) ; } ;
module . exports . ShortToStr = function ( v ) { return String . fromCharCode ( ( v >> 8 ) & 0xFF , v & 0xFF ) ; } ;
module . exports . ShortToStrX = function ( v ) { return String . fromCharCode ( v & 0xFF , ( v >> 8 ) & 0xFF ) ; } ;
module . exports . IntToStr = function ( v ) { return String . fromCharCode ( ( v >> 24 ) & 0xFF , ( v >> 16 ) & 0xFF , ( v >> 8 ) & 0xFF , v & 0xFF ) ; } ;
module . exports . IntToStrX = function ( v ) { return String . fromCharCode ( v & 0xFF , ( v >> 8 ) & 0xFF , ( v >> 16 ) & 0xFF , ( v >> 24 ) & 0xFF ) ; } ;
2020-02-18 23:02:42 +03:00
module . exports . MakeToArray = function ( v ) { if ( ! v || v == null || typeof v == 'object' ) return v ; return [ v ] ; } ;
module . exports . SplitArray = function ( v ) { return v . split ( ',' ) ; } ;
2018-08-30 03:40:30 +03:00
module . exports . Clone = function ( v ) { return JSON . parse ( JSON . stringify ( v ) ) ; } ;
module . exports . IsFilenameValid = ( function ( ) { var x1 = /^[^\\/:\*\?"<>\|]+$/ , x2 = /^\./ , x3 = /^(nul|prn|con|lpt[0-9]|com[0-9])(\.|$)/i ; return function isFilenameValid ( fname ) { return module . exports . validateString ( fname , 1 , 4096 ) && x1 . test ( fname ) && ! x2 . test ( fname ) && ! x3 . test ( fname ) && ( fname [ 0 ] != '.' ) ; } ; } ) ( ) ;
2019-09-26 03:06:35 +03:00
module . exports . makeFilename = function ( v ) { return v . split ( '\\' ) . join ( '' ) . split ( '/' ) . join ( '' ) . split ( ':' ) . join ( '' ) . split ( '*' ) . join ( '' ) . split ( '?' ) . join ( '' ) . split ( '"' ) . join ( '' ) . split ( '<' ) . join ( '' ) . split ( '>' ) . join ( '' ) . split ( '|' ) . join ( '' ) . split ( ' ' ) . join ( '' ) . split ( '\'' ) . join ( '' ) ; }
2021-07-29 17:38:44 +03:00
module . exports . joinPath = function ( base , path _ ) { return path . isAbsolute ( path _ ) ? path _ : path . join ( base , path _ ) ; }
2017-08-28 19:27:45 +03:00
// Move an element from one position in an array to a new position
module . exports . ArrayElementMove = function ( arr , from , to ) { arr . splice ( to , 0 , arr . splice ( from , 1 ) [ 0 ] ) ; } ;
2019-10-30 02:17:29 +03:00
// Format a string with arguments, "replaces {0} and {1}..."
module . exports . format = function ( format ) { var args = Array . prototype . slice . call ( arguments , 1 ) ; return format . replace ( /{(\d+)}/g , function ( match , number ) { return typeof args [ number ] != 'undefined' ? args [ number ] : match ; } ) ; } ;
2017-08-28 19:27:45 +03:00
// Print object for HTML
2018-08-30 03:40:30 +03:00
module . exports . ObjectToStringEx = function ( x , c ) {
2020-07-31 03:34:15 +03:00
var r = '' , i ;
2017-08-28 19:27:45 +03:00
if ( x != 0 && ( ! x || x == null ) ) return "(Null)" ;
2018-08-30 03:40:30 +03:00
if ( x instanceof Array ) { for ( i in x ) { r += '<br />' + gap ( c ) + "Item #" + i + ": " + module . exports . ObjectToStringEx ( x [ i ] , c + 1 ) ; } }
else if ( x instanceof Object ) { for ( i in x ) { r += '<br />' + gap ( c ) + i + " = " + module . exports . ObjectToStringEx ( x [ i ] , c + 1 ) ; } }
2017-08-28 19:27:45 +03:00
else { r += x ; }
return r ;
2018-08-30 03:40:30 +03:00
} ;
2017-08-28 19:27:45 +03:00
// Print object for console
2018-08-30 03:40:30 +03:00
module . exports . ObjectToStringEx2 = function ( x , c ) {
2020-07-31 03:34:15 +03:00
var r = '' , i ;
2017-08-28 19:27:45 +03:00
if ( x != 0 && ( ! x || x == null ) ) return "(Null)" ;
2018-08-30 03:40:30 +03:00
if ( x instanceof Array ) { for ( i in x ) { r += '\r\n' + gap2 ( c ) + "Item #" + i + ": " + module . exports . ObjectToStringEx2 ( x [ i ] , c + 1 ) ; } }
else if ( x instanceof Object ) { for ( i in x ) { r += '\r\n' + gap2 ( c ) + i + " = " + module . exports . ObjectToStringEx2 ( x [ i ] , c + 1 ) ; } }
2017-08-28 19:27:45 +03:00
else { r += x ; }
return r ;
2018-08-30 03:40:30 +03:00
} ;
2017-08-28 19:27:45 +03:00
// Create an ident gap
2018-08-30 03:40:30 +03:00
module . exports . gap = function ( c ) { var x = '' ; for ( var i = 0 ; i < ( c * 4 ) ; i ++ ) { x += ' ' ; } return x ; } ;
module . exports . gap2 = function ( c ) { var x = '' ; for ( var i = 0 ; i < ( c * 4 ) ; i ++ ) { x += ' ' ; } return x ; } ;
2017-08-28 19:27:45 +03:00
// Print an object in html
2018-08-30 03:40:30 +03:00
module . exports . ObjectToString = function ( x ) { return module . exports . ObjectToStringEx ( x , 0 ) ; } ;
module . exports . ObjectToString2 = function ( x ) { return module . exports . ObjectToStringEx2 ( x , 0 ) ; } ;
2017-08-28 19:27:45 +03:00
// Convert a hex string to a raw string
2018-08-30 03:40:30 +03:00
module . exports . hex2rstr = function ( d ) {
2017-08-28 19:27:45 +03:00
var r = '' , m = ( '' + d ) . match ( /../g ) , t ;
2018-08-30 03:40:30 +03:00
while ( t = m . shift ( ) ) { r += String . fromCharCode ( '0x' + t ) ; }
return r ;
} ;
2017-08-28 19:27:45 +03:00
// Convert decimal to hex
2018-08-30 03:40:30 +03:00
module . exports . char2hex = function ( i ) { return ( i + 0x100 ) . toString ( 16 ) . substr ( - 2 ) . toUpperCase ( ) ; } ;
2017-08-28 19:27:45 +03:00
// Convert a raw string to a hex string
2018-08-30 03:40:30 +03:00
module . exports . rstr2hex = function ( input ) {
2017-08-28 19:27:45 +03:00
var r = '' , i ;
for ( i = 0 ; i < input . length ; i ++ ) { r += module . exports . char2hex ( input . charCodeAt ( i ) ) ; }
return r ;
2018-08-30 03:40:30 +03:00
} ;
2017-08-28 19:27:45 +03:00
// UTF-8 encoding & decoding functions
2018-08-30 03:40:30 +03:00
module . exports . encode _utf8 = function ( s ) { return unescape ( encodeURIComponent ( s ) ) ; } ;
module . exports . decode _utf8 = function ( s ) { return decodeURIComponent ( escape ( s ) ) ; } ;
2017-08-28 19:27:45 +03:00
// Convert a string into a blob
2018-08-30 03:40:30 +03:00
module . exports . data2blob = function ( data ) {
2017-08-28 19:27:45 +03:00
var bytes = new Array ( data . length ) ;
for ( var i = 0 ; i < data . length ; i ++ ) bytes [ i ] = data . charCodeAt ( i ) ;
var blob = new Blob ( [ new Uint8Array ( bytes ) ] ) ;
return blob ;
2018-08-30 03:40:30 +03:00
} ;
2017-08-28 19:27:45 +03:00
2021-02-09 05:23:29 +03:00
// Generate random numbers between 0 and max without bias.
module . exports . random = function ( max ) {
const crypto = require ( 'crypto' ) ;
var maxmask = 1 , r ;
while ( maxmask < max ) { maxmask = ( maxmask << 1 ) + 1 ; }
do { r = ( crypto . randomBytes ( 4 ) . readUInt32BE ( 0 ) & maxmask ) ; } while ( r > max ) ;
return r ;
} ;
2017-08-28 19:27:45 +03:00
2022-07-19 23:24:59 +03:00
// Split a comma separated string, ignoring commas in quotes.
2017-08-28 19:27:45 +03:00
module . exports . quoteSplit = function ( str ) {
var tmp = '' , quote = 0 , result = [ ] ;
for ( var i in str ) { if ( str [ i ] == '"' ) { quote = ( quote + 1 ) % 2 ; } if ( ( str [ i ] == ',' ) && ( quote == 0 ) ) { tmp = tmp . trim ( ) ; result . push ( tmp ) ; tmp = '' ; } else { tmp += str [ i ] ; } }
if ( tmp . length > 0 ) result . push ( tmp . trim ( ) ) ;
return result ;
2018-08-30 03:40:30 +03:00
} ;
2017-08-28 19:27:45 +03:00
// Convert list of "name = value" into object
module . exports . parseNameValueList = function ( list ) {
var result = [ ] ;
for ( var i in list ) {
var j = list [ i ] . indexOf ( '=' ) ;
if ( j > 0 ) {
var v = list [ i ] . substring ( j + 1 ) . trim ( ) ;
if ( ( v [ 0 ] == '"' ) && ( v [ v . length - 1 ] == '"' ) ) { v = v . substring ( 1 , v . length - 1 ) ; }
result [ list [ i ] . substring ( 0 , j ) . trim ( ) ] = v ;
}
}
return result ;
2018-08-30 03:40:30 +03:00
} ;
2017-08-28 19:27:45 +03:00
// Compute the MD5 digest hash for a set of values
module . exports . ComputeDigesthash = function ( username , password , realm , method , path , qop , nonce , nc , cnonce ) {
2020-02-18 23:02:42 +03:00
var ha1 = crypto . createHash ( 'md5' ) . update ( username + ":" + realm + ":" + password ) . digest ( 'hex' ) ;
var ha2 = crypto . createHash ( 'md5' ) . update ( method + ":" + path ) . digest ( 'hex' ) ;
2017-08-28 19:27:45 +03:00
return crypto . createHash ( 'md5' ) . update ( ha1 + ":" + nonce + ":" + nc + ":" + cnonce + ":" + qop + ":" + ha2 ) . digest ( "hex" ) ;
2018-08-30 03:40:30 +03:00
} ;
2017-08-28 19:27:45 +03:00
2018-08-30 03:40:30 +03:00
module . exports . toNumber = function ( str ) { var x = parseInt ( str ) ; if ( x == str ) return x ; return str ; } ;
module . exports . escapeHtml = function ( string ) { return String ( string ) . replace ( /[&<>"'`=\/]/g , function ( s ) { return { '&' : '&' , '<' : '<' , '>' : '>' , '"' : '"' , "'" : ''' , '/' : '/' , '`' : '`' , '=' : '=' } [ s ] ; } ) ; } ;
module . exports . escapeHtmlBreaks = function ( string ) { return String ( string ) . replace ( /[&<>"'`=\/]/g , function ( s ) { return { '&' : '&' , '<' : '<' , '>' : '>' , '"' : '"' , "'" : ''' , '/' : '/' , '`' : '`' , '=' : '=' , '\r' : '<br />' , '\n' : '' } [ s ] ; } ) ; } ;
2020-07-31 03:34:15 +03:00
module . exports . zeroPad = function ( num , c ) { if ( c == null ) { c = 2 ; } var s = '000000' + num ; return s . substr ( s . length - c ) ; }
2018-01-05 02:59:57 +03:00
// Lowercase all the names in a object recursively
2019-04-11 23:41:51 +03:00
// Allow for exception keys, child of exceptions will not get lower-cased.
2022-11-02 23:59:00 +03:00
// Exceptions is an array of "keyname" or "parent\keyname"
module . exports . objKeysToLower = function ( obj , exceptions , parent ) {
2018-01-05 02:59:57 +03:00
for ( var i in obj ) {
2022-11-04 21:50:42 +03:00
if ( ( typeof obj [ i ] == 'object' ) &&
( ( exceptions == null ) || ( exceptions . indexOf ( i . toLowerCase ( ) ) == - 1 ) && ( ( parent == null ) || ( exceptions . indexOf ( parent . toLowerCase ( ) + '/' + i . toLowerCase ( ) ) == - 1 ) ) )
) {
2022-11-02 23:59:00 +03:00
module . exports . objKeysToLower ( obj [ i ] , exceptions , i ) ; // LowerCase all key names in the child object
}
2019-05-27 21:58:31 +03:00
if ( i . toLowerCase ( ) !== i ) { obj [ i . toLowerCase ( ) ] = obj [ i ] ; delete obj [ i ] ; } // LowerCase all key names
2018-08-30 03:40:30 +03:00
}
2018-01-05 02:59:57 +03:00
return obj ;
2018-08-30 03:40:30 +03:00
} ;
2018-04-06 02:45:56 +03:00
2024-03-04 04:50:26 +03:00
// Escape and unescape field names so there are no invalid characters for MongoDB
2019-10-12 01:14:38 +03:00
module . exports . escapeFieldName = function ( name ) { if ( ( name . indexOf ( '%' ) == - 1 ) && ( name . indexOf ( '.' ) == - 1 ) && ( name . indexOf ( '$' ) == - 1 ) ) return name ; return name . split ( '%' ) . join ( '%25' ) . split ( '.' ) . join ( '%2E' ) . split ( '$' ) . join ( '%24' ) ; } ;
module . exports . unEscapeFieldName = function ( name ) { if ( name . indexOf ( '%' ) == - 1 ) return name ; return name . split ( '%2E' ) . join ( '.' ) . split ( '%24' ) . join ( '$' ) . split ( '%25' ) . join ( '%' ) ; } ;
2018-07-14 05:18:43 +03:00
2024-03-03 22:13:16 +03:00
// Escape all links, SSH and RDP usernames
2024-03-04 04:50:26 +03:00
// This is required for databases like NeDB that don't accept "." as part of a field name.
2024-03-03 22:13:16 +03:00
module . exports . escapeLinksFieldNameEx = function ( docx ) { if ( ( docx . links == null ) && ( docx . ssh == null ) && ( docx . rdp == null ) ) { return docx ; } return module . exports . escapeLinksFieldName ( docx ) ; } ;
module . exports . escapeLinksFieldName = function ( docx ) {
var doc = Object . assign ( { } , docx ) ;
if ( doc . links != null ) { doc . links = Object . assign ( { } , doc . links ) ; for ( var i in doc . links ) { var ue = module . exports . escapeFieldName ( i ) ; if ( ue !== i ) { doc . links [ ue ] = doc . links [ i ] ; delete doc . links [ i ] ; } } }
if ( doc . ssh != null ) { doc . ssh = Object . assign ( { } , doc . ssh ) ; for ( var i in doc . ssh ) { var ue = module . exports . escapeFieldName ( i ) ; if ( ue !== i ) { doc . ssh [ ue ] = doc . ssh [ i ] ; delete doc . ssh [ i ] ; } } }
if ( doc . rdp != null ) { doc . rdp = Object . assign ( { } , doc . rdp ) ; for ( var i in doc . rdp ) { var ue = module . exports . escapeFieldName ( i ) ; if ( ue !== i ) { doc . rdp [ ue ] = doc . rdp [ i ] ; delete doc . rdp [ i ] ; } } }
return doc ;
} ;
module . exports . unEscapeLinksFieldName = function ( doc ) {
if ( doc . links != null ) { for ( var j in doc . links ) { var ue = module . exports . unEscapeFieldName ( j ) ; if ( ue !== j ) { doc . links [ ue ] = doc . links [ j ] ; delete doc . links [ j ] ; } } }
if ( doc . ssh != null ) { for ( var j in doc . ssh ) { var ue = module . exports . unEscapeFieldName ( j ) ; if ( ue !== j ) { doc . ssh [ ue ] = doc . ssh [ j ] ; delete doc . ssh [ j ] ; } } }
if ( doc . rdp != null ) { for ( var j in doc . rdp ) { var ue = module . exports . unEscapeFieldName ( j ) ; if ( ue !== j ) { doc . rdp [ ue ] = doc . rdp [ j ] ; delete doc . rdp [ j ] ; } } }
return doc ;
} ;
2019-12-30 09:38:53 +03:00
//module.exports.escapeAllLinksFieldName = function (docs) { for (var i in docs) { module.exports.escapeLinksFieldName(docs[i]); } return docs; };
module . exports . unEscapeAllLinksFieldName = function ( docs ) { for ( var i in docs ) { docs [ i ] = module . exports . unEscapeLinksFieldName ( docs [ i ] ) ; } return docs ; } ;
2018-07-14 05:18:43 +03:00
2022-08-14 04:32:17 +03:00
// Escape field names for aceBase
var aceEscFields = [ 'links' , 'ssh' , 'rdp' , 'notify' ] ;
module . exports . aceEscapeFieldNames = function ( docx ) { var doc = Object . assign ( { } , docx ) ; for ( var k in aceEscFields ) { if ( typeof doc [ aceEscFields [ k ] ] == 'object' ) { doc [ aceEscFields [ k ] ] = Object . assign ( { } , doc [ aceEscFields [ k ] ] ) ; for ( var i in doc [ aceEscFields [ k ] ] ) { var ue = encodeURIComponent ( i ) ; if ( ue !== i ) { doc [ aceEscFields [ k ] ] [ ue ] = doc [ aceEscFields [ k ] ] [ i ] ; delete doc [ aceEscFields [ k ] ] [ i ] ; } } } } return doc ; } ;
module . exports . aceUnEscapeFieldNames = function ( doc ) { for ( var k in aceEscFields ) { if ( typeof doc [ aceEscFields [ k ] ] == 'object' ) { for ( var j in doc [ aceEscFields [ k ] ] ) { var ue = decodeURIComponent ( j ) ; if ( ue !== j ) { doc [ aceEscFields [ k ] ] [ ue ] = doc [ aceEscFields [ k ] ] [ j ] ; delete doc [ aceEscFields [ k ] ] [ j ] ; } } } } return doc ; } ;
module . exports . aceUnEscapeAllFieldNames = function ( docs ) { for ( var i in docs ) { docs [ i ] = module . exports . aceUnEscapeFieldNames ( docs [ i ] ) ; } return docs ; } ;
2018-04-06 02:45:56 +03:00
// Validation methods
2018-08-30 03:40:30 +03:00
module . exports . validateString = function ( str , minlen , maxlen ) { return ( ( str != null ) && ( typeof str == 'string' ) && ( ( minlen == null ) || ( str . length >= minlen ) ) && ( ( maxlen == null ) || ( str . length <= maxlen ) ) ) ; } ;
module . exports . validateInt = function ( int , minval , maxval ) { return ( ( int != null ) && ( typeof int == 'number' ) && ( ( minval == null ) || ( int >= minval ) ) && ( ( maxval == null ) || ( int <= maxval ) ) ) ; } ;
module . exports . validateArray = function ( array , minlen , maxlen ) { return ( ( array != null ) && Array . isArray ( array ) && ( ( minlen == null ) || ( array . length >= minlen ) ) && ( ( maxlen == null ) || ( array . length <= maxlen ) ) ) ; } ;
2020-06-21 11:45:24 +03:00
module . exports . validateStrArray = function ( array , minlen , maxlen ) { if ( ( ( array != null ) && Array . isArray ( array ) ) == false ) return false ; for ( var i in array ) { if ( ( typeof array [ i ] != 'string' ) || ( ( minlen != null ) && ( array [ i ] . length < minlen ) ) || ( ( maxlen != null ) && ( array [ i ] . length > maxlen ) ) ) return false ; } return true ; } ;
2018-08-30 03:40:30 +03:00
module . exports . validateObject = function ( obj ) { return ( ( obj != null ) && ( typeof obj == 'object' ) ) ; } ;
2018-10-17 00:51:54 +03:00
module . exports . validateEmail = function ( email , minlen , maxlen ) { if ( module . exports . validateString ( email , minlen , maxlen ) == false ) return false ; var emailReg = /^(([^<>()\[\]\\.,;:\s@"]+(\.[^<>()\[\]\\.,;:\s@"]+)*)|(".+"))@((\[[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}])|(([a-zA-Z\-0-9]+\.)+[a-zA-Z]{2,}))$/ ; return emailReg . test ( email ) ; } ;
2019-05-30 22:40:10 +03:00
module . exports . validateUsername = function ( username , minlen , maxlen ) { return ( module . exports . validateString ( username , minlen , maxlen ) && ( username . indexOf ( ' ' ) == - 1 ) && ( username . indexOf ( '"' ) == - 1 ) && ( username . indexOf ( ',' ) == - 1 ) ) ; } ;
2020-06-21 11:45:24 +03:00
module . exports . isAlphaNumeric = function ( str ) { return ( str . match ( /^[A-Za-z0-9]+$/ ) != null ) ; } ;
module . exports . validateAlphaNumericArray = function ( array , minlen , maxlen ) { if ( ( ( array != null ) && Array . isArray ( array ) ) == false ) return false ; for ( var i in array ) { if ( ( typeof array [ i ] != 'string' ) || ( module . exports . isAlphaNumeric ( array [ i ] ) == false ) || ( ( minlen != null ) && ( array [ i ] . length < minlen ) ) || ( ( maxlen != null ) && ( array [ i ] . length > maxlen ) ) ) return false ; } return true ; } ;
2022-03-16 08:11:34 +03:00
module . exports . getEmailDomain = function ( email ) {
if ( ! module . exports . validateEmail ( email , 1 , 1024 ) ) {
return '' ;
}
const i = email . indexOf ( '@' ) ;
return email . substring ( i + 1 ) . toLowerCase ( ) ;
}
module . exports . validateEmailDomain = function ( email , allowedDomains ) {
// Check if this request is for an allows email domain
if ( ( allowedDomains != null ) && Array . isArray ( allowedDomains ) ) {
const emaildomain = module . exports . getEmailDomain ( email ) ;
if ( emaildomain === '' ) {
return false ;
}
var emailok = false ;
for ( var i in allowedDomains ) { if ( emaildomain == allowedDomains [ i ] . toLowerCase ( ) ) { emailok = true ; } }
return emailok ;
}
2018-12-21 01:14:37 +03:00
2022-03-16 08:11:34 +03:00
return true ;
}
2018-12-21 01:14:37 +03:00
// Check password requirements
module . exports . checkPasswordRequirements = function ( password , requirements ) {
if ( ( requirements == null ) || ( requirements == '' ) || ( typeof requirements != 'object' ) ) return true ;
if ( requirements . min ) { if ( password . length < requirements . min ) return false ; }
if ( requirements . max ) { if ( password . length > requirements . max ) return false ; }
2020-05-02 09:53:32 +03:00
var numeric = 0 , lower = 0 , upper = 0 , nonalpha = 0 ;
2018-12-21 01:14:37 +03:00
for ( var i = 0 ; i < password . length ; i ++ ) {
2020-05-02 09:53:32 +03:00
if ( /\d/ . test ( password [ i ] ) ) { numeric ++ ; }
2018-12-21 01:14:37 +03:00
if ( /[a-z]/ . test ( password [ i ] ) ) { lower ++ ; }
if ( /[A-Z]/ . test ( password [ i ] ) ) { upper ++ ; }
if ( /\W/ . test ( password [ i ] ) ) { nonalpha ++ ; }
}
2020-05-02 09:53:32 +03:00
if ( requirements . numeric && ( numeric < requirements . numeric ) ) return false ;
2018-12-21 01:14:37 +03:00
if ( requirements . lower && ( lower < requirements . lower ) ) return false ;
if ( requirements . upper && ( upper < requirements . upper ) ) return false ;
if ( requirements . nonalpha && ( nonalpha < requirements . nonalpha ) ) return false ;
return true ;
2019-01-05 23:04:18 +03:00
}
2019-01-29 02:47:54 +03:00
// Limits the number of tasks running to a fixed limit placing the rest in a pending queue.
// This is useful to limit the number of agents upgrading at the same time, to not swamp
// the network with traffic.
2019-02-09 01:17:35 +03:00
module . exports . createTaskLimiterQueue = function ( maxTasks , maxTaskTime , cleaningInterval ) {
var obj = { maxTasks : maxTasks , maxTaskTime : ( maxTaskTime * 1000 ) , nextTaskId : 0 , currentCount : 0 , current : { } , pending : [ [ ] , [ ] , [ ] ] , timer : null } ;
2019-01-29 02:47:54 +03:00
// Add a task to the super queue
2019-02-09 01:17:35 +03:00
// Priority: 0 = High, 1 = Medium, 2 = Low
obj . launch = function ( func , arg , pri ) {
if ( typeof pri != 'number' ) { pri = 2 ; }
2019-01-29 02:47:54 +03:00
if ( obj . currentCount < obj . maxTasks ) {
// Run this task now
const id = obj . nextTaskId ++ ;
obj . current [ id ] = Date . now ( ) + obj . maxTaskTime ;
obj . currentCount ++ ;
//console.log('ImmidiateLaunch ' + id);
func ( arg , id , obj ) ; // Start the task
if ( obj . timer == null ) { obj . timer = setInterval ( obj . clean , cleaningInterval * 1000 ) ; }
} else {
// Hold this task
//console.log('Holding');
2019-02-09 01:17:35 +03:00
obj . pending [ pri ] . push ( { func : func , arg : arg } ) ;
2019-01-29 02:47:54 +03:00
}
}
// Called when a task is completed
obj . completed = function ( taskid ) {
//console.log('Completed ' + taskid);
if ( obj . current [ taskid ] ) { delete obj . current [ taskid ] ; obj . currentCount -- ; } else { return ; }
2019-02-09 01:17:35 +03:00
while ( ( obj . currentCount < obj . maxTasks ) && ( ( obj . pending [ 0 ] . length > 0 ) || ( obj . pending [ 1 ] . length > 0 ) || ( obj . pending [ 2 ] . length > 0 ) ) ) {
2019-01-29 02:47:54 +03:00
// Run this task now
2019-02-09 01:17:35 +03:00
var t = null ;
if ( obj . pending [ 0 ] . length > 0 ) { t = obj . pending [ 0 ] . shift ( ) ; }
else if ( obj . pending [ 1 ] . length > 0 ) { t = obj . pending [ 1 ] . shift ( ) ; }
else if ( obj . pending [ 2 ] . length > 0 ) { t = obj . pending [ 2 ] . shift ( ) ; }
const id = obj . nextTaskId ++ ;
2019-01-29 02:47:54 +03:00
obj . current [ id ] = Date . now ( ) + obj . maxTaskTime ;
obj . currentCount ++ ;
//console.log('PendingLaunch ' + id);
t . func ( t . arg , id , obj ) ; // Start the task
}
2019-02-26 01:35:08 +03:00
if ( ( obj . currentCount == 0 ) && ( obj . pending [ 0 ] . length == 0 ) && ( obj . pending [ 1 ] . length == 0 ) && ( obj . pending [ 2 ] . length == 0 ) && ( obj . timer != null ) ) {
2019-02-09 01:17:35 +03:00
// All done, clear the timer
clearInterval ( obj . timer ) ; obj . timer = null ;
}
2019-01-29 02:47:54 +03:00
}
// Look for long standing tasks and clean them up
obj . clean = function ( ) {
const t = Date . now ( ) ;
for ( var i in obj . current ) { if ( obj . current [ i ] < t ) { obj . completed ( parseInt ( i ) ) ; } }
}
return obj ;
2019-02-09 01:17:35 +03:00
}
2020-01-08 02:10:12 +03:00
// Convert string translations to a standardized JSON we can use in GitHub
// Strings are sorder by english source and object keys are sorted
module . exports . translationsToJson = function ( t ) {
var arr2 = [ ] , arr = t . strings ;
for ( var i in arr ) {
var names = [ ] , el = arr [ i ] , el2 = { } ;
for ( var j in el ) { names . push ( j ) ; }
2020-03-22 23:33:21 +03:00
names . sort ( function ( a , b ) { if ( a == b ) { return 0 ; } if ( a == 'xloc' ) { return 1 ; } if ( b == 'xloc' ) { return - 1 ; } return a - b } ) ;
2020-01-08 02:10:12 +03:00
for ( var j in names ) { el2 [ names [ j ] ] = el [ names [ j ] ] ; }
2020-01-08 04:12:09 +03:00
if ( el2 . xloc != null ) { el2 . xloc . sort ( ) ; }
2020-01-08 02:10:12 +03:00
arr2 . push ( el2 ) ;
}
arr2 . sort ( function ( a , b ) { if ( a . en > b . en ) return 1 ; if ( a . en < b . en ) return - 1 ; return 0 ; } ) ;
return JSON . stringify ( { strings : arr2 } , null , ' ' ) ;
2020-02-01 01:44:11 +03:00
}
module . exports . copyFile = function ( source , target , cb ) {
var cbCalled = false , rd = fs . createReadStream ( source ) ;
rd . on ( 'error' , function ( err ) { done ( err ) ; } ) ;
var wr = fs . createWriteStream ( target ) ;
wr . on ( 'error' , function ( err ) { done ( err ) ; } ) ;
wr . on ( 'close' , function ( ex ) { done ( ) ; } ) ;
rd . pipe ( wr ) ;
function done ( err ) { if ( ! cbCalled ) { cb ( err ) ; cbCalled = true ; } }
2020-05-29 04:04:30 +03:00
}
module . exports . meshServerRightsArrayToNumber = function ( val ) {
if ( val == null ) return null ;
if ( typeof val == 'number' ) return val ;
if ( Array . isArray ( val ) ) {
var newAccRights = 0 ;
for ( var j in val ) {
var r = val [ j ] . toLowerCase ( ) ;
if ( r == 'fulladmin' ) { newAccRights = 4294967295 ; } // 0xFFFFFFFF
if ( r == 'serverbackup' ) { newAccRights |= 1 ; }
if ( r == 'manageusers' ) { newAccRights |= 2 ; }
if ( r == 'serverrestore' ) { newAccRights |= 4 ; }
if ( r == 'fileaccess' ) { newAccRights |= 8 ; }
if ( r == 'serverupdate' ) { newAccRights |= 16 ; }
if ( r == 'locked' ) { newAccRights |= 32 ; }
if ( r == 'nonewgroups' ) { newAccRights |= 64 ; }
if ( r == 'notools' ) { newAccRights |= 128 ; }
2024-04-09 15:31:00 +03:00
if ( r == 'usergroups' ) { newAccRights |= 256 ; }
if ( r == 'recordings' ) { newAccRights |= 512 ; }
if ( r == 'locksettings' ) { newAccRights |= 1024 ; }
if ( r == 'allevents' ) { newAccRights |= 2048 ; }
if ( r == 'nonewdevices' ) { newAccRights |= 4096 ; }
2020-05-29 04:04:30 +03:00
}
return newAccRights ;
}
return null ;
2021-03-01 10:39:50 +03:00
}
2021-04-04 04:29:02 +03:00
// Sort an object by key
module . exports . sortObj = function ( obj ) { return Object . keys ( obj ) . sort ( ) . reduce ( function ( result , key ) { result [ key ] = obj [ key ] ; return result ; } , { } ) ; }
2021-03-01 10:39:50 +03:00
// Validate an object to make sure it can be stored in MongoDB
module . exports . validateObjectForMongo = function ( obj , maxStrLen ) {
return validateObjectForMongoRec ( obj , maxStrLen ) ;
}
function validateObjectForMongoRec ( obj , maxStrLen ) {
if ( typeof obj != 'object' ) return false ;
for ( var i in obj ) {
// Check the key name is not too long
if ( i . length > 100 ) return false ;
// Check if all chars are alpha-numeric or underscore.
for ( var j in i ) { const c = i . charCodeAt ( j ) ; if ( ( c < 48 ) || ( ( c > 57 ) && ( c < 65 ) ) || ( ( c > 90 ) && ( c < 97 ) && ( c != 95 ) ) || ( c > 122 ) ) return false ; }
// If the value is a string, check it's not too long
if ( ( typeof obj [ i ] == 'string' ) && ( obj [ i ] . length > maxStrLen ) ) return false ;
// If the value is an object, check it.
if ( ( typeof obj [ i ] == 'object' ) && ( Array . isArray ( obj [ i ] ) == false ) && ( validateObjectForMongoRec ( obj [ i ] , maxStrLen ) == false ) ) return false ;
}
return true ;
2021-07-29 17:38:44 +03:00
}
2022-08-04 11:47:36 +03:00
// Parse a version string of the type n.n.n.n
module . exports . parseVersion = function ( verstr ) {
if ( typeof verstr != 'string' ) return null ;
const r = [ ] , verstrsplit = verstr . split ( '.' ) ;
if ( verstrsplit . length != 4 ) return null ;
for ( var i in verstrsplit ) {
var n = parseInt ( verstrsplit [ i ] ) ;
if ( isNaN ( n ) || ( n < 0 ) || ( n > 65535 ) ) return null ;
r . push ( n ) ;
}
return r ;
}
2022-08-27 00:19:28 +03:00
// Move old files. If we are about to overwrite a file, we can move if first just in case the change needs to be reverted
module . exports . moveOldFiles = function ( filelist ) {
// Fine an old extension that works for all files in the file list
var oldFileExt , oldFileExtCount = 0 , extOk ;
do {
extOk = true ;
if ( ++ oldFileExtCount == 1 ) { oldFileExt = '-old' ; } else { oldFileExt = '-old' + oldFileExtCount ; }
for ( var i in filelist ) { if ( fs . existsSync ( filelist [ i ] + oldFileExt ) == true ) { extOk = false ; } }
} while ( extOk == false ) ;
for ( var i in filelist ) { try { fs . renameSync ( filelist [ i ] , filelist [ i ] + oldFileExt ) ; } catch ( ex ) { } }
2024-03-04 03:03:27 +03:00
}
// Convert strArray to Array, returns array if strArray or null if any other type
module . exports . convertStrArray = function ( object , split ) {
if ( split && typeof object === 'string' ) {
return object . split ( split )
} else if ( typeof object === 'string' ) {
return Array ( object ) ;
} else if ( Array . isArray ( object ) ) {
return object
} else {
return [ ]
}
2024-06-11 22:06:19 +03:00
}
module . exports . uniqueArray = function ( a ) {
var seen = { } ;
var out = [ ] ;
var len = a . length ;
var j = 0 ;
for ( var i = 0 ; i < len ; i ++ ) {
var item = a [ i ] ;
if ( seen [ item ] !== 1 ) {
seen [ item ] = 1 ;
out [ j ++ ] = item ;
}
}
return out ;
2022-08-27 00:19:28 +03:00
}