const fs = require('fs')
const path = require('path')
const request = require('request-promise-native')

module.exports = async function (packageRepoName, apiToken, version, artifacts) {
  for (let artifact of artifacts) {
    let fileExt = path.extname(artifact)
    switch (fileExt) {
      case '.deb':
        await uploadDebPackage(version, artifact)
        break
      case '.rpm':
        await uploadRpmPackage(version, artifact)
        break
      default:
        continue
    }
  }

  async function uploadDebPackage (version, filePath) {
    // NOTE: Not sure if distro IDs update over time, might need
    // to query the following endpoint dynamically to find the right IDs:
    //
    // https://{apiToken}:@packagecloud.io/api/v1/distributions.json
    await uploadPackage({
      version,
      filePath,
      type: 'deb',
      arch: 'amd64',
      fileName: 'atom-amd64.deb',
      distroId: 35 /* Any .deb distribution */,
      distroName: 'any',
      distroVersion: 'any'
    })
  }

  async function uploadRpmPackage (version, filePath) {
    await uploadPackage({
      version,
      filePath,
      type: 'rpm',
      arch: 'x86_64',
      fileName: 'atom.x86_64.rpm',
      distroId: 140 /* Enterprise Linux 7 */,
      distroName: 'el',
      distroVersion: '7'
    })
  }

  async function uploadPackage (packageDetails) {
    // Infer the package suffix from the version
    if (/-beta\d+/.test(packageDetails.version)) {
      packageDetails.releaseSuffix = '-beta'
    } else if (/-nightly\d+/.test(packageDetails.version)) {
      packageDetails.releaseSuffix = '-nightly'
    }

    await removePackageIfExists(packageDetails)
    await uploadToPackageCloud(packageDetails)
  }

  function uploadToPackageCloud (packageDetails) {
    return new Promise(async (resolve, reject) => {
      console.log(`Uploading ${packageDetails.fileName} to https://packagecloud.io/AtomEditor/${packageRepoName}`)
      var uploadOptions = {
        url: `https://${apiToken}:@packagecloud.io/api/v1/repos/AtomEditor/${packageRepoName}/packages.json`,
        formData: {
          'package[distro_version_id]': packageDetails.distroId,
          'package[package_file]': fs.createReadStream(packageDetails.filePath)
        }
      }

      request.post(uploadOptions, (error, uploadResponse, body) => {
        if (error || uploadResponse.statusCode !== 201) {
          console.log(`Error while uploading '${packageDetails.fileName}' v${packageDetails.version}: ${uploadResponse}`)
          reject(uploadResponse)
        } else {
          console.log(`Successfully uploaded ${packageDetails.fileName}!`)
          resolve(uploadResponse)
        }
      })
    })
  }

  async function removePackageIfExists ({ version, type, arch, fileName, distroName, distroVersion, releaseSuffix }) {
    // RPM URI paths have an extra '/0.1' thrown in
    let versionJsonPath =
      type === 'rpm'
        ? `${version.replace('-', '.')}/0.1`
        : version

    try {
      const existingPackageDetails =
        await request({
          uri: `https://${apiToken}:@packagecloud.io/api/v1/repos/AtomEditor/${packageRepoName}/package/${type}/${distroName}/${distroVersion}/atom${releaseSuffix || ''}/${arch}/${versionJsonPath}.json`,
          method: 'get',
          json: true
        })

      if (existingPackageDetails && existingPackageDetails.destroy_url) {
        console.log(`Deleting pre-existing package ${fileName} in ${packageRepoName}`)
        await request({
          uri: `https://${apiToken}:@packagecloud.io/${existingPackageDetails.destroy_url}`,
          method: 'delete'
        })
      }
    } catch (err) {
      if (err.statusCode !== 404) {
        console.log(`Error while checking for existing '${fileName}' v${version}:\n\n`, err)
      }
    }
  }
}