/** * Copyright 2023 actions-toolkit authors * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ import fs from 'fs'; import path from 'path'; import * as exec from '@actions/exec'; import * as semver from 'semver'; import {Docker} from '../docker'; import {Context} from '../context'; import {Inputs} from './inputs'; import {Cert} from '../types/buildx'; export interface BuildxOpts { context: Context; standalone?: boolean; } export class Buildx { private readonly context: Context; private _version: string | undefined; public readonly inputs: Inputs; public readonly standalone: boolean; constructor(opts: BuildxOpts) { this.context = opts.context; this.inputs = new Inputs(this.context); this.standalone = opts?.standalone ?? !Docker.isAvailable; } static get configDir(): string { return process.env.BUILDX_CONFIG || path.join(Docker.configDir, 'buildx'); } static get certsDir(): string { return path.join(Buildx.configDir, 'certs'); } public getCommand(args: Array) { return { command: this.standalone ? 'buildx' : 'docker', args: this.standalone ? args : ['buildx', ...args] }; } public async isAvailable(): Promise { const cmd = this.getCommand([]); return await exec .getExecOutput(cmd.command, cmd.args, { ignoreReturnCode: true, silent: true }) .then(res => { if (res.stderr.length > 0 && res.exitCode != 0) { return false; } return res.exitCode == 0; }) // eslint-disable-next-line @typescript-eslint/no-unused-vars .catch(error => { return false; }); } public async printInspect(name: string): Promise { const cmd = this.getCommand(['inspect', name]); await exec.exec(cmd.command, cmd.args, { failOnStdErr: false }); } get version() { return (async () => { if (!this._version) { const cmd = this.getCommand(['version']); this._version = await exec .getExecOutput(cmd.command, cmd.args, { ignoreReturnCode: true, silent: true }) .then(res => { if (res.stderr.length > 0 && res.exitCode != 0) { throw new Error(res.stderr.trim()); } return Buildx.parseVersion(res.stdout.trim()); }); } return this._version; })(); } public async printVersion() { const cmd = this.getCommand(['version']); await exec.exec(cmd.command, cmd.args, { failOnStdErr: false }); } public static parseVersion(stdout: string): string { const matches = /\sv?([0-9a-f]{7}|[0-9.]+)/.exec(stdout); if (!matches) { throw new Error(`Cannot parse buildx version`); } return matches[1]; } public async versionSatisfies(range: string, version?: string): Promise { const ver = version ?? (await this.version); if (!ver) { return false; } return semver.satisfies(ver, range) || /^[0-9a-f]{7}$/.exec(ver) !== null; } public static resolveCertsDriverOpts(driver: string, endpoint: string, cert: Cert): Array { let url: URL; try { url = new URL(endpoint); } catch (e) { return []; } if (url.protocol != 'tcp:') { return []; } const driverOpts: Array = []; if (Object.keys(cert).length == 0) { return driverOpts; } let host = url.hostname; if (url.port.length > 0) { host += `-${url.port}`; } if (cert.cacert !== undefined) { const cacertpath = path.join(Buildx.certsDir, `cacert_${host}.pem`); fs.writeFileSync(cacertpath, cert.cacert); driverOpts.push(`cacert=${cacertpath}`); } if (cert.cert !== undefined) { const certpath = path.join(Buildx.certsDir, `cert_${host}.pem`); fs.writeFileSync(certpath, cert.cert); driverOpts.push(`cert=${certpath}`); } if (cert.key !== undefined) { const keypath = path.join(Buildx.certsDir, `key_${host}.pem`); fs.writeFileSync(keypath, cert.key); driverOpts.push(`key=${keypath}`); } if (driver != 'remote') { return []; } return driverOpts; } }