Move caching into invidual providers

This commit is contained in:
Josh Gross
2022-11-28 18:08:11 -05:00
parent b3dd82a7ed
commit 4663319c6f
3 changed files with 40 additions and 24 deletions
+6 -16
View File
@@ -18,14 +18,15 @@ export async function onCompletion(
): Promise<CompletionItem[]> { ): Promise<CompletionItem[]> {
const config: ValueProviderConfig = { const config: ValueProviderConfig = {
getCustomValues: async (key: string, context: WorkflowContext) => getCustomValues: async (key: string, context: WorkflowContext) =>
getCustomValuesWithCache(key, context, sessionToken, repoContext, cache), getCustomValues(key, context, sessionToken, repoContext, cache),
}; };
return await complete(document, position, config); return await complete(document, position, config);
} }
async function getCustomValuesWithCache(
async function getCustomValues(
key: string, key: string,
context: WorkflowContext, _: WorkflowContext,
sessionToken: string | undefined, sessionToken: string | undefined,
repo: RepositoryContext | undefined, repo: RepositoryContext | undefined,
cache: TTLCache, cache: TTLCache,
@@ -34,28 +35,17 @@ async function getCustomValuesWithCache(
return; return;
} }
const cacheKey = `${repo.owner}/${repo.name}/${key}`;
return cache.get(cacheKey, undefined, async () => await getCustomValues(key, context, sessionToken, repo));
}
async function getCustomValues(
key: string,
_: WorkflowContext,
sessionToken: string,
repo: RepositoryContext,
): Promise<Value[] | undefined> {
const octokit = new Octokit({ const octokit = new Octokit({
auth: sessionToken, auth: sessionToken,
}); });
switch (key) { switch (key) {
case "job-environment": { case "job-environment": {
return await getEnvironments(octokit, repo.owner, repo.name); return await getEnvironments(octokit, cache, repo.owner, repo.name);
} }
case "runs-on": { case "runs-on": {
return await getRunnerLabels(octokit, repo.owner, repo.name); return await getRunnerLabels(octokit, cache, repo.owner, repo.name);
} }
} }
} }
@@ -1,11 +1,22 @@
import { Value } from "@github/actions-languageservice/value-providers/config"; import { Value } from "@github/actions-languageservice/value-providers/config";
import { Octokit } from "@octokit/rest"; import { Octokit } from "@octokit/rest";
import { TTLCache } from "../utils/cache";
export async function getEnvironments( export async function getEnvironments(
client: Octokit, client: Octokit,
cache: TTLCache,
owner: string, owner: string,
name: string name: string
): Promise<Value[]> { ): Promise<Value[]> {
const environments = await cache.get(`${owner}/${name}/environments`, undefined, () => fetchEnvironments(client, owner, name));
return Array.from(environments).map((env) => ({ label: env }));
}
async function fetchEnvironments(
client: Octokit,
owner: string,
name: string
): Promise<string[]> {
let environments: string[] = []; let environments: string[] = [];
try { try {
const response = await client.repos.getAllEnvironments({ const response = await client.repos.getAllEnvironments({
@@ -20,5 +31,5 @@ export async function getEnvironments(
console.log("Failure to retrieve environments: ", e); console.log("Failure to retrieve environments: ", e);
} }
return Array.from(environments).map((env) => ({ label: env })); return environments;
} }
@@ -1,12 +1,14 @@
import { Value } from "@github/actions-languageservice/value-providers/config"; import { Value } from "@github/actions-languageservice/value-providers/config";
import { Octokit } from "@octokit/rest"; import { Octokit } from "@octokit/rest";
import { TTLCache } from "../utils/cache";
export async function getRunnerLabels( export async function getRunnerLabels(
client: Octokit, client: Octokit,
cache: TTLCache,
owner: string, owner: string,
name: string name: string
): Promise<Value[]> { ): Promise<Value[]> {
const labels = new Set<string>([ const defaultLabels = [
"ubuntu-22.04", "ubuntu-22.04",
"ubuntu-latest", "ubuntu-latest",
"ubuntu-20.04", "ubuntu-20.04",
@@ -20,8 +22,21 @@ export async function getRunnerLabels(
"macos-11", "macos-11",
"macos-10.15", "macos-10.15",
"self-hosted", "self-hosted",
]); ];
const repoLabels = await cache.get(`${owner}/${name}/runner-labels`, undefined, () => fetchRunnerLabels(client, owner, name));
for (const label of defaultLabels) {
repoLabels.add(label);
}
return Array.from(repoLabels).map((label) => ({ label }));
}
async function fetchRunnerLabels(
client: Octokit,
owner: string,
name: string
): Promise<Set<string>> {
const labels = new Set<string>();
try { try {
const response = await client.actions.listSelfHostedRunnersForRepo({ const response = await client.actions.listSelfHostedRunnersForRepo({
owner, owner,
@@ -37,5 +52,5 @@ export async function getRunnerLabels(
console.log("Failure to retrieve runner labels: ", e); console.log("Failure to retrieve runner labels: ", e);
} }
return Array.from(labels).map((label) => ({ label })); return labels;
} }