Infrastructure/verdaccio
0
Fork 0
mirror of https://github.com/verdaccio/verdaccio.git synced 2025-04-01 02:42:23 -05:00
Code Issues Activity

chore(flow): update flow definitions

Browse source
This commit is contained in:
Juan Picado @jotadeveloper 2018-02-04 14:35:03 +01:00
parent f7414e9bb2
commit d561580d68
No known key found for this signature in database
GPG key ID: 18AC54485952D158
2 changed files with 8 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/lib/storage.js
View file

@ -3,7 +3,7 @@
import _ from 'lodash';
import assert from 'assert';
import async from 'async';
import Error from 'http-errors';
import createError from 'http-errors';
import semver from 'semver';
import Stream from 'stream';
@ -116,7 +116,7 @@ class Storage implements IStorageHandler {
this.config.publish.allow_offline) {
return resolve();
}
return reject(Error[503]('one of the uplinks is down, refuse to publish'));
return reject(createError(503, 'one of the uplinks is down, refuse to publish'));
}
}
}
@ -571,7 +571,7 @@ class Storage implements IStorageHandler {
if (err || !upLinkResponse) {
// $FlowFixMe
return cb(null, [err || Error('no data')]);
return cb(null, [err || createError(500, 'no data')]);
}
try {
@ -612,7 +612,7 @@ class Storage implements IStorageHandler {
exists = true;
cb();
});
}, (err: any, upLinksErrors: any) => {
}, (err: Error, upLinksErrors: any) => {
assert(!err && Array.isArray(upLinksErrors));
if (!exists) {
return callback( Utils.ErrorCode.get404('no such package available')

16
src/lib/up-storage.js
View file

@ -19,15 +19,11 @@ import type {
import type {IUploadTarball} from '@verdaccio/streams';
const LoggerApi = require('./logger');
const encode = function(thing) {
return encodeURIComponent(thing).replace(/^%40/, '@');
};
const jsonContentType = 'application/json';
const contenTypeAccept = `${jsonContentType};`;
/**
@ -385,8 +381,7 @@ class ProxyStorage implements IProxy {
return callback( ErrorCode.get404('package doesn\'t exist on uplink'));
}
if (!(res.statusCode >= 200 && res.statusCode < 300)) {
// $FlowFixMe
const error = createError(`bad status code: ${res.statusCode}`);
const error = createError(500, `bad status code: ${res.statusCode}`);
// $FlowFixMe
error.remoteStatus = res.statusCode;
return callback(error);
@ -419,8 +414,7 @@ class ProxyStorage implements IProxy {
return stream.emit('error', ErrorCode.get404('file doesn\'t exist on uplink'));
}
if (!(res.statusCode >= 200 && res.statusCode < 300)) {
// $FlowFixMe
return stream.emit('error', createError('bad uplink status code: ' + res.statusCode));
return stream.emit('error', createError(500, 'bad uplink status code: ' + res.statusCode));
}
if (res.headers['content-length']) {
expected_length = res.headers['content-length'];
@ -441,8 +435,7 @@ class ProxyStorage implements IProxy {
current_length += data.length;
}
if (expected_length && current_length != expected_length) {
// $FlowFixMe
stream.emit('error', createError('content length mismatch'));
stream.emit('error', createError(500, 'content length mismatch'));
}
});
return stream;
@ -471,8 +464,7 @@ class ProxyStorage implements IProxy {
requestStream.on('response', (res) => {
if (!String(res.statusCode).match(/^2\d\d$/)) {
// $FlowFixMe
return transformStream.emit('error', createError(`bad status code ${res.statusCode} from uplink`));
return transformStream.emit('error', createError(500, `bad status code ${res.statusCode} from uplink`));
}
// See https://github.com/request/request#requestoptions-callback