Skip to content

Commit 6362ec7

Browse files
yuukiyuuki
authored
Merge pull request #29 from yuuki/feature/add-main-tests
refactor: consolidate utility functions and add comprehensive main.go tests
2 parents e5b32c8 + c3e619d commit 6362ec7

File tree

6 files changed

+246
-112
lines changed

6 files changed

+246
-112
lines changed

‎.gitignore‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1-
/connperf
21
.specstory/**
32
.claude/settings.local.json
3+
4+
/tcpulse

‎client_test.go‎

Lines changed: 1 addition & 75 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@ import (
77
"io"
88
"net"
99
"os"
10-
"reflect"
1110
"strings"
1211
"sync"
1312
"testing"
@@ -65,7 +64,7 @@ func testRunClient(out io.Writer, args []string) error {
6564
originalStdout := os.Stdout
6665

6766
var copyDone chan struct{}
68-
67+
6968
// Create pipe to capture output if needed
7069
if out != os.Stdout {
7170
r, w, err := os.Pipe()
@@ -139,79 +138,6 @@ func testRunClient(out io.Writer, args []string) error {
139138
return nil
140139
}
141140

142-
func TestGetAddrsFromFile(t *testing.T) {
143-
tests := []struct {
144-
name string
145-
content string
146-
expected []string
147-
wantErr bool
148-
}{
149-
{
150-
name: "single address",
151-
content: "127.0.0.1:8080",
152-
expected: []string{"127.0.0.1:8080"},
153-
wantErr: false,
154-
},
155-
{
156-
name: "multiple addresses",
157-
content: "127.0.0.1:8080 192.168.1.1:9090 example.com:3000",
158-
expected: []string{"127.0.0.1:8080", "192.168.1.1:9090", "example.com:3000"},
159-
wantErr: false,
160-
},
161-
{
162-
name: "addresses with newlines",
163-
content: "127.0.0.1:8080\n192.168.1.1:9090\n",
164-
expected: []string{"127.0.0.1:8080", "192.168.1.1:9090"},
165-
wantErr: false,
166-
},
167-
{
168-
name: "empty file",
169-
content: "",
170-
expected: []string{},
171-
wantErr: false,
172-
},
173-
{
174-
name: "whitespace only",
175-
content: " \n\t \n",
176-
expected: []string{},
177-
wantErr: false,
178-
},
179-
}
180-
181-
for _, tt := range tests {
182-
t.Run(tt.name, func(t *testing.T) {
183-
tmpfile, err := os.CreateTemp("", "addrs_test")
184-
if err != nil {
185-
t.Fatalf("Failed to create temp file: %v", err)
186-
}
187-
defer os.Remove(tmpfile.Name())
188-
189-
if _, err := tmpfile.WriteString(tt.content); err != nil {
190-
t.Fatalf("Failed to write to temp file: %v", err)
191-
}
192-
if err := tmpfile.Close(); err != nil {
193-
t.Fatalf("Failed to close temp file: %v", err)
194-
}
195-
196-
got, err := getAddrsFromFile(tmpfile.Name())
197-
if (err != nil) != tt.wantErr {
198-
t.Errorf("getAddrsFromFile() error = %v, wantErr %v", err, tt.wantErr)
199-
return
200-
}
201-
if !reflect.DeepEqual(got, tt.expected) {
202-
t.Errorf("getAddrsFromFile() = %v, want %v", got, tt.expected)
203-
}
204-
})
205-
}
206-
}
207-
208-
func TestGetAddrsFromFileNotFound(t *testing.T) {
209-
_, err := getAddrsFromFile("/nonexistent/file")
210-
if err == nil {
211-
t.Error("Expected error for non-existent file, got nil")
212-
}
213-
}
214-
215141
func TestWaitLim(t *testing.T) {
216142
tests := []struct {
217143
name string

‎main.go‎

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ import (
2323
_ "net/http/pprof"
2424
"os"
2525
"os/signal"
26+
"strings"
2627
"sync"
2728
"syscall"
2829
"time"
@@ -276,3 +277,31 @@ func setPprofServer() {
276277
}
277278
}()
278279
}
280+
281+
// SetRLimitNoFile avoids too many open files error.
282+
func SetRLimitNoFile() error {
283+
var rLimit syscall.Rlimit
284+
285+
err := syscall.Getrlimit(syscall.RLIMIT_NOFILE, &rLimit)
286+
if err != nil {
287+
return fmt.Errorf("could not get rlimit: %w", err)
288+
}
289+
290+
if rLimit.Cur < rLimit.Max {
291+
rLimit.Cur = rLimit.Max
292+
err = syscall.Setrlimit(syscall.RLIMIT_NOFILE, &rLimit)
293+
if err != nil {
294+
return fmt.Errorf("could not set rlimit: %w", err)
295+
}
296+
}
297+
298+
return nil
299+
}
300+
301+
func getAddrsFromFile(path string) ([]string, error) {
302+
data, err := os.ReadFile(path)
303+
if err != nil {
304+
return nil, fmt.Errorf("reading addresses file: %w", err)
305+
}
306+
return strings.Fields(string(data)), nil
307+
}

‎main_test.go‎

Lines changed: 214 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,214 @@
1+
package main
2+
3+
import (
4+
"os"
5+
"reflect"
6+
"strings"
7+
"syscall"
8+
"testing"
9+
)
10+
11+
func TestSetRLimitNoFile(t *testing.T) {
12+
// Save original rlimit
13+
var originalLimit syscall.Rlimit
14+
err := syscall.Getrlimit(syscall.RLIMIT_NOFILE, &originalLimit)
15+
if err != nil {
16+
t.Fatalf("Failed to get original rlimit: %v", err)
17+
}
18+
19+
// Test SetRLimitNoFile function
20+
err = SetRLimitNoFile()
21+
if err != nil {
22+
t.Errorf("SetRLimitNoFile failed: %v", err)
23+
}
24+
25+
// Verify that the limit was set correctly
26+
var newLimit syscall.Rlimit
27+
err = syscall.Getrlimit(syscall.RLIMIT_NOFILE, &newLimit)
28+
if err != nil {
29+
t.Fatalf("Failed to get new rlimit: %v", err)
30+
}
31+
32+
// The current limit should now equal the max limit
33+
if newLimit.Cur != newLimit.Max {
34+
t.Errorf("Expected current limit to equal max limit after SetRLimitNoFile, got cur=%d, max=%d", newLimit.Cur, newLimit.Max)
35+
}
36+
37+
// Restore original limit
38+
err = syscall.Setrlimit(syscall.RLIMIT_NOFILE, &originalLimit)
39+
if err != nil {
40+
t.Logf("Warning: Failed to restore original rlimit: %v", err)
41+
}
42+
}
43+
44+
// Test helper functions for flag validation
45+
func TestValidateClientFlags(t *testing.T) {
46+
tests := []struct {
47+
name string
48+
connectFlavor string
49+
protocol string
50+
expectError bool
51+
errorSubstring string
52+
}{
53+
{
54+
name: "valid persistent tcp",
55+
connectFlavor: flavorPersistent,
56+
protocol: "tcp",
57+
expectError: false,
58+
},
59+
{
60+
name: "valid ephemeral udp",
61+
connectFlavor: flavorEphemeral,
62+
protocol: "udp",
63+
expectError: false,
64+
},
65+
{
66+
name: "invalid connect flavor",
67+
connectFlavor: "invalid",
68+
protocol: "tcp",
69+
expectError: true,
70+
errorSubstring: "unexpected connect flavor",
71+
},
72+
{
73+
name: "invalid protocol",
74+
connectFlavor: flavorPersistent,
75+
protocol: "invalid",
76+
expectError: true,
77+
errorSubstring: "unexpected protocol",
78+
},
79+
}
80+
81+
for _, tt := range tests {
82+
t.Run(tt.name, func(t *testing.T) {
83+
// Save original values
84+
originalConnectFlavor := connectFlavor
85+
originalProtocol := protocol
86+
87+
// Set test values
88+
connectFlavor = tt.connectFlavor
89+
protocol = tt.protocol
90+
91+
// Test validation logic (simulate what's in runClient)
92+
var err error
93+
switch connectFlavor {
94+
case flavorPersistent, flavorEphemeral:
95+
default:
96+
err = &ValidationError{Field: "connectFlavor", Value: connectFlavor}
97+
}
98+
99+
if err == nil {
100+
switch protocol {
101+
case "tcp", "udp":
102+
default:
103+
err = &ValidationError{Field: "protocol", Value: protocol}
104+
}
105+
}
106+
107+
// Restore original values
108+
connectFlavor = originalConnectFlavor
109+
protocol = originalProtocol
110+
111+
if tt.expectError {
112+
if err == nil {
113+
t.Errorf("Expected error but got none")
114+
} else if tt.errorSubstring != "" && !strings.Contains(err.Error(), tt.errorSubstring) {
115+
t.Errorf("Expected error to contain '%s', got: %v", tt.errorSubstring, err)
116+
}
117+
} else {
118+
if err != nil {
119+
t.Errorf("Unexpected error: %v", err)
120+
}
121+
}
122+
})
123+
}
124+
}
125+
126+
// ValidationError represents a validation error for testing
127+
type ValidationError struct {
128+
Field string
129+
Value string
130+
}
131+
132+
func (e *ValidationError) Error() string {
133+
switch e.Field {
134+
case "connectFlavor":
135+
return "unexpected connect flavor \"" + e.Value + "\""
136+
case "protocol":
137+
return "unexpected protocol \"" + e.Value + "\""
138+
default:
139+
return "validation error"
140+
}
141+
}
142+
143+
func TestGetAddrsFromFile(t *testing.T) {
144+
tests := []struct {
145+
name string
146+
content string
147+
expected []string
148+
wantErr bool
149+
}{
150+
{
151+
name: "single address",
152+
content: "127.0.0.1:8080",
153+
expected: []string{"127.0.0.1:8080"},
154+
wantErr: false,
155+
},
156+
{
157+
name: "multiple addresses",
158+
content: "127.0.0.1:8080 192.168.1.1:9090 example.com:3000",
159+
expected: []string{"127.0.0.1:8080", "192.168.1.1:9090", "example.com:3000"},
160+
wantErr: false,
161+
},
162+
{
163+
name: "addresses with newlines",
164+
content: "127.0.0.1:8080\n192.168.1.1:9090\n",
165+
expected: []string{"127.0.0.1:8080", "192.168.1.1:9090"},
166+
wantErr: false,
167+
},
168+
{
169+
name: "empty file",
170+
content: "",
171+
expected: []string{},
172+
wantErr: false,
173+
},
174+
{
175+
name: "whitespace only",
176+
content: " \n\t \n",
177+
expected: []string{},
178+
wantErr: false,
179+
},
180+
}
181+
182+
for _, tt := range tests {
183+
t.Run(tt.name, func(t *testing.T) {
184+
tmpfile, err := os.CreateTemp("", "addrs_test")
185+
if err != nil {
186+
t.Fatalf("Failed to create temp file: %v", err)
187+
}
188+
defer os.Remove(tmpfile.Name())
189+
190+
if _, err := tmpfile.WriteString(tt.content); err != nil {
191+
t.Fatalf("Failed to write to temp file: %v", err)
192+
}
193+
if err := tmpfile.Close(); err != nil {
194+
t.Fatalf("Failed to close temp file: %v", err)
195+
}
196+
197+
got, err := getAddrsFromFile(tmpfile.Name())
198+
if (err != nil) != tt.wantErr {
199+
t.Errorf("getAddrsFromFile() error = %v, wantErr %v", err, tt.wantErr)
200+
return
201+
}
202+
if !reflect.DeepEqual(got, tt.expected) {
203+
t.Errorf("getAddrsFromFile() = %v, want %v", got, tt.expected)
204+
}
205+
})
206+
}
207+
}
208+
209+
func TestGetAddrsFromFileNotFound(t *testing.T) {
210+
_, err := getAddrsFromFile("/nonexistent/file")
211+
if err == nil {
212+
t.Error("Expected error for non-existent file, got nil")
213+
}
214+
}

‎tcpulse‎

-9.93 MB
Binary file not shown.

‎utils.go‎

Lines changed: 0 additions & 36 deletions
This file was deleted.

0 commit comments

Comments
 (0)