ls.js

'use strict'

const CID = require('cids')
const ndjson = require('iterable-ndjson')
const toAsyncIterable = require('../lib/stream-to-async-iterable')
const configure = require('../lib/configure')
const toCamelWithMetadata = require('../lib/object-to-camel-with-metadata')

module.exports = configure(({ ky }) => {
  return async function * ls (path, options) {
    if (typeof path !== 'string') {
      options = path
      path = '/'
    }

    options = options || {}

    const searchParams = new URLSearchParams(options.searchParams)
    searchParams.set('arg', CID.isCID(path) ? `/ipfs/${path}` : path)
    searchParams.set('stream', true)
    if (options.cidBase) searchParams.set('cid-base', options.cidBase)
    if (options.long != null) searchParams.set('long', options.long)

    const res = await ky.post('files/ls', {
      timeout: options.timeout,
      signal: options.signal,
      headers: options.headers,
      searchParams
    })

    for await (const result of ndjson(toAsyncIterable(res))) {
      // go-ipfs does not yet support the "stream" option
      if ('Entries' in result) {
        for (const entry of result.Entries || []) {
          yield toCamelWithMetadata(entry)
        }
        return
      }

      yield toCamelWithMetadata(result)
    }
  }
})