actions/magic-nix-cache-action
1
0
Fork 0
mirror of https://github.com/DeterminateSystems/magic-nix-cache-action.git synced 2024-12-27 01:30:35 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Don't use the daemonDir as a started hint

Browse source
This commit is contained in:
Graham Christensen 2024-05-06 13:13:38 -04:00
parent d01586aa11
commit 3426c8fc62
1 changed files with 24 additions and 33 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

57
src/index.ts
View file

@ -1,24 +1,26 @@
import { netrcPath, tailLog } from "./helpers.js"; import { netrcPath, tailLog } from "./helpers.js";
import * as actionsCore from "@actions/core"; import * as actionsCore from "@actions/core";
import { IdsToolbox, inputs } from "detsys-ts"; import { IdsToolbox, inputs } from "detsys-ts";
import { mkdir, stat } from "fs/promises";
import got, { Got } from "got"; import got, { Got } from "got";
import * as http from "http"; import * as http from "http";
import { SpawnOptions, exec, spawn } from "node:child_process"; import { SpawnOptions, exec, spawn } from "node:child_process";
import { openSync, readFileSync } from "node:fs"; import { mkdirSync, openSync, readFileSync } from "node:fs";
import * as fs from "node:fs/promises"; import * as fs from "node:fs/promises";
import * as os from "node:os"; import * as os from "node:os";
import * as path from "node:path"; import * as path from "node:path";
import { inspect, promisify } from "node:util"; import { inspect, promisify } from "node:util";
const ENV_CACHE_DAEMONDIR = "MAGIC_NIX_CACHE_DAEMONDIR"; const ENV_CACHE_DAEMONDIR = "MAGIC_NIX_CACHE_DAEMONDIR";
const ENV_CACHE_STARTED = "MAGIC_NIX_CACHE_STARTED";
const STARTED_HINT = "true";
class MagicNixCacheAction { class MagicNixCacheAction {
idslib: IdsToolbox; idslib: IdsToolbox;
private client: Got; private client: Got;
private daemonDir?: string; private daemonDir: string;
private unsafeDaemonDir: string; private daemonStarted: boolean;
constructor() { constructor() {
this.idslib = new IdsToolbox({ this.idslib = new IdsToolbox({
@ -44,33 +46,22 @@ class MagicNixCacheAction {
}, },
}); });
this.daemonStarted = process.env[ENV_CACHE_STARTED] === STARTED_HINT;
if (process.env[ENV_CACHE_DAEMONDIR]) { if (process.env[ENV_CACHE_DAEMONDIR]) {
this.unsafeDaemonDir = process.env[ENV_CACHE_DAEMONDIR]; this.daemonDir = process.env[ENV_CACHE_DAEMONDIR];
} else { } else {
this.unsafeDaemonDir = this.idslib.getTemporaryName(); this.daemonDir = this.idslib.getTemporaryName();
actionsCore.exportVariable(ENV_CACHE_DAEMONDIR, this.unsafeDaemonDir); mkdirSync(this.daemonDir);
actionsCore.exportVariable(ENV_CACHE_DAEMONDIR, this.daemonDir);
} }
this.idslib.stapleFile( this.idslib.stapleFile(
"daemon.log", "daemon.log",
path.join(this.unsafeDaemonDir, "daemon.log"), path.join(this.daemonDir, "daemon.log"),
); );
} }
async getDaemonDir(): Promise<string> {
if (this.daemonDir === undefined) {
await mkdir(this.unsafeDaemonDir, { recursive: true });
this.daemonDir = this.unsafeDaemonDir;
return this.unsafeDaemonDir;
} else {
return this.daemonDir;
}
}
async daemonDirExists(): Promise<boolean> {
const statRes = await stat(this.unsafeDaemonDir);
return statRes.isDirectory();
}
async setUpAutoCache(): Promise<void> { async setUpAutoCache(): Promise<void> {
const requiredEnv = [ const requiredEnv = [
"ACTIONS_CACHE_URL", "ACTIONS_CACHE_URL",
@ -96,6 +87,8 @@ class MagicNixCacheAction {
`GitHub Action Cache URL: ${process.env["ACTIONS_CACHE_URL"]}`, `GitHub Action Cache URL: ${process.env["ACTIONS_CACHE_URL"]}`,
); );
this.daemonStarted = true;
actionsCore.exportVariable(ENV_CACHE_STARTED, STARTED_HINT);
const sourceBinary = inputs.getStringOrNull("source-binary"); const sourceBinary = inputs.getStringOrNull("source-binary");
const daemonBin = const daemonBin =
sourceBinary !== null ? sourceBinary : await this.fetchAutoCacher(); sourceBinary !== null ? sourceBinary : await this.fetchAutoCacher();
@ -134,10 +127,9 @@ class MagicNixCacheAction {
}); });
// Start tailing the daemon log. // Start tailing the daemon log.
const daemonDir = await this.getDaemonDir(); const outputPath = `${this.daemonDir}/daemon.log`;
const outputPath = `${daemonDir}/daemon.log`;
const output = openSync(outputPath, "a"); const output = openSync(outputPath, "a");
const log = tailLog(daemonDir); const log = tailLog(this.daemonDir);
const netrc = await netrcPath(); const netrc = await netrcPath();
const nixConfPath = `${process.env["HOME"]}/.config/nix/nix.conf`; const nixConfPath = `${process.env["HOME"]}/.config/nix/nix.conf`;
@ -192,7 +184,7 @@ class MagicNixCacheAction {
// Start the server. Once it is ready, it will notify us via the notification server. // Start the server. Once it is ready, it will notify us via the notification server.
const daemon = spawn(daemonBin, daemonCliFlags, opts); const daemon = spawn(daemonBin, daemonCliFlags, opts);
const pidFile = path.join(daemonDir, "daemon.pid"); const pidFile = path.join(this.daemonDir, "daemon.pid");
await fs.writeFile(pidFile, `${daemon.pid}`); await fs.writeFile(pidFile, `${daemon.pid}`);
actionsCore.info("Waiting for magic-nix-cache to start..."); actionsCore.info("Waiting for magic-nix-cache to start...");
@ -239,7 +231,7 @@ class MagicNixCacheAction {
} }
async notifyAutoCache(): Promise<void> { async notifyAutoCache(): Promise<void> {
if (!(await this.daemonDirExists())) { if (!this.daemonStarted) {
actionsCore.debug("magic-nix-cache not started - Skipping"); actionsCore.debug("magic-nix-cache not started - Skipping");
return; return;
} }
@ -259,20 +251,19 @@ class MagicNixCacheAction {
} }
async tearDownAutoCache(): Promise<void> { async tearDownAutoCache(): Promise<void> {
if (!(await this.daemonDirExists())) { if (!this.daemonStarted) {
actionsCore.debug("magic-nix-cache not started - Skipping"); actionsCore.debug("magic-nix-cache not started - Skipping");
return; return;
} }
const daemonDir = await this.getDaemonDir();
const pidFile = path.join(daemonDir, "daemon.pid"); const pidFile = path.join(this.daemonDir, "daemon.pid");
const pid = parseInt(await fs.readFile(pidFile, { encoding: "ascii" })); const pid = parseInt(await fs.readFile(pidFile, { encoding: "ascii" }));
actionsCore.debug(`found daemon pid: ${pid}`); actionsCore.debug(`found daemon pid: ${pid}`);
if (!pid) { if (!pid) {
throw new Error("magic-nix-cache did not start successfully"); throw new Error("magic-nix-cache did not start successfully");
} }
const log = tailLog(daemonDir); const log = tailLog(this.daemonDir);
try { try {
actionsCore.debug(`about to post to localhost`); actionsCore.debug(`about to post to localhost`);
@ -296,7 +287,7 @@ class MagicNixCacheAction {
} finally { } finally {
if (actionsCore.isDebug()) { if (actionsCore.isDebug()) {
actionsCore.info("Entire log:"); actionsCore.info("Entire log:");
const entireLog = readFileSync(path.join(daemonDir, "daemon.log")); const entireLog = readFileSync(path.join(this.daemonDir, "daemon.log"));
actionsCore.info(entireLog.toString()); actionsCore.info(entireLog.toString());
} }
} }