@node-red/runtime - npm Package Compare versions

Comparing version 3.1.0-beta.4 to 3.1.0

lib/flows/Subflow.js

		@@ -482,3 +482,3 @@ /**
		}
		if ((node.type === 'complete' \|\| node.type === 'catch' \|\| node.type === 'status') && node.scope) {
		if ((node.type === 'complete' \|\| node.type === 'catch' \|\| node.type === 'status') && Array.isArray(node.scope)) {
		node.scope = node.scope.map(function(id) {
		@@ -485,0 +485,0 @@ return nodeMap[id]?nodeMap[id].id:""

lib/storage/localfilesystem/projects/git/index.js

		@@ -434,3 +434,3 @@ /**
		pull: function(cwd,remote,branch,allowUnrelatedHistories,auth,gitUser) {
		var args = ["pull"];
		var args = ["pull", "--no-rebase"];
		if (remote && branch) {
		@@ -437,0 +437,0 @@ args.push(remote);

lib/storage/localfilesystem/util.js

		@@ -74,2 +74,4 @@ /**

		const writeFileLocks = {}

		module.exports = {
		@@ -81,20 +83,18 @@ /**
		*/
		writeFile: function(path,content,backupPath) {
		var backupPromise;
		if (backupPath && fs.existsSync(path)) {
		backupPromise = fs.copy(path,backupPath);
		} else {
		backupPromise = Promise.resolve();
		writeFile: async function(path,content,backupPath) {
		if (!writeFileLocks[path]) {
		writeFileLocks[path] = Promise.resolve()
		}
		const result = writeFileLocks[path].then(async () => {
		var backupPromise;
		if (backupPath && fs.existsSync(path)) {
		await fs.copy(path,backupPath);
		log.trace(`utils.writeFile - copied ${path} TO ${backupPath}`)
		}

		const dirname = fspath.dirname(path);
		const tempFile = `${path}.$$$`;
		const dirname = fspath.dirname(path);
		const tempFile = `${path}.$$$`;
		await fs.ensureDir(dirname)

		return backupPromise.then(() => {
		if (backupPath) {
		log.trace(`utils.writeFile - copied ${path} TO ${backupPath}`)
		}
		return fs.ensureDir(dirname)
		}).then(() => {
		return new Promise(function(resolve,reject) {
		await new Promise(function(resolve,reject) {
		var stream = fs.createWriteStream(tempFile);
		@@ -115,6 +115,7 @@ stream.on('open',function(fd) {
		});
		});
		}).then(() => {
		})

		log.trace(`utils.writeFile - written content to ${tempFile}`)
		return new Promise(function(resolve,reject) {

		await new Promise(function(resolve,reject) {
		fs.rename(tempFile,path,err => {
		@@ -128,4 +129,6 @@ if (err) {
		})
		});
		});
		})
		})
		writeFileLocks[path] = result.catch(() => {})
		return result
		},
		@@ -132,0 +135,0 @@ readFile: readFile,

locales/ko/runtime.json

package.json

New alerts