feat: introduce SendCommandWithSyncTestCase for enhanced command execution in tests

- Added SendCommandWithSyncTestCase struct to facilitate command execution with synchronization and retry logic.
- Updated testStreamsXreadBlockMaxID to utilize the new SendCommandWithSyncTestCase for improved handling of XREAD commands.

Author: andy1li

…al/test_cases/await_command_test_case.go …ases/send_command_with_sync_test_case.gointernal/test_cases/await_command_test_case.go renamed to internal/test_cases/send_command_with_sync_test_case.go internal/test_cases/await_command_test_case.go renamed to internal/test_cases/send_command_with_sync_test_case.go

@@ -11,7 +11,7 @@ import (
 	"github.com/codecrafters-io/tester-utils/logger"
 )
 
-type AwaitCommandTestCase struct {
+type SendCommandWithSyncTestCase struct {
 	Command                   string
 	Args                      []string
 	Assertion                 resp_assertions.RESPAssertion
@@ -26,7 +26,7 @@ type AwaitCommandTestCase struct {
 	DoneChan  chan bool
 }
 
-func (t *AwaitCommandTestCase) Run(client *resp_client.RespConnection, logger *logger.Logger) error {
+func (t *SendCommandWithSyncTestCase) Run(client *resp_client.RespConnection, logger *logger.Logger) error {
 	var value resp_value.Value
 	var err error
 
@@ -41,6 +41,8 @@ func (t *AwaitCommandTestCase) Run(client *resp_client.RespConnection, logger *l
 			return err
 		}
 
+		<-t.AwaitChan
+
 		value, err = client.ReadValue()
 		if err != nil {
 			return err
@@ -64,8 +66,6 @@ func (t *AwaitCommandTestCase) Run(client *resp_client.RespConnection, logger *l
 
 	t.ReceivedResponse = value
 
-	<-t.AwaitChan
-
 	if err = t.Assertion.Run(value); err != nil {
 		return err
 	}

internal/test_streams_xread_block_max_id.go

@@ -54,7 +54,7 @@ func testStreamsXreadBlockMaxID(stageHarness *test_case_harness.TestCaseHarness)
 				FieldValuePairs: [][]string{{"temperature", strconv.Itoa(randomInt)}},
 			}},
 		}})
-		awaitXReadTestCase := &test_cases.AwaitCommandTestCase{
+		xReadWithSyncTestCase := &test_cases.SendCommandWithSyncTestCase{
 			Command:                   "XREAD",
 			Args:                      []string{"block", "0", "streams", randomKey, "$"},
 			Assertion:                 assertion,
@@ -63,7 +63,7 @@ func testStreamsXreadBlockMaxID(stageHarness *test_case_harness.TestCaseHarness)
 			DoneChan:                  xReadDone,
 		}
 
-		return awaitXReadTestCase.Run(client1, logger)
+		return xReadWithSyncTestCase.Run(client1, logger)
 	}()
 
 	time.Sleep(1000 * time.Millisecond)