jjkiers/cloudron-box
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Fix some more crashes

Browse Source
This commit is contained in:
Girish Ramakrishnan
2021-08-26 18:34:32 -07:00
parent f5c169f881
commit 7413ccd22e
2 changed files with 16 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/services.js
View File

@@ -1214,7 +1214,7 @@ async function pipeRequestToFile(url, filename) {
assert.strictEqual(typeof url, 'string');
assert.strictEqual(typeof filename, 'string');
return new Promise((resolve, reject) => {
await new Promise((resolve, reject) => {
const writeStream = fs.createWriteStream(filename);
const done = once(function (error) { // the writeStream and the request can both error
@@ -1262,7 +1262,7 @@ async function restoreMySql(app, options) {
const result = await getContainerDetails('mysql', 'CLOUDRON_MYSQL_TOKEN');
return new Promise((resolve, reject) => {
await new Promise((resolve, reject) => {
reject = once(reject); // protect from multiple returns with streams
const input = fs.createReadStream(dumpPath('mysql', app.id));
@@ -1424,7 +1424,7 @@ async function restorePostgreSql(app, options) {
const result = await getContainerDetails('postgresql', 'CLOUDRON_POSTGRESQL_TOKEN');
return new Promise((resolve, reject) => {
await new Promise((resolve, reject) => {
resolve = once(resolve); // protect from multiple returns with streams
const input = fs.createReadStream(dumpPath('postgresql', app.id));
@@ -1589,7 +1589,7 @@ async function restoreMongoDb(app, options) {
const database = await addonConfigs.getByName(app.id, 'mongodb', '%MONGODB_DATABASE');
if (!database) throw new BoxError(BoxError.NOT_FOUND, 'Error restoring mongodb. No database');
return new Promise((resolve, reject) => {
await new Promise((resolve, reject) => {
reject = once(reject); // protect from multiple returns with streams
const readStream = fs.createReadStream(dumpPath('mongodb', app.id));
@@ -1800,7 +1800,7 @@ async function restoreRedis(app, options) {
const result = await getContainerDetails('redis-' + app.id, 'CLOUDRON_REDIS_TOKEN');
return new Promise((resolve, reject) => {
await new Promise((resolve, reject) => {
reject = once(reject); // protect from multiple returns with streams
let input;