v1.5.16

.gitignore

@@ -1,3 +1,5 @@
 cmd/
 .idea/
-.vscode/
+.vscode/
+.fleet/
+.DS_Store

CHANGELOG.md

@@ -1,13 +1,4 @@
-## Version 1.5.8
+## Version 1.5.16
 
 ### Bugfix
-- Fix model the RecordK8CI to cloudbroker/k8ci/models to correctly receive information on get request
-- Add model the RecordK8CIList to cloudbroker/k8ci/models to correctly receive information on list request
-- Refactored clients to fix the problems with concurrency safety
-- Add the Routes field in the CreateInRGRequest and CreateInAccountRequest models in cb/vins. The fields for creating the resource are matched
-
-For get request to work correctly:
-- Fix the Rules field (fix type) in the NATConfig model in cb/vins/models and ca/vins/models
-- Fix the InfoVNF model (remove the excess field, add the Routes field) in cb/vins/models 
-- Add the ItemRoutes model in cb/vins/models 
-- Fix the RecordVINS model (remove the excess fields) in cb/vins/models 
+- Fix EOF error by closing request

client.go

@@ -140,24 +140,37 @@ func (dc *DecortClient) do(req *http.Request) (*http.Response, error) {
 	req.Header.Add("Authorization", "bearer "+dc.cfg.Token)
 	req.Header.Set("Accept", "application/json")
 
-	var resp *http.Response
-	var err error
 	buf, _ := io.ReadAll(req.Body)
 
-	for i := uint64(0); i < dc.cfg.Retries; i++ {
-		req := req.Clone(req.Context())
-		req.Body = io.NopCloser(bytes.NewBuffer(buf))
-		resp, err = dc.client.Do(req)
-
-		if err == nil {
-			if resp.StatusCode == 200 {
-				return resp, err
+	req.Body = io.NopCloser(bytes.NewBuffer(buf))
+	resp, err := dc.client.Do(req)
+	req.Close = true
+	if err != nil || resp == nil {
+		if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
+			for i := uint64(0); i < dc.cfg.Retries; i++ {
+				time.Sleep(5 * time.Second)
+				resp, err = dc.client.Do(req)
+				if err == nil {
+					break
+				}
+				if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
+					continue
+				}
+				if err != nil {
+					return nil, err
+				}
 			}
-			respBytes, _ := io.ReadAll(resp.Body)
-			err = fmt.Errorf("%s", respBytes)
-			resp.Body.Close()
 		}
+		return resp, err
 	}
 
+	if resp.StatusCode == 200 {
+		return resp, nil
+	}
+
+	respBytes, _ := io.ReadAll(resp.Body)
+	err = fmt.Errorf("%s", respBytes)
+	resp.Body.Close()
+
 	return nil, fmt.Errorf("could not execute request: %w", err)
 }

legacy-client.go

@@ -137,24 +137,42 @@ func (ldc *LegacyDecortClient) do(req *http.Request) (*http.Response, error) {
 	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
 	req.Header.Set("Accept", "application/json")
 
-	var resp *http.Response
-	var err error
+	// var resp *http.Response
+	// var err error
 	buf, _ := io.ReadAll(req.Body)
 
-	for i := uint64(0); i < ldc.cfg.Retries; i++ {
-		req := req.Clone(req.Context())
-		req.Body = io.NopCloser(bytes.NewBuffer(buf))
-		resp, err = ldc.client.Do(req)
-
-		if err == nil {
-			if resp.StatusCode == 200 {
-				return resp, err
+	// for i := uint64(0); i < ldc.cfg.Retries; i++ {
+	// req = req.Clone(req.Context())
+	req.Body = io.NopCloser(bytes.NewBuffer(buf))
+	resp, err := ldc.client.Do(req)
+	req.Close = true
+	if err != nil || resp == nil {
+		if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
+			for i := uint64(0); i < ldc.cfg.Retries; i++ {
+				time.Sleep(5 * time.Second)
+				resp, err = ldc.client.Do(req)
+				if err == nil {
+					break
+				}
+				if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
+					continue
+				}
+				if err != nil {
+					return nil, err
+				}
 			}
-			respBytes, _ := io.ReadAll(resp.Body)
-			err = fmt.Errorf("%s", respBytes)
-			resp.Body.Close()
 		}
+		return resp, err
 	}
 
+	if resp.StatusCode == 200 {
+		return resp, nil
+	}
+
+	respBytes, _ := io.ReadAll(resp.Body)
+	err = fmt.Errorf("%s", respBytes)
+	resp.Body.Close()
+	// }
+
 	return nil, fmt.Errorf("could not execute request: %w", err)
 }