Соответствие моим readPackageFiles для размещения внутри функции "Parallel" - PullRequest
Новая
       9

Соответствие моим readPackageFiles для размещения внутри функции "Parallel"

0 голосов
/ 21 мая 2019

Я получил большую помощь от этого ТАКОГО вопроса о захвате каталогов и поиске файлов. Я пытаюсь настроить свою функцию readPackageFiles на использование данной мне функции Parallel; Однако я изо всех сил стараюсь, чтобы это сработало.

Ошибка: 

UnhandledPromiseRejectionWarning: TypeError: Cannot use 'in' operator to search for 'throws' in 1
    at readFile (/Users/harwood/udev/dotcom-components/tools/dependency-version-comparison/node_modules/jsonfile/index.js:22:16)
    at Promise (/Users/harwood/udev/dotcom-components/tools/dependency-version-comparison/node_modules/universalify/index.js:13:12)
    at new Promise (<anonymous>)
    at readFile (/Users/harwood/udev/dotcom-components/tools/dependency-version-comparison/node_modules/universalify/index.js:7:14)
    at Array.map (<anonymous>)
    at /Users/harwood/udev/dotcom-components/tools/dependency-version-comparison/dist/index.js:1:1833
    at <anonymous>
(node:70097) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 63)
(node:70097) [DEP0018] DeprecationWarning: Unhandled promise rejections are deprecated. In the future, promise rejections that are not handled will terminate the Node.js process with a non-zero exit code.
/Users/harwood/udev/dotcom-components/tools/dependency-version-comparison/node_modules/jsonfile/index.js:43
    callback(null, obj)

Вопрос: Как мне настроить readPackageFiles для работы с Parallel? 

import {readdir, stat, readJson} from 'fs-extra';
import {join, basename} from 'path';

const Parallel = p =>
  ({
    map: async f =>
      Promise.all((await p).map(f))
    ,
    filter: async f =>
      Promise.all((await p).filter(f))
    ,
    flatMap: async f =>
      Promise.all((await p).map(f)).then(ys => [].concat(...ys))
    ,
  });
const files = async (path = '.') =>
  (await stat(path)).isDirectory()
  ? Parallel(readdir(path))
    .flatMap(f => files(join(path, f)))
  : [path];

const search = async (query, path = ".") =>
  Parallel (files (path))
    .filter (f => basename (f) === query);

// How can I write this to use Parallel    
const readPackageFiles = async (packages) => await Promise.all(packages.map(async x => (await readJson(x))));

// this will not work but it's my attempt

const readPackageFilesNOTWORKING = async(path = ".") =>
  Parallel (search('package.json', path))
    .map (readJson)

использование: 

search('package.json', '.')
  .then(readPackageFiles)
  .then(console.log);

1 Ответ

1 голос
/ 22 мая 2019

Я надеялся, что вы поближе познакомитесь со связанными вопросами и ответами.Я подозревал, что вам нужно что-то подобное, и эта функция, readPackages, была в первой ссылке Я поделился с вами - 

const { readFile } =
  require ("fs") .promises

const readPackages = async (path = ".") =>
  Parallel (search ("package.json", path))
    .map (readFile)
    .then
      ( buffers =>
          buffers .map (b => JSON .parse (String (b)))
      )

readPackages (".") .then (console.log, console.error)
// [ ... ]

Примечание, fs-extra не требуется влюбой из моих ответов.

...