Do insecure upload if user allows it

Author: divolgin

cmd/troubleshoot/cli/run.go

@@ -246,11 +246,11 @@ func parseTimeFlags(v *viper.Viper) (*time.Time, error) {
 	return &sinceTime, nil
 }
 
-func shouldRetryRequest(err error, httpClient *http.Client) bool {
-	if strings.Contains(err.Error(), "x509") && httpClient == http.DefaultClient && canTryInsecure() {
-		httpClient = &http.Client{Transport: &http.Transport{
+func shouldRetryRequest(err error) bool {
+	if strings.Contains(err.Error(), "x509") && canTryInsecure() {
+		httputil.AddTransport(&http.Transport{
 			TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
-		}}
+		})
 		return true
 	}
 	return false

pkg/client/troubleshootclientset/fake/register.go

@@ -14,7 +14,6 @@ func AddTransport(transport *http.Transport) {
 }
 
 func GetHttpClient() *http.Client {
-
 	if httpTransport != nil {
 		httpClient.Transport = httpTransport
 		return httpClient

pkg/httputil/config.go

@@ -48,7 +48,7 @@ func uploadSupportBundle(r *troubleshootv1beta2.ResultRequest, archivePath strin
 		httpClient := httputil.GetHttpClient()
 		resp, err := httpClient.Do(req)
 		if err != nil {
-			if shouldRetryRequest(err, httpClient) {
+			if shouldRetryRequest(err) {
 				continue
 			}
 			return errors.Wrap(err, "execute request")
@@ -82,7 +82,7 @@ func uploadSupportBundle(r *troubleshootv1beta2.ResultRequest, archivePath strin
 			httpClient := httputil.GetHttpClient()
 			resp, err := httpClient.Do(req)
 			if err != nil {
-				if shouldRetryRequest(err, httpClient) {
+				if shouldRetryRequest(err) {
 					continue
 				}
 				return errors.Wrap(err, "execute redaction request")
@@ -109,7 +109,7 @@ func callbackSupportBundleAPI(r *troubleshootv1beta2.ResultRequest, archivePath
 		httpClient := httputil.GetHttpClient()
 		resp, err := httpClient.Do(req)
 		if err != nil {
-			if shouldRetryRequest(err, httpClient) {
+			if shouldRetryRequest(err) {
 				continue
 			}
 			return errors.Wrap(err, "execute request")
@@ -133,11 +133,11 @@ func getExpectedContentType(uploadURL string) string {
 	return parsedURL.Query().Get("Content-Type")
 }
 
-func shouldRetryRequest(err error, httpClient *http.Client) bool {
-	if strings.Contains(err.Error(), "x509") && httpClient == http.DefaultClient && canTryInsecure() {
-		httpClient = &http.Client{Transport: &http.Transport{
+func shouldRetryRequest(err error) bool {
+	if strings.Contains(err.Error(), "x509") && canTryInsecure() {
+		httputil.AddTransport(&http.Transport{
 			TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
-		}}
+		})
 		return true
 	}
 	return false

pkg/supportbundle/aftercollection.go

@@ -182,7 +182,7 @@ func loadSpecFromURL(arg string) ([]byte, error) {
 		httpClient := httputil.GetHttpClient()
 		resp, err := httpClient.Do(req)
 		if err != nil {
-			if shouldRetryRequest(err, httpClient) {
+			if shouldRetryRequest(err) {
 				continue
 			}
 			return nil, errors.Wrap(err, "execute request")