import * as core from "@actions/core"; import { exec } from "@actions/exec"; import * as io from "@actions/io"; import * as path from "path"; import * as cacheHttpClient from "./cacheHttpClient"; import { Events, Inputs, State } from "./constants"; import * as utils from "./utils/actionUtils"; async function run(): Promise { try { // Validate inputs, this can cause task failure if (!utils.isValidEvent()) { core.setFailed( `Event Validation Error: The event type ${ process.env[Events.Key] } is not supported. Only ${utils .getSupportedEvents() .join(", ")} events are supported at this time.` ); } const cachePath = utils.resolvePath( core.getInput(Inputs.Path, { required: true }) ); core.debug(`Cache Path: ${cachePath}`); const primaryKey = core.getInput(Inputs.Key, { required: true }); core.saveState(State.CacheKey, primaryKey); const restoreKeys = core .getInput(Inputs.RestoreKeys) .split("\n") .filter(x => x !== ""); const keys = [primaryKey, ...restoreKeys]; core.debug("Resolved Keys:"); core.debug(JSON.stringify(keys)); if (keys.length > 10) { core.setFailed( `Key Validation Error: Keys are limited to a maximum of 10.` ); return; } for (const key of keys) { if (key.length > 512) { core.setFailed( `Key Validation Error: ${key} cannot be larger than 512 characters.` ); return; } const regex = /^[^,]*$/; if (!regex.test(key)) { core.setFailed( `Key Validation Error: ${key} cannot contain commas.` ); return; } } try { const cacheEntry = await cacheHttpClient.getCacheEntry(keys); if (!cacheEntry) { core.info( `Cache not found for input keys: ${keys.join(", ")}.` ); return; } const archivePath = path.join( await utils.createTempDirectory(), "cache.tgz" ); core.debug(`Archive Path: ${archivePath}`); // Store the cache result utils.setCacheState(cacheEntry); // Download the cache from the cache entry await cacheHttpClient.downloadCache(cacheEntry, archivePath); const archiveFileSize = utils.getArchiveFileSize(archivePath); core.info( `Cache Size: ~${Math.round( archiveFileSize / (1024 * 1024) )} MB (${archiveFileSize} B)` ); io.mkdirP(cachePath); // http://man7.org/linux/man-pages/man1/tar.1.html // tar [-options] [files or directories which to add into archive] const IS_WINDOWS = process.platform === "win32"; const args = IS_WINDOWS ? [ "-xz", "--force-local", "-f", archivePath.replace(/\\/g, "/"), "-C", cachePath.replace(/\\/g, "/") ] : ["-xz", "-f", archivePath, "-C", cachePath]; const tarPath = await io.which("tar", true); core.debug(`Tar Path: ${tarPath}`); await exec(`"${tarPath}"`, args); const isExactKeyMatch = utils.isExactKeyMatch( primaryKey, cacheEntry ); utils.setCacheHitOutput(isExactKeyMatch); core.info( `Cache restored from key: ${cacheEntry && cacheEntry.cacheKey}` ); } catch (error) { core.warning(error.message); utils.setCacheHitOutput(false); } } catch (error) { core.setFailed(error.message); } } run(); export default run;