12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485 |
- 'use strict';
- const fs = require('graceful-fs');
- function createSyncFs(fs) {
- const methods = ['mkdir', 'realpath', 'stat', 'rmdir', 'utimes'];
- const newFs = { ...fs };
- methods.forEach((method) => {
- newFs[method] = (...args) => {
- const callback = args.pop();
- let ret;
- try {
- ret = fs[`${method}Sync`](...args);
- } catch (err) {
- return callback(err);
- }
- callback(null, ret);
- };
- });
- return newFs;
- }
- // ----------------------------------------------------------
- function toPromise(method) {
- return (...args) => new Promise((resolve, reject) => {
- args.push((err, result) => {
- if (err) {
- reject(err);
- } else {
- resolve(result);
- }
- });
- method(...args);
- });
- }
- function toSync(method) {
- return (...args) => {
- let err;
- let result;
- args.push((_err, _result) => {
- err = _err;
- result = _result;
- });
- method(...args);
- if (err) {
- throw err;
- }
- return result;
- };
- }
- function toSyncOptions(options) {
- // Shallow clone options because we are oging to mutate them
- options = { ...options };
- // Transform fs to use the sync methods instead
- options.fs = createSyncFs(options.fs || fs);
- // Retries are not allowed because it requires the flow to be sync
- if (
- (typeof options.retries === 'number' && options.retries > 0) ||
- (options.retries && typeof options.retries.retries === 'number' && options.retries.retries > 0)
- ) {
- throw Object.assign(new Error('Cannot use retries with the sync api'), { code: 'ESYNC' });
- }
- return options;
- }
- module.exports = {
- toPromise,
- toSync,
- toSyncOptions,
- };
|