mirror of
https://github.com/MillironX/setup-nextflow.git
synced 2024-10-18 18:33:11 +00:00
97 lines
2.4 KiB
TypeScript
97 lines
2.4 KiB
TypeScript
|
import * as core from '@actions/core'
|
||
|
import * as fs from 'fs'
|
||
|
import retry = require('async-retry')
|
||
|
import semver = require('semver')
|
||
|
|
||
|
const NEXTFLOW_REPO = {owner: 'nextflow-io', repo: 'nextflow'}
|
||
|
|
||
|
async function all_nf_releases(ok) {
|
||
|
return await ok.paginate(
|
||
|
ok.rest.repos.listReleases,
|
||
|
NEXTFLOW_REPO,
|
||
|
response => response.data
|
||
|
)
|
||
|
}
|
||
|
|
||
|
async function latest_stable_release_data(ok) {
|
||
|
const {data: stable_release} = await ok.rest.repos.getLatestRelease(
|
||
|
NEXTFLOW_REPO
|
||
|
)
|
||
|
|
||
|
return stable_release
|
||
|
}
|
||
|
|
||
|
export async function release_data(version, ok) {
|
||
|
// Setup tag-based filtering
|
||
|
let filter = r => {
|
||
|
return semver.satisfies(r.tag_name, version, true)
|
||
|
}
|
||
|
|
||
|
// Check if the user passed a 'latest*' tag, and override filtering
|
||
|
// accordingly
|
||
|
if (version.includes('latest')) {
|
||
|
if (version.includes('-everything')) {
|
||
|
// No filtering
|
||
|
filter = r => {
|
||
|
return true
|
||
|
}
|
||
|
} else if (version.includes('-edge')) {
|
||
|
filter = r => {
|
||
|
return r.tag_name.endsWith('-edge')
|
||
|
}
|
||
|
} else {
|
||
|
// This is special: passing 'latest' or 'latest-stable' allows us to use
|
||
|
// the latest stable GitHub release direct from the API
|
||
|
const stable_release = await latest_stable_release_data(ok)
|
||
|
return stable_release
|
||
|
}
|
||
|
}
|
||
|
|
||
|
// Get all the releases
|
||
|
const all_releases = await all_nf_releases(ok)
|
||
|
|
||
|
let matching_releases = all_releases.filter(filter)
|
||
|
|
||
|
matching_releases.sort(function (x, y) {
|
||
|
semver.compare(x.tag_name, y.tag_name, true)
|
||
|
})
|
||
|
|
||
|
return matching_releases[0]
|
||
|
}
|
||
|
|
||
|
export function nextflow_bin_url(release, get_all) {
|
||
|
const release_assets = release.assets
|
||
|
const all_asset = release_assets.filter(a => {
|
||
|
return a.browser_download_url.endsWith('-all')
|
||
|
})[0]
|
||
|
const regular_asset = release_assets.filter(a => {
|
||
|
return a.name == 'nextflow'
|
||
|
})[0]
|
||
|
|
||
|
const dl_asset = get_all ? all_asset : regular_asset
|
||
|
|
||
|
return dl_asset.browser_download_url
|
||
|
}
|
||
|
|
||
|
export async function install_nextflow(url, version) {
|
||
|
core.debug(`Downloading Nextflow from ${url}`)
|
||
|
const nf_dl_path = await retry(
|
||
|
async bail => {
|
||
|
return await tc.downloadTool(url)
|
||
|
},
|
||
|
{
|
||
|
onRetry: err => {
|
||
|
core.debug(`Download of ${url} failed, trying again. Error ${err}`)
|
||
|
}
|
||
|
}
|
||
|
)
|
||
|
|
||
|
const temp_install_dir = fs.mkdtempSync(`nxf-${version}`)
|
||
|
const nf_path = `${temp_install_dir}/nextflow`
|
||
|
|
||
|
fs.renameSync(nf_dl_path, nf_path)
|
||
|
fs.chmodSync(nf_path, '0711')
|
||
|
|
||
|
return temp_install_dir
|
||
|
}
|