pull-streams-madness.js

function addPipeline (index, addStream, list) {
  pull(
    zip(
      pull.values(list),
      pull(
        pull.values(list),
        paramap(fs.stat.bind(fs), 50)
      )
    ),
    pull.map((pair) => ({
      path: pair[0],
      isDirectory: pair[1].isDirectory()
    })),
    pull.filter((file) => !file.isDirectory),
    pull.map((file) => ({
      path: file.path.substring(index, file.path.length),
      content: fs.createReadStream(file.path)
    })),
    addStream,
    pull.map((file) => ({
      hash: file.hash,
      path: file.path
    })),
    pull.collect((err, added) => {
      if (err) {
        throw err
      }

      sortBy(added, 'path')
        .reverse()
        .map((file) => `added ${file.hash} ${file.path}`)
        .forEach((msg) => console.log(msg))
    })
  )
}