137 lines
3.6 KiB
JavaScript
137 lines
3.6 KiB
JavaScript
'use strict';
|
|
|
|
const path = require('path');
|
|
const {
|
|
stat, readdir, readFile, writeFile,
|
|
} = require('fs');
|
|
const { promisify } = require('util');
|
|
const errno = require('./errno');
|
|
|
|
const statAsync = promisify(stat);
|
|
const readdirAsync = promisify(readdir);
|
|
const readFileAsync = promisify(readFile);
|
|
const writeFileAsync = promisify(writeFile);
|
|
|
|
class ProcessingError extends Error {
|
|
constructor(message, err) {
|
|
super(message + ((err && err.errno) ? ` (${errno[err.errno]})` : ''));
|
|
this.cause = err;
|
|
}
|
|
}
|
|
|
|
async function getStats(filePath) {
|
|
try {
|
|
return await statAsync(filePath);
|
|
} catch (err) {
|
|
throw new ProcessingError(`Can't read directory/file at "${filePath}"`, err);
|
|
}
|
|
}
|
|
|
|
async function processFile(filePath, opts) {
|
|
try {
|
|
let data;
|
|
try {
|
|
data = await readFileAsync(filePath, 'utf8');
|
|
} catch (err) {
|
|
throw new ProcessingError(`Can't read file at "${filePath}"`, err);
|
|
}
|
|
|
|
let shouldWriteFile = false;
|
|
let obj;
|
|
try {
|
|
obj = JSON.parse(data);
|
|
} catch (err) {
|
|
throw new ProcessingError(`Malformed package.json file at "${filePath}"`, err);
|
|
}
|
|
|
|
Object.keys(obj).forEach((key) => {
|
|
const shouldBeDeleted = opts.fields ? (opts.fields.indexOf(key) !== -1) : (key[0] === '_');
|
|
if (shouldBeDeleted) {
|
|
delete obj[key];
|
|
shouldWriteFile = true;
|
|
}
|
|
});
|
|
|
|
if (shouldWriteFile || opts.force) {
|
|
try {
|
|
await writeFileAsync(filePath, JSON.stringify(obj, null, ' '));
|
|
} catch (err) {
|
|
throw new ProcessingError(`Can't write processed file to "${filePath}"`, err);
|
|
}
|
|
|
|
return { filePath, rewritten: true, success: true };
|
|
}
|
|
|
|
return { filePath, rewritten: false, success: true };
|
|
} catch (err) {
|
|
return { filePath, err, success: false };
|
|
}
|
|
}
|
|
|
|
async function processDir(dirPath, opts) {
|
|
try {
|
|
let files;
|
|
try {
|
|
files = await readdirAsync(dirPath);
|
|
} catch (err) {
|
|
throw new ProcessingError(`Can't read directory at "${dirPath}"`, err);
|
|
}
|
|
|
|
const results = await Promise.all(files.map(async (fileName) => {
|
|
const filePath = path.join(dirPath, fileName);
|
|
|
|
const stats = await getStats(filePath);
|
|
|
|
if (stats.isDirectory()) {
|
|
return processDir(filePath, opts);
|
|
}
|
|
|
|
if (fileName === 'package.json') {
|
|
return processFile(filePath, opts);
|
|
}
|
|
|
|
return undefined;
|
|
}));
|
|
|
|
return results.reduce((arr, value) => {
|
|
if (!value) {
|
|
return arr;
|
|
}
|
|
|
|
if (value.constructor === Array) {
|
|
return arr.concat(value);
|
|
}
|
|
|
|
arr.push(value);
|
|
return arr;
|
|
}, [{ dirPath, success: true }]);
|
|
} catch (err) {
|
|
return [{ dirPath, err, success: false }];
|
|
}
|
|
}
|
|
|
|
async function removeNPMAbsolutePaths(filePath, opts) {
|
|
opts = opts || {}; // eslint-disable-line no-param-reassign
|
|
|
|
if (!filePath) {
|
|
throw new ProcessingError('Missing path.\nThe first argument should be the path to a directory or a package.json file.');
|
|
}
|
|
|
|
if (opts.fields && (opts.fields.constructor !== Array || opts.fields.length === 0)) {
|
|
throw new ProcessingError('Invalid option: fields.\nThe fields option should be an array cotaining the names of the specific fields that should be removed.');
|
|
}
|
|
|
|
const stats = await getStats(filePath);
|
|
|
|
if (stats.isDirectory()) {
|
|
return processDir(filePath, opts);
|
|
}
|
|
|
|
if (path.basename(filePath) === 'package.json') {
|
|
return [await processFile(filePath, opts)];
|
|
}
|
|
|
|
throw new Error('Invalid path provided. The path should be a directory or a package.json file.');
|
|
}
|
|
|
|
module.exports = removeNPMAbsolutePaths;
|