mirror of
https://github.com/verdaccio/verdaccio.git
synced 2024-12-16 21:56:25 -05:00
Merge branch '4.x' of github.com:verdaccio/verdaccio into 4.x
This commit is contained in:
commit
5299e58341
10 changed files with 42 additions and 17 deletions
|
@ -78,7 +78,7 @@
|
||||||
"@commitlint/config-conventional": "7.1.2",
|
"@commitlint/config-conventional": "7.1.2",
|
||||||
"@material-ui/core": "3.1.0",
|
"@material-ui/core": "3.1.0",
|
||||||
"@material-ui/icons": "3.0.1",
|
"@material-ui/icons": "3.0.1",
|
||||||
"@verdaccio/types": "4.1.3",
|
"@verdaccio/types": "4.1.4",
|
||||||
"autosuggest-highlight": "3.1.1",
|
"autosuggest-highlight": "3.1.1",
|
||||||
"babel-core": "7.0.0-bridge.0",
|
"babel-core": "7.0.0-bridge.0",
|
||||||
"babel-eslint": "10.0.1",
|
"babel-eslint": "10.0.1",
|
||||||
|
|
|
@ -61,7 +61,7 @@ export default function(route, auth, storage) {
|
||||||
stream.on('data', function each(pkg) {
|
stream.on('data', function each(pkg) {
|
||||||
processing_pkgs++;
|
processing_pkgs++;
|
||||||
|
|
||||||
auth.allow_access(pkg.name, req.remote_user, function(err, allowed) {
|
auth.allow_access({ packageName: pkg.name }, req.remote_user, function(err, allowed) {
|
||||||
processing_pkgs--;
|
processing_pkgs--;
|
||||||
|
|
||||||
if (err) {
|
if (err) {
|
||||||
|
|
|
@ -5,7 +5,7 @@
|
||||||
|
|
||||||
import _ from 'lodash';
|
import _ from 'lodash';
|
||||||
|
|
||||||
import { validateName as utilValidateName, validatePackage as utilValidatePackage, isObject, ErrorCode } from '../lib/utils';
|
import { validateName as utilValidateName, validatePackage as utilValidatePackage, getVersionFromTarball, isObject, ErrorCode } from '../lib/utils';
|
||||||
import { API_ERROR, HEADER_TYPE, HEADERS, HTTP_STATUS, TOKEN_BASIC, TOKEN_BEARER } from '../lib/constants';
|
import { API_ERROR, HEADER_TYPE, HEADERS, HTTP_STATUS, TOKEN_BASIC, TOKEN_BEARER } from '../lib/constants';
|
||||||
import { stringToMD5 } from '../lib/crypto-utils';
|
import { stringToMD5 } from '../lib/crypto-utils';
|
||||||
import type { $ResponseExtend, $RequestExtend, $NextFunctionVer, IAuth } from '../../types';
|
import type { $ResponseExtend, $RequestExtend, $NextFunctionVer, IAuth } from '../../types';
|
||||||
|
@ -99,12 +99,11 @@ export function allow(auth: IAuth) {
|
||||||
return function(action: string) {
|
return function(action: string) {
|
||||||
return function(req: $RequestExtend, res: $ResponseExtend, next: $NextFunctionVer) {
|
return function(req: $RequestExtend, res: $ResponseExtend, next: $NextFunctionVer) {
|
||||||
req.pause();
|
req.pause();
|
||||||
let packageName = req.params.package;
|
const packageName = req.params.scope ? `@${req.params.scope}/${req.params.package}` : req.params.package;
|
||||||
if (req.params.scope) {
|
const packageVersion = req.params.filename ? getVersionFromTarball(req.params.filename) : undefined;
|
||||||
packageName = `@${req.params.scope}/${packageName}`;
|
|
||||||
}
|
|
||||||
// $FlowFixMe
|
// $FlowFixMe
|
||||||
auth['allow_' + action](packageName, req.remote_user, function(error, allowed) {
|
auth['allow_' + action]({ packageName, packageVersion }, req.remote_user, function(error, allowed) {
|
||||||
req.resume();
|
req.resume();
|
||||||
if (error) {
|
if (error) {
|
||||||
next(error);
|
next(error);
|
||||||
|
|
|
@ -18,7 +18,7 @@ function addPackageWebApi(route: Router, storage: IStorageHandler, auth: IAuth,
|
||||||
const checkAllow = (name, remoteUser) =>
|
const checkAllow = (name, remoteUser) =>
|
||||||
new Promise((resolve, reject) => {
|
new Promise((resolve, reject) => {
|
||||||
try {
|
try {
|
||||||
auth.allow_access(name, remoteUser, (err, allowed) => {
|
auth.allow_access({ packageName: name }, remoteUser, (err, allowed) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
resolve(false);
|
resolve(false);
|
||||||
} else {
|
} else {
|
||||||
|
|
|
@ -20,7 +20,7 @@ function addSearchWebApi(route: Router, storage: IStorageHandler, auth: IAuth) {
|
||||||
uplinksLook: false,
|
uplinksLook: false,
|
||||||
callback: (err, entry) => {
|
callback: (err, entry) => {
|
||||||
if (!err && entry) {
|
if (!err && entry) {
|
||||||
auth.allow_access(entry.name, req.remote_user, function(err, allowed) {
|
auth.allow_access({ packageName: entry.name }, req.remote_user, function(err, allowed) {
|
||||||
if (err || !allowed) {
|
if (err || !allowed) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
|
@ -23,7 +23,7 @@ import {
|
||||||
import { convertPayloadToBase64, ErrorCode } from './utils';
|
import { convertPayloadToBase64, ErrorCode } from './utils';
|
||||||
import { getMatchedPackagesSpec } from './config-utils';
|
import { getMatchedPackagesSpec } from './config-utils';
|
||||||
|
|
||||||
import type { Config, Logger, Callback, IPluginAuth, RemoteUser, JWTSignOptions, Security } from '@verdaccio/types';
|
import type { Config, Logger, Callback, IPluginAuth, RemoteUser, JWTSignOptions, Security, AuthPluginPackage } from '@verdaccio/types';
|
||||||
import type { $Response, NextFunction } from 'express';
|
import type { $Response, NextFunction } from 'express';
|
||||||
import type { $RequestExtend, IAuth } from '../../types';
|
import type { $RequestExtend, IAuth } from '../../types';
|
||||||
|
|
||||||
|
@ -160,10 +160,10 @@ class Auth implements IAuth {
|
||||||
/**
|
/**
|
||||||
* Allow user to access a package.
|
* Allow user to access a package.
|
||||||
*/
|
*/
|
||||||
allow_access(packageName: string, user: RemoteUser, callback: Callback) {
|
allow_access({ packageName, packageVersion }: AuthPluginPackage, user: RemoteUser, callback: Callback) {
|
||||||
const plugins = this.plugins.slice(0);
|
const plugins = this.plugins.slice(0);
|
||||||
// $FlowFixMe
|
// $FlowFixMe
|
||||||
const pkg = Object.assign({ name: packageName }, getMatchedPackagesSpec(packageName, this.config.packages));
|
const pkg = Object.assign({ name: packageName, version: packageVersion }, getMatchedPackagesSpec(packageName, this.config.packages));
|
||||||
const self = this;
|
const self = this;
|
||||||
this.logger.trace({ packageName }, 'allow access for @{packageName}');
|
this.logger.trace({ packageName }, 'allow access for @{packageName}');
|
||||||
|
|
||||||
|
@ -193,11 +193,11 @@ class Auth implements IAuth {
|
||||||
/**
|
/**
|
||||||
* Allow user to publish a package.
|
* Allow user to publish a package.
|
||||||
*/
|
*/
|
||||||
allow_publish(packageName: string, user: string, callback: Callback) {
|
allow_publish({ packageName, packageVersion }: AuthPluginPackage, user: string, callback: Callback) {
|
||||||
const plugins = this.plugins.slice(0);
|
const plugins = this.plugins.slice(0);
|
||||||
const self = this;
|
const self = this;
|
||||||
// $FlowFixMe
|
// $FlowFixMe
|
||||||
const pkg = Object.assign({ name: packageName }, getMatchedPackagesSpec(packageName, this.config.packages));
|
const pkg = Object.assign({ name: packageName, version: packageVersion }, getMatchedPackagesSpec(packageName, this.config.packages));
|
||||||
this.logger.trace({ packageName }, 'allow publish for @{packageName}');
|
this.logger.trace({ packageName }, 'allow publish for @{packageName}');
|
||||||
|
|
||||||
(function next() {
|
(function next() {
|
||||||
|
|
|
@ -502,3 +502,13 @@ export function parseReadme(packageName: string, readme: string): string {
|
||||||
export function buildToken(type: string, token: string): string {
|
export function buildToken(type: string, token: string): string {
|
||||||
return `${_.capitalize(type)} ${token}`;
|
return `${_.capitalize(type)} ${token}`;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* return package version from tarball name
|
||||||
|
* @param {String} name
|
||||||
|
* @returns {String}
|
||||||
|
*/
|
||||||
|
export function getVersionFromTarball(name: string) {
|
||||||
|
// $FlowFixMe
|
||||||
|
return /.+-(\d.+)\.tgz/.test(name) ? name.match(/.+-(\d.+)\.tgz/)[1] : undefined;
|
||||||
|
}
|
||||||
|
|
|
@ -24,7 +24,7 @@ export default class ExampleMiddlewarePlugin implements IPluginMiddleware {
|
||||||
name: 'test'
|
name: 'test'
|
||||||
};
|
};
|
||||||
auth.authenticate('user', 'password', () => {});
|
auth.authenticate('user', 'password', () => {});
|
||||||
auth.allow_access('packageName', remoteUser, () => {});
|
auth.allow_access({packageName: 'packageName'}, remoteUser, () => {});
|
||||||
auth.add_user('user', 'password', () => {});
|
auth.add_user('user', 'password', () => {});
|
||||||
auth.aesEncrypt(new Buffer('pass'));
|
auth.aesEncrypt(new Buffer('pass'));
|
||||||
// storage
|
// storage
|
||||||
|
|
|
@ -11,7 +11,8 @@ import {
|
||||||
combineBaseUrl,
|
combineBaseUrl,
|
||||||
getVersion,
|
getVersion,
|
||||||
normalizeDistTags,
|
normalizeDistTags,
|
||||||
getWebProtocol
|
getWebProtocol,
|
||||||
|
getVersionFromTarball
|
||||||
} from '../../../src/lib/utils';
|
} from '../../../src/lib/utils';
|
||||||
import { DIST_TAGS } from '../../../src/lib/constants';
|
import { DIST_TAGS } from '../../../src/lib/constants';
|
||||||
import Logger, { setup } from '../../../src/lib/logger';
|
import Logger, { setup } from '../../../src/lib/logger';
|
||||||
|
@ -259,6 +260,21 @@ describe('Utilities', () => {
|
||||||
}).toThrow(expect.hasAssertions());
|
}).toThrow(expect.hasAssertions());
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
|
describe('getVersionFromTarball', () => {
|
||||||
|
test('should get the right version', () => {
|
||||||
|
const simpleName = 'test-name-4.2.12.tgz'
|
||||||
|
const complexName = 'test-5.6.4-beta.2.tgz'
|
||||||
|
const otherComplexName = 'test-3.5.0-6.tgz'
|
||||||
|
expect(getVersionFromTarball(simpleName)).toEqual('4.2.12')
|
||||||
|
expect(getVersionFromTarball(complexName)).toEqual('5.6.4-beta.2')
|
||||||
|
expect(getVersionFromTarball(otherComplexName)).toEqual('3.5.0-6')
|
||||||
|
})
|
||||||
|
|
||||||
|
test('should don\'n fall at incorrect tarball name', () => {
|
||||||
|
expect(getVersionFromTarball('incorrectName')).toBeUndefined()
|
||||||
|
})
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('String utilities', () => {
|
describe('String utilities', () => {
|
||||||
|
|
BIN
yarn.lock
BIN
yarn.lock
Binary file not shown.
Loading…
Reference in a new issue