} */\r\n this.shutdownBackend = null;\r\n /** @type {bp.Server} */\r\n // @ts-ignore\r\n this.server = null;\r\n }\r\n esJavascript(type){\r\n return ['js','mjs'].includes(type)\r\n }\r\n clearCaches(){\r\n this.caches={\r\n procedures:{}\r\n }\r\n }\r\n}\r\nAppBackend.prototype.configStaticConfig = function configStaticConfig(){\r\n this.setStaticConfig(`\r\n login:\r\n unloggedLandPage: /not-logged-in\r\n plus:\r\n successRedirect: /menu\r\n successReturns: true\r\n store: {}\r\n loginForm:\r\n autoLogin: true\r\n chPassUrlPath: /chpass\r\n activeClausule: true\r\n lockedClausule: false\r\n keepAlive: 1800\r\n data:\r\n transformers:\r\n text: keepAll\r\n db:\r\n motor: postgresql\r\n min-version: 12\r\n fkOnUpdate: cascade\r\n max: 50\r\n log: \r\n db:\r\n until: 2001-01-01 00:00\r\n last-error: false\r\n on-demand: false\r\n server:\r\n base-url: ''\r\n bitacoraSchema: his\r\n bitacoraTableName: bitacora\r\n skins:\r\n \"\":\r\n local-path: for-client\r\n bin: {}\r\n client-setup: \r\n skin: \"\"\r\n lang: en\r\n version: 1.0\r\n inherit-fields-mode: display-fk\r\n install:\r\n dump:\r\n db:\r\n host: localhost\r\n extensions: []\r\n scripts:\r\n parts-order: []\r\n post-adapt: []\r\n devel:\r\n delay: false\r\n imports:\r\n allow-plain-xls: false\r\n `);\r\n}\r\nAppBackend.exposes={};\r\nAppBackend.prototype.i18n={messages:{}};\r\n\r\nAppBackend.prototype.messages=\r\nAppBackend.prototype.i18n.messages.en={\r\n unlogged:{\r\n login:{\r\n title: \"log in\",\r\n username: \"username\",\r\n password: \"password\",\r\n button: \"Sign In\",\r\n forget: \"Forgot your password?\",\r\n userOrPassFail: \"username or password error\",\r\n lockedFail: \"user account is locked\",\r\n inactiveFail: \"user account is marked as inactive\",\r\n internalError: \"internal error\",\r\n passTooShort: \"pass too short (minimum length $1)\",\r\n passDoesntMatch: \"pass doesn't match\"\r\n },\r\n newPassword:{\r\n button: \"Reset password\",\r\n email: \"Email\",\r\n invalidMail: \"invalid email\",\r\n mailSubject: \"Password Reset Request\",\r\n mailHtml: `You told us you forgot your password. If you really did, click here to choose a new one:
\r\n
\r\n If you didn’t mean to reset your password, then you can just ignore this email; your password will not change.
`,\r\n mayBeMailSent: \"Mail sent if found.\",\r\n return: \"I know my password. Go to login.\",\r\n title: \"Forgot password form\",\r\n },\r\n loading:'loading',\r\n },\r\n logged:{\r\n login:{\r\n title: \"log in\",\r\n username: \"username\",\r\n password: \"password\",\r\n button: \"Sign In\"\r\n },\r\n chpass:{\r\n title: 'change password',\r\n username: 'Username',\r\n oldPassword:'Old password',\r\n newPassword:'New password',\r\n repPassword:'Reenter password',\r\n button:'Change',\r\n cancel: 'Cancel'\r\n },\r\n fileUploaded:'file uploaded',\r\n unkownExt:'unkown file extension'\r\n },\r\n server:{\r\n backupNotAvailable: 'Backup not available',\r\n backupReady: 'Backup ready to download',\r\n backupZipping: 'Zipping backup file',\r\n badBackupEncryptKey: 'encrypt key not present or less than 10 characters',\r\n cantDelete_TLDR:'Can\\'t delete. May be rights problems, locked records or internal problems',\r\n cantInsert_TLDR:'Can\\'t insert. May be rights problems, locked records or internal problems',\r\n cantUpdate_TLDR:'Can\\'t update. May be rights problems, locked records or internal problems',\r\n checkingConstraints:'checking constraints',\r\n cellOfA1DoesNotExists:'cell of A1 does not exists',\r\n columnDoesNotExistInTable:'column $1 does not exist in table',\r\n dbMinVersionFail:'database min version $2 fail. Actual version $1',\r\n deleted:'deleted',\r\n deleting:'deleting',\r\n dependences:'dependences',\r\n ErrorCheckDatabaseStructure:'ERROR checkDatabaseStructure fail in startup',\r\n fileReaded:'file readed',\r\n files:'files',\r\n importColumnDoesNotHasColumnName:'column $1 does not has a string value',\r\n insertingRows:'inserting rows',\r\n lackOfBackendPlusInImport:'lack of #backend-plus signal in A1 or imports.allow-plain-xls in local-config',\r\n line:'line',\r\n missingPrimaryKeyValues:'missing primary key values',\r\n noMailerConfig:'not mailer configurated',\r\n notInputCuidado:'The uploaded file is not a \"#cuidado\" file',\r\n notLoggedIn:'not logged in',\r\n oldPassDontMatch:'old password does not matchs or username is not longer valid or token is invalid',\r\n passChangedSuccesfully: 'password was changed successfully',\r\n passDontMatch:'passwords does not matchs or password is not long enough',\r\n prefilledField1IsInConflictWithImportedField:'Prefilled field \"$1\" is in conclict with imported field',\r\n primarKeyCantBeNull4:'error at line $1. Primary key field \"$2\" can not be #NULL',\r\n spreadsheetProcessed:'spread sheet processed',\r\n unkownHashValue4Import:'unknown # code in value import',\r\n updateWithoutModfiedColumns:'update without modified columns',\r\n updatingDb:'updating database',\r\n versions:'versions',\r\n }\r\n};\r\n\r\nAppBackend.prototype.i18n.messages.es={\r\n unlogged:{\r\n login:{\r\n title: \"entrada\",\r\n username: \"usuario\",\r\n password: \"clave\",\r\n button: \"Entrar\",\r\n forget: \"me olvidé la clave / es mi primer ingreso\",\r\n userOrPassFail: \"usuario o clave incorrecta\",\r\n lockedFail: \"usuario bloqueado\",\r\n inactiveFail: \"el usuario está marcado como inactivo\",\r\n internalError: \"error interno en login\",\r\n passTooShort: \"la clave es demasiado corta (el mínimo es $1)\",\r\n passDoesntMatch: \"las claves no coinciden\"\r\n },\r\n newPassword:{\r\n button: \"Obtener una nueva contraseña\",\r\n email: \"e-mail\",\r\n invalidMail: \"la dirección de mail es incorrecta\",\r\n mailSubject: \"Solicitud de cambio de contraseña\",\r\n mailHtml: `Hemos recibido una solicitud para restablecer la contraseña de su cuenta. Si usted realizó esta petición, por favor, haga clic en el siguiente enlace para crear una nueva contraseña:
\r\n
\r\n Si usted no solicitó este cambio, puede ignorar este correo electrónico. Su contraseña actual permanecerá sin modificaciones.
`,\r\n mayBeMailSent: \"Se procede a buscar el usuario correspondiente al email. Si se encuentra se envia al mismo un correo que permite cambiar la contraseña. Si envió más de un formulario solo el último es válido.\",\r\n return: \"Recuerdo mi contraseña. Ir a la pantalla de ingreso.\",\r\n title: \"Formulario de recuperación de contraseña\",\r\n },\r\n loading:'cargando',\r\n },\r\n logged:{\r\n chpass:{\r\n title: 'cambio de clave',\r\n username: 'usuario',\r\n oldPassword:'clave anterior',\r\n newPassword:'nueva clave',\r\n repPassword:'repetir nueva clave',\r\n button:'Cambiar',\r\n cancel: 'Cancelar'\r\n },\r\n fileUploaded:'archivo subido',\r\n unkownExt:'extensión de archivo desconocida'\r\n },\r\n server:{\r\n backupNotAvailable: 'Backup no disponible',\r\n backupReady: 'Archivo listo para bajar',\r\n backupZipping: 'Compactando el backup',\r\n badBackupEncryptKey: 'Debe proveer una clave de encriptacion de 10 caracteres o mas para encriptar el archivo de destino',\r\n cantDelete_TLDR:'no se pudo eliminar el registro. Podrían haber problemas de persmisos, bloqueo de registros o problemas internos en la definición de la PK',\r\n cantInsert_TLDR:'no se pudo insertar el registro. Podrían haber problemas de persmisos, bloqueo de registros o problemas internos en la definición de la PK',\r\n cantUpdate_TLDR:'no se pudo modificar el registro. Podrían haber problemas de persmisos, bloqueo de registros o problemas internos en la definición de la PK',\r\n checkingConstraints:'verificando las restricciones',\r\n cellOfA1DoesNotExists:'no hay valor en la celda A1',\r\n columnDoesNotExistInTable:'la columna $1 no existe en la tabla',\r\n dbMinVersionFail:'La versión actual de la base de datos es $1, pero debe ser como mínimo $2',\r\n deleted:'borrado',\r\n deleting:'borrando',\r\n dependences:'dependencias',\r\n ErrorCheckDatabaseStructure:'ERROR en checkDatabaseStructure. Falló al controlar la estructura de la base de datos',\r\n fileReaded:'archivo leído',\r\n files:'archivos',\r\n importColumnDoesNotHasStringValue:'la columna $1 no valor de texto',\r\n insertingRows:'insertando registros',\r\n lackOfBackendPlusInImport:'falta la señal #backend-plus en la celda A1 o la opción imports.allow-plain-xls en local-config',\r\n line:'linea',\r\n missingPrimaryKeyValues:'faltan valores en los campos de la clave principal',\r\n noMailerConfig:'falta la configuración del mailer',\r\n notInputCuidado:'El archivo no es un archivo \"#cuidado\"',\r\n notLoggedIn:'sin inicio de sesión',\r\n oldPassDontMatch:'la clave anterior no coincide o el usuario es inválido o el token está vencido',\r\n passChangedSuccesfully: 'password was changed successfully',\r\n passDontMatch:'las claves no coinciden o son muy cortas',\r\n prefilledField1IsInConflictWithImportedField:'El valor del campo \"$1\" está en conflicto con el esperado',\r\n primarKeyCantBeNull4:'error en la línea $1. El campo \"$2\" de la clave principal no puede ser #NULL',\r\n spreadsheetProcessed:'hoja de datos procesada',\r\n unkownHashValue4Import:'código # desconocido en la importación de un valor',\r\n updateWithoutModfiedColumns:'se detectó una orden de modificación sin columnas a modificar',\r\n updatingDb:'actualizando la base de datos',\r\n versions:'versiones',\r\n }\r\n};\r\n\r\nfunction BindMemoryPerodicallySaved(be){\r\n return (\r\n/**\r\n * @param {Express.Session} session\r\n */\r\nfunction MemoryPerodicallySaved(session){\r\n var MemoryStoreConstructor = memorystore(session);\r\n class MemoryDevelConstructor extends MemoryStoreConstructor{\r\n /**\r\n * @param {memorystore.MemoryConsOpts} opts\r\n */\r\n constructor(opts){\r\n super(opts);\r\n var store=this;\r\n var fileName='sessions/local-sessions.dump';\r\n Promise.resolve().then(function(){\r\n return fs.mkdir('sessions').then(function(){\r\n console.log('sessions dir created');\r\n },function(err){\r\n if(err.code!='EEXIST'){\r\n console.log('ERROR in mkdir sessions');\r\n console.log(err.code);\r\n console.log(err);\r\n process.exit(1);\r\n }\r\n });\r\n }).then(function(){\r\n return fs.writeFile('sessions/local-start','running since '+new Date(), {encoding:'utf8'});\r\n }).then(function(){\r\n return fs.stat(fileName);\r\n }).then(function(stats){\r\n if(new Date().getTime() - stats.mtimeMs > 15*60*1000){\r\n console.log('Sessions is 15 minutes old or more');\r\n }else{\r\n return fs.readFile(fileName, {encoding:'utf8'}).then(function(content){\r\n var sessionInfo = json4all.parse(content);\r\n store.store.load(sessionInfo);\r\n console.log('session reabsorved with ',sessionInfo.length, 'sessions')\r\n });\r\n }\r\n },function(err){\r\n console.log('No sessions stored for reabsorve');\r\n }).catch(function(err){\r\n console.log('ERROR REABSORVING sessions');\r\n console.log(err);\r\n }).then(function(){\r\n var dumpEverySeconds=4;\r\n console.log('dumping sessions every',dumpEverySeconds,'seconds');\r\n var errorsToShow=4;\r\n // TODO: hangs the server in devel mode\r\n var interval = setInterval(function(){\r\n try{\r\n fs.writeFile(fileName,json4all.stringify(store.store.dump()));\r\n }catch(err){\r\n if(errorsToShow-->0){\r\n console.log('error saving local-sessions.dump');\r\n console.log(err);\r\n console.log(err.stack);\r\n }\r\n }\r\n },dumpEverySeconds*1000);\r\n be.shutdownCallbackListAdd({\r\n message:'session saver',\r\n fun:()=>clearInterval(interval)\r\n })\r\n });\r\n }\r\n }\r\n return MemoryDevelConstructor;\r\n})}\r\n\r\n/**\r\n * @param {string} text \r\n */\r\nAppBackend.prototype.jsonPass = function jsonPass(text){\r\n return JSON.stringify(text,null,' ').replace(/\\n(.*\".*(pass|clave|secret).*\":\\s*\").*(\",?)\\n/gi,'\\n$1********$3\\n');\r\n};\r\n\r\nAppBackend.prototype.setStaticConfig = function setStaticConfig(defConfigYamlString){\r\n var be=this;\r\n this.staticConfig=this.staticConfig||{};\r\n this.staticConfig=changing(this.staticConfig,jsYaml.load(defConfigYamlString));\r\n var controlNotSet=['db.password', 'kill-9.master-pass', 'login.plus.secret'];\r\n controlNotSet.forEach(function(attrs){\r\n var attrList=attrs.split('.');\r\n var value=be.staticConfig;\r\n while(attrList.length && value && typeof value == \"object\"){\r\n value=value[attrList.shift()];\r\n }\r\n if(value != null){\r\n console.log('configuración insegura del servidor, no debe especificarse en modo estatico:',attrs);\r\n throw Error('insecure config')\r\n }\r\n })\r\n}\r\n\r\nAppBackend.prototype.configList = function configList(){\r\n var list=[\r\n {\r\n package:{\r\n version: packagejson.version\r\n }\r\n },\r\n this.staticConfig];\r\n if(!this.staticConfig[\"client-setup\"]?.title && fs.existsSync(this.rootPath+'/def-config.yaml')){\r\n console.log('DEPRECATED!!!!!!')\r\n console.error('ERROR el def-config hay que ponerlo dentro de staticConfig');\r\n console.log('DEPRECATED!!!!!!')\r\n console.error('DEPRECATED!!!!!!')\r\n console.log('DEPRECATED!!!!!!')\r\n console.error('DEPRECATED!!!!!!')\r\n list.push(this.rootPath+'/def-config.yaml')\r\n };\r\n list.push(this.rootPath+'/local-config');\r\n list.push(process.env.BACKEND_PLUS_LOCAL_CONFIG?.trim()||{});\r\n return list;\r\n};\r\n\r\n/**\r\n * @param {bp.Request} req\r\n */\r\nAppBackend.prototype.getMachineId = function getMachineId(req){\r\n var be = this;\r\n var ip = req.connection.remoteAddress;\r\n var ipParts = ip.split('.');\r\n var prefix = (be.config.server[\"ip-replacer\"]||{})[ipParts.slice(0,3).join('.')];\r\n if(prefix){\r\n return prefix+ipParts[3];\r\n }\r\n var iSame = 0;\r\n var serverIpParts=req.socket.address().address.split('.');\r\n while(iSame0){\r\n pg.logExceptions = true;\r\n var dumps=[];\r\n while(iPosDbDump && iPosDbDumpExpress.Application} */\r\n // @ts-ignore : only for testing */\r\n this.getMainApp = function getMainApp(){ return mainApp; };\r\n }\r\n this.shutdownBackend = async function shutdownBackend(opts){\r\n var shootingDown = opts == null || !opts.onlyTurnOff;\r\n var turningOff = opts == null || !opts.skipTurnOff;\r\n if(!shootingDown){\r\n console.log('shooting down:');\r\n var waitFor = [\r\n new Promise(function(resolve,reject){\r\n console.log('*','express server');\r\n be.server.close(/** @param {Error} err */function(err){\r\n if(err){\r\n console.log('*', err)\r\n reject(err);\r\n }else{\r\n console.log('*','express server done!')\r\n resolve();\r\n }\r\n });\r\n }),\r\n ...(be.shutdownCallbackList.map(x => (async function(){\r\n console.log('shut:', x.message)\r\n await x.fun()\r\n console.log('done:', x.message)\r\n })())),\r\n ];\r\n console.log('*', 'waiting for all')\r\n await Promise.all(waitFor);\r\n console.log('*', 'all done')\r\n mainApp = null;\r\n }\r\n if(turningOff){\r\n console.log('turning off:');\r\n await pg.shutdown();\r\n console.log('pg shutdown done!');\r\n console.log('* logWhy',logWhy)\r\n logWhy && logWhy();\r\n }\r\n };\r\n return Promise.resolve().then(function(){\r\n var configList=be.configList();\r\n if(opts.config){\r\n configList.push(opts.config)\r\n }\r\n return MiniTools.readConfig(configList,opts.readConfig).catch(function(err){\r\n console.log(\"be: error reading or merging config\");\r\n throw err;\r\n });\r\n }).then(function(config){\r\n be.config = config;\r\n be.clientSetup = {config: be.config[\"client-setup\"]};\r\n be.clientSetup.config.prefix = be.clientSetup.config.prefix || be.config.server[\"base-url\"].substr(1)+':';\r\n if(config.nodb){\r\n console.log(\"server without database\");\r\n }else{\r\n if(be.config.login[\"double-dragon\"]){\r\n be.DoubleDragon = {dbParams:{}}\r\n }\r\n return Promise.resolve().then(function(){\r\n if(config.db.which){\r\n if(!config.db[config.db.which]){\r\n throw new Error('lack of '+config.db.which+' in config.db');\r\n }else{\r\n config.db = {...config.db, ...config.db[config.db.which]};\r\n }\r\n }\r\n var sessionStoreName=be.config.server[\"session-store\"];\r\n if(sessionStoreName){\r\n if(config.devel && be.sessionStores[sessionStoreName+'Devel']){\r\n sessionStoreName+='Devel';\r\n }\r\n var storeModule = be.sessionStores[sessionStoreName];\r\n be.config.login.plus.store.module = storeModule;\r\n }else{\r\n console.error('###################### DEPRECATED #####################')\r\n console.error('LACK OF server.session-store')\r\n }\r\n be.config.install.dump.db.owner=coalesce(be.config.db.owner,be.config.install.dump.db.owner,be.config.db.user);\r\n be.config.install.dump.db[\"owner4special-scripts\"]=coalesce(be.config.install.dump.db[\"owner4special-scripts\"],be.config.install.dump.db.owner)\r\n be.config.install.dump.db[\"user4special-scripts\"]=coalesce(be.config.install.dump.db[\"user4special-scripts\"],be.config.db.user)\r\n verboseStartup=!be.config.server[\"silent-startup\"];\r\n serveContent.logAll = be.config.log[\"serve-content\"];\r\n MiniTools.logServe = be.config.log[\"serve-content\"];\r\n if(be.clientSetup.config.lang in be.i18n.messages){\r\n be.messages = {...be.i18n.messages.en, ...be.i18n.messages[be.clientSetup.config.lang]};\r\n typeStore.locale = typeStore.i18n.locale[be.clientSetup.config.lang];\r\n typeStore.messages = typeStore.i18n.messages[be.clientSetup.config.lang];\r\n pg.setLang(be.clientSetup.config.lang);\r\n }\r\n }).then(function(){\r\n if(be.config.db.motor!='postgresql'){\r\n throw new Error(\"backend-plus: Motor not recongnized: \"+be.config.db.motor);\r\n }\r\n be.db = pg;\r\n be.dbUserNameExpr=\"get_app_user()\";\r\n be.dbUserRolExpr=`(select ${be.db.quoteIdent(be.config.login.rolFieldName)} \r\n from ${be.config.login.schema?be.db.quoteIdent(be.config.login.schema)+'.':''}${be.db.quoteIdent(be.config.login.table)} \r\n where ${be.db.quoteIdent(be.config.login.userFieldName)} = ${be.dbUserNameExpr})`\r\n }).then(function(){\r\n if(opts[\"dump-db\"]){\r\n return be.dumpDb(opts[\"dump-db\"]).then(function(){\r\n var err = new Error('DB DUMP OK');\r\n err.dumping='ok';\r\n throw err;\r\n },function(err){\r\n err.dumping='bad';\r\n throw err;\r\n });\r\n }\r\n }).then(function(){\r\n if(be.config.log.db['last-error'] || be.config.devel || be.config.log.db['on-demand']){\r\n if(be.config.devel || be.config.log.db['on-demand']){\r\n be.setLog=function(opts){\r\n const LOG_MINUTES = 5; // minutes\r\n if(opts.until){\r\n try{\r\n var ti=bestGlobals.timeInterval.iso(opts.until)\r\n be.config.log.db.until = bestGlobals.datetime.now().add(ti);\r\n }catch(err){\r\n try{\r\n be.config.log.db.until = bestGlobals.datetime.iso(opts.until);\r\n }catch(err2){\r\n console.log('invalid log-until format. Setting '+LOG_MINUTES+' minutes');\r\n }\r\n }\r\n }else{\r\n be.config.log.db.until = bestGlobals.datetime.now().add({ms:LOG_MINUTES*60*1000}); // LOG_MIN minutes\r\n }\r\n be.config.log.db.results=!!opts.results && !/^(0|false|f|no|n|нет|н)$/i.test(opts.results);\r\n }\r\n be.setLog({until:be.config.log.db.until});\r\n var logWaiter=Promise.resolve(); // para mandar todo en orden\r\n console.log('SQL: log all until',be.config.log.db.until.toYmdHms())\r\n pg.log = function logAll(message, type){\r\n if(bestGlobals.datetime.now()<=be.config.log.db.until){\r\n logWaiter=logWaiter.then(function(){\r\n if(be.config.log.db.results || !(type=='ROW' || type=='RESULT' || type=='QUERY-A' || type=='QUERY-P')){\r\n fs.appendFile('./local-log-all.sql','-- '+(type||'')+'\\n'+message+'\\n');\r\n }\r\n })\r\n }else{\r\n pg.logLastError(message, type);\r\n }\r\n }\r\n }else{\r\n pg.log = pg.logLastError;\r\n }\r\n pg.log.inFileName = 'last-pg-error-local.sql'\r\n pg.logLastError.inFileName = 'last-pg-error-local.sql'\r\n }\r\n be.config.db.search_path = be.config.db.search_path ?? [be.config.db.schema, 'public'];\r\n be.getDbClient = function getDbClient(req){\r\n var username = req?.user?.[be.config.login.userFieldName];\r\n var paramsDb = be.DoubleDragon?.dbParams?.[username] ?? be.config.db;\r\n return pg.connect(paramsDb).then(function(client){\r\n var dbAppName=req?(\r\n ((req.user||{})[be.config.login.userFieldName]||'!logged')+\r\n ' '+(req.machineId||'?')+\r\n ' '+(((req.useragent)||{}).shortDescription||'?')\r\n ):'!app local internal';\r\n return client.executeSentences([\r\n \"SET application_name = \"+be.db.quoteLiteral(dbAppName),\r\n ]).then(function(){\r\n var search_path = be.config.db.search_path;\r\n if(search_path.length>0){\r\n return client.query(\"set SEARCH_PATH TO \"+be.db.quoteIdentList(search_path)).execute().then(function(){\r\n return client;\r\n });\r\n }else{\r\n return client;\r\n }\r\n }).then(function(client){\r\n if(username){\r\n return client.query(`CALL set_app_user(${be.db.quoteLiteral(username)})`).execute().then(function(){\r\n return client;\r\n });\r\n }else{\r\n return client.query(`CALL set_app_user('!login')`).execute().then(function(){\r\n return client;\r\n });\r\n }\r\n }).then(function(client){\r\n if(be.config[\"client-setup\"].lang=='es'){\r\n return client.query(\"set datestyle TO iso,dmy\").execute().then(function(){\r\n return client;\r\n });\r\n }else{\r\n return client;\r\n }\r\n });\r\n });\r\n };\r\n be.inDbClient = async function inDbClient(req, doThisWithDbClient){\r\n var be=this;\r\n try{\r\n var client = await be.getDbClient(req);\r\n var result = await doThisWithDbClient.call(be, client /*,req?*/);\r\n client.done();\r\n return result;\r\n }catch(err){\r\n if(client && typeof client.done === \"function\"){\r\n client.done();\r\n }\r\n throw err;\r\n }\r\n };\r\n be.inTransaction = async function inTransaction(req, doThisWithDbTransaction){\r\n var be = this;\r\n return be.inDbClient(req, async function(client){\r\n try{\r\n await client.query(\"BEGIN TRANSACTION\").execute();\r\n var result = await doThisWithDbTransaction.call(be, client /*,req?*/);\r\n await client.query(\"COMMIT\").execute();\r\n return result;\r\n }catch(err){\r\n try{\r\n await client.query(\"ROLLBACK\").execute();\r\n }catch(err2){\r\n console.log(\"Error in database when rollback\",err,\" Error trying to rollback \",err2);\r\n }\r\n throw err;\r\n }\r\n });\r\n };\r\n return be.inDbClient(null, async function(client){\r\n if(verboseStartup){\r\n console.log(\r\n 'db-connected',\r\n be.jsonPass(be.config.db)\r\n );\r\n }\r\n try{\r\n await be.checkDatabaseStructure(client);\r\n }catch(err){\r\n console.log('*******************************************')\r\n console.error(be.messages.server.ErrorCheckDatabaseStructure)\r\n console.log(err);\r\n throw err;\r\n }\r\n var data = await client.query(\"SELECT current_timestamp as cts\").fetchUniqueRow();\r\n if(verboseStartup){\r\n console.log('NOW in Database',data.row.cts);\r\n }\r\n });\r\n });\r\n }\r\n }).then(function(){\r\n if(!be.config.nologin){\r\n return Promise.all([\r\n fs.stat('unlogged/login.jade').then(function(){\r\n throw new Error('login.jade must be in client dir not in unlogged');\r\n },function(){ /*OK, login.jade must not be here */ }),\r\n fs.stat('client/login.jade').then(function(){\r\n return Path.resolve(be.rootPath,'client/login');\r\n },function(){ \r\n return Path.join(__dirname,'../for-client/login');\r\n }).then(function(loginFile){\r\n be.config.login.plus.loginPageServe=function(req,res,next){\r\n return MiniTools.serveJade(loginFile,be.optsGenericForFiles(req,{withFlash:true}).jade)(req,res,next);\r\n };\r\n be.config.login.plus.newPassPageServe=function(req,res,next){\r\n return MiniTools.serveJade(loginFile.replace(/\\blogin\\b/,'new-password'),be.optsGenericForFiles(req,{withFlash:true}).jade)(req,res,next);\r\n };\r\n be.config.login.plus.newPassPageServe2=function(req,res,next){\r\n return MiniTools.serveJade(loginFile.replace(/\\blogin\\b/,'new-password-result'),be.optsGenericForFiles(req,{withFlash:true}).jade)(req,res,next);\r\n };\r\n be.config.login.plus.newPassPageEnter=function(username, token){\r\n return function(req,res,next){\r\n return MiniTools.serveJade(loginFile.replace(/\\blogin\\b/,'new-pass-enter'),{...be.optsGenericForFiles(req,{withFlash:true}).jade, username, token})(req,res,next);\r\n }\r\n };\r\n })\r\n ]);\r\n }\r\n }).then(async function(){\r\n mainApp = express();\r\n //mainApp.use(cookieParser());\r\n if(be.config.server.allowedHosts){\r\n if(!Array.isArray(be.config.server.allowedHosts)){\r\n throw Error('allowedHosts must be an Array')\r\n }\r\n const whitelist = ['localhost'].concat(be.config.server.allowedHosts);\r\n const corsOptions = {\r\n origin: function (origin, callback) {\r\n if (whitelist.some((element)=>origin?.includes(element)) || !origin){\r\n callback(null, true);\r\n }else{\r\n callback(new Error('Not allowed by CORS'));\r\n }\r\n },\r\n credentials: true\r\n };\r\n mainApp.use(cors(corsOptions));\r\n }\r\n mainApp.use(bodyParser.urlencoded({extended:true, limit: '50mb'}));\r\n mainApp.use(function(req,res,next){\r\n if((req.headers['content-type']||'').match(/^multipart\\/form-data/)){\r\n var form = new multiparty.Form();\r\n form.parse(req, function(err, fields, files) {\r\n req.multipartErr=err;\r\n req.fields=fields;\r\n req.files=files;\r\n next(err);\r\n });\r\n }else{\r\n next();\r\n }\r\n });\r\n if(be.config.log.req){\r\n mainApp.use(function(req,res,next){\r\n if(\r\n (!/keep-alive.json$/.test(req.originalUrl) || be.config?.log?.req?.['keep-alive']) &&\r\n (!/(.png|.jpg|.js|.jsx|.css|.html)$/.test(req.originalUrl) || be.config?.log?.req?.['all'])\r\n ){\r\n console.log('REQ',req.method,req.protocol,req.hostname,req.originalUrl,'from:',req.ip,req.query);\r\n }\r\n next();\r\n });\r\n }\r\n mainApp.use(useragent.express());\r\n mainApp.use(function(req,res,next){\r\n be.seenBrowsers=be.seenBrowsers||{};\r\n if(be.config.devel){\r\n var jsonBro = req.useragent.source;\r\n if(!(jsonBro in be.seenBrowsers)){\r\n be.seenBrowsers[jsonBro]={first:new Date(), times:0};\r\n }\r\n }\r\n req.useragent.shortDescription = (be._Browsers[req.useragent.browser]||{short:req.useragent.browser}).short+(req.useragent.version||'0').split('.')[0];\r\n req.machineId = be.getMachineId(req);\r\n if(be.config.devel){\r\n be.seenBrowsers[jsonBro].last=new Date();\r\n be.seenBrowsers[jsonBro].short=req.useragent.shortDescription;\r\n if(!be.seenBrowsers[jsonBro].times){\r\n fs.writeFile('local-browsers',JSON.stringify(be.seenBrowsers,null,' ')).catch(function(err){\r\n });\r\n be.seenBrowsers[jsonBro].times++;\r\n }\r\n }\r\n next();\r\n });\r\n if(be.config.server[\"kill-9\"]){\r\n /*eslint global-require: 0 */\r\n var kill9 = require('kill-9');\r\n mainApp.use(be.config.server[\"base-url\"], kill9(be.config.server[\"kill-9\"]));\r\n }\r\n if(be.config.server[\"base-url\"] && be.config.server[\"base-url\"]!='/'){\r\n mainApp.get('/favicon.ico', function(req,res,next){\r\n MiniTools.serveFile(__dirname+'/../for-client/img/warning128.png')(req,res,next)\r\n })\r\n }\r\n be.addUnloggedServices(mainApp, be.config.server[\"base-url\"]);\r\n var unloggedApp = await be.addProcedureServices(true);\r\n if(be.config.nologin){\r\n console.log(\"server without login\");\r\n }else{\r\n mainApp.loginPlusManager = new loginPlus.Manager();\r\n be.config.login.plus.baseUrl = coalesce(be.config.login.plus.baseUrl, be.config.server[\"base-url\"], '/');\r\n be.config.login.plus.userFieldName = be.config.login.plus.userFieldName || be.config.login.userFieldName;\r\n if(verboseStartup){\r\n console.log('-------------------');\r\n console.log(\r\n 'be.config.login', \r\n be.jsonPass(be.config.login)\r\n );\r\n }\r\n be.config.login.plus=changing(be.config.login.plus,{session:{\r\n name: 'bp'+(packagejson.name+be.config.server[\"base-url\"]||Math.random()).replace(/\\//g,'#')+'-connect.sid',\r\n cookie:{\r\n path: be.config.server[\"base-url\"]||'/',\r\n }\r\n }});\r\n var loginPlusOpts={\r\n schrödinger:function(){\r\n mainApp.use(be.config.server[\"base-url\"], unloggedApp);\r\n be.addSchrödingerServices(mainApp, be.config.server[\"base-url\"]);\r\n },\r\n messages: be.messages.unlogged.login\r\n }\r\n if(be.config.login.unloggedLandPage){\r\n loginPlusOpts.noLoggedUrlPath=be.config.login.unloggedLandPage;\r\n }\r\n mainApp.loginPlusManager.init(mainApp,changing(be.config.login.plus,loginPlusOpts));\r\n be.shutdownCallbackListAdd({\r\n message:'login-plus manager',\r\n fun:function(){\r\n mainApp.loginPlusManager.closeManager();\r\n }\r\n });\r\n const updatePassword = async ({client, username, password, setUpdateDate, errorIfNoResult}) => {\r\n const {table, passFieldName, userFieldName, passUpdatedAtFieldName, passAlgorithmFieldName, schema} = be.config.login; \r\n const hashPass = await generateScramVerifier(password);\r\n let params = [username, hashPass];\r\n let setters = [`${be.db.quoteIdent(passFieldName)} = $2`];\r\n if(passAlgorithmFieldName){\r\n setters.push(`${be.db.quoteIdent(passAlgorithmFieldName)} = $3`);\r\n params.push('PG-SHA256')\r\n }\r\n if(setUpdateDate && passUpdatedAtFieldName){\r\n setters.push(`${be.db.quoteIdent(passUpdatedAtFieldName)} = current_timestamp`)\r\n }\r\n \r\n const result = await client.query(`\r\n UPDATE ${(schema ? be.db.quoteIdent(schema) + '.' : '') + be.db.quoteIdent(table)} \r\n SET ${setters.join(', ')}\r\n WHERE ${be.db.quoteIdent(userFieldName)} = $1\r\n returning 1 as ok\r\n `, params\r\n ).fetchOneRowIfExists();\r\n\r\n if(result.rowCount === 0 && errorIfNoResult){\r\n throw Error ('no se encontró el usuario')\r\n };\r\n return result\r\n }\r\n mainApp.loginPlusManager.setValidatorStrategy(\r\n async function(req, username, password, done) {\r\n try{\r\n var client;\r\n if(!be.config.login[\"preserve-case\"]){\r\n username = username.toLowerCase().trim();\r\n }\r\n client = await be.getDbClient(req);\r\n await client.query(\"CALL set_app_user('!login')\").execute();\r\n const {passFieldName, rolFieldName, userFieldName} = be.config.login;\r\n var infoFieldList=(\r\n be.config.login.infoFieldList||(\r\n rolFieldName?\r\n [userFieldName, rolFieldName]\r\n :\r\n [userFieldName]\r\n )\r\n ).concat(passFieldName);\r\n \r\n const sql = \"SELECT \"+infoFieldList.map(function(fieldOrPair){ return fieldOrPair.split(' as ').map(function(ident){ return be.db.quoteIdent(ident)}).join(' as '); })+\r\n \", \"+be.config.login.activeClausule+\" as active \"+\r\n \", \"+be.config.login.lockedClausule+\" as locked \"+\r\n \" FROM \"+(be.config.login.from ?? (\r\n (be.config.login.schema?be.db.quoteIdent(be.config.login.schema)+'.':'')+\r\n be.db.quoteIdent(be.config.login.table)\r\n ))+\r\n \" WHERE \"+be.db.quoteIdent(be.config.login.userFieldName)+\" = $1 \";\r\n const data = await client.query(sql,[username]).fetchOneRowIfExists();\r\n\r\n if(data.rowCount != 1){\r\n done(null,false,{message:be.messages.unlogged.login.userOrPassFail});\r\n return\r\n }else{\r\n let needsMigration = false;\r\n const user = data.row;\r\n if(!user[passFieldName]){\r\n done(null,false,{message:be.messages.unlogged.login.userOrPassFail});\r\n return\r\n }\r\n const usaScramSha256 = user[passFieldName].startsWith('SCRAM-SHA-256$')\r\n if (usaScramSha256){\r\n let isScramValid = false;\r\n // 1. Intento con formato PG-Compatible (Nuevo)\r\n if(await verifyScramPG(password, user[passFieldName])){\r\n isScramValid = true;\r\n }\r\n \r\n // 2. Intento con formato Legacy (64 bytes)\r\n else if(await verifyScramLegacy(password, user[passFieldName])){\r\n isScramValid = true;\r\n needsMigration = true;\r\n }\r\n if(!isScramValid){\r\n done(null,false,{message:be.messages.unlogged.login.userOrPassFail});\r\n return\r\n }\r\n }else{ \r\n if (md5(password+username.toLowerCase()) === user[passFieldName]){\r\n needsMigration = true;\r\n }else{\r\n done(null,false,{message:be.messages.unlogged.login.userOrPassFail});\r\n return\r\n }\r\n }\r\n if(needsMigration){\r\n if (be.config.log[\"pass-migration\"]) console.log('Ejecutando migración a SCRAM...');\r\n await updatePassword({client, username, password, setUpdateDate:false, errorIfNoResult:true});\r\n if (be.config.log[\"pass-migration\"]) console.log('Migración completada.');\r\n }\r\n }\r\n //continua validando \r\n if(data.rowCount==1){\r\n if(!data.row.active){\r\n done(null,false,{message:be.messages.unlogged.login.inactiveFail});\r\n return\r\n }else if(data.row.locked){\r\n done(null,false,{message:be.messages.unlogged.login.lockedFail});\r\n return\r\n }else{\r\n if(req.query[\"return-to\"]){\r\n req.session.loginReturnTo = req.query[\"return-to\"];\r\n }\r\n if(be.config.login[\"double-dragon\"]){\r\n be.DoubleDragon.dbParams[username] = changing(be.config.db, {user:username, password});\r\n }\r\n }\r\n }else{\r\n done(null,false,{message:be.messages.unlogged.login.userOrPassFail});\r\n return\r\n }\r\n\r\n const userInfo = data.row;\r\n if (!userInfo) return;\r\n if (!be.config.login.skipBitacora) {\r\n var context = be.getContext(req);\r\n var sessionInfo = await client.query(be.generateInsertSQL(be.config.server.bitacoraSchema, be.config.server.bitacoraTableName,{\r\n procedure_name: '@login',\r\n username,\r\n machine_id: context.machineId,\r\n navigator: context.navigator,\r\n init_date: bestGlobals.datetime.now(),\r\n parameters: {}\r\n })).fetchUniqueValue();\r\n userInfo.bitacoraId = sessionInfo.value;\r\n }\r\n done(null, userInfo);\r\n }catch(err){\r\n if(be.config.login[\"double-dragon\"]){\r\n done(null,false,{message:be.messages.unlogged.login.userOrPassFail});\r\n }\r\n console.log('login error',err);\r\n console.log(err.stack);\r\n done(new Error('internal login error'));\r\n } finally {\r\n if(client && typeof client.done === \"function\"){\r\n client.done();\r\n }\r\n }\r\n }\r\n );\r\n be.changePassword=async function(client,username,oldPassword,newPassword){\r\n const { table, passFieldName, userFieldName, schema } = be.config.login;\r\n let ok = false;\r\n const data = await client.query(\r\n `SELECT *\r\n FROM ${(schema ? be.db.quoteIdent(schema) + '.' : '')}${be.db.quoteIdent(table)}\r\n WHERE ${be.db.quoteIdent(userFieldName)} = $1`, \r\n [username]\r\n ).fetchOneRowIfExists();\r\n if (data.rowCount !== 1) {\r\n // Usuario no encontrado\r\n return false;\r\n }\r\n const user = data.row\r\n const storedHash = user[passFieldName];\r\n if (oldPassword !== false) {\r\n if (storedHash.startsWith('SCRAM-SHA-256$')) {//Intento SCRAM-SHA-256\r\n ok = await verifyScramPG(oldPassword, storedHash);\r\n if (!ok) {\r\n ok = await verifyScramLegacy(oldPassword, storedHash);\r\n }\r\n } else { //Intento MD5\r\n const md5Hash = md5(oldPassword + username.toLowerCase()); \r\n ok = (md5Hash === storedHash);\r\n }\r\n if (!ok) {\r\n // La contraseña antigua es incorrecta\r\n return false;\r\n }\r\n } else {\r\n // Si no se requiere la contraseña antigua continua\r\n ok = true;\r\n }\r\n // Si la verificación fue exitosa o se omitió (ok == true), generamos el nuevo hash SCRAM\r\n if (ok) {\r\n const updateResult = await updatePassword({client, username, password:newPassword, setUpdateDate:true, errorIfNoResult:false});\r\n ok = updateResult.rowCount === 1;\r\n if (ok && be.config.login['double-dragon']) {\r\n const doubleDragonSql = \"ALTER USER \" + be.db.quoteIdent(username) + \" WITH PASSWORD \" + be.db.quoteLiteral(newPassword);\r\n await client.query(doubleDragonSql, []).execute();\r\n }\r\n }\r\n return ok;\r\n };\r\n be.passwordChanger=function(req, username, oldPassword, newPassword, done) {\r\n if(be.config.login.disableChangePassword){\r\n done(null,false,'el cambio de contraseña está deshabilitado');\r\n }else{\r\n be.inTransaction(req,function(client){\r\n return be.changePassword(client,username,oldPassword,newPassword)\r\n }).then(function(ok){\r\n done(null,ok,ok?null:be.messages.server.oldPassDontMatch);\r\n }).catch(function(err){\r\n console.log('error changing pass',err);\r\n console.log('stack',err.stack);\r\n throw err;\r\n }).catch(done);\r\n }\r\n }\r\n mainApp.loginPlusManager.setPasswordChanger(be.passwordChanger);\r\n if(be.config.devel.delay){\r\n mainApp.use(function(req,res,next){\r\n if(/^[^.]*$/.test(req.path)){\r\n bestGlobals.sleep(be.config.devel.delay/2+Math.random()*be.config.devel.delay).then(next);\r\n }else{\r\n next();\r\n }\r\n });\r\n }\r\n be.addLoggedServices();\r\n }\r\n be.app.use(function(err,req,res,next){\r\n console.log('******************', next);\r\n console.log(err);\r\n MiniTools.serveErr(req, res)(err);\r\n });\r\n return be.addProcedureServices();\r\n }).then(function(){\r\n return new Promise(function(resolve, reject){\r\n try{\r\n be.server = mainApp.listen(be.config.server.port, resolve);\r\n }catch(err){\r\n reject(err);\r\n }\r\n });\r\n }).then(function(){\r\n return be.postConfig();\r\n }).then(function(){\r\n if(be.config[\"client-setup\"].menu===true){\r\n var contextForDump = be.getContextForDump();\r\n // var menuDef=be.getMenu({rol:'admin', be});\r\n var menuDef=be.getMenu(contextForDump);\r\n controlMenuDefinition(menuDef.menu);\r\n }\r\n mainApp.use(be.config.server[\"base-url\"],be.app);\r\n }).then(function(){\r\n if(verboseStartup){\r\n console.log('listening on','http://localhost:'+be.config.server.port+be.config.server[\"base-url\"]);\r\n console.log('datetime:',new Date().toISOString());\r\n }\r\n if(be.config.server.port == null){\r\n console.log('backend-plus: Lack of mandatory server.port in config');\r\n throw new Error('backend-plus: Lack of mandatory server.port in config');\r\n }\r\n be.timeReadyBackendPlus = new Date();\r\n if(verboseStartup){\r\n console.log('READY',numeral((be.timeReadyBackendPlus-timeStartBackendPlus)/1000).format(\"0.0\"),'s elapsed');\r\n }\r\n if (Array.prototype.indexOf.call(process.argv,'--dump-includes')+1) {\r\n console.log(\"Resolved modules from: \" + process.cwd())\r\n likeAr(resolved_modules_log).forEach((c,l)=>console.log(` ${c} ${l}`));\r\n }\r\n return be.sendMail({\r\n to: be.config.mailer?.supervise?.to,\r\n subject: `npm start ${be.config[\"client-setup\"]?.title || packagejson.name} ok ✔️`,\r\n text:`Inicio del servicio: ${new Date().toJSON()}\r\n \r\n Contexto: ${os.userInfo().username} ${process.cwd()}\r\n `\r\n }, {ignoreNoMailer:true, event:'restart-ok'})\r\n }).catch(function(err){\r\n if(err.dumping=='ok'){\r\n console.log('db struct dumped');\r\n process.exit(0);\r\n return; \r\n }\r\n console.log('ERROR',err.stack || err);\r\n if(err.context){\r\n console.log('context', err.context);\r\n }\r\n if(err.dumping){\r\n console.log('error dumping db');\r\n process.exit(1);\r\n }\r\n var mailDeAvisoDeFalla = be.sendMail({\r\n to: be.config.mailer?.supervise?.to,\r\n subject: `npm start ${be.config[\"client-setup\"]?.title || packagejson.name} fallido 🛑`,\r\n text:`Falla en el inicio del servicio: ${new Date().toJSON()}\r\n \r\n Contexto: ${os.userInfo().username} ${process.cwd()}\r\n\r\n Mensaje: ${err.message}\r\n \r\n ${err.stack}\r\n `\r\n }, {ignoreNoMailer:true, event:'restart-fail'})\r\n console.log('backend-plus: start up canceled');\r\n mailDeAvisoDeFalla.then(function(){\r\n if(be.config.mailer){\r\n console.log('avisado por mail')\r\n }\r\n },function(){\r\n console.log('no pudo avisarse por mail')\r\n }).finally(function(){\r\n process.exit(1);\r\n });\r\n });\r\n};\r\n\r\nAppBackend.prototype.rootPath = process.cwd();\r\n\r\nAppBackend.prototype.specialValueWhenInsert = {\r\n currentUsername:function(context){\r\n return context.username;\r\n },\r\n lineNumberWhenImported:function(_context, _defField, parameters){\r\n return parameters.lineNumber\r\n }\r\n}\r\n\r\nAppBackend.prototype.specialSqlDefaultExpressions = {\r\n 'current_user': 'get_app_user()',\r\n}\r\n\r\nAppBackend.prototype.checkDatabaseStructure = async function checkDatabaseStructure(client){\r\n var be=this;\r\n var result = await client.query(`select setting from pg_settings where name='server_version';`).fetchUniqueValue();\r\n if(result.value`\r\n alter table ${be.config.login.schema?be.db.quoteIdent(be.config.login.schema)+'.':''}${be.config.login.table} add column ${name} text;`).join('')}\r\n `;\r\n err.message += mensaje;\r\n console.log(mensaje)\r\n throw err;\r\n }\r\n }\r\n }\r\n var bitacoraTableName = be.config.server.bitacoraTableName || 'bitacora';\r\n var bitacoraId = await client.query(`SELECT data_type \r\n FROM information_schema.columns\r\n WHERE /*table_schema = 'his' AND*/ table_name = '${bitacoraTableName}' AND column_name = 'id'\r\n `).fetchOneRowIfExists();\r\n if (bitacoraId.row?.data_type != 'bigint') {\r\n var message = `\r\n ------- hay que cambiar la bitacora (${bitacoraTableName})de lugar (a his) y agrandar el id (a bigint)\r\n alter table ${be.config.db.schema}.${bitacoraTableName} set schema his;\r\n alter table ${be.config.db.schema}.tokens set schema his;\r\n alter table his.${bitacoraTableName} alter column id type bigint;\r\n grant usage on schema his to ${be.config.db.user};\r\n grant select, insert, update on his.${bitacoraTableName} to ${be.config.db.user};\r\n alter table his.${bitacoraTableName} alter column parameters_definition drop not null;\r\n `;\r\n throw new Error(message);\r\n }\r\n var {rows: sql_routines} = await client.query(`SELECT routine_name, routine_schema, routine_type, routine_definition\r\n FROM information_schema.routines\r\n WHERE routine_schema in (${be.config.db.search_path.map(path => be.db.quoteLiteral(path)).join(', ')})\r\n `).fetchAll();\r\n var sqlRoutines = likeAr.createIndex(sql_routines, 'routine_name');\r\n var set_app_user_RoutineType = sqlRoutines.set_app_user?.routine_type || 'inexsistente';\r\n if (set_app_user_RoutineType != 'PROCEDURE') {\r\n throw new Error('ERROR en la DB: set_app_user no es un PROCEDURE es ' + set_app_user_RoutineType);\r\n }\r\n var message = ''\r\n likeAr(AppBackend.prototype.sql_routines).forEach((routine_name, def) => {\r\n if (sqlRoutines[routine_name] && def.dump.includes(sqlRoutines[routine_name].routine_definition)) {\r\n message += `\r\n ----- hay que crear o actualizar la rutina ${routine_name}:\r\n ${def.dump}\r\n `;\r\n }\r\n })\r\n if (message) throw new Error(message);\r\n};\r\n\r\nAppBackend.prototype.postConfig = function postConfig(){\r\n this.fieldDomain={};\r\n this.scanSkinFiles();\r\n};\r\n\r\nAppBackend.prototype.getContext = function getContext(req){\r\n var be = this;\r\n return {\r\n be, user:req.user, session:req.session, \r\n username:req.user && req.user[be.config.login.userFieldName], \r\n machineId:req.machineId, \r\n navigator:(req.userAgent||{}).shortDescription||'?'\r\n };\r\n}\r\n\r\nAppBackend.prototype.isThisProcedureAllowed = async function(){\r\n return true;\r\n}\r\n\r\nAppBackend.prototype.inTransactionProcedureContext = function inTransactionProcedureContext(req, coreFunction, context){\r\n var be = this;\r\n context = context ?? be.getContext(req);\r\n if(be.config.nodb){\r\n return coreFunction(context);\r\n }\r\n if (!context.informProgress) {\r\n context.informProgress = function informProgress(){}\r\n }\r\n return be.inTransaction(req, function(client){\r\n context.client=client;\r\n return coreFunction(context);\r\n });\r\n}\r\n\r\nAppBackend.prototype.generateInsertSQL = function generateInsertSQL(schemaName, tableName, insertElement){\r\n var {db} = this;\r\n var cleanKeys = [];\r\n var cleanValues = [];\r\n for (var key in insertElement) {\r\n cleanKeys.push(db.quoteIdent(key));\r\n cleanValues.push(db.quoteNullable(insertElement[key])); \r\n }\r\n var sql = `INSERT INTO ${db.quoteIdent(schemaName)}.${db.quoteIdent(tableName)}\r\n (${cleanKeys.join(',')}) VALUES (${cleanValues.join(',')}) returning id`;\r\n return sql;\r\n}\r\n\r\nAppBackend.prototype.updateUpdateSQL = function updateUpdateSQL(schemaName, tableName, updateElement, updateConditions){\r\n var be = this;\r\n var {db} = this;\r\n var setPairs = [];\r\n for (var key in updateElement) {\r\n setPairs.push(db.quoteIdent(key) + \" = \" + db.quoteNullable(updateElement[key]));\r\n }\r\n var filterPairs = [];\r\n for (var key in updateConditions) {\r\n filterPairs.push(be.db.quoteIdent(key) + \" = \" + be.db.quoteLiteral(updateConditions[key]));\r\n };\r\n var sql = `UPDATE ${db.quoteIdent(schemaName)}.${db.quoteIdent(tableName)} \r\n SET ${setPairs.join(',')}\r\n WHERE ${filterPairs.join(' AND ')}`;\r\n return sql;\r\n}\r\n\r\n\r\n/** @param {boolean} forUnlogged */\r\nAppBackend.prototype.addProcedureServices = function addProcedureServices(forUnlogged){ \r\n var be = this;\r\n if(forUnlogged){\r\n var app = express();\r\n }else{\r\n var app = be.app;\r\n }\r\n return this.getProcedures().then(function(defs){\r\n defs.forEach(function(def){\r\n if(!def.isCompleted){\r\n be.procedureDefCompleter(def);\r\n }\r\n })\r\n /** @type { {[key:string]:bp.procedureDef} } */\r\n be.procedure = be.procedure||{};\r\n be.procedures = defs;\r\n be.clientSetup.procedure = be.procedure;\r\n app.get('/client-setup',async function(req, res, next){\r\n if(forUnlogged && req.user){ \r\n // este pedido es para unlogged y está logueado, va al próximo\r\n next();\r\n }else{\r\n var clientSetup = await be.getClientSetupForSendToFrontEnd(req);\r\n MiniTools.serveJson(clientSetup)(req, res, next);\r\n }\r\n });\r\n if(!be.proceduresPrepared){\r\n be.proceduresPrepared=true;\r\n // esto es preparación, debe correrse una sola vez\r\n be.procedures.forEach(function(procedureDef){\r\n if(be.procedure[procedureDef.action]){\r\n console.log('REDEFINED procedure',procedureDef.action);\r\n }\r\n be.procedure[procedureDef.action] = procedureDef;\r\n });\r\n }\r\n likeAr(be.procedure).forEach(function(procedureDef){\r\n if( (!forUnlogged) !== (!procedureDef.unlogged)){\r\n return;\r\n }\r\n procedureDef.parameters.forEach(function(paramDef){\r\n if(paramDef.enconding==='plain' && procedureDef.multipart){\r\n throw new Error(\"plain enconding in parameters not allowed in multipart procedure\"+procedureDef.action);\r\n }\r\n });\r\n if(!isLowerIdent(procedureDef.action)){\r\n console.error('**** DEPRECATED ***** procedureDef action '+JSON.stringify(procedureDef.action)+' must be a Lower Ident');\r\n }\r\n app[procedureDef.method]('/'+procedureDef.action, \r\n /**\r\n * \r\n * @param {Request} req \r\n * @param {Response} res \r\n * @param {import('express').NextFunction} next \r\n */\r\n async function(req, res, next){\r\n const BITACORA_SCHEMA = be.config.server.bitacoraSchema;\r\n const BITACORA_TABLENAME = be.config.server.bitacoraTableName;\r\n var getDatetimeString = function getDatetimeString(){\r\n return datetime.now().toPlainString()\r\n }\r\n var initDatetimeString = getDatetimeString();\r\n var context=be.getContext(req);\r\n var getSource = function(){\r\n var source=procedureDef.method=='post'?(\r\n procedureDef.files?'fields':'body'\r\n ):'query';\r\n return source;\r\n }\r\n var getParams = function(){\r\n var source = getSource();\r\n var params={};\r\n procedureDef.parameters.forEach(function(paramDef){\r\n var undecodedValue = req[source][paramDef.name];\r\n undecodedValue = paramDef.encoding == 'plain' || undecodedValue === undefined ? undecodedValue : undecodedValue + '';\r\n var value = undecodedValue===undefined?undecodedValue:myOwn.encoders[paramDef.encoding].parse(undecodedValue);\r\n if(undecodedValue===undefined){\r\n if(paramDef.defaultSpecial === 'currentYear'){\r\n value = new Date().getFullYear();\r\n }else if('defaultValue' in paramDef){\r\n value = paramDef.defaultValue;\r\n }else{\r\n throw new Error(\"internal procedure \"+procedureDef.action+\" error: lack of mandatory paramater \"+paramDef.name);\r\n }\r\n }\r\n if(source==='fields' && false){\r\n if(value.length!==1){\r\n throw new Error(\"internal procedure \"+procedureDef.action+\" error: non unique paramater \"+paramDef.name+\" in multipart\");\r\n }\r\n value=value[0];\r\n }\r\n params[paramDef.name] = value;\r\n });\r\n return params;\r\n }\r\n var processBitacora = async function(hasError, status){\r\n var params = getParams();\r\n var defInsertBitacoraElement = {\r\n procedure_name : procedureDef.action,\r\n parameters: JSON.stringify(params),\r\n username: context.username,\r\n machine_id: context.machineId,\r\n navigator: context.navigator,\r\n init_date: initDatetimeString,\r\n };\r\n var getFinalStatusBitacoraElement = function getFinalStatusBitacoraElement(){\r\n return { \r\n end_date: getDatetimeString(), \r\n end_status: status, \r\n has_error: hasError\r\n }\r\n }\r\n if(procedureDef.bitacora.always){\r\n if(lastBitacoraInsertedId){\r\n await be.inTransaction(req, async function(client){\r\n var updateConditions = { id: lastBitacoraInsertedId };\r\n await client.query(be.updateUpdateSQL(BITACORA_SCHEMA, BITACORA_TABLENAME, getFinalStatusBitacoraElement(), updateConditions)).execute();\r\n });\r\n }else{\r\n await be.inTransaction(req, async function(client){\r\n var result = await client.query(be.generateInsertSQL(BITACORA_SCHEMA, BITACORA_TABLENAME, defInsertBitacoraElement)).fetchUniqueRow();\r\n lastBitacoraInsertedId = result.row.id;\r\n });\r\n }\r\n }else if(hasError && procedureDef.bitacora.error){\r\n await be.inTransaction(req,async function(client){\r\n var insertElement = changing(defInsertBitacoraElement, getFinalStatusBitacoraElement());\r\n await client.query(be.generateInsertSQL(BITACORA_SCHEMA, BITACORA_TABLENAME, insertElement)).execute();\r\n });\r\n }\r\n //tengo configurada otra tabla para guardar el resultado de la bitacora y tengo la pk de esa tabla\r\n if(procedureDef.bitacora.targetTable && procedureDef.bitacora.targetTableUpdateFieldsCondition){\r\n var targetTableUpdateFieldsCondition = procedureDef.bitacora.targetTableUpdateFieldsCondition || ['init_date','end_date','has_error', 'end_status'];\r\n var updateElement = {};\r\n var updateConditions = {};\r\n var params = getParams();\r\n if(status){\r\n //terminó ejecucion\r\n updateElement[procedureDef.bitacora.targetTableBitacoraFields.end_date] = getDatetimeString(); \r\n updateElement[procedureDef.bitacora.targetTableBitacoraFields.end_status] = status;\r\n updateElement[procedureDef.bitacora.targetTableBitacoraFields.has_error] = hasError;\r\n }else{\r\n //empezó ejecucion\r\n updateElement[procedureDef.bitacora.targetTableBitacoraFields.init_date] = initDatetimeString; \r\n }\r\n await be.inTransaction(req,async function(client){\r\n targetTableUpdateFieldsCondition.forEach(function(field){\r\n updateConditions[field] = params[field];\r\n });\r\n await client.query(be.updateUpdateSQL(BITACORA_SCHEMA, procedureDef.bitacora.targetTable, updateElement, updateConditions)).execute();\r\n })\r\n }\r\n }\r\n var processCoreFunction = function(){\r\n return Promise.resolve().then(function(){\r\n if(procedureDef.roles && procedureDef.roles.indexOf(req.user[be.config.login.rolFieldName])<0){\r\n throw changing(new Error(\"Not allowed\"), {status:\"403\"});\r\n }\r\n var files=[];\r\n var params=getParams();\r\n if(procedureDef.files){\r\n if(procedureDef.cacheable){\r\n console.error('DEPRECATE procedure cacheable with files');\r\n procedureDef.cacheable=false;\r\n }\r\n for(var name in req.files){\r\n files = files.concat(req.files[name]);\r\n }\r\n if(\r\n 'minCount' in procedureDef.files && files.length 500 || progressInfo.force){\r\n context.lastMessageSended[progressInfo.idGroup]=new Date();\r\n res.write(JSON.stringify({progress:progressInfo})+\"\\n\");\r\n if(progressInfo.total){\r\n var rate100=Math.floor(progressInfo.loaded*100/progressInfo.total);\r\n var rate1000=Math.floor(progressInfo.loaded*1000/progressInfo.total);\r\n var message = rate100<1 && progressInfo.loaded>0 ? '('+(rate1000||'½')+'‰)' : rate100+'%';\r\n progress2send={message, ephemeral:true, idGroup:progressInfo.idGroup};\r\n }\r\n }else{\r\n progress2send=null;\r\n }\r\n }else{\r\n progress2send=progressInfo;\r\n }\r\n }\r\n // console.log('informProgress J',JSON.stringify(progress2send));\r\n // console.log('informProgress J',json4all.stringify(progress2send));\r\n // console.log('informProgress',progress2send);\r\n if(progress2send){\r\n res.write(JSON.stringify({progress:progress2send})+\"\\n\");\r\n }\r\n };\r\n }\r\n if(!req.cookies){\r\n context.cookies = myOwn.parseStrCookies(req.headers.cookie, be.clientSetup.config.prefix);\r\n }else{\r\n context.cookies = req.cookies;\r\n }\r\n if(procedureDef.setCookies){\r\n context.setCookie = function(name, value, opts){\r\n res.cookie(be.clientSetup.config.prefix+name, value, {path: be.config['base-url'] , ...opts})\r\n }\r\n context.clearCookie = function(name, opts){\r\n var {expires, maxAge, ...otherOpts} = opts;\r\n res.clearCookie(be.clientSetup.config.prefix+name, {path: be.config['base-url'] , ...otherOpts})\r\n }\r\n }\r\n context.regenerateSession = async function regenerateSession(){\r\n await new Promise(function(resolve, reject){\r\n req.session.regenerate(function(err){\r\n if(err) reject(err);\r\n resolve();\r\n })\r\n })\r\n }\r\n var bpClientTs = req.get('BP-Client-TS');\r\n if(bpClientTs){\r\n res.append('BP-Client-TS', bpClientTs);\r\n }\r\n res.append('Content-Type', 'application/octet-stream');\r\n return Promise.resolve().then(function(){\r\n var thisCache;\r\n if(procedureDef.cacheable){\r\n var jsonParams = JSON.stringify(params);\r\n thisCache = be.caches.procedures[jsonParams];\r\n if(!thisCache){\r\n thisCache = be.caches.procedures[jsonParams] = {timestamp:new Date().getTime()};\r\n }\r\n if(thisCache.result !== undefined){\r\n return thisCache.result;\r\n }\r\n }\r\n var keepAliveManager=null;\r\n return Promise.resolve().then(function(){\r\n return be.isThisProcedureAllowed(context,procedureDef,params)\r\n }).then(function(allowed){\r\n if(!allowed){\r\n console.log('FORBIDDEN',procedureDef.action,params.table,context.username);\r\n var err = new Error(\"FORBIDDEN\");\r\n err.code=\"403\";\r\n throw err;\r\n }\r\n }).then(function(){\r\n if(procedureDef.progress && be.config.server[\"keep-alive\"]){\r\n keepAliveManager=setInterval(function(){\r\n res.write(JSON.stringify({progress:{keepAlive:true, ts:new Date().getTime()}})+\"\\n\")\r\n },5000)\r\n }\r\n return be.inTransactionProcedureContext(req, function(context){\r\n return procedureDef.coreFunction(context, params, files);\r\n }, context);\r\n }).then(function(result){\r\n if (procedureDef.forExport) {\r\n return be.exportacionesGenerico(result, procedureDef, context, params, files);\r\n } else {\r\n return result;\r\n }\r\n }).then(function(result){\r\n if(thisCache){\r\n thisCache.result = result;\r\n thisCache.timestamp = new Date().getTime();\r\n }\r\n if(keepAliveManager){\r\n clearInterval(keepAliveManager)\r\n }\r\n return result;\r\n },function(err){\r\n if(keepAliveManager){\r\n clearInterval(keepAliveManager)\r\n }\r\n throw err;\r\n });\r\n }).then(function(result){\r\n if(result===undefined){\r\n console.log('undefined in',procedureDef,'for',req[getSource()]);\r\n throw new Error(\"Bad return value in procedure. Undefined detected.\");\r\n }\r\n if(procedureDef.encoding==='download'){\r\n res.download(result.path, result.fileName);\r\n }else{\r\n try{\r\n result = myOwn.encoders[procedureDef.encoding].stringify(result);\r\n }catch(err){\r\n throw err;\r\n }\r\n if(procedureDef.progress!==false){\r\n res.write('--\\n');\r\n }\r\n res.end(result);\r\n }\r\n return result;\r\n });\r\n });\r\n }\r\n var lastBitacoraInsertedId = null;\r\n try{\r\n await processBitacora(null,null);\r\n var result = await processCoreFunction();\r\n await processBitacora(false, json4all.stringify(result));\r\n }catch(err){\r\n await processBitacora(true, err.message);\r\n if(procedureDef.progress!==false){\r\n var error = {};\r\n MiniTools.globalOpts.serveErr.propertiesWhiteList.forEach(function(attrName){\r\n if(attrName in err || err[attrName]){\r\n error[attrName]=err[attrName];\r\n }\r\n });\r\n res.write(JSON.stringify({error:error})+\"\\n\");\r\n res.end();\r\n }else{\r\n MiniTools.serveErr(req,res,next)(err);\r\n }\r\n };\r\n });\r\n });\r\n return app;\r\n });\r\n};\r\n\r\n/** @param {bp.Context} context */\r\nAppBackend.prototype.getMenu = function getMenu(context){\r\n return { menu:[] };\r\n}\r\n\r\nfunction controlMenuDefinition(menuContent){\r\n var somethingWrong='';\r\n menuContent.forEach(function(menu){\r\n if(!isLowerIdent(menu.name)){\r\n somethingWrong=JSON.stringify(menu.name);\r\n console.error('*** DEPRECATED *** The menu item name: '+JSON.stringify(menu.name)+' must be a Lower Ident');\r\n }\r\n if(menu.label && /\\b[A-Z][a-z]+\\b/.test(menu.label)){\r\n console.log('** DEPRECATED ** The menu item label: '+JSON.stringify(menu.label)+' must be a in lower case');\r\n }\r\n })\r\n if(somethingWrong){\r\n throw new Error('The menu item name: '+somethingWrong+' must be a Lower Ident');\r\n }\r\n}\r\n\r\nAppBackend.prototype.getClientSetupForSendToFrontEnd = function getClientSetupForSendToFrontEnd(req){\r\n var be=this;\r\n var clientSetup=changing(be.clientSetup, {username:req.user && req.user[be.config.login.userFieldName]});\r\n var context=be.getContext(req);\r\n clientSetup.useragent = req.useragent;\r\n if(be.config[\"client-setup\"].menu===true){\r\n var menuDef=be.getMenu(context);\r\n controlMenuDefinition(menuDef.menu);\r\n clientSetup=changing(clientSetup, be.getVisibleMenu(menuDef, context));\r\n }\r\n clientSetup.procedures = likeAr(be.clientSetup.procedure).filter(function(procedureDef){\r\n return !procedureDef.roles || procedureDef.unlogged || req.user && procedureDef.roles.indexOf(req.user[be.config.login.rolFieldName])>=0;\r\n }).array();\r\n return clientSetup;\r\n};\r\n\r\nvar resolved_modules_log = {}\r\n\r\nfunction require_resolve(moduleName){\r\n var resolved;\r\n var ok = 'require';\r\n try{\r\n resolved = require.resolve(moduleName);\r\n }catch(err){\r\n var ok = 'node_modules';\r\n var packageJson = fs.readJsonSync(Path.join(process.cwd(),'node_modules',moduleName,'package.json'));\r\n resolved = Path.join(...[process.cwd(),'node_modules',moduleName,(packageJson.main?packageJson.main:'package.json')])\r\n if(!fs.existsSync(resolved)){\r\n ok = err.message\r\n throw err;\r\n }\r\n }finally{\r\n var resolved_modules_line = `${moduleName} -> ${Path.relative(process.cwd(), Path.dirname(resolved))} -> ${Path.basename(resolved)} : ${ok}`;\r\n resolved_modules_log[resolved_modules_line] = (resolved_modules_log[resolved_modules_line] ?? 0 ) + 1;\r\n }\r\n return resolved;\r\n}\r\n\r\n/* MEJORA:\r\nfunction module_root_dir(file){\r\n var dir = Path.dirname(file);\r\n while(!fs.existsSync(Path.join(dir,'package.json'))){\r\n var parent = Path.dirname(dir);\r\n if(parent==dir){ return Path.dirname(file); }\r\n dir = parent;\r\n }\r\n return dir;\r\n}\r\n// */\r\n\r\nfunction resolve_module_dir(moduleName,path,fileToCheck){\r\n var baseDir;\r\n if(packagejson.name==moduleName){\r\n baseDir=Path.join(process.cwd(), packagejson.main);\r\n }else{\r\n baseDir=require_resolve(moduleName);\r\n }\r\n// var resultDir = Path.join(path?module_root_dir(baseDir):Path.dirname(baseDir),path||'');\r\n var resultDir = Path.join(Path.dirname(baseDir),path||'');\r\n if (fileToCheck) {\r\n fs.stat(Path.join(resultDir, fileToCheck)).then(function(status){\r\n if (!status) {\r\n console.error('Error resolve_module_dir in:',resultDir,'no:',fileToCheck);\r\n } else if(!status.isFile() && fileToCheck != '.') {\r\n console.error('Error resolve_module_dir in:',resultDir,',',fileToCheck,'is not a file');\r\n }\r\n },function(err){\r\n console.error('Error resolve_module_dir in:',resultDir,'err:',err);\r\n });\r\n }\r\n return resultDir;\r\n}\r\n\r\nAppBackend.prototype.optsGenericForFiles = function optsGenericForFiles(req, opts){\r\n var be = this;\r\n var title=be.config['client-setup'].formTitle;\r\n var skin=be.config['client-setup'].skin;\r\n var skinUrl=(skin?skin+'/':'');\r\n return changing(be.optsGenericForAll||{},{\r\n allowedExts:be.exts.normal,\r\n jade:{\r\n skin:skin, \r\n skinUrl:skinUrl,\r\n formTitle:title,\r\n ...(opts?.withFlash ? {flash:req?.flash?.()} : {}),\r\n msgs:changing(be.messages.unlogged, req?.user?be.messages.logged:{chpass:be.messages.logged.chpass}),\r\n modules:req?.user?be.clientModules():[],\r\n lang:be.config[\"client-setup\"].lang,\r\n username:req?.user?req.user[be.config.login.userFieldName]:'',\r\n forget:be.config.login.forget?.urlPath\r\n },\r\n });\r\n}\r\n\r\nAppBackend.prototype.unloggedLandPage = function unloggedLandPage(req){\r\n var be = this;\r\n return html.div([\r\n html.h2({style:'text-align:center; margin-top:15%; font-family:arial, sans-serif'},[be.messages.server.notLoggedIn]),\r\n html.h2({style:'text-align:center'},[html.code([\r\n html.a({\r\n id:'goto-login', \r\n style:'border:0.5px solid blue; border-radius: 6px; padding: 6px', \r\n href:Path.posix.join(be.config.server[\"base-url\"],(be.config.login.plus.loginUrlPath||'/login'))\r\n },'login')\r\n ])]),\r\n html.script({src:'auto-login.js'})\r\n ]);\r\n}\r\n\r\nAppBackend.prototype.addUnloggedServices = function addUnloggedServices(mainApp, baseUrl){\r\n var be=this;\r\n if(be.config.login.forget?.urlPath){\r\n mainApp.get(Path.posix.join(baseUrl,be.config.login.forget.urlPath), be.config.login.plus.newPassPageServe)\r\n mainApp.get(Path.posix.join(baseUrl,be.config.login.forget.urlPathOk), be.config.login.plus.newPassPageServe2)\r\n mainApp.post(Path.posix.join(baseUrl,be.config.login.forget.urlPath), function(req,res,next){\r\n var resultCode;\r\n if(!req.body.email || !/@/.test(req.body.email)){\r\n resultCode='error';\r\n }else{\r\n resultCode='ok';\r\n var promise = be.inDbClient(req, async (client)=>{\r\n var now = bestGlobals.datetime.now();\r\n var token = crypto.randomUUID();\r\n var {rows} = await client.query(`select ${be.db.quoteIdent(be.config.login.userFieldName)} as username\r\n from ${be.config.login.schema?be.db.quoteIdent(be.config.login.schema)+'.':''}${be.db.quoteIdent(be.config.login.table)} \r\n where $1 in (${be.db.quoteIdentList(be.config.login.forget.mailFields)}) \r\n and ${be.config.login.activeClausule}\r\n and ${be.config.login.lockedClausule} is not true\r\n `, [req.body.email.toLowerCase()]).fetchAll();\r\n if(rows?.length>0){\r\n await client.query(\r\n \"insert into his.tokens(token, tokentype, date, username, useragent, due) values ($1, 'new-pass', $2, $3, $4, $5) returning token\",\r\n [token, now, rows[0].username, req.useragent, now.add({days:1})]\r\n ).fetchUniqueRow();\r\n var chpath = (be.config.login.forget?.urlDomainAndRoot ?? req.protocol+'://' +Path.posix.join(req.hostname+baseUrl,'new-pass')) +\r\n '?token='+token+'&nueva=clave';\r\n // console.log('chpass', chpath)\r\n await be.sendMail({\r\n to: req.body.email,\r\n subject: be.messages.unlogged.newPassword.mailSubject,\r\n html: be.messages.unlogged.newPassword.mailHtml.replace(\r\n '',\r\n `${chpath}`\r\n )\r\n })\r\n }\r\n })\r\n promise.catch(err=>{\r\n console.log('error in /new-password');\r\n console.log(err);\r\n })\r\n }\r\n res.redirect(Path.posix.join(baseUrl, be.config.login.forget?.urlPathOk+'?result'+resultCode));\r\n })\r\n mainApp.get(Path.posix.join(baseUrl,'/new-pass'), function(req,res,next){\r\n var resultCode;\r\n if(!req.query.token){\r\n res.send('No token');\r\n res.end();\r\n }else{\r\n var promise = be.inDbClient(req, async (client)=>{\r\n var now = bestGlobals.datetime.now();\r\n var {row} = await client.query(`select *\r\n from his.tokens\r\n where tokentype = 'new-pass' and token = $1\r\n and due > $2\r\n limit 1;\r\n `, [req.query.token, now]).fetchOneRowIfExists();\r\n if(!row){\r\n res.send('Invalid token');\r\n res.end();\r\n }else{\r\n be.config.login.plus.newPassPageEnter(row.username, req.query.token)(req,res,next);\r\n }\r\n })\r\n }\r\n })\r\n mainApp.post(Path.posix.join(baseUrl,'/new-pass-enter'), function(req,res,next){\r\n var newPassword = req.body.newPassword.trim();\r\n if(newPassword != req.body.repPassword.trim()){\r\n res.send(be.messages.server.passDontMatch);\r\n res.end();\r\n return;\r\n }\r\n if(newPassword.length < 6){\r\n res.send(be.messages.server.passDontMatch);\r\n res.end();\r\n return;\r\n }\r\n var promise = be.inDbClient(req, async (client)=>{\r\n var now = bestGlobals.datetime.now();\r\n var {row} = await client.query(`select *\r\n from his.tokens\r\n where tokentype = 'new-pass' and token = $1\r\n and $2 < due\r\n limit 1;\r\n `, [req.body.token, now]).fetchOneRowIfExists();\r\n if(!row){\r\n res.send('Invalid token');\r\n res.end();\r\n return;\r\n }\r\n await new Promise((resolve, reject)=>{\r\n be.passwordChanger(req, row.username, false, newPassword, function done(err, ok, message){\r\n if(err){\r\n reject(err)\r\n }else if(ok){\r\n resolve()\r\n }else{\r\n // console.log(arguments)\r\n reject(message.message)\r\n }\r\n })\r\n })\r\n res.redirect(Path.posix.join(baseUrl, be.config.login.noLoggedUrlPath || '/login'));\r\n await client.query(`update his.tokens set due = null\r\n where tokentype = 'new-pass' and token = $1;\r\n `, [req.body.token]).execute();\r\n })\r\n return promise;\r\n });\r\n }\r\n if(be.config.login.unloggedLandPage){\r\n mainApp.get(Path.posix.join(baseUrl,be.config.login.unloggedLandPage), function(req, res, next){\r\n res.status(401);\r\n return MiniTools.serveText(be.unloggedLandPage(req).toHtmlDoc({\r\n title:be.messages.server.notLoggedIn\r\n }),'html')(req,res,next);\r\n })\r\n }\r\n // http://localhost:3033/img/login-logo-icon.png\r\n mainApp.get(Path.posix.join(baseUrl,'/img/login-logo-icon.png'), async function(req,res,next){\r\n var buscar = [\r\n 'unlogged/img/login-logo-icon.svg', \r\n 'dist/unlogged/img/login-logo-icon.svg', \r\n 'dist/client/unlogged/img/login-logo-icon.svg', \r\n 'unlogged/img/login-logo-icon.png', \r\n 'dist/unlogged/img/login-logo-icon.png', \r\n 'dist/client/unlogged/img/login-logo-icon.png', \r\n 'unlogged/img/logo.png', \r\n 'dist/unlogged/img/logo.png', \r\n 'dist/client/unlogged/img/logo.png', \r\n 'client/img/logo.png', \r\n 'dist/client/img/logo.png', \r\n 'dist/client/client/img/logo.png', \r\n 'unlogged/img/logo-128.png',\r\n 'dist/unlogged/img/logo-128.png',\r\n 'dist/client/unlogged/img/logo-128.png' \r\n ];\r\n buscar = buscar.map(n=>be.rootPath+'/'+n);\r\n buscar.push(__dirname+'/../for-client/img/login-logo-icon.png');\r\n for(var nombre of buscar){\r\n try{\r\n await fs.stat(nombre)\r\n break;\r\n }catch{}\r\n }\r\n MiniTools.serveFile(nombre/*,[['Content-Type', 'image/png']]*/)(req,res,next);\r\n });\r\n be.clientIncludesCompleted(null).filter(x => x.module).forEach(function (moduleDef) {\r\n if(baseUrl=='/'){\r\n baseUrl='';\r\n } \r\n let baseLib = baseUrl + '/' + (moduleDef.path ? moduleDef.path : be.esJavascript(moduleDef.type)? 'lib': 'css');\r\n resolve_module_dir(moduleDef.module, moduleDef.modPath, moduleDef.file ?? '.')\r\n try {\r\n var allowedExts=(moduleDef.type=='js'?['js','map']:[moduleDef.type]);\r\n mainApp.use(baseLib, serveContent(resolve_module_dir(moduleDef.module, moduleDef.modPath), { allowedExts }));\r\n if(moduleDef.ts){\r\n if(typeof moduleDef.ts === \"object\"){\r\n console.log('serve:',baseUrl+ '/' + moduleDef.ts.url, resolve_module_dir(moduleDef.module, moduleDef.ts.path));\r\n mainApp.use(baseUrl+ '/' + moduleDef.ts.url, serveContent(resolve_module_dir(moduleDef.module, moduleDef.ts.path), { allowedExts: 'ts' }));\r\n }else{\r\n mainApp.use(baseUrl+ '/' + moduleDef.ts, serveContent(resolve_module_dir(moduleDef.module, moduleDef.modPath).replace(Path.sep+'lib'+Path.sep,Path.sep+'src'+Path.sep), { allowedExts: 'ts' }));\r\n mainApp.use(baseUrl+ '/lib/' + moduleDef.ts, serveContent(resolve_module_dir(moduleDef.module, moduleDef.modPath).replace(Path.sep+'client'+Path.sep,Path.sep+'src'+Path.sep+'client'), { allowedExts: 'ts' }));\r\n }\r\n }\r\n } catch (error) {\r\n console.error('ERROR: No se pudo servir el módulo', moduleDef.module);\r\n throw error;\r\n }\r\n })\r\n\r\n // ----------------------------------------------------\r\n var skin=be.config['client-setup'].skin;\r\n var skinUrl=(skin?skin+'/':'');\r\n var optsGenericForFilesUnlogged=be.optsGenericForFiles(); \r\n var skinPaths=[Path.join(be.rootPath,'skins')];\r\n if(be.config.server.skins[skin]['local-path']){\r\n skinPaths=skinPaths.concat(be.config.server.skins[skin]['local-path']).map(function(path){\r\n return Path.join(path,skin);\r\n });\r\n }else{\r\n console.log(\"No skin local-path for \"+skin);\r\n process.exit(1);\r\n }\r\n var unloggedPaths=[];\r\n var dist=/(^|[/\\\\])dist[/\\\\]server[/\\\\]server[/\\\\]/.test(packagejson.main)?'dist/client/':regexpDistCheck.test(packagejson.main)?'dist/':'';\r\n unloggedPaths.push(Path.join(Path.resolve(be.rootPath),dist));\r\n if(dist=='dist/client/'){\r\n if(fs.existsSync('dist/unlogged/unlogged')){\r\n unloggedPaths.push('dist/unlogged/');\r\n }else{\r\n unloggedPaths.push('dist/');\r\n }\r\n }\r\n if(Path.join(__dirname,'..')!=Path.resolve(be.rootPath)){\r\n unloggedPaths.push(Path.join(__dirname,'..'));\r\n }\r\n skinPaths.concat(unloggedPaths).forEach(function(path){\r\n var pathToNodeModulesSkin=Path.join(path, 'unlogged');\r\n mainApp.use(baseUrl+(skin?'/'+skin:''),serveContent(pathToNodeModulesSkin,optsGenericForFilesUnlogged));\r\n });\r\n unloggedPaths.forEach(function(path){\r\n var pathToNodeModulesSkin=Path.join(path, 'unlogged');\r\n mainApp.use(baseUrl,serveContent(pathToNodeModulesSkin,optsGenericForFilesUnlogged));\r\n });\r\n};\r\n\r\nAppBackend.prototype.sendMail = async function sendMail(mailInfo, options){\r\n var be = this;\r\n if(be.config.mailer){\r\n if(!options || !options.event || be.config.mailer?.supervise?.event[options.event]){\r\n var transporter = nodemailer.createTransport(be.config.mailer.conn);\r\n return await transporter.sendMail({...mailInfo, ...be.config.mailer[\"mail-info\"]});\r\n }\r\n }else{\r\n if(!options.ignoreNoMailer){\r\n throw new Error(\"no mailer configured\");\r\n }\r\n }\r\n};\r\n\r\nAppBackend.prototype.getVisibleMenu = function getVisibleMenu(menu, context){\r\n return menu;\r\n};\r\n\r\nAppBackend.prototype.clientIncludes = function clientIncludes(req, opts) {\r\n const hideBEPlusInclusions = opts === true || opts && typeof opts == \"object\" && opts.hideBEPlusInclusions;\r\n opts = opts === true ? {} : opts || {}; \r\n var list = [];\r\n if (!hideBEPlusInclusions) {\r\n list = [\r\n // { type: 'js', module: 'xlsx', modPath: 'dist', file: 'xlsx.core.min.js' },\r\n { type: 'js', module: 'xlsx', modPath: 'dist', file: 'xlsx.full.min.js' },\r\n { type: 'js', module: 'require-bro' },\r\n { type: 'js', module: 'js-yaml', modPath: 'browser', file: 'js-yaml.umd.min.js' },\r\n { type: 'js', module: 'cast-error' },\r\n { type: 'js', module: 'lazy-some' },\r\n { type: 'js', module: 'like-ar' },\r\n { type: 'js', module: 'best-globals' },\r\n { type: 'js', module: 'json4all' },\r\n { type: 'js', module: 'dialog-promise', path: 'dialog-promise' },\r\n { type: 'css', module: 'dialog-promise', path: 'dialog-promise' },\r\n { type: 'js', module: 'js-to-html' },\r\n { type: 'js', module: 'moment', path: 'moment/min' },\r\n { type: 'js', module: 'pikaday', path: 'pikaday' },\r\n { type: 'css', module: 'pikaday', path: 'pikaday', modPath: 'css' },\r\n { type: 'js', module: 'big.js' },\r\n { type: 'js', module: 'type-store' },\r\n { type: 'js', module: 'typed-controls' },\r\n { type: 'js', module: 'ajax-best-promise' },\r\n { type: 'js', module: 'sql-tools' },\r\n // { type: 'js' , module: 'regexplicit'},\r\n { type: 'js', file: 'my-localdb.js', modPath:'src/for-client', ts:'src/for-client'},\r\n { type: 'js', file: 'my-websqldb.js', modPath:'src/for-client', ts:'src/for-client'},\r\n { type: 'js', file: 'my-ajax.js', path:'.', modPath:'unlogged/for-client' },\r\n ];\r\n if(opts.skipMenu){\r\n list.push({ type: 'js', file: 'my-start.js', path:'.', modPath:'unlogged/for-client' });\r\n list.push({ type: 'js', file: 'my-skin.js'});\r\n }else{\r\n list = list.concat([\r\n { type: 'js', file: 'my-things.js' },\r\n { type: 'js', file: 'my-skin.js' },\r\n { type: 'js', file: 'my-tables.js' },\r\n { type: 'js', file: 'my-inform-net-status.js' },\r\n { type: 'css', file: \"my-things.css\" },\r\n { type: 'css', file: \"my-tables.css\" },\r\n { type: 'css', file: \"my-menu.css\" },\r\n ])\r\n };\r\n var browInfo=req && this._Browsers[req.useragent.browser]||{polly:true};\r\n if(!req || browInfo.polly === true || (req.useragent.version || '0').split('.')[0] < browInfo.polly){\r\n list.unshift({ type: 'js', src: 'lib/polyfills-bro.js' })\r\n }\r\n var clientConfig = this.config[\"client-setup\"];\r\n if(clientConfig.menu === true && !opts.skipMenu){\r\n list.push({ type: 'js', file: 'my-menu.js' });\r\n }\r\n if(clientConfig.lang==='es'){\r\n list.push({ type: 'js', module: 'castellano' });\r\n }\r\n }\r\n return list;\r\n}\r\n\r\nAppBackend.prototype.clientIncludesCompleted = function clientIncludesCompleted(req, opts) {\r\n let list = this.clientIncludes(req, opts);\r\n if(opts && opts.extraFiles){\r\n list = list.concat(opts.extraFiles)\r\n }\r\n var be = this;\r\n if(this.config.devel && this.config.devel.useFileDevelopment){\r\n list=list.map(includeDef=>{\r\n if(includeDef.fileProduction){\r\n // deprecated;\r\n }\r\n if(includeDef.fileDevelopment){\r\n includeDef.file=includeDef.fileDevelopment;\r\n }\r\n return includeDef;\r\n });\r\n }\r\n var rPaths={paths:[process.cwd()]};\r\n return list.map(inclusion =>{\r\n var filename = inclusion.file? inclusion.file: (inclusion.module? Path.basename(require_resolve(inclusion.module,rPaths)): '');\r\n return changing({\r\n src: be.esJavascript(inclusion.type) ? ((inclusion.path ? inclusion.path : 'lib') + '/' + (inclusion.file ? inclusion.file : filename)) : '',\r\n href: inclusion.type == 'css' ? ((inclusion.path ? inclusion.path : 'css') + '/' + (inclusion.file ? inclusion.file : (inclusion.module + '.css'))) : ''\r\n }, inclusion);\r\n });\r\n}\r\n\r\nAppBackend.prototype.clientModules = function clientModules(req, opts) {\r\n var be = this;\r\n return { scripts: this.clientIncludesCompleted(req, opts).filter(x => be.esJavascript(x.type)).map(mod => {return { src: mod.src, type:mod.type=='mjs'?\"module\":null }})};\r\n}\r\n\r\n/**\r\n * @param {string} tableName \r\n * @param {(tableDef:typesOpe.TableDefinition, context?:TableContext)=>void} appenderFunction\r\n */\r\nAppBackend.prototype.appendToTableDefinition = function appendToTableDefinition(tableName, appenderFunction){\r\n var previousDefiniterFunction=this.getTableDefinition[tableName]\r\n if(previousDefiniterFunction==null){\r\n throw new Error(tableName+\" does not exists in getTableDefinition\")\r\n }\r\n this.getTableDefinition[tableName]=function(context){\r\n var defTable=previousDefiniterFunction(context);\r\n defTable.fields =defTable.fields ||[];\r\n defTable.foreignKeys =defTable.foreignKeys ||[];\r\n defTable.softForeignKeys =defTable.softForeignKeys ||[];\r\n defTable.detailTables =defTable.detailTables ||[];\r\n defTable.constraints =defTable.constraints ||[];\r\n defTable.sql =defTable.sql ||{};\r\n appenderFunction(defTable, context)\r\n return defTable;\r\n }\r\n}\r\n\r\n\r\nAppBackend.prototype.prepareGetTables = function prepareGetTables(){\r\n}\r\n\r\nAppBackend.prototype.getTables = function getTables(){\r\n var be=this;\r\n this.getTableDefinition=this.getTableDefinition||{};\r\n var tables=[];\r\n tables.push({path: __dirname + '/tables', name:'bitacora'});\r\n tables.push({path: __dirname + '/tables', name:'summary'});\r\n var gridBuffer = be.staticConfig['client-setup']['grid-buffer'];\r\n var offlineMode = gridBuffer && (gridBuffer === 'idbx' || gridBuffer === 'wsql');\r\n if(offlineMode){\r\n tables.push({path: __dirname + '/tables', name:'locks'});\r\n }\r\n tables.push({path: __dirname + '/tables', name:'tokens'});\r\n this.prepareGetTables();\r\n return tables.concat(\r\n likeAr(this.getTableDefinition).map(function(tableDef, tableName){\r\n if(!tableDef || typeof tableDef !==\"function\"){\r\n throw new Error(\"ERROR: tableDef of \"+JSON.stringify(tableName)+\" is not a function\")\r\n }\r\n return {name:tableName, tableGenerator:function(context){\r\n return be.tableDefAdapt(tableDef(context), context);\r\n }};\r\n }).array()\r\n );\r\n}\r\n\r\nAppBackend.prototype.csss = function csss(hideBEPlusInclusions){\r\n return this.clientIncludesCompleted(null, hideBEPlusInclusions).filter(x => x.type == 'css').map(x => x.href);\r\n};\r\n\r\nAppBackend.prototype.scanSkinFiles = function scanSkinFiles() {\r\n var be = this;\r\n var skinName = be.config['client-setup'].skin;\r\n be.activeSkinFiles = new Set(); \r\n\r\n var skinConfig = be.config.server.skins && be.config.server.skins[skinName];\r\n\r\n if (skinName && skinConfig && skinConfig['local-path']) {\r\n try {\r\n var skinPath = Path.join(Path.resolve(skinConfig['local-path']), skinName);\r\n \r\n if (fs.existsSync(skinPath)) {\r\n \r\n const walk = (currentPath) => {\r\n const entries = fs.readdirSync(currentPath, { withFileTypes: true });\r\n\r\n for (var i = 0; i < entries.length; i++) {\r\n var entry = entries[i];\r\n var fullPath = Path.join(currentPath, entry.name);\r\n\r\n if (entry.isDirectory()) {\r\n walk(fullPath);\r\n } else if (entry.isFile()) {\r\n if (entry.name.endsWith('.css') || entry.name.endsWith('.styl')) {\r\n var relativePath = Path.relative(skinPath, fullPath)\r\n .replace(/\\\\/g, '/')\r\n .replace(/^\\//, '');\r\n \r\n be.activeSkinFiles.add(relativePath);\r\n }\r\n }\r\n }\r\n };\r\n\r\n walk(skinPath);\r\n } else {\r\n console.warn(`[SKIN SCAN] No existe la carpeta del skin: ${skinPath}`);\r\n }\r\n } catch (err) {\r\n console.error(\"[SKIN SCAN] Error al inicializar:\", err);\r\n }\r\n }\r\n};\r\n\r\nAppBackend.prototype.mainPage = function mainPage(req, offlineMode, opts){\r\n var be = this;\r\n opts = opts||{};\r\n if(!opts.icons){\r\n if(!opts.icon){\r\n opts.icons={\r\n iconShortcut: \"img/logo-128.png\",\r\n icon : \"img/logo.png\",\r\n iconApple : \"img/logo.png\",\r\n }\r\n }else{\r\n opts.icons={\r\n iconShortcut: opts.icon,\r\n icon : opts.icon,\r\n iconApple : opts.icon,\r\n }\r\n }\r\n }\r\n var be=this;\r\n var attr={lang: be.config[\"client-setup\"].lang};\r\n var viewportAttrs=null;\r\n if(offlineMode && req && req.user){\r\n attr.manifest=opts.manifestPath || \"ext/app.manifest\";\r\n }\r\n var viewportContent=[];\r\n viewportContent.push('width=' + (be.config[\"client-setup\"][\"deviceWidthForMobile\"] || 'device-width'));\r\n var clientSetup = be.config[\"client-setup\"];\r\n if(clientSetup[\"initial-scale\"]){\r\n viewportContent.push('initial-scale=' + clientSetup[\"initial-scale\"])\r\n }\r\n if(clientSetup[\"minimum-scale\"]){\r\n viewportContent.push('minimum-scale=' + clientSetup[\"minimum-scale\"])\r\n }\r\n if(clientSetup[\"maximum-scale\"]){\r\n viewportContent.push('maximum-scale=' + clientSetup[\"maximum-scale\"])\r\n }\r\n if(clientSetup[\"user-scalable\"]){\r\n viewportContent.push('user-scalable=' + clientSetup[\"user-scalable\"])\r\n }\r\n viewportAttrs={name:\"viewport\", content:viewportContent.join(', ')};\r\n var cssList = be.csss();\r\n if(offlineMode){\r\n cssList.push('css/offline-mode.css');\r\n }\r\n cssList = cssList.concat((opts.extraFiles ?? []).filter((extraFile)=>extraFile.type == 'css').map((extraFile)=>extraFile.file));\r\n return html.html(attr,[\r\n html.head([\r\n html.title(be.config[\"client-setup\"]?.title),\r\n html.meta({charset:\"utf-8\"}),\r\n viewportAttrs?html.meta(viewportAttrs):null,\r\n opts.baseUrlForRelativePaths?html.base({href:`${be.config.server[\"base-url\"]}/`}):null,\r\n html.link({href: opts.icons.iconShortcut , rel: \"shortcut icon\", type: \"image/png\"}),\r\n html.link({href: opts.icons.icon , rel: \"icon\", type: \"image/png\"}),\r\n html.link({href: opts.icons.iconApple , rel: \"apple-touch-icon\"}),\r\n html.meta({name:\"format-detection\", content:\"telephone=no\"}),\r\n opts.webManifestPath?null:html.meta({name:\"apple-mobile-web-app-capable\", content:\"yes\"}),\r\n opts.webManifestPath?null:html.meta({name:\"apple-mobile-web-app-status-bar-style\", content:\"black\"}),\r\n opts.webManifestPath?null:html.meta({name:\"mobile-web-app-capable\", content:\"yes\"}),\r\n opts.webManifestPath?null:html.meta({name:\"mobile-web-app-status-bar-style\", content:\"black\"}),\r\n opts.webManifestPath?html.link({rel:\"manifest\", crossorigin:\"use-credentials\", href:opts.webManifestPath}):null,\r\n // html.meta({name:'viewport', content:'user-scalable=no, width=768'})\r\n ].concat(cssList.map(function(css){\r\n return html.link({href: css, rel: \"stylesheet\"});\r\n })).concat(cssList.map(function(css){\r\n const EXTENSIONES_SKIN = ['.css', '.styl'];\r\n var skin = be.config['client-setup'].skin;\r\n if(!skin || !be.activeSkinFiles) return null;\r\n\r\n var lastDotIndex = css.lastIndexOf('.');\r\n var cssBase = (lastDotIndex !== -1) ? css.substring(0, lastDotIndex) : css;\r\n \r\n var existsInSkin = EXTENSIONES_SKIN.some(function(ext) {\r\n return be.activeSkinFiles.has(cssBase + ext);\r\n });\r\n\r\n if (existsInSkin) {\r\n var skinUrl = skin + '/';\r\n return html.link({href: skinUrl + css, rel: \"stylesheet\"});\r\n }\r\n return null;\r\n }))),\r\n html.body({'app-version':packagejson.version},[\r\n html.div({id: \"total-layout\"}, [\r\n html.img({class:\"main-loading\", src: \"img/main-loading.gif\"}),\r\n html.div(be.messages.unlogged.loading),\r\n req.useragent.os=='iOS'&&req.useragent.version.split('.')[0]<9?html.div(`La versión del dispositivo ${req.useragent.version} no es compatible`):null\r\n ]),\r\n html.div({id: \"total-scripts\"}, be.clientModules(req,opts).scripts.map(function(scriptDef){\r\n return html.script(scriptDef);\r\n }).concat([html.script({src:'client/menu.js'})]))\r\n ]),\r\n ]);\r\n}\r\n\r\nAppBackend.prototype.addSchrödingerServices = function addSchrödingerServices(mainApp,baseUrl){\r\n var be=this;\r\n mainApp.get(baseUrl,function(req, res){\r\n /*\r\n 'url,originalUrl,path,query'.split(',').forEach(function(name){\r\n console.log('req.'+name,req[name]);\r\n });\r\n */\r\n if(!req.isAuthenticated || !req.isAuthenticated()){\r\n res.redirect(Path.posix.join(baseUrl,mainApp.loginPlusManager.opts.noLoggedUrlPath));\r\n }else{\r\n res.redirect(Path.posix.join(baseUrl,mainApp.loginPlusManager.opts.successRedirect));\r\n }\r\n });\r\n mainApp.use(baseUrl,function(req,res,next){\r\n next();\r\n })\r\n};\r\n\r\nAppBackend.prototype.addLoggedServices = function addLoggedServices(){\r\n var be = this;\r\n var skin=be.config['client-setup'].skin;\r\n var skinUrl=(skin?skin+'/':'');\r\n var slashSkin=(skin?'/'+skin:'');\r\n var imgUrl=skinUrl+'img/';\r\n be.optsGenericForAll={};\r\n if(!be.config.devel || be.config.devel['cache-content']){\r\n be.optsGenericForAll.cacheControl='private';\r\n be.optsGenericForAll.maxAge=1000*60*60*24*15;\r\n }\r\n var optsGenericForImg=changing(be.optsGenericForAll,{\r\n allowedExts:be.exts.img,\r\n });\r\n if(be.config[\"client-setup\"].menu){\r\n be.app.get('/menu',function(req,res,next){\r\n return MiniTools.serveText(be.mainPage(req, false).toHtmlDoc(),'html')(req,res,next);\r\n });\r\n var gridBuffer = be.config['client-setup']['grid-buffer'];\r\n var offlineMode = gridBuffer && (gridBuffer === 'idbx' || gridBuffer === 'wsql');\r\n if(offlineMode){\r\n be.app.get('/ext', function(req,res,next){\r\n return MiniTools.serveText(be.mainPage(req, true).toHtmlDoc(),'html')(req,res,next);\r\n });\r\n }\r\n }\r\n be.app.get('/clear-cache', function(req, res){\r\n if(be.isAdmin(req)){\r\n be.clearCaches();\r\n res.end('cache cleared')\r\n }else{\r\n res.end(403,'FORBIDEN')\r\n }\r\n })\r\n be.app.get('/lib/my-skin.js',MiniTools.serveText(`\r\n \"use strict\";\r\n myOwn.path = myOwn.path || {};\r\n myOwn.path.img='${imgUrl}';\r\n myOwn.appName='${packagejson.name}${be.config.server[\"base-url\"]}';\r\n myOwn.clientVersion='${be.config[\"client-setup\"].version}';\r\n window.addEventListener('load', function(){\r\n document.body.setAttribute('my-skin', '${skin}')\r\n });\r\n `, 'application/javascript'));\r\n be.app.use(slashSkin,serveContent(Path.join(be.config.server.skins[skin]['local-path'],skin),{allowedExts:be.exts.img.concat(['css'])}));\r\n be.app.use(slashSkin,serveContent(Path.join(be.rootPath,'skins',skin),{allowedExts:be.exts.img.concat(['css'])}));\r\n var dist=/(^|[/\\\\])dist[/\\\\]server[/\\\\]server[/\\\\]/.test(packagejson.main)?'dist/client/':regexpDistCheck.test(packagejson.main)?'dist/':'';\r\n [Path.resolve(be.rootPath,dist+'client'), Path.join(__dirname,'../for-client')].forEach(function(path){\r\n if(!fs.existsSync(path)){\r\n console.error('****************** WARNING!!!!')\r\n console.log('NO EXISTE EL path PARA EL CLIENT INCLUDES',path)\r\n if(/client.client/.test(path)){\r\n console.log('si hay server/server tiene que haber client/client');\r\n }\r\n }\r\n be.app.use(function(req,res,next){\r\n return serveContent(path,be.optsGenericForFiles(req))(req,res,next);\r\n });\r\n be.app.use('/client', function(req,res,next){\r\n return serveContent(path,be.optsGenericForFiles(req))(req,res,next);\r\n });\r\n be.app.use('/lib', function(req,res,next){\r\n return serveContent(path,be.optsGenericForFiles(req))(req,res,next);\r\n });\r\n });\r\n [\r\n {client:'client' , path:Path.resolve(be.rootPath,'src/client' )},\r\n {client:'for-client', path:Path.resolve(__dirname,'../src/for-client')},\r\n ].forEach(function(info){\r\n var path=info.path;\r\n be.app.use('/src/'+info.client, function(req,res,next){\r\n return serveContent(path,changing(be.optsGenericForFiles(req),{allowedExts:['ts']}))(req,res,next);\r\n });\r\n });\r\n be.app.use('/img',serveContent(Path.join(__dirname,'../for-client/img'), optsGenericForImg));\r\n be.app.use('/img',serveContent(Path.join(Path.dirname(require_resolve('dialog-promise')),'../img'), optsGenericForImg));\r\n if(be.config.log.session){\r\n be.app.use(function(req, res, next){\r\n console.log(new Date().getTime(),req.session,new Date().getTime() - req.session.lastNonKeepAlive > be.config.login.keepAlive*1000?'LOGOUT':'stay-in',req.cookies);\r\n try{\r\n console.log(new Date().getTime() - req.session.lastNonKeepAlive, new Date(req.session.cookie._expires).getTime() - new Date().getTime())\r\n }catch(e){\r\n }\r\n next();\r\n });\r\n }\r\n be.app.use('/keep-alive.json', function(req, res, next){\r\n try{\r\n if(new Date().getTime() - req.session.lastNonKeepAlive > be.config.login.keepAlive*1000){\r\n req.logout();\r\n // res.clearCookie(options.name);\r\n return next();\r\n }else{\r\n res.send(Math.random().toString());\r\n }\r\n }catch(err){\r\n console.log(err);\r\n console.log(err.stack);\r\n throw err;\r\n }\r\n });\r\n be.app.get('/--version',async function(req,res,next){\r\n var simpleGit = require('simple-git');\r\n var git = simpleGit(process.cwd());\r\n var info=[\r\n html.h1(be.messages.server.versions),\r\n html.h3([packagejson.name,' ',packagejson.version]),\r\n html.ul([\r\n html.li([(await git.revparse(['HEAD'])).trim()]),\r\n ...((git.tags().all || []).map(tag => html.li([tag]))),\r\n ])\r\n ];\r\n Promise.resolve().then(function(){\r\n if(be.isAdmin(req)){\r\n info=info.concat([\r\n html.h2(be.messages.server.dependences),\r\n html.ul(\r\n likeAr(packagejson.dependencies).map(function(version, name){\r\n return html.li([name,': ',version])\r\n }).array()\r\n )\r\n ])\r\n return Promise.all(\r\n ['def-config.yaml', 'local-config.yaml', 'package.json', 'last-pg-error-local.sql']\r\n .map(function(fileName){\r\n return fs.stat(fileName).then(function(stat){\r\n return html.li([fileName, ': ', stat.size/* , ' ', bestGlobals.datetime.ms(stat.mtime.getMilliseconds()).toYmdHms()*/ ]);\r\n },function(err){\r\n return html.li([fileName, ': ', err.messages]);\r\n });\r\n })\r\n ).then(function(htmls){\r\n info = info.concat([\r\n html.h2(be.messages.server.files),\r\n html.ul(htmls)\r\n ]);\r\n info = info.concat([\r\n html.h2('process'),\r\n html.ul(\r\n ['title','version','execPath','platform','arch'].map(function(attr){\r\n return html.li([attr,': ',process[attr]]);\r\n })\r\n )\r\n ]);\r\n });\r\n }\r\n }).then(function(){\r\n MiniTools.serveText(html.body(info).toHtmlDoc({title:'version'}),'html')(req,res);\r\n }).catch(MiniTools.serveErr(req,res,next));\r\n });\r\n if(be.config.log.db['on-demand']){\r\n be.app.get('/--log-db',function(req,res,next){\r\n var info=html.pre('not logging');\r\n Promise.resolve().then(function(){\r\n if(be.isAdmin(req)){\r\n if(be.setLog){\r\n be.setLog(req.query);\r\n info=[\r\n html.h1('log'),\r\n html.pre('until: '+be.config.log.db.until.toYmdHms()),\r\n html.pre('results: '+be.config.log.db.results)\r\n ];\r\n }\r\n }else{\r\n throw new Error('forbiden');\r\n }\r\n }).then(function(){\r\n MiniTools.serveText(html.body(info).toHtmlDoc({title:'loggin'}),'html')(req,res);\r\n }).catch(MiniTools.serveErr(req,res,next));\r\n });\r\n }\r\n if(be.config.db['downloadable-backup-path']){\r\n be.app.get('/backup-db.zip', function(req,res,next){\r\n if (be.can(req, 'DownloadBackup')) {\r\n MiniTools.serveFile('./local-private/backup-db.zip')(req,res,next);\r\n }\r\n })\r\n }\r\n be.app.use(function(req,res,next){\r\n // req != '/keep-alive.json'\r\n req.session.lastNonKeepAlive = new Date().getTime();\r\n next();\r\n });\r\n this.app.use('/info', async function(req,res,next){\r\n if(req.path.endsWith('.md')){\r\n var fileName=__dirname+'/../public-docs/'+req.path;\r\n var content = await fs.readFile(fileName,'utf8');\r\n var md = await markdownRender('html', content);\r\n MiniTools.serveText(md.content, 'html')(req,res);\r\n }else{\r\n serveContent(__dirname+'/../docs',be.optsGenericForFiles(req))(req,res,next);\r\n }\r\n });\r\n var logo=this.config.logo;\r\n};\r\n\r\nAppBackend.prototype.getEditableForDump = function getEditableForDump(){\r\n var be=this;\r\n var contextForDump={be:be, forDump:true, user:{}};\r\n if(be.config.login){\r\n contextForDump.user[be.config.login.userFieldName]='!dump';\r\n contextForDump.user[be.config.login.rolFieldName]='admin';\r\n }\r\n return contextForDump;\r\n};\r\n\r\nAppBackend.prototype.getContextForDump = function getContextForDump(){\r\n var be=this;\r\n var contextForDump={be:be, forDump:true, user:{}};\r\n if(be.config.login){\r\n contextForDump.user[be.config.login.userFieldName]='!dump';\r\n contextForDump.user[be.config.login.rolFieldName]='admin';\r\n }\r\n return contextForDump;\r\n};\r\n\r\nAppBackend.prototype.validateBitacora = function validateBitacora(procedureDef){\r\n var be = this;\r\n if(procedureDef.bitacora.targetTable in be.tableStructures){\r\n var contextForDump=be.getContextForDump();\r\n var tableDefFields = be.tableStructures[procedureDef.bitacora.targetTable](contextForDump).fields;\r\n var targetTableBitacoraFields = procedureDef.bitacora.targetTableBitacoraFields;\r\n for (var fieldForSearch in targetTableBitacoraFields) {\r\n var searchResult = tableDefFields.find(function findByName(field) { \r\n return field.name === targetTableBitacoraFields[fieldForSearch];\r\n });\r\n if(!searchResult){\r\n throw Error(\"Bitacora bad definition in core function '\" + procedureDef.action + \"', targetTableBitacoraField '\" + targetTableBitacoraFields[fieldForSearch] + \"' not exists in table '\" + procedureDef.bitacora.targetTable + \"'.\");\r\n }\r\n }\r\n var targetTableUpdateFieldsCondition = procedureDef.bitacora.targetTableUpdateFieldsCondition || ['init_date','end_date','has_error', 'end_status'];\r\n if(targetTableUpdateFieldsCondition){ \r\n if(targetTableUpdateFieldsCondition.length == 0){\r\n throw Error(\"Bitacora bad definition in core function '\" + procedureDef.action + \"', targetTableUpdateFieldsCondition must to be defined for table '\" + procedureDef.bitacora.targetTable + \"'.\");\r\n }\r\n targetTableUpdateFieldsCondition.forEach(function(fieldName){\r\n var searchResult = tableDefFields.find(function findByName(field) { \r\n return field.name === fieldName;\r\n });\r\n if(!searchResult){\r\n throw Error(\"Bitacora bad definition in core function '\" + procedureDef.action + \"', targetTableUpdateFieldsCondition '\" + fieldName + \"' not exists in table '\" + procedureDef.bitacora.targetTable + \"'.\");\r\n }\r\n });\r\n }else{\r\n throw Error(\"Bitacora bad definition in core function '\" + procedureDef.action + \"', targetTableUpdateFieldsCondition '\" + fieldName + \"' is null for table '\" + procedureDef.bitacora.targetTable + \"'.\");\r\n }\r\n }else{\r\n throw Error(\"Bitacora bad definition in core function '\" + procedureDef.action + \"'. '\" + procedureDef.bitacora.targetTable + \"' table defined in TargetTable not exists.\");\r\n }\r\n return true;\r\n};\r\n\r\nAppBackend.prototype.procedureDefCompleter = function procedureDefCompleter(procedureDef){\r\n procedureDef.isCompleted=true;\r\n procedureDef.withFastWindow=procedureDef.withFastWindow||true;\r\n procedureDef.method=procedureDef.method||this.defaultMethod;\r\n procedureDef.encoding=procedureDef.encoding||'JSON4all';\r\n procedureDef.resultOk=procedureDef.resultOk ?? (procedureDef.forExport ? 'showDownloadUrl' : 'showText');\r\n procedureDef.progress = procedureDef.progress ?? (procedureDef.forExport && true);\r\n procedureDef.uniqueUse = procedureDef.uniqueUse ?? !!procedureDef.forExport;\r\n procedureDef.resultErr=procedureDef.resultErr||'showError';\r\n procedureDef.resultClass=procedureDef.resultClass||'result-div';\r\n procedureDef.parameters.forEach(function(paramDef){\r\n paramDef.encoding=paramDef.encoding||'JSON4all';\r\n });\r\n procedureDef.bitacora = procedureDef.bitacora || {always: false, error: false};\r\n if(procedureDef.bitacora.always || procedureDef.bitacora.error){\r\n procedureDef.bitacora=changing({\r\n targetTable:'bitacora',\r\n targetTableBitacoraFields: {end_date: 'end_date', end_status: 'end_status', has_error: 'has_error'}\r\n },procedureDef.bitacora);\r\n this.validateBitacora(procedureDef);\r\n }\r\n return procedureDef;\r\n};\r\n\r\nAppBackend.prototype.getProcedures = function getProcedures(){\r\n return Promise.resolve(require('./procedures-table.js'));\r\n};\r\n\r\nAppBackend.prototype.tableDefAdapt = require('./table-def-adapt.js');\r\n\r\nAppBackend.prototype.tableMixin = require('./table-mixin.js');\r\n\r\nvar typeDb={ // pasar a type-store\r\n integer: 'integer',\r\n number: 'numeric',\r\n date: 'date',\r\n boolean: 'boolean',\r\n text: 'text'\r\n};\r\nvar test=typeStore.typerFrom\r\nfor(var typeName in typeStore.type){\r\n typeDb[typeName]= typeStore.typerFrom({typeName}).typeDbPg;\r\n //typeDb[typeName]=typeStore.type[typeName].typeDbPg;\r\n}\r\n\r\nAppBackend.prototype.dumpDbCreateDatabase = function dumpDbCreateDatabase(){\r\n var be = this;\r\n var db=be.db;\r\n var lines=[];\r\n var owner=db.quoteIdent(be.config.db.owner||be.config.install.dump.db.owner||be.config.db.user);\r\n if(be.config.install.dump.db.password || be.config.db[\"owner-password\"] && !be.config.db[\"for-test\"]){\r\n throw new Error(\"password must not be setted in config\");\r\n }\r\n if(be.config.install.dump.db.owner!=be.config.db.user){\r\n lines.push(`create user ${owner} ${be.config.db[\"for-test\"]?`password ${db.quoteLiteral(be.config.db[\"owner-password\"])}`:`nologin`};`);\r\n }\r\n if(!be.config.db.password){\r\n throw new Error('Lack of config.db.password in local-config');\r\n }\r\n lines.push(\"create user \"+db.quoteIdent(be.config.db.user)+\" password \"+db.quoteLiteral(be.config.db.password)+\";\");\r\n lines.push(\"create database \"+db.quoteIdent(be.config.db.database)+\" owner \"+owner+\r\n (be.config.db.tablespace?\" tablespace \"+db.quoteIdent(be.config.db.tablespace):\"\")+\r\n \";\");\r\n lines.push(\"grant connect, temporary on database \"+db.quoteIdent(be.config.db.database)+\" to \"+db.quoteIdent(be.config.db.user)+\";\");\r\n lines.push(\"\\\\c \"+db.quoteIdent(be.config.db.database));\r\n return fs.writeFile('local-db-dump-create-db.sql', lines.join('\\n')+'\\n');\r\n};\r\n\r\nAppBackend.prototype.dumpFkConstraint = function dumpFkConstraint(fk, tableDef, forced){\r\n var db=this.db;\r\n var sourceFieldList=fk.fields.map(function(pair){ return db.quoteIdent(pair.source); }).join(', ');\r\n var targetFieldList=fk.fields.map(function(pair){ return db.quoteIdent(pair.target); }).join(', ');\r\n var consName=db.quoteIdent(fk.consName?fk.consName:(tableDef.alias||tableDef.sql.tableName)+' '+(fk.alias||fk.references)+' REL');\r\n var clause =\r\n 'constraint '+consName+' '+\r\n 'foreign key ('+sourceFieldList+') '+\r\n 'references '+db.quoteIdent(fk.references)+' ('+targetFieldList+') '+\r\n (forced?\r\n ' on update no action on delete no action':\r\n (fk.onDelete?' on delete '+fk.onDelete:'')+\r\n ((fk.onUpdate||this.config.db.fkOnUpdate)?' on update '+(fk.onUpdate||this.config.db.fkOnUpdate):'')+\r\n (fk.initiallyDeferred?' initially deferred':'')\r\n );\r\n return {consName, clause, sourceFieldList};\r\n}\r\n\r\nAppBackend.prototype.isGeneratedSequence = function isGeneratedSequence(sequence, not){\r\n return sequence && ((!sequence.name && !sequence.madMax) == !not)\r\n}\r\n\r\nAppBackend.prototype.isSequenceNonGenerated = function isSequenceNonGenerated(sequence){\r\n return this.isGeneratedSequence(sequence, true);\r\n}\r\n\r\nAppBackend.prototype.dumpDbTableFields = function dumpDbTableFields(tableDef, opts = {}, complements = null){\r\n var be = this;\r\n var db = this.db;\r\n var fields=[];\r\n tableDef.fields.forEach(function(fieldDef){\r\n if(!fieldDef.clientSide && fieldDef.inTable!==false && !fieldDef.inJoin && !(tableDef.sql.fields[fieldDef.name]||{}).expr || fieldDef.inTable){\r\n var fieldType=typeDb[fieldDef.typeName]||'\"'+fieldDef.typeName+'\"';\r\n if(fieldDef.sizeByte==4){\r\n fieldType = 'integer';\r\n }\r\n fields.push(\r\n ' '+db.quoteIdent(fieldDef.name)+\r\n ' '+(fieldDef.dataLength?(fieldType=='text'?'varchar':fieldType)+'('+fieldDef.dataLength+')':fieldType)+\r\n ( be.specialSqlDefaultExpressions[fieldDef.defaultDbValue] != null ? ' default ' + be.specialSqlDefaultExpressions[fieldDef.defaultDbValue]\r\n : fieldDef.defaultDbValue != null ? ' default ' + fieldDef.defaultDbValue \r\n : be.specialSqlDefaultExpressions[fieldDef.specialDefaultValue] != null ? ' default ' + be.specialSqlDefaultExpressions[fieldDef.specialDefaultValue]\r\n : fieldDef.defaultValue != null ? ' default ' + db.quoteLiteral(fieldDef.defaultValue) \r\n : ''\r\n ) +\r\n (be.isGeneratedSequence(fieldDef.sequence)?' generated always as identity':'')+\r\n (fieldDef.generatedAs!=null?` generated always as (${fieldDef.generatedAs}) stored`:'')\r\n );\r\n if(complements){\r\n complements(fieldDef)\r\n }\r\n }\r\n });\r\n return fields\r\n}\r\n\r\nAppBackend.prototype.dumpDbSchemaPartial = async function dumpDbSchemaPartial(partialTableStructures, opts = {}){\r\n var complete = opts.complete;\r\n var be = this;\r\n var db=be.db;\r\n db.quoteInteger = function quoteInteger(integerValue){\r\n // TODO: Cambiar esta ubicación provisoria. Pasarlo a pg-promise-strict\r\n if(!/^\\d+$/.test(integerValue.toString())){\r\n throw new Error('not an integer in quoteInteger');\r\n }\r\n return integerValue;\r\n };\r\n var linesCreate=[];\r\n var searchPathline=[];\r\n var lines=[];\r\n var dataText=[];\r\n var fkLines=[];\r\n var indexLines=[];\r\n var consLines=[];\r\n var policyLines=[];\r\n var enanceLines=[];\r\n var enancePart='';\r\n var user=be.config.db.user;\r\n var owner=be.config.install.dump.db.owner||be.config.db.user;\r\n if(!isLowerIdent(user)){\r\n throw new Error(\"user malformed name\")\r\n }\r\n if(!isLowerIdent(owner)){\r\n throw new Error(\"owner malformed name\")\r\n }\r\n var schema=db.quoteIdent(be.config.db.schema);\r\n linesCreate.push(\"set role to \"+owner+\";\");\r\n var control = `-- CONTROL\r\n do $do$\r\n declare\r\n vExpectedVersion text := '${be.config.db[\"min-version\"]}';\r\n vCurrentVersion text := (select setting from pg_settings where name = 'server_version');\r\n begin\r\n if semver_to_decimal(vCurrentVersion) < semver_to_decimal(vExpectedVersion) then\r\n raise exception 'BACKEND-PLUS DUMP: Old PostrgreSQL Version % expected %', vCurrentVersion, vExpectedVersion;\r\n end if;\r\n end;\r\n $do$;\r\n do $do$\r\n declare\r\n vExpected text := 'UTF8';\r\n vCurrent text := coalesce((select setting from pg_settings where name = 'server_encoding'),'unknown');\r\n begin\r\n if vCurrent is distinct from vExpected then\r\n raise exception 'BACKEND-PLUS DUMP: PostrgreSQL server_encoding %, expected %', vCurrent, vExpected;\r\n end if;\r\n end;\r\n $do$;\r\n `;\r\n linesCreate.push(\"drop schema if exists \"+schema+' cascade;');\r\n if (be.config.install.dump[\"drop-his\"]) {\r\n linesCreate.push(\"drop schema if exists his cascade;\");\r\n }\r\n linesCreate.push(\"create schema \"+schema+';');\r\n linesCreate.push(\"grant usage on schema \"+schema+' to '+user+';');\r\n linesCreate.push(\"create schema if not exists his;\");\r\n linesCreate.push(\"grant usage on schema his to \"+user+';');\r\n if(be.config.install.dump[\"admin-can-create-tables\"]){\r\n linesCreate.push(\"grant create on schema \"+schema+' to '+user+';');\r\n }\r\n linesCreate.push('');\r\n\r\n if(!complete && opts.forDump){\r\n linesCreate.push(\"set role to \"+owner+\";\");\r\n }\r\n searchPathline.push(\"set search_path = \"+schema+', public;');\r\n searchPathline.push(\"set client_encoding = 'UTF8';\");\r\n searchPathline.push('');\r\n /*eslint guard-for-in: 0*/\r\n /*eslint no-loop-func: 0*/\r\n /*jshint loopfunc:true */\r\n var contextForDump=be.getContextForDump();\r\n var functionLines = (await be.getDbFunctions(opts)).map(fdef=>fdef.dumpText);\r\n var tablesWithStrictSequence={}\r\n for(var tableName in partialTableStructures) if(partialTableStructures.hasOwnProperty(tableName)){\r\n try{\r\n var tableDef=partialTableStructures[tableName](contextForDump);\r\n if(!tableDef.adapted){\r\n if(!tableDef.fields){\r\n throw new Error('DUMP ERROR. '+tableName+' without fields')\r\n }\r\n tableDef=be.tableDefAdapt(tableDef);\r\n }\r\n var fieldsForSequences=[];\r\n var cualQuoteTableName=(tableDef.schema?db.quoteIdent(tableDef.schema)+'.':'')+db.quoteIdent(tableDef.sql.tableName);\r\n if(tableDef.sql.isTable){\r\n if(tableDef.sql.viewBody){\r\n throw new Error('table '+tableDef.sql.tableName+' has viewBody. It must has isTable=false');\r\n }\r\n lines.push('create table '+cualQuoteTableName+' (');\r\n var fields = be.dumpDbTableFields(tableDef, opts,\r\n function complements(fieldDef){\r\n if(be.isGeneratedSequence(fieldDef.sequence)){\r\n tablesWithStrictSequence[tableName]={}\r\n }\r\n if(fieldDef.typeName==='text' && !fieldDef.allowEmptyText){\r\n consLines.push(\r\n 'alter table '+cualQuoteTableName+\r\n ' add constraint '+db.quoteIdent(fieldDef.name+\"<>''\")+\r\n ' check ('+db.quoteIdent(fieldDef.name)+\"<>'');\"\r\n );\r\n }\r\n if(fieldDef.options){\r\n consLines.push(\r\n 'alter table '+cualQuoteTableName+\r\n ' add constraint '+db.quoteIdent(fieldDef.name+\" invalid option\")+\r\n ' check ('+db.quoteIdent(fieldDef.name)+\r\n ` in (${fieldDef.options.map(opt=>db.quoteLiteral(opt.option===undefined?opt:opt.option))}) );`\r\n );\r\n }\r\n if(fieldDef.nullable===false || fieldDef.dbNullable===false){\r\n consLines.push(\r\n 'alter table '+cualQuoteTableName+\r\n ' alter column '+db.quoteIdent(fieldDef.name)+' set not null;'\r\n );\r\n }\r\n if(be.isSequenceNonGenerated(fieldDef.sequence)){\r\n fieldsForSequences.push(fieldDef);\r\n }\r\n }\r\n );\r\n lines.push(fields.join(', \\n'));\r\n if(tableDef.primaryKey){\r\n lines.push(', primary key ('+tableDef.primaryKey.map(function(name){ return db.quoteIdent(name); }).join(', ')+')');\r\n if(!opts.skipEnance && !tableDef.sql.skipEnance){\r\n enanceLines.push(\r\n 'PERFORM enance_table('+db.quoteLiteral(tableDef.sql.tableName)+','+db.quoteLiteral(\r\n tableDef.primaryKey.join(',')\r\n )+');'\r\n );\r\n }\r\n }\r\n lines.push(');');\r\n //TODO: REFACTOR: Hacerlo mas sencillo\r\n // este codigo se encarga de convertir a rights de sql nuestros propios rights\r\n // por ej (import -> [insert, update]) \r\n var allows = tableDef.allow;\r\n var appToSqlRights = {'import': ['insert', 'update'], 'export': ['select'], 'deleteAll': ['delete']};\r\n [ 'import', 'export', 'deleteAll'].filter(function(right){\r\n return allows[right];\r\n }).forEach(function(right){\r\n appToSqlRights[right].forEach(function(sqlRight){\r\n allows[sqlRight] = true;\r\n })\r\n });\r\n var sqlRights = ['select', 'insert', 'update', 'delete'].filter(function(right){\r\n return allows[right];\r\n });\r\n if(tableDef.sql.isReferable){\r\n sqlRights.push('references')\r\n }\r\n sqlRights=sqlRights.join(', ')\r\n if(sqlRights){\r\n lines.push('grant '+sqlRights+' on '+cualQuoteTableName+' to '+user+';');\r\n }\r\n if (user != owner){\r\n lines.push('grant all on '+cualQuoteTableName+' to '+owner+';');\r\n }\r\n tableDef.foreignKeys.map(function(fk){\r\n var { clause:fullClause, sourceFieldList } = be.dumpFkConstraint(fk, tableDef);\r\n var indexName=db.quoteIdent(sourceFieldList.replace(/[ \"]/g,'')+' 4 '+tableDef.sql.tableName+' IDX');\r\n if(indexName.length>63){\r\n indexName=db.quoteIdent(fk.consName?fk.consName+' IDX':(tableDef.alias||tableDef.sql.tableName)+' '+fk.references+' IDX');\r\n }\r\n indexLines.push('create index '+indexName+' ON '+cualQuoteTableName+' ('+sourceFieldList+');');\r\n fkLines.push('alter table '+cualQuoteTableName+\r\n ' add '+fullClause+';'\r\n );\r\n });\r\n if(tableDef.sql.constraintsDeferred){\r\n var fkEnabling=tableDef.foreignKeys.filter(fk=>fk.forceDeferrable).map(function(fk){\r\n var {consName, clause:clauseFalse} = be.dumpFkConstraint(fk, tableDef, false);\r\n return `\r\n if enable then\r\n ALTER TABLE ${cualQuoteTableName} ADD ${clauseFalse};\r\n else\r\n ALTER TABLE ${cualQuoteTableName} DROP constraint ${consName};\r\n end if;\r\n `\r\n });\r\n if(fkEnabling.length){\r\n functionLines.push(\r\n `create or replace function ${(tableDef.schema?be.db.quoteIdent(tableDef.schema)+'.':'')+be.db.quoteIdent(`${tableDef.tableName}_toggle_consts`)}(enable boolean) returns text\r\n language plpgsql security definer as \\n$BODY$\\nbegin`+fkEnabling.join('')+' return $$ok$$;\\nend;\\n$BODY$;\\n'\r\n );\r\n }\r\n }\r\n tableDef.constraints.map(function(cons){\r\n var sql;\r\n var prefix = 'alter table '+cualQuoteTableName+' add '+\r\n (cons.consName?'constraint '+db.quoteIdent(cons.consName)+' ':'');\r\n switch(cons.constraintType){\r\n case 'unique': \r\n sql='('+cons.fields.map(function(field){ return db.quoteIdent(field); }).join(', ')+')';\r\n if(cons.where){\r\n if(cons.consName == null){\r\n console.error('create unique index constraint: must include consName in ',cons);\r\n }\r\n prefix = 'create unique index '+db.quoteIdent(cons.consName)+' on '+cualQuoteTableName;\r\n sql += 'where ' + cons.where;\r\n }else{\r\n prefix += 'unique ';\r\n }\r\n break;\r\n case 'check': \r\n sql='check ('+cons.expr+')';\r\n break;\r\n case 'exclude': \r\n sql=`exclude using ${cons.using} (${cons.fields.map(f => typeof f == \"string\"?`${f} WITH =`:`${f.fieldName} WITH ${f.operator}`).join(', ')})${cons.where ? ` WHERE (${cons.where})`:``}`;\r\n break;\r\n default:\r\n throw new Error('constraintType not implemented: '+cons.constraintType);\r\n }\r\n consLines.push(\r\n prefix + sql + ';'\r\n );\r\n });\r\n lines.push(tableDef.sql.postCreateSqls);\r\n lines.push('');\r\n await Promise.all(fieldsForSequences.map(async function(fieldDef) {\r\n var sequence = fieldDef.sequence;\r\n if (sequence.name) {\r\n if (sequence.madMax) throw new Error('a sequence with madMax cannot have name');\r\n lines.push(\"CREATE SEQUENCE \"+db.quoteIdent(sequence.name)+\" START \"+db.quoteInteger(sequence.firstValue||1)+\";\");\r\n lines.push(\r\n \"ALTER TABLE \"+cualQuoteTableName+\r\n \" ALTER COLUMN \"+db.quoteIdent(fieldDef.name)+\r\n (sequence.prefix==null\r\n ?\" SET DEFAULT nextval(\"+db.quoteLiteral(sequence.name)+\"::regclass);\"\r\n :\" SET DEFAULT (\"+db.quoteLiteral(sequence.prefix)+\" || nextval(\"+db.quoteLiteral(sequence.name)+\"::regclass)::text);\"\r\n )\r\n );\r\n lines.push('GRANT USAGE, SELECT ON SEQUENCE '+db.quoteIdent(sequence.name)+' TO '+user+';');\r\n } else if (sequence.madMax) {\r\n lines.push(await pgTriggers.dumpMaxIdTrigger(tableDef.sql.tableName, fieldDef.name, {grouping: sequence.madMax.grouping, firstValue: sequence.firstValue}));\r\n } else {\r\n throw new Error('a sequence without madMax nor name');\r\n }\r\n }));\r\n lines.push('');\r\n if(tableDef.sql.policies.enabled){\r\n policyLines.push(`ALTER TABLE ${cualQuoteTableName} ENABLE ROW LEVEL SECURITY;`);\r\n [null, 'all', 'select', 'insert', 'update', 'delete'].forEach((command)=>{\r\n var polcom=tableDef.sql.policies[command] ?? {using: `true`, permissive:true};\r\n if(polcom?.using || polcom?.check){\r\n policyLines.push(`CREATE POLICY ${be.db.quoteIdent(polcom.name ?? `bp ${command ?? `base`}`)} ON ${cualQuoteTableName} `+\r\n `AS ${polcom.permissive ? `PERMISSIVE` : `RESTRICTIVE`} FOR ${command ?? `all`} TO ${be.config.db.user}`+\r\n (polcom.using? ` USING ( ${polcom.using} )`:'')+\r\n (polcom.check?` WITH CHECK ( ${polcom.check} )`:'')+';'\r\n );\r\n } \r\n });\r\n }\r\n }else{\r\n if(tableDef.sql.viewBody){\r\n lines.push('create or replace view '+cualQuoteTableName+' (');\r\n var viewFields=[];\r\n tableDef.fields.forEach(function(fieldDef){\r\n if(!fieldDef.clientSide && fieldDef.inTable!==false && !(tableDef.sql.fields[fieldDef.name]||{}).expr || fieldDef.inView){\r\n viewFields.push(db.quoteIdent(fieldDef.name));\r\n }\r\n });\r\n lines.push(' '+viewFields.join(', '));\r\n lines.push(') as '+tableDef.sql.viewBody+';');\r\n lines.push('grant select on '+cualQuoteTableName+' to '+user+';');\r\n lines.push('');\r\n }\r\n }\r\n }catch(err){\r\n err.context=(err.context||'')+'dumping structure of table '+tableName+' \\n ';\r\n throw err;\r\n }\r\n }\r\n lines.push(`\r\ncreate or replace procedure set_app_user(p_username text)\r\n security definer language plpgsql\r\nas\r\n$body$\r\ndeclare\r\n ${be.config.login.infoFieldList.map(fieldName => `\r\n ${db.quoteIdent('v_'+fieldName)} text;`\r\n ).join('')}\r\nbegin\r\n if p_username = '!login' then\r\n ${be.config.login.infoFieldList.map(fieldName => `\r\n set backend_plus._${fieldName} = '!';`).join('')}\r\n\r\n set backend_plus._mode = login;\r\n else\r\n select ${be.config.login.infoFieldList.map(fieldName => db.quoteIdent(fieldName)).join(', ')}\r\n into ${be.config.login.infoFieldList.map(fieldName => db.quoteIdent('v_'+fieldName)).join(', ')}\r\n \r\n from ${(be.config.login.from ?? (\r\n (be.config.login.schema?be.db.quoteIdent(be.config.login.schema)+'.':'')+\r\n be.db.quoteIdent(be.config.login.table)))}\r\n where ${db.quoteIdent(be.config.login.userFieldName)} = p_username;\r\n ${be.config.login.infoFieldList.map(fieldName => `\r\n perform set_config('backend_plus._${fieldName}', v_${fieldName}, false);`).join('')}\r\n\r\n set backend_plus._mode = normal;\r\n end if;\r\n perform set_config('backend_plus._user', p_username, false);\r\nend; \r\n$body$;\r\n\r\n `)\r\n var enancePart= 'do $SQL_ENANCE$\\n begin\\n' + enanceLines.join('\\n')+'\\n' + 'end\\n$SQL_ENANCE$;';\r\n var someNotFound=false;\r\n try {\r\n var allTableData = await fs.readFile('install/local-data-dump.psql','utf-8');\r\n } catch(err) {\r\n if (err.code != 'ENOENT') throw err;\r\n try {\r\n var allTableContent = await fs.readFile('install/local-dump.psql','utf-8');\r\n var startIndex = allTableContent.indexOf('-- Data for Name: ');\r\n console.log('startIndex', startIndex);\r\n var lastUseful = allTableContent.lastIndexOf('\\nSELECT pg_catalog.setval') \r\n console.log('lastUseful', lastUseful);\r\n if (lastUseful == -1) lastUseful = allTableContent.lastIndexOf('\\n\\\\.\\n');\r\n console.log('lastUseful', lastUseful);\r\n var lastIndex = allTableContent.indexOf('\\n--', lastUseful);\r\n console.log('lastIndex', lastIndex);\r\n allTableData = allTableContent.slice(startIndex, lastIndex);\r\n } catch(err) {\r\n if (err.code != 'ENOENT') throw err;\r\n //throw err;\r\n }\r\n }\r\n if (allTableData) {\r\n var prepa = await be.getDataDumpTransformations(allTableData)\r\n dataText = [\r\n '-- BEGIN DATA FROM DUMP',\r\n ...prepa.prepareTransformationSql,\r\n prepa.rawData,\r\n ...prepa.endTransformationSql,\r\n '-- END DATA FROM DUMP'\r\n ]\r\n } else {\r\n await Promise.all(likeAr(partialTableStructures).map(function(tableDef, tableName, _, i){\r\n if(tableDef?.sql?.isTable === false) return;\r\n // TODO: buscar\r\n var buscarEn=[Path.join('local-install',tableName+'.tab')].concat(\r\n be.appStack.map(function(stackNode){\r\n return Path.join(stackNode.path,'../install',tableName+'.tab').replace(regexpDistReplacer,'$1$2');\r\n })\r\n );\r\n if(be.config.install['table-data-dir'] instanceof Array){\r\n buscarEn=be.config.install['table-data-dir'].map(path=>Path.join(path,tableName+'.tab')).concat(buscarEn);\r\n }else if(be.config.install['table-data-dir']){\r\n buscarEn=[].concat(Path.join(be.config.install['table-data-dir'],tableName+'.tab')).concat(buscarEn);\r\n }\r\n if(!i) console.log('buscar en', buscarEn)\r\n return locatePath(buscarEn).then(function(theTableFileName){\r\n if(theTableFileName==undefined){\r\n var err = new Error('not found');\r\n err.code='ENOENT'\r\n throw err;\r\n }\r\n return fs.readFile(theTableFileName, {encoding:'UTF8'}).then(function(content){\r\n return {path:Path.relative(process.cwd(),theTableFileName),content};\r\n });\r\n }).then(function({path,content}){\r\n dataText.push(\"\\n-- table data: \"+path);\r\n var lines;\r\n var rows;\r\n var tableDef=partialTableStructures[tableName](contextForDump);\r\n var filterField=function(fieldName){\r\n if(fieldName==null){\r\n throw new Error('ERROR empty name or extra column in '+tableName+'.tab')\r\n }\r\n var defField=tableDef.field[fieldName];\r\n if(!defField && !fieldName.startsWith('!')){\r\n throw new Error('field '+fieldName+' does no exists in .tab for '+tableName+' in '+path);\r\n }\r\n return !fieldName.startsWith('!') && defField.inTable!==false && !defField.inJoin && (!defField.clientSide || defField.serverSide) && !defField.generatedAs;\r\n }\r\n if(/[-[]/.test(content[0])){\r\n var filterField2=function(_value,fieldName){\r\n var fieldDef = tableDef.field[fieldName];\r\n if(!fieldDef){\r\n console.log('lack of field',fieldName,'in table',tableName,'filtering fields')\r\n }\r\n return (!fieldDef.sequence || fieldDef.sequence.name) && filterField(fieldName);\r\n }\r\n lines = jsYaml.load(content);\r\n lines.forEach(function(line){\r\n var dataString=\"insert into \"+db.quoteIdent(tableName)+\" (\"+\r\n likeAr(line).filter(filterField2).keys().map(db.quoteIdent).join(', ')+\r\n ') values ('+\r\n likeAr(line).filter(filterField2).map(function(value){\r\n return db.quoteNullable(value);\r\n }).join(', ')+\");\\n\";\r\n dataText.push(dataString);\r\n });\r\n rows=lines;\r\n }else{\r\n var lines=content.split(/\\r?\\n/)\r\n .filter(line => !(/^[-| ]*$/.test(line)) )\r\n .map(line => splitRawRowIntoRow(line))\r\n .filter(line => line.length>1 || line.length==1 && line[0].trim() );\r\n if(lines.length>1){\r\n if(lines[0][0].startsWith('\\ufeff')){\r\n lines[0][0]=lines[0][0].replace('\\ufeff','')\r\n }\r\n rows=lines.slice(1);\r\n var filteredFieldDef = lines[0].filter(filterField);\r\n if(tablesWithStrictSequence[tableName]){\r\n var dataString=\"COPY \"+db.quoteIdent(tableName)+\" (\"+\r\n filteredFieldDef.map(db.quoteIdent).join(', ')+\r\n ') FROM stdin;\\n'+\r\n rows.map(function(line){\r\n return line.filter(function(_,i){ return filterField(lines[0][i]);}).map(function(value,i){\r\n var def = tableDef.field[filteredFieldDef[i]];\r\n return value==='' ? (\r\n def.allowEmptyText && ('nullable' in def) && !def.nullable ? '' : '\\\\N'\r\n ): value.replace(/\\\\/g,'\\\\\\\\').replace(/\\t/g,'\\\\t').replace(/\\n/g,'\\\\n').replace(/\\r/g,'\\\\r');\r\n }).join('\\t')+'\\n';\r\n }).join('')+'\\\\.\\n';\r\n }else{\r\n var dataString=\"insert into \"+db.quoteIdent(tableName)+\" (\"+\r\n filteredFieldDef.map(db.quoteIdent).join(', ')+\r\n ') values\\n'+\r\n rows.map(function(line){\r\n return \"(\"+line.filter(function(_,i){ return filterField(lines[0][i]);}).map(function(value,i){\r\n var def = tableDef.field[filteredFieldDef[i]];\r\n if(def == null) {\r\n throw Error(\"no se encuentra la columna \"+filteredFieldDef[i]+\" en \"+tableName);\r\n }\r\n return value==='' ? (\r\n def.allowEmptyText && ('nullable' in def) && !def.nullable ? \"''\" : 'null' \r\n ) : db.quoteNullable(value);\r\n }).join(', ')+\")\";\r\n }).join(',\\n')+';\\n';\r\n }\r\n dataText.push(dataString);\r\n }\r\n // tablesWithStrictSequence[tableName]\r\n }\r\n }).catch(function(err){\r\n if(err.code=='ENOENT'){\r\n if(!be.config.install.dump[\"skip-content\"]){\r\n console.log('skipping content for','install/'+tableName+'.tab');\r\n someNotFound=true;\r\n }\r\n }else{\r\n throw err;\r\n }\r\n });\r\n }).array())\r\n if(someNotFound){\r\n console.log('silence \"skipping content\" messages in \"local-config.yaml\".install.dump.skip-content=true');\r\n }\r\n }\r\n let installFolders = be.config.install.dump.folders ?? ['install']\r\n let texts = await Promise.all(\r\n [\r\n ['prepare.sql'],\r\n ['pre-adapt.sql'].concat(be.config.install.dump.scripts['pre-adapt']),\r\n ['adapt.sql'],\r\n be.config.install.dump.scripts['prepare'] ?? [],\r\n be.config.install.dump.scripts['post-adapt'] ?? []\r\n ]\r\n .map(async function(fileNames){\r\n if (!fileNames) return '';\r\n var i = 0; \r\n return (await Promise.all(fileNames.map(async fileName => {\r\n var content;\r\n do {\r\n var folder = installFolders[i];\r\n try{\r\n content = await fs.readFile(be.rootPath+'/'+folder+'/'+fileName, {encoding:'UTF8'});\r\n } catch (err) {\r\n if(err.code!='ENOENT') throw err;\r\n }\r\n i++;\r\n } while (i < installFolders.length && !content);\r\n if (!content) {\r\n return '-- no '+fileName+'\\n';\r\n } else {\r\n return '-- '+folder+'/'+fileName+'\\n'+content;\r\n };\r\n }))).join('\\n')\r\n })\r\n );\r\n\r\n var common = (await Promise.all(be.appStack.map(async function(stackNode){\r\n var common = [];\r\n for (var prefix of ['../', '../../']) {\r\n try {\r\n var dirName = Path.join(stackNode.path,prefix+'install').replace(regexpDistReplacer,'$1$2')\r\n var list = await fs.readdir(dirName);\r\n } catch (err) {\r\n if (err.code != 'ENOENT') throw err;\r\n var list = [];\r\n }\r\n for(var fileName of list){\r\n if (fileName.endsWith('-fun.sql') && !opts?.commonFunsToDisable?.includes(fileName)) {\r\n common.push(await fs.readFile(Path.join(dirName,fileName), 'utf-8'));\r\n }\r\n }\r\n }\r\n return common.join('\\n');\r\n }))).join('\\n');\r\n\r\n var prepareList=(be.config.install.dump.scripts['prepare']||[]);\r\n var mainSql=(\r\n (complete? linesCreate.join('\\n'): '')+\r\n (complete||opts.forDump? searchPathline.join('\\n'): '')+\r\n '\\n-- common'+\r\n common+'\\n'+\r\n control+'\\n'+\r\n (complete? '\\n\\n--prepare.sql\\n'+ texts[0]+'\\n\\n' :'' )+\r\n (complete? texts[3] + '\\n\\n' : '' )+\r\n '\\n-- functions\\n' + functionLines.join('\\n')+\r\n '\\n-- lines \\n' + lines.join('\\n')+\r\n (complete? ('\\n\\n-- pre-ADAPTs\\n'+texts[1]+'\\n\\n') : '' )+\r\n (complete? ('\\n\\n-- DATA\\n'+ dataText.join('\\n')) : '' )+ \r\n (complete? ('\\n\\n-- ADAPTs\\n'+ texts[2]+'\\n\\n') : '' )+\r\n '\\n-- conss\\n' + consLines.join('\\n')+\r\n '\\n-- FKs\\n' + fkLines.join('\\n')+\r\n '\\n-- index\\n' + indexLines.join('\\n')+\r\n '\\n-- policies\\n' + policyLines.join('\\n')+\r\n (complete? texts[4] + '\\n\\n' : '' )+\r\n (complete? (be.config.install.dump.enances==='inline'?enancePart:'') :'')\r\n ).replace(/\\uFEFF/g /*inner BOM replacing*/,'\\n\\n').replace(\r\n new RegExp(escapeRegExp(db.quoteIdent(be.config.install.dump.db[\"owner4special-scripts\"])),'g'),\r\n db.quoteIdent(be.config.install.dump.db.owner)\r\n ).replace(\r\n new RegExp(escapeRegExp(db.quoteIdent(be.config.install.dump.db[\"user4special-scripts\"])),'g'),\r\n db.quoteIdent(be.config.db.user)\r\n );\r\n if(be.config.install.dump.db[\"apply-generic-user-replaces\"]){\r\n mainSql=mainSql.replace(/((\\bto\\s|=)\\s*\"?)\\w+(_user\\b)/ig, \"$1\"+user);\r\n mainSql=mainSql.replace(/((\\bto\\s|=)\\s*\"?)\\w+(_owner\\b)/ig, \"$1\"+owner);\r\n }\r\n return {mainSql,enancePart};\r\n}\r\n\r\nAppBackend.prototype.getDbFunctions = async function (){\r\n return [];\r\n}\r\n\r\n/** @param {{complete:boolean, tableNames:string[]}} opts */\r\nAppBackend.prototype.dumpDbSchema = async function dumpDbSchema(opts){\r\n var be = this;\r\n var {mainSql,enancePart} = await be.dumpDbSchemaPartial(\r\n opts.complete?be.tableStructures:likeAr(be.tableStructures).filter((_, name)=>opts.tableNames.includes(name)), \r\n opts\r\n )\r\n mainSql=be.config.install.dump.db.extensions.map(function(extension){\r\n return ({\r\n gist: \"create extension if not exists btree_gist;\",\r\n pg_trgm: \"create extension if not exists pg_trgm;\",\r\n pgcrypto: \"create extension if not exists pgcrypto;\"\r\n }[extension]||('--unknown exension '+extension))+'\\n';\r\n }).join('')+mainSql;\r\n await fs.writeFile('local-db-dump.sql', mainSql);\r\n if(be.config.install.dump.enances==='file'){\r\n await fs.writeFile('local-db-dump-enances.sql', enancePart);\r\n }\r\n};\r\n\r\nAppBackend.prototype.getDataDumpTransformations = function getDataDumpTransformations(rawData){\r\n return Promise.resolve({rawData, prepareTransformationSql:[], endTransformationSql:[]});\r\n}\r\n\r\nAppBackend.prototype.queryValuesOfUniqueRow = function queryValuesOfUniqueRow(context, defTable, pkValues){\r\n var be=this;\r\n return context.client.query(\r\n \"SELECT \"+defTable.sql.select.join(', ')+\r\n \" FROM \"+defTable.sql.from.replace(/\\/\\*\\{insertIfNotUpdate:[^}]*\\}\\*\\//gm,' true ')+\r\n \" WHERE \"+defTable.primaryKey.map(function(fieldName, i){\r\n return be.db.quoteIdent(defTable.alias)+'.'+be.db.quoteIdent(fieldName)+\" = $\"+(i+1);\r\n }).join(\" AND \"),\r\n defTable.primaryKey.map(function(fieldName, i){\r\n return pkValues[fieldName];\r\n })\r\n ).fetchUniqueRow().then(function(result){\r\n return result;\r\n });\r\n};\r\n\r\n/** @param {{complete:boolean, tableNames:string[]}} opts */\r\nAppBackend.prototype.dumpDb = function dumpDb(opts){\r\n if(!this.fieldDomain){\r\n this.fieldDomain={};\r\n }\r\n return Promise.all([\r\n this.dumpDbCreateDatabase(),\r\n this.dumpDbSchema(opts)\r\n ]);\r\n};\r\n\r\nAppBackend.prototype.inputTransformers={\r\n keepAll:{},\r\n normal:{\r\n replaceNewLines:' ',\r\n simplificateSpaces:true\r\n },\r\n upper:{\r\n replaceNewLines:' ',\r\n simplificateSpaces:true,\r\n fun:t=>t.toLocaleUpperCase()\r\n }\r\n}\r\n\r\nAppBackend.prototype.transformInput = function transformInput(fieldDef, value){\r\n var be = this;\r\n if(fieldDef.typeName == 'text'){\r\n var idTransformer = fieldDef.transformer ?? be.config.data.transformers.text;\r\n var parameters = be.inputTransformers[idTransformer] ?? idTransformer ?? {}\r\n if(value != null){\r\n if(parameters.replaceNewLines != null){\r\n value = value.replace(/\\r|\\n/g,' ').trim()\r\n }\r\n if(parameters.simplificateSpaces){\r\n value = value.replace(/(\\s|\\u00A0)+/g,' ').trim()\r\n }\r\n if(parameters.fun){\r\n value = parameters.fun(value)\r\n }\r\n }\r\n }\r\n return value;\r\n}\r\n\r\n/** \r\n * xxxparam {{ action:string, parameters:any, conRegistro:boolean, conPadron:boolean, fileName?:string, csvFileName?:string, csvSeparator?:string, queries:{titulo:string, sql:string, params:string[]}[] }}\r\n * @param {{title:string, rows:Record[]}[]} result\r\n * @returns {Promise}\r\n */\r\n\r\nAppBackend.prototype.exportacionesGenerico = async function exportacionesGenerico(result, procedureDef, context, params, files){\r\n var {csvFileName, fileName} = procedureDef.forExport\r\n if (!(result instanceof Array)) {\r\n if (!result || !(result instanceof Object)) {\r\n throw new Error (\"exportacionesGenerico debe recibir {title:string, rows:Record[]}[]\")\r\n }\r\n result = [result]\r\n }\r\n if (typeof result[0].title !== \"string\" || typeof result[0].rows !== \"object\" && !(result[0].rows instanceof Array) ) {\r\n throw new Error (\"exportacionesGenerico debe recibir {title:string, rows:Record[]}\")\r\n }\r\n csvFileName = result[0].csvFileName ?? csvFileName;\r\n fileName = result[0].fileName ?? fileName;\r\n await bestGlobals.sleep(100);\r\n context.informProgress({message:`buscando archivos recién generados`})\r\n /** @type {{url:string, label:string}[]} */\r\n var hayGenerados = [];\r\n const MINUTESms = 60*1000;\r\n var buscarGenerados = async (name) => {\r\n if(name){\r\n try{\r\n var stat = await fs.stat(`dist/client/${name}`);\r\n if(stat && stat.mtimeMs > new Date().getTime() - 10 * MINUTESms){\r\n hayGenerados.push(\r\n {url:name, label:name+' generado '+stat.mtime.toLocaleDateString(\"es-ES\")}\r\n )\r\n }\r\n }catch(err){\r\n var code = err.code\r\n if(code != 'ENOENT') throw err;\r\n }\r\n }\r\n }\r\n if (!procedureDef.forExport.generarInmediato) {\r\n await buscarGenerados(csvFileName);\r\n await buscarGenerados(fileName);\r\n }\r\n if(hayGenerados.length>0){\r\n return hayGenerados;\r\n }\r\n await bestGlobals.sleep(100);\r\n if(csvFileName){\r\n async function writeLine(f, values){\r\n return f.write(values.map(function q(value){\r\n if(value==null) return '';\r\n if(value instanceof Date){\r\n return value.toLocaleDateString(\"es-ES\");\r\n }\r\n // @ts-expect-error no reconoce el parámetro\r\n value = value.toLocaleString(\"es-ES\")\r\n if(/[,\"]/.test(value)){\r\n return '\"'+value.replace(/\"/g, '\"\"')+'\"'\r\n }else{\r\n return value\r\n }\r\n }).join(',')+\"\\n\", null, 'utf-8');\r\n }\r\n context.informProgress({message:`guardando CSV: ${csvFileName}`})\r\n try {\r\n var f = await fsP.open(`dist/client/${csvFileName}`,'w')\r\n await f.write('\\ufeff',null,'utf-8');\r\n if (result[0].rows.length) {\r\n await writeLine(f,Object.keys(result[0].rows[0]))\r\n } else {\r\n await writeLine(f,['no data']);\r\n }\r\n for (var row of result[0].rows) {\r\n await writeLine(f,Object.values(row));\r\n }\r\n } finally {\r\n await f.close();\r\n }\r\n }\r\n if(fileName){\r\n context.informProgress({message:'armando XLSX'})\r\n var wb = XLSX.utils.book_new();\r\n result.map(({title, rows})=>{\r\n var rowsA = rows.map(row=>Object.values(row));\r\n if(rows[0]){\r\n rowsA.unshift(Object.keys(rows[0]));\r\n }\r\n var ws = XLSX.utils.aoa_to_sheet(rowsA);\r\n XLSX.utils.book_append_sheet(wb, ws, title);\r\n return ws;\r\n })\r\n context.informProgress({message:`guardando XLSX: ${fileName}`})\r\n await bestGlobals.sleep(100);\r\n await new Promise((resolve,reject)=>XLSX.writeFileAsync(`dist/client/${fileName}`,wb,{},\r\n (err)=>err?reject(err):resolve()\r\n ))\r\n }\r\n return [\r\n ...(fileName?[{url:fileName, label:csvFileName?'xlsx de control':fileName}]:[]), \r\n ...(csvFileName?[{url:csvFileName, label:fileName?'csv (formato UTF-8)':csvFileName}]:[]),\r\n ];\r\n}\r\n\r\n\r\nbackendPlus.AppBackend = AppBackend;\r\nbackendPlus.require_resolve = require_resolve;\r\n\r\nmodule.exports = backendPlus;\r\n"]}