Method copy

lib/ldp.mjs:573–683

(from, to, options)

  }

  async copy (from, to, options) {
    if (overQuota(this.quotaFile, this.quota)) {
      debug.handlers('COPY -- Over quota')
      throw error(413, 'Storage quota exceeded')
    }

    const originalParsedPath = urlModule.parse(from)
    const parsedPath = urlModule.parse(to)
    const fromPath = this.resourceMapper.resolveFilePath(
      originalParsedPath.hostname,
      decodeURIComponent(originalParsedPath.pathname)
    )
    const toPath = this.resourceMapper.resolveFilePath(
      parsedPath.hostname,
      decodeURIComponent(parsedPath.pathname)
    )

    // Check if file already exists
    if (fs.existsSync(toPath)) {
      throw error(412, 'Target file already exists')
    }

    let copyPromise

    // create destination directory if not exists
    mkdirp(dirname(toPath))

    // If original is a single file
    if (!fromPath.endsWith('/')) {
      copyPromise = new Promise((resolve, reject) => {
        const readStream = fs.createReadStream(fromPath)
        const writeStream = fs.createWriteStream(toPath)
        readStream.on('error', function (err) {
          debug.handlers('Error reading file: ' + err)
          reject(error(500, err))
        })
        writeStream.on('error', function (err) {
          debug.handlers('Error writing file: ' + err)
          reject(error(500, err))
        })
        writeStream.on('finish', function () {
          debug.handlers('Finished copying file')
          resolve()
        })
        readStream.pipe(writeStream)
      })
    } else {
      // If original is a folder, copy recursively
      copyPromise = new Promise((resolve, reject) => {
        exec(`cp -r "${fromPath}" "${toPath}"`, function (err) {
          if (err) {
            debug.handlers('Error copying directory: ' + err)
            reject(error(500, err))
          } else {
            debug.handlers('Finished copying directory')
            resolve()
          }
        })