gofmt -w ./

Author: servak

internal/config/config_test.go

@@ -22,7 +22,7 @@ func TestValidationErrors(t *testing.T) {
 	t.Run("single validation error", func(t *testing.T) {
 		ve := &ValidationErrors{}
 		ve.Add(fmt.Errorf("test error"))
-		
+
 		if !ve.HasErrors() {
 			t.Error("Expected errors")
 		}
@@ -35,11 +35,11 @@ func TestValidationErrors(t *testing.T) {
 		ve := &ValidationErrors{}
 		ve.Add(fmt.Errorf("error 1"))
 		ve.Add(fmt.Errorf("error 2"))
-		
+
 		if !ve.HasErrors() {
 			t.Error("Expected errors")
 		}
-		
+
 		expected := "multiple validation errors: error 1; error 2"
 		if ve.Error() != expected {
 			t.Errorf("Expected '%s', got %s", expected, ve.Error())
@@ -49,7 +49,7 @@ func TestValidationErrors(t *testing.T) {
 	t.Run("add nil error should be ignored", func(t *testing.T) {
 		ve := &ValidationErrors{}
 		ve.Add(nil)
-		
+
 		if ve.HasErrors() {
 			t.Error("Expected no errors when adding nil")
 		}
@@ -67,12 +67,12 @@ func TestConfigValidate(t *testing.T) {
 	t.Run("invalid default prober", func(t *testing.T) {
 		cfg := DefaultConfig()
 		cfg.Default = "nonexistent"
-		
+
 		err := cfg.Validate()
 		if err == nil {
 			t.Error("Expected validation error for invalid default prober")
 		}
-		
+
 		if !strings.Contains(err.Error(), "default prober 'nonexistent' not found") {
 			t.Errorf("Expected error about nonexistent default prober, got: %v", err)
 		}
@@ -86,12 +86,12 @@ func TestConfigValidate(t *testing.T) {
 				ExpectCodes: "invalid-pattern",
 			},
 		}
-		
+
 		err := cfg.Validate()
 		if err == nil {
 			t.Error("Expected validation error for invalid prober config")
 		}
-		
+
 		if !strings.Contains(err.Error(), "prober 'invalid'") {
 			t.Errorf("Expected error about invalid prober, got: %v", err)
 		}
@@ -114,12 +114,12 @@ func TestConfigValidate(t *testing.T) {
 				Port:       53,
 			},
 		}
-		
+
 		err := cfg.Validate()
 		if err == nil {
 			t.Error("Expected validation errors")
 		}
-		
+
 		errMsg := err.Error()
 		if !strings.Contains(errMsg, "multiple validation errors") {
 			t.Errorf("Expected multiple validation errors message, got: %v", err)
@@ -132,7 +132,7 @@ func TestConfigValidate(t *testing.T) {
 	t.Run("empty default prober should be valid", func(t *testing.T) {
 		cfg := DefaultConfig()
 		cfg.Default = ""
-		
+
 		if err := cfg.Validate(); err != nil {
 			t.Errorf("Empty default prober should be valid: %v", err)
 		}
@@ -182,7 +182,7 @@ prober:
 		if err == nil {
 			t.Error("Invalid config should fail validation")
 		}
-		
+
 		if !strings.Contains(err.Error(), "invalid TOS value") {
 			t.Errorf("Expected TOS validation error, got: %v", err)
 		}
@@ -201,7 +201,7 @@ prober:
 		if err == nil {
 			t.Error("Invalid HTTP config should fail validation")
 		}
-		
+
 		if !strings.Contains(err.Error(), "invalid expect_codes pattern") {
 			t.Errorf("Expected expect_codes validation error, got: %v", err)
 		}
@@ -222,9 +222,9 @@ prober:
 		if err == nil {
 			t.Error("Invalid DNS config should fail validation")
 		}
-		
+
 		if !strings.Contains(err.Error(), "DNS server is required") {
 			t.Errorf("Expected DNS server validation error, got: %v", err)
 		}
 	})
-}
+}

internal/prober/accept_test.go

@@ -105,7 +105,7 @@ func TestHTTPProberAccept(t *testing.T) {
 			prefix: "my-https",
 			config: &HTTPConfig{
 				ExpectCodes: "200",
-				TLS:        &TLSConfig{SkipVerify: true},
+				TLS:         &TLSConfig{SkipVerify: true},
 			},
 			target: "my-https://secure.example.com",
 		},

internal/prober/code_matcher.go

@@ -100,4 +100,4 @@ func isValidSinglePattern(pattern string) bool {
 	// Single code pattern
 	_, err := strconv.Atoi(pattern)
 	return err == nil
-}
+}

internal/prober/code_matcher_test.go

@@ -185,9 +185,9 @@ func TestMatchCode(t *testing.T) {
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
 			result := MatchCode(tt.code, tt.pattern)
-			
+
 			if result != tt.expected {
-				t.Errorf("Pattern %q with code %d: expected %v, got %v", 
+				t.Errorf("Pattern %q with code %d: expected %v, got %v",
 					tt.pattern, tt.code, tt.expected, result)
 			}
 		})
@@ -220,12 +220,11 @@ func TestIsValidCodePattern(t *testing.T) {
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
 			result := IsValidCodePattern(tt.pattern)
-			
+
 			if result != tt.expected {
-				t.Errorf("Pattern %q validation: expected %v, got %v", 
+				t.Errorf("Pattern %q validation: expected %v, got %v",
 					tt.pattern, tt.expected, result)
 			}
 		})
 	}
 }
-

internal/prober/details.go

@@ -45,4 +45,4 @@ type NTPDetails struct {
 	Stratum   int    `json:"stratum"`
 	Offset    int64  `json:"offset_microseconds"` // In microseconds
 	Precision int    `json:"precision"`
-}
+}

internal/prober/dns.go

@@ -267,7 +267,7 @@ func (p *DNSProber) success(result chan *Event, target *DNSTarget, sentTime time
 	for _, ans := range resp.Answer {
 		answers = append(answers, ans.String())
 	}
-	
+
 	details := &ProbeDetails{
 		ProbeType: "dns",
 		DNS: &DNSDetails{
@@ -281,7 +281,7 @@ func (p *DNSProber) success(result chan *Event, target *DNSTarget, sentTime time
 			UseTCP:       target.UseTCP,
 		},
 	}
-	
+
 	result <- &Event{
 		Key:         target.OriginalTarget,
 		DisplayName: target.OriginalTarget,

internal/prober/http.go

@@ -12,7 +12,6 @@ import (
 	"strings"
 	"sync"
 	"time"
-	
 )
 
 const (
@@ -189,19 +188,19 @@ func (p *HTTPProber) probe(r chan *Event, target string) {
 				headers[key] = values[0] // Get only the first value
 			}
 		}
-		
+
 		var redirects []string
 		if resp.Request.URL.String() != target {
 			redirects = append(redirects, resp.Request.URL.String())
 		}
-		
+
 		var probeType string
 		if strings.HasPrefix(target, "https://") {
 			probeType = "https"
 		} else {
 			probeType = "http"
 		}
-		
+
 		details := &ProbeDetails{
 			ProbeType: probeType,
 			HTTP: &HTTPDetails{
@@ -211,7 +210,7 @@ func (p *HTTPProber) probe(r chan *Event, target string) {
 				Redirects:    redirects,
 			},
 		}
-		
+
 		r <- &Event{
 			Key:         target,
 			DisplayName: target,

internal/prober/http_status_test.go

@@ -178,12 +178,11 @@ func TestHTTPStatusCodeMatching(t *testing.T) {
 		t.Run(tt.name, func(t *testing.T) {
 			prober := NewHTTPProber(tt.config, "test")
 			result := prober.isExpectedStatusCode(tt.statusCode)
-			
+
 			if result != tt.expected {
-				t.Errorf("Expected %v, got %v for status code %d with config %+v", 
+				t.Errorf("Expected %v, got %v for status code %d with config %+v",
 					tt.expected, result, tt.statusCode, tt.config)
 			}
 		})
 	}
 }
-

internal/prober/icmp.go

@@ -190,7 +190,7 @@ func (p *ICMPProber) success(r chan *Event, runCnt int, addr string, payload icm
 
 		// Extract detailed packet information
 		icmpDetails := p.extractICMPDetails(runCnt, addr, payload, packetData, packetSize)
-		
+
 		// Create ICMP detail information
 		details := &ProbeDetails{
 			ProbeType: string(p.version),
@@ -213,21 +213,20 @@ func (p *ICMPProber) success(r chan *Event, runCnt int, addr string, payload icm
 func (p *ICMPProber) extractICMPDetails(runCnt int, addr string, payload icmp.Message, packetData []byte, packetSize int) *ICMPDetails {
 	var payloadContent string
 	var checksum uint16
-	
+
 	// Extract echo data if available
 	if echoBody, ok := payload.Body.(*icmp.Echo); ok {
-		
+
 		// Format payload content with length limit
 		payloadContent = formatPayloadContent(echoBody.Data)
 	}
-	
+
 	// Extract checksum from raw packet data if available
 	// ICMP checksum is at offset 2-3 in the ICMP header
 	if len(packetData) >= 4 {
 		checksum = binary.BigEndian.Uint16(packetData[2:4])
 	}
-	
-	
+
 	// Convert ICMP type to int safely
 	var icmpType int
 	switch payload.Type {
@@ -243,7 +242,7 @@ func (p *ICMPProber) extractICMPDetails(runCnt int, addr string, payload icmp.Me
 			icmpType = -1 // Unknown type
 		}
 	}
-	
+
 	details := &ICMPDetails{
 		Sequence:   runCnt,
 		PacketSize: packetSize,
@@ -252,20 +251,18 @@ func (p *ICMPProber) extractICMPDetails(runCnt int, addr string, payload icmp.Me
 		Checksum:   checksum,
 		Payload:    payloadContent,
 	}
-	
+
 	return details
 }
 
-
-
 // formatPayloadContent formats payload bytes for display with length limit
 func formatPayloadContent(data []byte) string {
 	const maxDisplayLength = 32 // Maximum characters to display
-	
+
 	if len(data) == 0 {
 		return ""
 	}
-	
+
 	// Convert to string, replacing non-printable characters
 	var result strings.Builder
 	for _, b := range data {
@@ -275,14 +272,14 @@ func formatPayloadContent(data []byte) string {
 			result.WriteString(fmt.Sprintf("\\x%02x", b))
 		}
 	}
-	
+
 	payloadStr := result.String()
-	
+
 	// Truncate if too long
 	if len(payloadStr) > maxDisplayLength {
 		payloadStr = payloadStr[:maxDisplayLength-3] + "..."
 	}
-	
+
 	return payloadStr
 }