You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
89 lines
2.5 KiB
TypeScript
89 lines
2.5 KiB
TypeScript
import * as core from "@actions/core"
|
|
import * as exec from "@actions/exec"
|
|
import * as tc from "@actions/tool-cache"
|
|
import * as fs from "fs"
|
|
import semver from "semver"
|
|
|
|
import {
|
|
check_cache,
|
|
get_nextflow_release,
|
|
install_nextflow
|
|
} from "./functions"
|
|
import { NextflowRelease } from "./nextflow-release"
|
|
import {
|
|
get_latest_nextflow_version,
|
|
get_nextflow_versions
|
|
} from "./nf-core-api-wrapper"
|
|
|
|
async function run(): Promise<void> {
|
|
// CAPSULE_LOG leads to a bunch of boilerplate being output to the logs: turn
|
|
// it off
|
|
core.exportVariable("CAPSULE_LOG", "none")
|
|
|
|
// Read in the arguments
|
|
const version = core.getInput("version")
|
|
const get_all = core.getBooleanInput("all")
|
|
|
|
// Check the cache for the Nextflow version that matched last time
|
|
if (check_cache(version)) {
|
|
return
|
|
}
|
|
|
|
// Get the release info for the desired release
|
|
let release = {} as NextflowRelease
|
|
let resolved_version = ""
|
|
try {
|
|
if (version.includes("latest")) {
|
|
let flavor = version.split("-")[1]
|
|
flavor = flavor ? flavor : "stable"
|
|
release = await get_latest_nextflow_version(flavor)
|
|
} else {
|
|
const nextflow_releases = await get_nextflow_versions()
|
|
release = await get_nextflow_release(version, nextflow_releases)
|
|
}
|
|
resolved_version = release.version
|
|
core.info(
|
|
`Input version '${version}' resolved to Nextflow ${release.version}`
|
|
)
|
|
} catch (e: unknown) {
|
|
if (e instanceof Error) {
|
|
core.setFailed(
|
|
`Could not retrieve Nextflow release matching ${version}.\n${e.message}`
|
|
)
|
|
}
|
|
}
|
|
|
|
try {
|
|
// Download Nextflow and add it to path
|
|
if (!check_cache(resolved_version)) {
|
|
const nf_install_path = await install_nextflow(release, get_all)
|
|
const cleaned_version = String(semver.clean(resolved_version, true))
|
|
const nf_path = await tc.cacheDir(
|
|
nf_install_path,
|
|
"nextflow",
|
|
cleaned_version
|
|
)
|
|
core.addPath(nf_path)
|
|
core.info(`Downloaded \`nextflow\` to ${nf_path} and added to PATH`)
|
|
core.debug(`Added Nextflow to cache: ${nf_path}`)
|
|
fs.rmdirSync(nf_install_path, { recursive: true })
|
|
}
|
|
} catch (e: unknown) {
|
|
if (e instanceof Error) {
|
|
core.setFailed(e.message)
|
|
}
|
|
}
|
|
|
|
// Run Nextflow so it downloads its dependencies
|
|
try {
|
|
await exec.exec("nextflow", ["help"])
|
|
} catch (e: unknown) {
|
|
if (e instanceof Error) {
|
|
// fail workflow if Nextflow run does not succeed
|
|
core.setFailed(`Could not run 'nextflow help'. Error: ${e.message}`)
|
|
}
|
|
}
|
|
}
|
|
|
|
run()
|