| // Copyright 2022 The Bazel Authors. All rights reserved. |
| // |
| // 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. |
| |
| package com.google.devtools.build.lib.authandtls.credentialhelper; |
| |
| import static com.google.devtools.build.lib.profiler.ProfilerTask.CREDENTIAL_HELPER; |
| import static java.nio.charset.StandardCharsets.UTF_8; |
| |
| import com.google.common.annotations.VisibleForTesting; |
| import com.google.common.base.Preconditions; |
| import com.google.common.collect.ImmutableList; |
| import com.google.common.io.CharStreams; |
| import com.google.devtools.build.lib.profiler.Profiler; |
| import com.google.devtools.build.lib.profiler.SilentCloseable; |
| import com.google.devtools.build.lib.shell.JavaSubprocessFactory; |
| import com.google.devtools.build.lib.shell.Subprocess; |
| import com.google.devtools.build.lib.shell.SubprocessBuilder; |
| import com.google.devtools.build.lib.vfs.Path; |
| import com.google.errorprone.annotations.Immutable; |
| import com.google.gson.Gson; |
| import com.google.gson.JsonSyntaxException; |
| import java.io.IOException; |
| import java.io.InputStreamReader; |
| import java.io.OutputStreamWriter; |
| import java.io.Reader; |
| import java.io.Writer; |
| import java.net.URI; |
| import java.util.Locale; |
| import java.util.Objects; |
| |
| /** Wraps an external tool used to obtain credentials. */ |
| @Immutable |
| public final class CredentialHelper { |
| private static final Gson GSON = new Gson(); |
| |
| // `Path` is immutable, but not annotated. |
| @SuppressWarnings("Immutable") |
| private final Path path; |
| |
| CredentialHelper(Path path) { |
| this.path = Preconditions.checkNotNull(path); |
| } |
| |
| @VisibleForTesting |
| public Path getPath() { |
| return path; |
| } |
| |
| /** |
| * Fetches credentials for the specified {@link URI} by invoking the credential helper as |
| * subprocess according to the <a |
| * href="https://github.com/bazelbuild/proposals/blob/main/designs/2022-06-07-bazel-credential-helpers.md">credential |
| * helper protocol</a>. |
| * |
| * @param environment The environment to run the subprocess in. |
| * @param uri The {@link URI} to fetch credentials for. |
| * @return The response from the subprocess. |
| */ |
| public GetCredentialsResponse getCredentials(CredentialHelperEnvironment environment, URI uri) |
| throws IOException { |
| Preconditions.checkNotNull(environment); |
| Preconditions.checkNotNull(uri); |
| |
| Profiler prof = Profiler.instance(); |
| |
| try (SilentCloseable c = prof.profile(CREDENTIAL_HELPER, "calling credential helper")) { |
| Subprocess process = spawnSubprocess(environment, "get"); |
| try (Reader stdout = new InputStreamReader(process.getInputStream(), UTF_8); |
| Reader stderr = new InputStreamReader(process.getErrorStream(), UTF_8)) { |
| try (Writer stdin = new OutputStreamWriter(process.getOutputStream(), UTF_8)) { |
| GSON.toJson(GetCredentialsRequest.newBuilder().setUri(uri).build(), stdin); |
| } |
| |
| try { |
| process.waitFor(); |
| } catch (InterruptedException e) { |
| throw new CredentialHelperException( |
| String.format( |
| Locale.US, |
| "Failed to get credentials for '%s' from helper '%s': process was interrupted", |
| uri, |
| path)); |
| } |
| |
| if (process.timedout()) { |
| throw new CredentialHelperException( |
| String.format( |
| Locale.US, |
| "Failed to get credentials for '%s' from helper '%s': process timed out", |
| uri, |
| path)); |
| } |
| if (process.exitValue() != 0) { |
| throw new CredentialHelperException( |
| String.format( |
| Locale.US, |
| "Failed to get credentials for '%s' from helper '%s': process exited with code" |
| + " %d. stderr: %s", |
| uri, |
| path, |
| process.exitValue(), |
| CharStreams.toString(stderr))); |
| } |
| |
| try { |
| GetCredentialsResponse response = GSON.fromJson(stdout, GetCredentialsResponse.class); |
| if (response == null) { |
| throw new CredentialHelperException( |
| String.format( |
| Locale.US, |
| "Failed to get credentials for '%s' from helper '%s': process exited without" |
| + " output. stderr: %s", |
| uri, |
| path, |
| CharStreams.toString(stderr))); |
| } |
| return response; |
| } catch (JsonSyntaxException e) { |
| throw new CredentialHelperException( |
| String.format( |
| Locale.US, |
| "Failed to get credentials for '%s' from helper '%s': error parsing output." |
| + " stderr: %s", |
| uri, |
| path, |
| CharStreams.toString(stderr)), |
| e); |
| } |
| } |
| } |
| } |
| |
| private Subprocess spawnSubprocess(CredentialHelperEnvironment environment, String... args) |
| throws IOException { |
| Preconditions.checkNotNull(environment); |
| Preconditions.checkNotNull(args); |
| |
| // Force using JavaSubprocessFactory on Windows, because for some reasons, |
| // WindowsSubprocessFactory cannot redirect stdin to subprocess. |
| return new SubprocessBuilder(JavaSubprocessFactory.INSTANCE) |
| .setArgv(ImmutableList.<String>builder().add(path.getPathString()).add(args).build()) |
| .setWorkingDirectory(environment.getWorkspacePath().getPathFile()) |
| .setEnv(environment.getClientEnvironment()) |
| .setTimeoutMillis(environment.getHelperExecutionTimeout().toMillis()) |
| .start(); |
| } |
| |
| @Override |
| public boolean equals(Object o) { |
| if (o instanceof CredentialHelper) { |
| CredentialHelper that = (CredentialHelper) o; |
| return Objects.equals(this.getPath(), that.getPath()); |
| } |
| |
| return false; |
| } |
| |
| @Override |
| public int hashCode() { |
| return Objects.hashCode(getPath()); |
| } |
| } |