Skip to content

Commit

Permalink
Use sudo to write microk8s registry config file
Browse files Browse the repository at this point in the history
  • Loading branch information
@weiiwang01
weiiwang01 committed Jan 11, 2024
1 parent acc5880 commit 8675496
Show file tree
Hide file tree
Showing 2 changed files with 74 additions and 38 deletions.
53 changes: 34 additions & 19 deletions dist/bootstrap/index.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5492,7 +5492,6 @@ var __importDefault = (this && this.__importDefault) || function (mod) {
Object.defineProperty(exports, "__esModule", ({ value: true }));
const core = __importStar(__nccwpck_require__(2186));
const exec = __importStar(__nccwpck_require__(1514));
const fs = __importStar(__nccwpck_require__(5747));
const utils_1 = __nccwpck_require__(2828);
const semver_1 = __importDefault(__nccwpck_require__(1383));
const ts_dedent_1 = __importDefault(__nccwpck_require__(3604));
Expand Down Expand Up @@ -5556,29 +5555,45 @@ function retry_until_rc(cmd, expected_rc = 0, maxRetries = 12, timeout = 10000)
return false;
});
}
function microk8s_init(addons, container_registry_url) {
function microk8s_init(channel, addons, container_registry_url) {
return __awaiter(this, void 0, void 0, function* () {
// microk8s needs some additional things done to ensure it's ready for Juju.
// Add container registry configuration if given.
if (container_registry_url) {
let hostname;
let port;
try {
const url = new URL(container_registry_url);
hostname = url.hostname;
port = url.port;
const versionMatch = channel.match(/\d+\.\d+/g);
if (versionMatch && parseFloat(versionMatch[0]) <= 1.22) {
const templateFile = "/var/snap/microk8s/current/args/containerd-template.toml";
let template = "";
yield exec.exec("sudo", ["cat", templateFile], {
listeners: {
stdout: (data) => { template += data.toString(); }
}
});
yield exec.exec("sudo", ["tee", templateFile], { input: Buffer.from(template.replace("https://registry-1.docker.io", container_registry_url)) });
}
catch (err) {
core.setFailed(`Failed to parse URL of container registry for microk8s: ${err}`);
return false;
else {
let hostname;
let port;
try {
const url = new URL(container_registry_url);
hostname = url.hostname;
port = url.port;
}
catch (err) {
core.setFailed(`Failed to parse URL of container registry for microk8s: ${err}`);
return false;
}
let content = ts_dedent_1.default `
server = "${container_registry_url}"
[host."${hostname}:${port}"]
capabilities = ["pull", "resolve"]
`;
yield exec.exec("sudo", ["tee", "/var/snap/microk8s/current/args/certs.d/docker.io/hosts.toml"], { input: Buffer.from(content) });
}
let content = ts_dedent_1.default `
server = "${container_registry_url}"
[host."${hostname}:${port}"]
capabilities = ["pull", "resolve"]
`;
fs.writeFileSync("/var/snap/microk8s/current/args/certs.d/docker.io/hosts.toml", content);
yield exec.exec("sudo", ["microk8s", "stop"]);
yield exec.exec("sudo", ["microk8s", "start"]);
}
// Add the given addons if any were given.
yield exec_as_microk8s("microk8s status --wait-ready");
Expand Down Expand Up @@ -5732,7 +5747,7 @@ function run() {
core.endGroup();
core.startGroup("Initialize microk8s");
yield exec.exec('bash', ['-c', `sudo usermod -a -G ${microk8s_group} $USER`]);
if (!(yield microk8s_init(microk8s_addons, container_registry_url))) {
if (!(yield microk8s_init(channel, microk8s_addons, container_registry_url))) {
return;
}
group = microk8s_group;
Expand Down
59 changes: 40 additions & 19 deletions src/bootstrap/index.ts
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
import * as core from '@actions/core';
import * as exec from '@actions/exec';
import * as fs from 'fs';
import { retryAsyncDecorator } from 'ts-retry/lib/cjs/retry/utils';
import semver from 'semver';
import dedent from 'ts-dedent';
Expand Down Expand Up @@ -73,27 +72,49 @@ async function retry_until_rc(cmd: string, expected_rc=0, maxRetries=12, timeout
return false;
}

async function microk8s_init(addons, container_registry_url:string) {
async function microk8s_init(channel, addons, container_registry_url:string) {
// microk8s needs some additional things done to ensure it's ready for Juju.
// Add container registry configuration if given.
if (container_registry_url) {
let hostname;
let port;
try {
const url = new URL(container_registry_url);
hostname = url.hostname;
port = url.port;
} catch(err) {
core.setFailed(`Failed to parse URL of container registry for microk8s: ${err}`);
return false;
const versionMatch = channel.match(/\d+\.\d+/g);
if (versionMatch && parseFloat(versionMatch[0]) <= 1.22) {
const templateFile = "/var/snap/microk8s/current/args/containerd-template.toml";
let template = "";
await exec.exec("sudo", ["cat", templateFile], {
listeners: {
stdout: (data) => { template += data.toString() }
}
}
)
await exec.exec(
"sudo", ["tee", templateFile],
{input: Buffer.from(template.replace("https://registry-1.docker.io", container_registry_url))}
);
} else {
let hostname;
let port;
try {
const url = new URL(container_registry_url);
hostname = url.hostname;
port = url.port;
} catch (err) {
core.setFailed(`Failed to parse URL of container registry for microk8s: ${err}`);
return false;
}
let content = dedent`
server = "${container_registry_url}"
[host."${hostname}:${port}"]
capabilities = ["pull", "resolve"]
`;
await exec.exec(
"sudo", ["tee", "/var/snap/microk8s/current/args/certs.d/docker.io/hosts.toml"],
{input: Buffer.from(content)}
);
}
let content = dedent`
server = "${container_registry_url}"
[host."${hostname}:${port}"]
capabilities = ["pull", "resolve"]
`;
fs.writeFileSync("/var/snap/microk8s/current/args/certs.d/docker.io/hosts.toml", content)
await exec.exec("sudo", ["microk8s", "stop"])
await exec.exec("sudo", ["microk8s", "start"])
}

// Add the given addons if any were given.
Expand Down Expand Up @@ -246,7 +267,7 @@ async function run() {
core.endGroup();
core.startGroup("Initialize microk8s");
await exec.exec('bash', ['-c', `sudo usermod -a -G ${microk8s_group} $USER`]);
if(!await microk8s_init(microk8s_addons, container_registry_url)) {
if(!await microk8s_init(channel, microk8s_addons, container_registry_url)) {
return;
}
group = microk8s_group;
Expand Down

0 comments on commit 8675496

Please sign in to comment.