diff --git a/index.js b/index.js index 4c3b298..cc7f049 100644 --- a/index.js +++ b/index.js @@ -193,7 +193,7 @@ function incrementalBackup(event, context, callback) { }; var req = change.eventName === 'REMOVE' ? 'deleteObject' : 'putObject'; - if (req === 'putObject') params.Body = JSON.stringify(change.dynamodb.NewImage); + if (req === 'putObject') params.Body = JSON.stringify(change.dynamodb.NewImage) + '\n'; s3[req](params, function(err) { if (err) console.log( diff --git a/s3-snapshot.js b/s3-snapshot.js index fe3b3d0..fe94dd1 100644 --- a/s3-snapshot.js +++ b/s3-snapshot.js @@ -41,7 +41,9 @@ module.exports = function(config, done) { stringify._writableState.objectMode = true; stringify._transform = function(data, enc, callback) { if (!data) return callback(); - callback(null, data.Body.toString() + '\n'); + var body = data.Body.toString(); + if (!body.endsWith('\n')) body += '\n'; + callback(null, body); }; var upload = s3.upload({