2023-12-23 17:37:50 +00:00
|
|
|
import * as core from "@actions/core"
|
2024-01-15 03:34:59 +00:00
|
|
|
import { getOctokitOptions, GitHub } from "@actions/github/lib/utils"
|
|
|
|
import { throttling } from "@octokit/plugin-throttling"
|
2023-12-23 17:37:50 +00:00
|
|
|
|
2024-01-09 12:28:07 +00:00
|
|
|
import { nextflow_release, NextflowRelease } from "./nextflow-release"
|
2023-12-23 17:37:50 +00:00
|
|
|
|
2024-01-26 01:04:30 +00:00
|
|
|
const NEXTFLOW_REPO = { owner: "nextflow-io", repo: "nextflow", per_page: 100 }
|
2023-12-23 17:37:50 +00:00
|
|
|
|
|
|
|
export async function setup_octokit(
|
2024-01-15 03:34:59 +00:00
|
|
|
github_token: string,
|
|
|
|
cooldown = 60,
|
|
|
|
max_retries = 3
|
2023-12-23 17:37:50 +00:00
|
|
|
): Promise<InstanceType<typeof GitHub>> {
|
2024-01-15 03:34:59 +00:00
|
|
|
const throttledOctokit = GitHub.plugin(throttling)
|
2023-12-23 17:37:50 +00:00
|
|
|
let octokit = {} as InstanceType<typeof GitHub>
|
|
|
|
try {
|
2024-01-15 03:34:59 +00:00
|
|
|
octokit = new throttledOctokit(
|
|
|
|
getOctokitOptions(github_token, {
|
|
|
|
throttle: {
|
|
|
|
onRateLimit: (retryAfter, options, ok, retryCount) => {
|
|
|
|
ok.log.warn(
|
|
|
|
`Request quota exhausted for request ${options.method} ${options.url}`
|
|
|
|
)
|
|
|
|
|
|
|
|
if (retryCount < max_retries) {
|
|
|
|
ok.log.info(`Retrying after ${retryAfter} seconds!`)
|
|
|
|
return true
|
|
|
|
}
|
|
|
|
},
|
|
|
|
onSecondaryRateLimit: (retryAfter, options, ok, retryCount) => {
|
|
|
|
ok.log.warn(
|
|
|
|
`SecondaryRateLimit detected for request ${options.method} ${options.url}`
|
|
|
|
)
|
|
|
|
|
|
|
|
if (retryCount < max_retries) {
|
|
|
|
octokit.log.info(`Retrying after ${retryAfter} seconds!`)
|
|
|
|
return true
|
|
|
|
}
|
|
|
|
},
|
|
|
|
fallbackSecondaryRateRetryAfter: cooldown
|
|
|
|
}
|
|
|
|
})
|
|
|
|
)
|
2023-12-23 17:37:50 +00:00
|
|
|
} catch (e: unknown) {
|
|
|
|
if (e instanceof Error) {
|
|
|
|
core.setFailed(
|
|
|
|
`Could not authenticate to GitHub Releases API with provided token\n${e.message}`
|
|
|
|
)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return octokit
|
|
|
|
}
|
|
|
|
|
2024-01-26 20:10:46 +00:00
|
|
|
export async function* release_iter(
|
|
|
|
octokit: InstanceType<typeof GitHub>
|
|
|
|
): AsyncGenerator<NextflowRelease> {
|
|
|
|
const iterator = octokit.paginate.iterator(
|
|
|
|
octokit.rest.repos.listReleases,
|
|
|
|
NEXTFLOW_REPO
|
|
|
|
)
|
|
|
|
let item_index = 0
|
|
|
|
let release_items = []
|
|
|
|
|
|
|
|
/* eslint-disable-next-line @typescript-eslint/unbound-method */
|
|
|
|
const { next } = iterator[Symbol.asyncIterator]()
|
|
|
|
|
|
|
|
let request = await next()
|
|
|
|
|
|
|
|
return {
|
|
|
|
async next() {
|
|
|
|
if (item_index >= release_items.length) {
|
|
|
|
if (request.done) {
|
|
|
|
return { done: true }
|
|
|
|
}
|
|
|
|
|
|
|
|
request = await next()
|
|
|
|
release_items = request.value.data
|
|
|
|
item_index = 0
|
|
|
|
}
|
|
|
|
return {
|
|
|
|
value: nextflow_release(release_items[item_index++]),
|
|
|
|
done: false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2023-12-23 17:37:50 +00:00
|
|
|
export async function pull_releases(
|
|
|
|
ok: InstanceType<typeof GitHub>
|
2024-01-26 04:12:49 +00:00
|
|
|
): Promise<NextflowRelease[]> {
|
2023-12-23 17:37:50 +00:00
|
|
|
return await ok.paginate(
|
|
|
|
ok.rest.repos.listReleases,
|
|
|
|
NEXTFLOW_REPO,
|
2024-01-26 04:12:49 +00:00
|
|
|
response => {
|
|
|
|
const all_releases: NextflowRelease[] = []
|
|
|
|
const releases_data = response.data
|
|
|
|
for (const release_data of releases_data) {
|
|
|
|
all_releases.push(nextflow_release(release_data))
|
|
|
|
}
|
|
|
|
return all_releases
|
|
|
|
}
|
2023-12-23 17:37:50 +00:00
|
|
|
)
|
|
|
|
}
|
|
|
|
|
2024-01-26 04:18:33 +00:00
|
|
|
export async function pull_latest_stable_release(
|
2023-12-23 17:37:50 +00:00
|
|
|
ok: InstanceType<typeof GitHub>
|
2024-01-26 04:18:33 +00:00
|
|
|
): Promise<NextflowRelease> {
|
2023-12-23 17:37:50 +00:00
|
|
|
const { data: stable_release } = await ok.rest.repos.getLatestRelease(
|
|
|
|
NEXTFLOW_REPO
|
|
|
|
)
|
|
|
|
|
2024-01-26 04:18:33 +00:00
|
|
|
return nextflow_release(stable_release)
|
2023-12-23 17:37:50 +00:00
|
|
|
}
|