From 788873e858ba3b1e238ab111aadb4beb3ff3f1f6 Mon Sep 17 00:00:00 2001
From: Johannes Zellner <johannes@cloudron.io>
Date: Thu, 20 Apr 2017 16:18:27 +0200
Subject: [PATCH] Add error callbacks for backup in filesystem and s3

---
 src/storage/filesystem.js | 4 ++++
 src/storage/s3.js         | 3 +++
 2 files changed, 7 insertions(+)

diff --git a/src/storage/filesystem.js b/src/storage/filesystem.js
index 70005326b..edab7beec 100644
--- a/src/storage/filesystem.js
+++ b/src/storage/filesystem.js
@@ -68,18 +68,22 @@ function backup(apiConfig, backupId, source, callback) {
 
         pack.on('error', function (error) {
             console.error('[%s] backup: tar stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         gzip.on('error', function (error) {
             console.error('[%s] backup: gzip stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         encrypt.on('error', function (error) {
             console.error('[%s] backup: encrypt stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         fileStream.on('error', function (error) {
             console.error('[%s] backup: out stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         fileStream.on('close', function () {
diff --git a/src/storage/s3.js b/src/storage/s3.js
index ef3f5cecc..93def6b14 100644
--- a/src/storage/s3.js
+++ b/src/storage/s3.js
@@ -91,14 +91,17 @@ function backup(apiConfig, backupId, source, callback) {
 
         pack.on('error', function (error) {
             console.error('[%s] backup: tar stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         gzip.on('error', function (error) {
             console.error('[%s] backup: gzip stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         encrypt.on('error', function (error) {
             console.error('[%s] backup: encrypt stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         pack.pipe(gzip).pipe(encrypt);