mirrors/etherpad-lite
1
0
Fork 0
mirror of https://github.com/ether/etherpad-lite.git synced 2025-04-22 16:36:15 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 33

staleCode: Async update

Browse source
This commit is contained in:
John McLear 2020-06-07 14:56:45 +01:00 • committed by GitHub
parent 0669280af0
commit 009e1d01f7
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 47 additions and 37 deletions
Download patch file Download diff file Expand all files Collapse all files

58
src/node/utils/caching_middleware.js
View file

@ -14,7 +14,6 @@
* limitations under the License.
*/
var async = require('async');
var Buffer = require('buffer').Buffer;
var fs = require('fs');
var path = require('path');
@ -145,30 +144,39 @@ CachingMiddleware.prototype = new function () {
res.write = function(data, encoding) {
buffer += data.toString(encoding);
};
res.end = function(data, encoding) {
async.parallel([
function (callback) {
var path = CACHE_DIR + 'minified_' + cacheKey;
fs.writeFile(path, buffer, function (error, stats) {
callback();
});
}
, function (callback) {
var path = CACHE_DIR + 'minified_' + cacheKey + '.gz';
zlib.gzip(buffer, function(error, content) {
if (error) {
callback();
} else {
fs.writeFile(path, content, function (error, stats) {
callback();
});
}
});
}
], function () {
responseCache[cacheKey] = {statusCode: status, headers: headers};
respond();
});
res.end = async function(data, encoding) {
// Parallel.
Promise.all([compressMinified(), compressMinifiedGz()])
async function compressMinified() {
var path = CACHE_DIR + 'minified_' + cacheKey;
fs.writeFile(path, buffer, function (error, stats) {
if(error){
return Promise.reject(error)
}
else{
return Promise.resolve(stats)
}
});
}
async function compressMinifiedGz() {
var path = CACHE_DIR + 'minified_' + cacheKey + '.gz';
zlib.gzip(buffer, function(error, content) {
if (error) {
return Promise.reject(error)
} else {
fs.writeFile(path, content, function (error, stats) {
if(error){
return Promise.reject(error)
}
return Promise.resolve('ok')
});
}
});
}
responseCache[cacheKey] = {statusCode: status, headers: headers};
respond();
};
} else if (status == 304) {
// Nothing new changed from the cached version.