millironx/setup-nextflow
1
0
Fork 0
mirror of https://github.com/MillironX/setup-nextflow.git synced 2024-10-18 10:23:10 +00:00
Code Issues Releases Packages Activity

refactor: Add short-circuit cache checking for already-installed Nextflow

Browse source
This commit is contained in:
Thomas A. Christensen II 2023-05-16 18:15:48 -05:00
parent 545262d3b9
commit fe166f9eb6
1 changed files with 21 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
src/main.ts
View file

@ -4,8 +4,14 @@ import * as github from "@actions/github"
import { GitHub } from "@actions/github/lib/utils" import { GitHub } from "@actions/github/lib/utils"
import * as tc from "@actions/tool-cache" import * as tc from "@actions/tool-cache"
import * as fs from "fs" import * as fs from "fs"
import semver from "semver"
import { install_nextflow, nextflow_bin_url, release_data } from "./functions" import {
check_cache,
install_nextflow,
nextflow_bin_url,
release_data
} from "./functions"
async function run(): Promise<void> { async function run(): Promise<void> {
// Set environment variables // Set environment variables
@ -16,7 +22,10 @@ async function run(): Promise<void> {
const version = core.getInput("version") const version = core.getInput("version")
const get_all = core.getBooleanInput("all") const get_all = core.getBooleanInput("all")
let resolved_version = "" // Check the cache for the Nextflow version that matched last time
if (check_cache(version)) {
return
}
// Setup the API // Setup the API
let octokit: InstanceType<typeof GitHub> | undefined let octokit: InstanceType<typeof GitHub> | undefined
@ -32,6 +41,7 @@ async function run(): Promise<void> {
// Get the release info for the desired release // Get the release info for the desired release
let release = {} let release = {}
let resolved_version = ""
try { try {
if (octokit !== undefined) { if (octokit !== undefined) {
release = await release_data(version, octokit) release = await release_data(version, octokit)
@ -60,24 +70,19 @@ async function run(): Promise<void> {
} }
try { try {
// Download Nextflow and add it to path // Download Nextflow and add it to path
let nf_path = "" if (!check_cache(resolved_version)) {
nf_path = tc.find("nextflow", resolved_version)
if (!nf_path) {
core.debug(`Could not find Nextflow ${resolved_version} in cache`)
const nf_install_path = await install_nextflow(url, resolved_version) const nf_install_path = await install_nextflow(url, resolved_version)
const cleaned_version = String(semver.clean(resolved_version, true))
nf_path = await tc.cacheDir(nf_install_path, "nextflow", resolved_version) const nf_path = await tc.cacheDir(
core.debug(`Added Nextflow to cache: ${nf_path}`) nf_install_path,
"nextflow",
fs.rmdirSync(nf_install_path, { recursive: true }) cleaned_version
} else { )
core.debug(`Using cached version of Nextflow: ${nf_path}`)
}
core.addPath(nf_path) core.addPath(nf_path)
core.info(`Downloaded \`nextflow\` to ${nf_path} and added to 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) { } catch (e: unknown) {
if (e instanceof Error) { if (e instanceof Error) {
core.setFailed(e.message) core.setFailed(e.message)