Skip to content

Commit 6861543

Browse files
- Refactor: BLPOP test cases
- Add: NoResponseTestCase - Add: markdowns for stage description
1 parent a37bdd9 commit 6861543

18 files changed

+1173
-1091
lines changed

internal/test_cases/blocking_client_group_test_case.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ func (t *BlockingClientGroupTestCase) SendBlockingCommands() error {
5454
func (t *BlockingClientGroupTestCase) AssertResponses(logger *logger.Logger) error {
5555
for _, clientWithExpectedResponse := range t.clientsWithExpectedResponses {
5656
if clientWithExpectedResponse.Assertion == nil {
57-
testCase := NoUnreadDataTestCase{}
57+
testCase := NoResponseTestCase{}
5858
if err := testCase.Run(clientWithExpectedResponse.Client, logger); err != nil {
5959
return err
6060
}
@@ -67,6 +67,5 @@ func (t *BlockingClientGroupTestCase) AssertResponses(logger *logger.Logger) err
6767
}
6868
}
6969
}
70-
7170
return nil
7271
}
Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
package test_cases
2+
3+
import (
4+
"fmt"
5+
6+
resp_connection "github.com/codecrafters-io/redis-tester/internal/resp/connection"
7+
"github.com/codecrafters-io/tester-utils/logger"
8+
)
9+
10+
type NoResponseTestCase struct{}
11+
12+
func (n *NoResponseTestCase) Run(client *resp_connection.RespConnection, logger *logger.Logger) error {
13+
client.ReadIntoBuffer()
14+
if client.UnreadBuffer.Len() > 0 {
15+
return fmt.Errorf("%s received unexpected response: %q", client.GetIdentifier(), client.UnreadBuffer.String())
16+
}
17+
return nil
18+
}

internal/test_cases/send_command_test_case.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -65,13 +65,9 @@ func (t *SendCommandTestCase) Run(client *resp_client.RespConnection, logger *lo
6565
}
6666
}
6767

68-
return t.ProcessResponse(value, client, logger)
69-
}
70-
71-
func (t *SendCommandTestCase) ProcessResponse(value resp_value.Value, client *resp_client.RespConnection, logger *logger.Logger) error {
7268
t.ReceivedResponse = value
7369

74-
if err := t.Assertion.Run(value); err != nil {
70+
if err = t.Assertion.Run(value); err != nil {
7571
return err
7672
}
7773

0 commit comments

Comments
 (0)