Function wrappedArtifactConn

app/cli/cmd/artifact.go:39–72

(cpConn *grpc.ClientConn, role pb.CASCredentialsServiceGetRequest_Role, digest string)

}

func wrappedArtifactConn(cpConn *grpc.ClientConn, role pb.CASCredentialsServiceGetRequest_Role, digest string) (*grpc.ClientConn, error) {
	// Retrieve temporary credentials for uploading
	client := pb.NewCASCredentialsServiceClient(cpConn)
	resp, err := client.Get(context.Background(), &pb.CASCredentialsServiceGetRequest{
		Role:   role,
		Digest: digest,
	})
	if err != nil {
		return nil, err
	}

	if apiInsecure() {
		logger.Warn().Msg("API contacted in insecure mode")
	}

	var opts = []grpcconn.Option{
		grpcconn.WithInsecure(apiInsecure()),
		grpcconn.WithCLIVersion(fullVersion()),
	}

	if maxRecv := apiMaxRecvMsgSize(); maxRecv > 0 {
		opts = append(opts, grpcconn.WithMaxRecvMsgSize(maxRecv))
	}

	if caValue := viper.GetString(confOptions.CASCA.viperKey); caValue != "" {
		if _, err := os.Stat(caValue); err == nil {
			opts = append(opts, grpcconn.WithCAFile(caValue))
		} else {
			opts = append(opts, grpcconn.WithCAContent(caValue))
		}
	}

	return grpcconn.New(viper.GetString(confOptions.CASAPI.viperKey), resp.Result.Token, opts...)
}