2022-11-15 15:57:34 +00:00
|
|
|
import * as core from "@actions/core"
|
|
|
|
import * as tc from "@actions/tool-cache"
|
|
|
|
import retry from "async-retry"
|
|
|
|
import * as fs from "fs"
|
|
|
|
import semver from "semver"
|
2022-11-13 05:00:23 +00:00
|
|
|
|
2024-01-09 12:28:07 +00:00
|
|
|
import { NextflowRelease } from "./nextflow-release"
|
2022-11-13 05:00:23 +00:00
|
|
|
|
2023-12-23 17:39:47 +00:00
|
|
|
function tag_filter(version: string): (r: NextflowRelease) => Boolean {
|
2022-11-13 05:00:23 +00:00
|
|
|
// Setup tag-based filtering
|
2023-12-23 17:39:47 +00:00
|
|
|
let filter = (r: NextflowRelease): boolean => {
|
|
|
|
return semver.satisfies(r.versionNumber, version, true)
|
2022-11-13 05:00:23 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// Check if the user passed a 'latest*' tag, and override filtering
|
|
|
|
// accordingly
|
2022-11-15 15:57:34 +00:00
|
|
|
if (version.includes("latest")) {
|
|
|
|
if (version.includes("-everything")) {
|
2022-11-13 05:00:23 +00:00
|
|
|
// No filtering
|
2022-11-13 21:56:49 +00:00
|
|
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
2023-12-23 17:39:47 +00:00
|
|
|
filter = (r: NextflowRelease) => {
|
2022-11-13 05:00:23 +00:00
|
|
|
return true
|
|
|
|
}
|
2022-11-15 15:57:34 +00:00
|
|
|
} else if (version.includes("-edge")) {
|
2023-12-23 17:39:47 +00:00
|
|
|
filter = (r: NextflowRelease) => {
|
|
|
|
return r.versionNumber.endsWith("-edge")
|
2022-11-13 05:00:23 +00:00
|
|
|
}
|
|
|
|
} else {
|
2023-12-23 17:39:47 +00:00
|
|
|
filter = (r: NextflowRelease) => {
|
|
|
|
return !r.isEdge
|
|
|
|
}
|
2022-11-13 05:00:23 +00:00
|
|
|
}
|
|
|
|
}
|
2023-12-23 17:39:47 +00:00
|
|
|
return filter
|
|
|
|
}
|
2022-11-13 05:00:23 +00:00
|
|
|
|
2023-12-23 17:42:54 +00:00
|
|
|
export async function get_nextflow_release(
|
|
|
|
version: string,
|
|
|
|
releases: NextflowRelease[]
|
|
|
|
): Promise<NextflowRelease> {
|
|
|
|
// Filter the releases
|
|
|
|
const filter = tag_filter(version)
|
|
|
|
const matching_releases = releases.filter(filter)
|
2022-11-13 05:00:23 +00:00
|
|
|
|
2022-11-14 02:19:06 +00:00
|
|
|
matching_releases.sort((x, y) => {
|
|
|
|
// HACK IDK why the value flip is necessary with the return
|
2023-12-23 17:42:54 +00:00
|
|
|
return semver.compare(x.versionNumber, y.versionNumber, true) * -1
|
2022-11-13 05:00:23 +00:00
|
|
|
})
|
|
|
|
|
|
|
|
return matching_releases[0]
|
|
|
|
}
|
|
|
|
|
2022-11-13 21:56:49 +00:00
|
|
|
export async function install_nextflow(
|
2023-12-23 17:43:41 +00:00
|
|
|
release: NextflowRelease,
|
|
|
|
get_all: boolean
|
2022-11-13 21:56:49 +00:00
|
|
|
): Promise<string> {
|
2023-12-23 17:43:41 +00:00
|
|
|
const url = get_all ? release.allBinaryURL : release.binaryURL
|
|
|
|
const version = release.versionNumber
|
|
|
|
|
2022-11-13 05:00:23 +00:00
|
|
|
core.debug(`Downloading Nextflow from ${url}`)
|
|
|
|
const nf_dl_path = await retry(
|
2022-11-13 21:56:49 +00:00
|
|
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
2022-11-13 05:00:23 +00:00
|
|
|
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`
|
|
|
|
|
2023-06-22 07:18:37 +00:00
|
|
|
try {
|
|
|
|
fs.renameSync(nf_dl_path, nf_path)
|
|
|
|
} catch (err: unknown) {
|
|
|
|
core.debug(`Failed to rename file: ${err}`)
|
|
|
|
fs.copyFileSync(nf_dl_path, nf_path)
|
|
|
|
fs.unlinkSync(nf_dl_path)
|
|
|
|
}
|
2022-11-15 15:57:34 +00:00
|
|
|
fs.chmodSync(nf_path, "0711")
|
2022-11-13 05:00:23 +00:00
|
|
|
|
|
|
|
return temp_install_dir
|
|
|
|
}
|
2023-05-16 23:13:04 +00:00
|
|
|
|
|
|
|
export function check_cache(version: string): boolean {
|
2024-01-06 16:08:13 +00:00
|
|
|
// A 'latest*' version indicates that a cached version would be invalid until
|
|
|
|
// the version is resolved: abort
|
|
|
|
if (version.includes("latest")) {
|
|
|
|
return false
|
|
|
|
}
|
2023-05-16 23:13:04 +00:00
|
|
|
const cleaned_version = semver.clean(version, true)
|
|
|
|
if (cleaned_version === null) {
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
const resolved_version = String(cleaned_version)
|
|
|
|
|
|
|
|
const nf_path = tc.find("nextflow", resolved_version)
|
|
|
|
if (!nf_path) {
|
|
|
|
core.debug(`Could not find Nextflow ${resolved_version} in the tool cache`)
|
|
|
|
return false
|
|
|
|
} else {
|
|
|
|
core.debug(`Found Nextflow ${resolved_version} at path '${nf_path}'`)
|
|
|
|
core.debug(`Adding '${nf_path}' to PATH`)
|
|
|
|
core.addPath(nf_path)
|
|
|
|
return true
|
|
|
|
}
|
|
|
|
}
|