test progress

Author: PatStiles

core/retry_test.go

@@ -948,19 +948,17 @@ func TestSendSignedTaskResponse(t *testing.T) {
 			fmt.Errorf("Could not start Aggregator %s", err)
 		}
 	}()
-	if err != nil {
-		fmt.Errorf("Could not start Aggregator %s", err)
-	}
 
 	logger := operatorConfig.BaseConfig.Logger
 	rpcClient, err := operator.NewAggregatorRpcClient(operatorConfig.Operator.AggregatorServerIpPortAddress, logger)
 	// This is a mock to verify that a lost connection to the aggregator does not return anything.
-	disconnected_rpcClient, err := operator.NewAggregatorRpcClient("localhost:8999", logger)
-	if err != nil {
-		fmt.Errorf("Could not create RPC client: %s. Is aggregator running?", err)
-	}
+	/*
+		disconnected_rpcClient, err := operator.NewAggregatorRpcClient("localhost:8999", logger)
+		if err != nil {
+			fmt.Errorf("Could not create RPC client: %s. Is aggregator running?", err)
+		}
+	*/
 
-	//zero_bytes := [32]byte{}
 	signedTaskResponse := &core_types.SignedTaskResponse{
 		BatchIdentifierHash: [32]byte{},
 		BatchMerkleRoot:     [32]byte{},
@@ -973,21 +971,17 @@ func TestSendSignedTaskResponse(t *testing.T) {
 	_, err = task_resp_func()
 	assert.Nil(t, err)
 
-	fmt.Printf("stuff")
-	task_resp_func = operator.SendSignedTaskResponse(disconnected_rpcClient, signedTaskResponse)
-	// NOTE: This the expected behavior of a net/rpc/clint/Go for an invalid connection ref: https://cs.opensource.google/go/go/+/refs/tags/go1.23.3:src/net/rpc/client.go;l=298
-	assert.Panics(t, func() { _, err = task_resp_func() })
-	fmt.Printf("error: %s", err)
-	assert.Nil(t, err)
-
-	task_resp_func = operator.SendSignedTaskResponse(rpcClient, signedTaskResponse)
-	_, err = task_resp_func()
-	assert.Nil(t, err)
-
 	// Kill Aggregator
 	cancel()
 
-	if err := cmd.Process.Kill(); err != nil {
+	/*
+		fmt.Printf("stuff")
+		task_resp_func = operator.SendSignedTaskResponse(disconnected_rpcClient, signedTaskResponse)
+		// NOTE: This the expected behavior of a net/rpc/clint/Go for an invalid connection ref: https://cs.opensource.google/go/go/+/refs/tags/go1.23.3:src/net/rpc/client.go;l=298
+		assert.Panics(t, func() { _, err = task_resp_func() })
+	*/
+
+	if err = cmd.Process.Kill(); err != nil {
 		t.Errorf("Error killing process: %v\n", err)
 		return
 	}