added tests for GetBestBlockHashAsync

now testing that GetBestBlockHashAsync sends the getbestblockhash command via websocket connection and that the channel returned can be used to send the response when it is received

rpcclient/chain_test.go

@@ -6,6 +6,7 @@ import (
 	"net/http"
 	"net/http/httptest"
 	"strings"
+	"sync"
 	"testing"
 	"time"
 )
@@ -190,6 +191,48 @@ func TestClientConnectedToWSServerRunner(t *testing.T) {
 				}
 			},
 		},
+		TestTableItem{
+			Name: "TestGetBestBlockHashAsync",
+			TestCase: func(t *testing.T) {
+				client, serverReceivedChannel, cleanup := makeClient(t)
+				defer cleanup()
+				ch := client.GetBestBlockHashAsync()
+
+				message := <-serverReceivedChannel
+				if message != "{\"jsonrpc\":\"1.0\",\"method\":\"getbestblockhash\",\"params\":[],\"id\":1}" {
+					t.Fatalf("received unexpected message: %s", message)
+				}
+
+				expectedResponse := Response{}
+
+				wg := sync.WaitGroup{}
+
+				wg.Add(1)
+				go func() {
+					defer wg.Done()
+					for {
+						client.requestLock.Lock()
+						if client.requestList.Len() > 0 {
+							r := client.requestList.Back()
+							r.Value.(*jsonRequest).responseChan <- &expectedResponse
+							client.requestLock.Unlock()
+							return
+						}
+						client.requestLock.Unlock()
+					}
+				}()
+
+				response := <-ch
+
+				if &expectedResponse != response {
+					t.Fatalf("received unexepcted response")
+				}
+
+				// ensure the goroutine created in this test exists,
+				// the test is ran with a timeout
+				wg.Wait()
+			},
+		},
 	}
 
 	// since these tests rely on concurrency, ensure there is a resonable timeout