registry-sync
Advanced tools
Comparing version 2.0.0 to 2.0.1
{ | ||
"name": "registry-sync", | ||
"version": "2.0.0", | ||
"version": "2.0.1", | ||
"description": "synchronize a remote npm registry for private use", | ||
@@ -5,0 +5,0 @@ "repository": "https://github.com/heikkipora/registry-sync", |
@@ -31,3 +31,3 @@ 'use strict'; | ||
version = _ref2.version; | ||
var registryMetadata, versionMetadata, localFolder, data, localPregypFolder, localVersionMetadata; | ||
var registryMetadata, versionMetadata, localFolder, data, localPregypFolder; | ||
return _regenerator2.default.wrap(function _callee$(_context) { | ||
@@ -42,3 +42,3 @@ while (1) { | ||
registryMetadata = _context.sent; | ||
versionMetadata = registryMetadata.versions[version]; | ||
versionMetadata = _lodash2.default.cloneDeep(registryMetadata.versions[version]); | ||
@@ -89,5 +89,6 @@ if (versionMetadata) { | ||
case 23: | ||
localVersionMetadata = (0, _metadata.rewriteVersionMetadata)(versionMetadata, data, localUrl); | ||
(0, _metadata.rewriteVersionMetadata)(versionMetadata, data, localUrl); | ||
_context.next = 26; | ||
return updateMetadata(localVersionMetadata, registryMetadata, registryUrl, localFolder); | ||
return updateMetadata(versionMetadata, registryMetadata, registryUrl, localFolder); | ||
@@ -258,2 +259,6 @@ case 26: | ||
var _lodash = require('lodash'); | ||
var _lodash2 = _interopRequireDefault(_lodash); | ||
var _client = require('./client'); | ||
@@ -260,0 +265,0 @@ |
@@ -20,10 +20,5 @@ 'use strict'; | ||
var _extends2 = require('babel-runtime/helpers/extends'); | ||
var _extends3 = _interopRequireDefault(_extends2); | ||
var rewriteMetadataInTarball = exports.rewriteMetadataInTarball = function () { | ||
var _ref3 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee(data, versionMetadata, localUrl, localFolder) { | ||
var tmpFolder, manifestPath, json, metadata, _hostAndRemotePath, host, remote_path, updatedData; | ||
var _ref = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee(data, versionMetadata, localUrl, localFolder) { | ||
var tmpFolder, manifestPath, json, metadata, updatedData; | ||
return _regenerator2.default.wrap(function _callee$(_context) { | ||
@@ -49,25 +44,21 @@ while (1) { | ||
metadata = JSON.parse(json); | ||
// eslint-disable-next-line camelcase | ||
_hostAndRemotePath = hostAndRemotePath(versionMetadata, localUrl), host = _hostAndRemotePath.host, remote_path = _hostAndRemotePath.remote_path; | ||
metadata.binary.host = host; | ||
// eslint-disable-next-line camelcase | ||
metadata.binary.remote_path = remote_path; | ||
_context.next = 15; | ||
metadata.binary.host = localUrl; | ||
metadata.binary.remote_path = '/' + versionMetadata.name + '/' + versionMetadata.version + '/'; | ||
_context.next = 14; | ||
return fs.writeFileAsync(manifestPath, (0, _stringify2.default)(metadata, null, 2)); | ||
case 15: | ||
_context.next = 17; | ||
case 14: | ||
_context.next = 16; | ||
return compressTgz(tmpFolder); | ||
case 17: | ||
case 16: | ||
updatedData = _context.sent; | ||
_context.next = 20; | ||
_context.next = 19; | ||
return rimrafAsync(tmpFolder); | ||
case 20: | ||
case 19: | ||
return _context.abrupt('return', updatedData); | ||
case 21: | ||
case 20: | ||
case 'end': | ||
@@ -81,3 +72,3 @@ return _context.stop(); | ||
return function rewriteMetadataInTarball(_x, _x2, _x3, _x4) { | ||
return _ref3.apply(this, arguments); | ||
return _ref.apply(this, arguments); | ||
}; | ||
@@ -132,34 +123,12 @@ }(); | ||
function rewriteVersionMetadata(versionMetadata, data, localUrl) { | ||
var dist = { | ||
integrity: (0, _integrity.sha512)(data), | ||
shasum: (0, _integrity.sha1)(data), | ||
tarball: localTarballUrl(versionMetadata, localUrl) | ||
}; | ||
var binaryHostAndRemotePath = (0, _pregyp.hasPrebuiltBinaries)(versionMetadata) && hostAndRemotePath(versionMetadata, localUrl); | ||
var binary = (0, _extends3.default)({}, versionMetadata.binary, binaryHostAndRemotePath); | ||
return (0, _extends3.default)({}, versionMetadata, { dist: dist, binary: binary }); | ||
} | ||
versionMetadata.dist.tarball = localTarballUrl(versionMetadata, localUrl); | ||
function hostAndRemotePath(_ref, host) { | ||
var name = _ref.name, | ||
version = _ref.version; | ||
return { | ||
host: host, | ||
remote_path: '/' + name + '/' + version + '/' | ||
}; | ||
if ((0, _pregyp.hasPrebuiltBinaries)(versionMetadata)) { | ||
versionMetadata.binary.host = localUrl; | ||
versionMetadata.binary.remote_path = '/' + versionMetadata.name + '/' + versionMetadata.version + '/'; | ||
versionMetadata.dist.integrity = (0, _integrity.sha512)(data); | ||
versionMetadata.dist.shasum = (0, _integrity.sha1)(data); | ||
} | ||
} | ||
function localTarballUrl(_ref2, localUrl) { | ||
var name = _ref2.name, | ||
version = _ref2.version; | ||
return _url2.default.resolve(localUrl, name + '/' + tarballFilename(name, version)); | ||
} | ||
function tarballFilename(name, version) { | ||
var normalized = name.replace(/\//g, '-'); | ||
return normalized + '-' + version + '.tgz'; | ||
} | ||
function extractTgz(data, folder) { | ||
@@ -186,2 +155,14 @@ return new _bluebird2.default(function (resolve, reject) { | ||
}); | ||
} | ||
function localTarballUrl(_ref2, localUrl) { | ||
var name = _ref2.name, | ||
version = _ref2.version; | ||
return _url2.default.resolve(localUrl, name + '/' + tarballFilename(name, version)); | ||
} | ||
function tarballFilename(name, version) { | ||
var normalized = name.replace(/\//g, '-'); | ||
return normalized + '-' + version + '.tgz'; | ||
} |
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
0
39890
805