gofmt -w

Author: ZhangYongguang5467

pkg/backup/external_simple.go

@@ -474,7 +474,7 @@ func (e *BackupExecutor) countRecordsInFile(filePath string) (int, float64, erro
 	const maxCapacity = 1024 * 1024 // 1MB
 	buf := make([]byte, maxCapacity)
 	scanner.Buffer(buf, maxCapacity)
-	
+
 	count := 0
 
 	for scanner.Scan() {
@@ -496,7 +496,7 @@ func (e *BackupExecutor) countRecordsInFile(filePath string) (int, float64, erro
 func (e *BackupExecutor) maskSensitiveArgs(args []string) string {
 	maskedArgs := make([]string, len(args))
 	copy(maskedArgs, args)
-	
+
 	for i, arg := range maskedArgs {
 		if arg == "--uri" && i+1 < len(maskedArgs) {
 			// Mask credentials in URI
@@ -507,11 +507,11 @@ func (e *BackupExecutor) maskSensitiveArgs(args []string) string {
 				if len(parts) == 2 {
 					protocolPart := parts[0] + "://"
 					remaining := parts[1]
-					
+
 					if atIndex := strings.Index(remaining, "@"); atIndex != -1 {
 						hostPart := remaining[atIndex:]
 						credPart := remaining[:atIndex]
-						
+
 						// Check if there are credentials
 						if strings.Contains(credPart, ":") {
 							maskedArgs[i+1] = protocolPart + "***:***" + hostPart
@@ -521,7 +521,7 @@ func (e *BackupExecutor) maskSensitiveArgs(args []string) string {
 			}
 		}
 	}
-	
+
 	return strings.Join(maskedArgs, " ")
 }
 

pkg/syncer/mongodb/mongodb.go

@@ -1163,11 +1163,11 @@ func (s *MongoDBSyncer) convertRawBSONToWriteModel(rawData bson.Raw, sourceDB, c
 		// Check if delete operations should be ignored for this collection
 		advancedSettings := s.findTableAdvancedSettings(collectionName)
 		if advancedSettings.IgnoreDeleteOps {
-			s.logger.Debugf("[MongoDB] Ignoring delete operation for %s.%s (ignoreDeleteOps=true)", 
+			s.logger.Debugf("[MongoDB] Ignoring delete operation for %s.%s (ignoreDeleteOps=true)",
 				sourceDB, collectionName)
 			return nil
 		}
-		
+
 		var docID interface{}
 		if dk, ok := event["documentKey"].(bson.M); ok {
 			docID = dk["_id"]
@@ -2026,11 +2026,11 @@ func (s *MongoDBSyncer) deserializeWriteModel(data json.RawMessage, collectionNa
 		// Check if delete operations should be ignored for this collection
 		advancedSettings := s.findTableAdvancedSettings(collectionName)
 		if advancedSettings.IgnoreDeleteOps {
-			s.logger.Debugf("[MongoDB] Ignoring delete operation during retry for %s (ignoreDeleteOps=true)", 
+			s.logger.Debugf("[MongoDB] Ignoring delete operation during retry for %s (ignoreDeleteOps=true)",
 				collectionName)
 			return nil, nil
 		}
-		
+
 		filter, ok := modelData["filter"]
 		if !ok {
 			return nil, fmt.Errorf("missing filter for delete operation")

pkg/syncer/test/api_coverage_test.go

@@ -18,65 +18,65 @@ func TestAPICoverage(t *testing.T) {
 		// Test backup list handler
 		req := httptest.NewRequest("GET", "/api/backup", nil)
 		w := httptest.NewRecorder()
-		
+
 		api.BackupListHandler(w, req)
-		
+
 		if w.Code == 0 {
 			t.Error("Expected response code to be set")
 		}
 		t.Logf("BackupListHandler returned status: %d", w.Code)
-		
+
 		// Test backup create handler with invalid JSON
 		invalidJSON := `{"invalid": json}`
 		req = httptest.NewRequest("POST", "/api/backup", bytes.NewBufferString(invalidJSON))
 		req.Header.Set("Content-Type", "application/json")
 		w = httptest.NewRecorder()
-		
+
 		api.BackupCreateHandler(w, req)
 		t.Logf("BackupCreateHandler with invalid JSON returned status: %d", w.Code)
-		
+
 		// Test backup create handler with valid JSON but missing fields
 		validJSONMissingFields := `{"name": "test"}`
 		req = httptest.NewRequest("POST", "/api/backup", bytes.NewBufferString(validJSONMissingFields))
 		req.Header.Set("Content-Type", "application/json")
 		w = httptest.NewRecorder()
-		
+
 		api.BackupCreateHandler(w, req)
 		t.Logf("BackupCreateHandler with missing fields returned status: %d", w.Code)
-		
+
 		// Test backup update handler
 		req = httptest.NewRequest("PUT", "/api/backup/1", bytes.NewBufferString(`{"enable": true}`))
 		req.Header.Set("Content-Type", "application/json")
 		w = httptest.NewRecorder()
-		
+
 		api.BackupUpdateHandler(w, req)
 		t.Logf("BackupUpdateHandler returned status: %d", w.Code)
-		
+
 		// Test backup delete handler
 		req = httptest.NewRequest("DELETE", "/api/backup/1", nil)
 		w = httptest.NewRecorder()
-		
+
 		api.BackupDeleteHandler(w, req)
 		t.Logf("BackupDeleteHandler returned status: %d", w.Code)
-		
+
 		// Test backup pause handler
 		req = httptest.NewRequest("PUT", "/api/backup/1/pause", nil)
 		w = httptest.NewRecorder()
-		
+
 		api.BackupPauseHandler(w, req)
 		t.Logf("BackupPauseHandler returned status: %d", w.Code)
-		
+
 		// Test backup resume handler
 		req = httptest.NewRequest("PUT", "/api/backup/1/resume", nil)
 		w = httptest.NewRecorder()
-		
+
 		api.BackupResumeHandler(w, req)
 		t.Logf("BackupResumeHandler returned status: %d", w.Code)
-		
+
 		// Test backup run handler
 		req = httptest.NewRequest("POST", "/api/backup/1/run", nil)
 		w = httptest.NewRecorder()
-		
+
 		api.BackupRunHandler(w, req)
 		t.Logf("BackupRunHandler returned status: %d", w.Code)
 
@@ -88,7 +88,7 @@ func TestAPICoverage(t *testing.T) {
 		// For now, just test that the API package is accessible
 		req := httptest.NewRequest("GET", "/api/backup", nil)
 		w := httptest.NewRecorder()
-		
+
 		api.BackupListHandler(w, req)
 		t.Logf("Additional API test returned status: %d", w.Code)
 
@@ -97,27 +97,27 @@ func TestAPICoverage(t *testing.T) {
 
 	t.Run("APIErrorHandling", func(t *testing.T) {
 		// Test various error conditions
-		
+
 		// Test with unsupported method
 		req := httptest.NewRequest("PATCH", "/api/backup", nil)
 		w := httptest.NewRecorder()
-		
+
 		api.BackupListHandler(w, req)
 		t.Logf("BackupListHandler with PATCH method returned status: %d", w.Code)
-		
+
 		// Test with malformed request body
 		req = httptest.NewRequest("POST", "/api/backup", bytes.NewBufferString("{"))
 		req.Header.Set("Content-Type", "application/json")
 		w = httptest.NewRecorder()
-		
+
 		api.BackupCreateHandler(w, req)
 		t.Logf("BackupCreateHandler with malformed JSON returned status: %d", w.Code)
-		
+
 		// Test with empty body
 		req = httptest.NewRequest("POST", "/api/backup", bytes.NewBufferString(""))
 		req.Header.Set("Content-Type", "application/json")
 		w = httptest.NewRecorder()
-		
+
 		api.BackupCreateHandler(w, req)
 		t.Logf("BackupCreateHandler with empty body returned status: %d", w.Code)
 
@@ -126,18 +126,18 @@ func TestAPICoverage(t *testing.T) {
 
 	t.Run("HTTPMethodValidation", func(t *testing.T) {
 		// Test all handlers with incorrect HTTP methods
-		
+
 		handlers := map[string]func(http.ResponseWriter, *http.Request){
 			"GET /api/backup (POST)":     api.BackupListHandler,
-			"POST /api/backup (GET)":     api.BackupCreateHandler, 
+			"POST /api/backup (GET)":     api.BackupCreateHandler,
 			"PUT /api/backup/1 (GET)":    api.BackupUpdateHandler,
 			"DELETE /api/backup/1 (GET)": api.BackupDeleteHandler,
 		}
-		
+
 		for testName, handler := range handlers {
 			req := httptest.NewRequest("GET", "/api/backup", nil)
 			w := httptest.NewRecorder()
-			
+
 			handler(w, req)
 			t.Logf("%s returned status: %d", testName, w.Code)
 		}
@@ -147,19 +147,19 @@ func TestAPICoverage(t *testing.T) {
 
 	t.Run("RequestValidation", func(t *testing.T) {
 		// Test request validation with various content types
-		
+
 		// Test with wrong content type
 		req := httptest.NewRequest("POST", "/api/backup", bytes.NewBufferString(`{"test": "data"}`))
 		req.Header.Set("Content-Type", "text/plain")
 		w := httptest.NewRecorder()
-		
+
 		api.BackupCreateHandler(w, req)
 		t.Logf("BackupCreateHandler with text/plain returned status: %d", w.Code)
-		
+
 		// Test with missing content type
 		req = httptest.NewRequest("POST", "/api/backup", bytes.NewBufferString(`{"test": "data"}`))
 		w = httptest.NewRecorder()
-		
+
 		api.BackupCreateHandler(w, req)
 		t.Logf("BackupCreateHandler with no content type returned status: %d", w.Code)
 
@@ -174,13 +174,13 @@ func TestAPIResponseHandling(t *testing.T) {
 		req := httptest.NewRequest("GET", "/api/backup", nil)
 		req.Header.Set("Accept", "application/json")
 		w := httptest.NewRecorder()
-		
+
 		api.BackupListHandler(w, req)
-		
+
 		// Check if response has proper content type
 		contentType := w.Header().Get("Content-Type")
 		t.Logf("BackupListHandler content type: %s", contentType)
-		
+
 		// Try to parse response as JSON
 		if w.Body.Len() > 0 {
 			var response interface{}
@@ -198,30 +198,30 @@ func TestAPIResponseHandling(t *testing.T) {
 	t.Run("ErrorResponses", func(t *testing.T) {
 		// Test error response handling
 		invalidRequests := []struct {
-			method string
-			path   string
-			body   string
+			method      string
+			path        string
+			body        string
 			contentType string
 		}{
 			{"POST", "/api/backup", `{"incomplete"}`, "application/json"},
 			{"PUT", "/api/backup/invalid_id", `{"enable": true}`, "application/json"},
 			{"DELETE", "/api/backup/999999", "", ""},
 		}
-		
+
 		for _, req := range invalidRequests {
 			httpReq := httptest.NewRequest(req.method, req.path, bytes.NewBufferString(req.body))
 			if req.contentType != "" {
 				httpReq.Header.Set("Content-Type", req.contentType)
 			}
 			w := httptest.NewRecorder()
-			
+
 			// Route to appropriate handler based on path
 			if req.path == "/api/backup" && req.method == "POST" {
 				api.BackupCreateHandler(w, httpReq)
 			} else {
 				api.BackupListHandler(w, httpReq) // Default handler for testing
 			}
-			
+
 			t.Logf("%s %s returned status: %d", req.method, req.path, w.Code)
 		}
 
@@ -233,14 +233,14 @@ func TestAPIResponseHandling(t *testing.T) {
 func TestAPIIntegrationScenarios(t *testing.T) {
 	t.Run("BackupWorkflow", func(t *testing.T) {
 		// Simulate a complete backup workflow
-		
+
 		// 1. List existing backups
 		req := httptest.NewRequest("GET", "/api/backup", nil)
 		w := httptest.NewRecorder()
 		api.BackupListHandler(w, req)
 		initialStatus := w.Code
 		t.Logf("1. List backups: %d", initialStatus)
-		
+
 		// 2. Try to create a backup
 		createReq := map[string]interface{}{
 			"name": "test-backup",
@@ -251,21 +251,21 @@ func TestAPIIntegrationScenarios(t *testing.T) {
 			},
 		}
 		createJSON, _ := json.Marshal(createReq)
-		
+
 		req = httptest.NewRequest("POST", "/api/backup", bytes.NewBuffer(createJSON))
 		req.Header.Set("Content-Type", "application/json")
 		w = httptest.NewRecorder()
 		api.BackupCreateHandler(w, req)
 		createStatus := w.Code
 		t.Logf("2. Create backup: %d", createStatus)
-		
+
 		// 3. Try to run the backup
 		req = httptest.NewRequest("POST", "/api/backup/1/run", nil)
 		w = httptest.NewRecorder()
 		api.BackupRunHandler(w, req)
 		runStatus := w.Code
 		t.Logf("3. Run backup: %d", runStatus)
-		
+
 		// 4. Try to pause the backup
 		req = httptest.NewRequest("PUT", "/api/backup/1/pause", nil)
 		w = httptest.NewRecorder()
@@ -275,15 +275,15 @@ func TestAPIIntegrationScenarios(t *testing.T) {
 
 		t.Log("Backup workflow test completed")
 	})
-	
+
 	t.Run("ConcurrentRequests", func(t *testing.T) {
 		// Test handling of concurrent requests
 		ctx, cancel := context.WithCancel(context.Background())
 		defer cancel()
-		
+
 		var wg sync.WaitGroup
 		results := make(chan int, 5)
-		
+
 		// Launch multiple concurrent requests
 		for i := 0; i < 5; i++ {
 			wg.Add(1)
@@ -300,20 +300,20 @@ func TestAPIIntegrationScenarios(t *testing.T) {
 				}
 			}(i)
 		}
-		
+
 		// Wait for all goroutines to complete
 		go func() {
 			wg.Wait()
 			close(results)
 		}()
-		
+
 		// Collect results safely in the main test goroutine
 		requestCount := 0
 		for code := range results {
 			t.Logf("Concurrent request %d returned status: %d", requestCount, code)
 			requestCount++
 		}
-		
+
 		t.Log("Concurrent requests test completed")
 	})
-}
+}