fix: add support for a ws client & batch processing over ws

.github/workflows/docker.yml

@@ -34,7 +34,7 @@ jobs:
           registry: ghcr.io
           username: ${{ github.actor }}
           password: ${{ secrets.GITHUB_TOKEN }}
-        
+
       - name: Build and push
         uses: docker/build-push-action@v3
         with:
@@ -49,7 +49,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        target: [gnoland-slim, gnokey-slim, gno-slim, gnofaucet-slim, gnoweb-slim]
+        target: [ gnoland-slim, gnokey-slim, gno-slim, gnofaucet-slim, gnoweb-slim ]
     steps:
       - name: Checkout
         uses: actions/checkout@v4
@@ -71,7 +71,7 @@ jobs:
           registry: ghcr.io
           username: ${{ github.actor }}
           password: ${{ secrets.GITHUB_TOKEN }}
-        
+
       - name: Build and push
         uses: docker/build-push-action@v3
         with:

contribs/gnodev/go.mod

@@ -49,6 +49,7 @@ require (
 	github.com/rivo/uniseg v0.4.3 // indirect
 	github.com/rogpeppe/go-internal v1.12.0 // indirect
 	github.com/rs/cors v1.10.1 // indirect
+	github.com/rs/xid v1.5.0 // indirect
 	github.com/syndtr/goleveldb v1.0.1-0.20210819022825-2ae1ddf74ef7 // indirect
 	github.com/zondax/hid v0.9.2 // indirect
 	github.com/zondax/ledger-go v0.14.3 // indirect

contribs/gnokeykc/go.mod

@@ -31,6 +31,7 @@ require (
 	github.com/peterbourgon/ff/v3 v3.4.0 // indirect
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
+	github.com/rs/xid v1.5.0 // indirect
 	github.com/stretchr/testify v1.9.0 // indirect
 	github.com/syndtr/goleveldb v1.0.1-0.20210819022825-2ae1ddf74ef7 // indirect
 	github.com/zondax/hid v0.9.2 // indirect

docs/how-to-guides/connecting-from-go.md

@@ -109,7 +109,7 @@ A few things to note:
 You can initialize the RPC Client used to connect to the Gno.land network with
 the following line:
 ```go
-rpc := rpcclient.NewHTTP("<gno_chain_endpoint>", "")
+rpc := rpcclient.NewHTTP("<gno_chain_endpoint>")
 ```
 
 A list of Gno.land network endpoints & chain IDs can be found in the [Gno RPC 
@@ -138,7 +138,7 @@ func main() {
 	}
 
 	// Initialize the RPC client
-	rpc := rpcclient.NewHTTP("<gno.land_remote_endpoint>", "")
+	rpc := rpcclient.NewHTTP("<gno.land_remote_endpoint>")
 
 	// Initialize the gnoclient
 	client := gnoclient.Client{

gno.land/pkg/gnoclient/example_test.go

@@ -16,7 +16,7 @@ func Example_withDisk() {
 	}
 
 	remote := "127.0.0.1:26657"
-	rpcClient := rpcclient.NewHTTP(remote, "/websocket")
+	rpcClient, _ := rpcclient.NewHTTPClient(remote)
 
 	client := gnoclient.Client{
 		Signer:    signer,
@@ -35,7 +35,7 @@ func Example_withInMemCrypto() {
 	signer, _ := gnoclient.SignerFromBip39(mnemo, chainID, bip39Passphrase, account, index)
 
 	remote := "127.0.0.1:26657"
-	rpcClient := rpcclient.NewHTTP(remote, "/websocket")
+	rpcClient, _ := rpcclient.NewHTTPClient(remote)
 
 	client := gnoclient.Client{
 		Signer:    signer,
@@ -47,7 +47,7 @@ func Example_withInMemCrypto() {
 // Example_readOnly demonstrates how to initialize a read-only gnoclient, which can only query.
 func Example_readOnly() {
 	remote := "127.0.0.1:26657"
-	rpcClient := rpcclient.NewHTTP(remote, "/websocket")
+	rpcClient, _ := rpcclient.NewHTTPClient(remote)
 
 	client := gnoclient.Client{
 		RPCClient: rpcClient,

gno.land/pkg/gnoclient/integration_test.go

@@ -25,7 +25,8 @@ func TestCallSingle_Integration(t *testing.T) {
 
 	// Init Signer & RPCClient
 	signer := newInMemorySigner(t, "tendermint_test")
-	rpcClient := rpcclient.NewHTTP(remoteAddr, "/websocket")
+	rpcClient, err := rpcclient.NewHTTPClient(remoteAddr)
+	require.NoError(t, err)
 
 	// Setup Client
 	client := Client{
@@ -68,7 +69,8 @@ func TestCallMultiple_Integration(t *testing.T) {
 
 	// Init Signer & RPCClient
 	signer := newInMemorySigner(t, "tendermint_test")
-	rpcClient := rpcclient.NewHTTP(remoteAddr, "/websocket")
+	rpcClient, err := rpcclient.NewHTTPClient(remoteAddr)
+	require.NoError(t, err)
 
 	// Setup Client
 	client := Client{
@@ -119,7 +121,8 @@ func TestSendSingle_Integration(t *testing.T) {
 
 	// Init Signer & RPCClient
 	signer := newInMemorySigner(t, "tendermint_test")
-	rpcClient := rpcclient.NewHTTP(remoteAddr, "/websocket")
+	rpcClient, err := rpcclient.NewHTTPClient(remoteAddr)
+	require.NoError(t, err)
 
 	// Setup Client
 	client := Client{
@@ -167,7 +170,8 @@ func TestSendMultiple_Integration(t *testing.T) {
 
 	// Init Signer & RPCClient
 	signer := newInMemorySigner(t, "tendermint_test")
-	rpcClient := rpcclient.NewHTTP(remoteAddr, "/websocket")
+	rpcClient, err := rpcclient.NewHTTPClient(remoteAddr)
+	require.NoError(t, err)
 
 	// Setup Client
 	client := Client{
@@ -223,7 +227,8 @@ func TestRunSingle_Integration(t *testing.T) {
 
 	// Init Signer & RPCClient
 	signer := newInMemorySigner(t, "tendermint_test")
-	rpcClient := rpcclient.NewHTTP(remoteAddr, "/websocket")
+	rpcClient, err := rpcclient.NewHTTPClient(remoteAddr)
+	require.NoError(t, err)
 
 	client := Client{
 		Signer:    signer,
@@ -281,7 +286,8 @@ func TestRunMultiple_Integration(t *testing.T) {
 
 	// Init Signer & RPCClient
 	signer := newInMemorySigner(t, "tendermint_test")
-	rpcClient := rpcclient.NewHTTP(remoteAddr, "/websocket")
+	rpcClient, err := rpcclient.NewHTTPClient(remoteAddr)
+	require.NoError(t, err)
 
 	client := Client{
 		Signer:    signer,
@@ -361,7 +367,8 @@ func TestAddPackageSingle_Integration(t *testing.T) {
 
 	// Init Signer & RPCClient
 	signer := newInMemorySigner(t, "tendermint_test")
-	rpcClient := rpcclient.NewHTTP(remoteAddr, "/websocket")
+	rpcClient, err := rpcclient.NewHTTPClient(remoteAddr)
+	require.NoError(t, err)
 
 	// Setup Client
 	client := Client{
@@ -404,7 +411,7 @@ func Echo(str string) string {
 	}
 
 	// Execute AddPackage
-	_, err := client.AddPackage(baseCfg, msg)
+	_, err = client.AddPackage(baseCfg, msg)
 	assert.Nil(t, err)
 
 	// Check for deployed file on the node
@@ -429,7 +436,8 @@ func TestAddPackageMultiple_Integration(t *testing.T) {
 
 	// Init Signer & RPCClient
 	signer := newInMemorySigner(t, "tendermint_test")
-	rpcClient := rpcclient.NewHTTP(remoteAddr, "/websocket")
+	rpcClient, err := rpcclient.NewHTTPClient(remoteAddr)
+	require.NoError(t, err)
 
 	// Setup Client
 	client := Client{
@@ -495,7 +503,7 @@ func Hello(str string) string {
 	}
 
 	// Execute AddPackage
-	_, err := client.AddPackage(baseCfg, msg1, msg2)
+	_, err = client.AddPackage(baseCfg, msg1, msg2)
 	assert.Nil(t, err)
 
 	// Check Package #1

gno.land/pkg/gnoweb/gnoweb.go

@@ -421,7 +421,11 @@
 		// Prove: false, XXX
 	}
 	remote := cfg.RemoteAddr
-	cli := client.NewHTTP(remote, "/websocket")
+	cli, err := client.NewHTTPClient(remote)
+	if err != nil {
+		return nil, fmt.Errorf("unable to create HTTP client, %w", err)
+	}
+
 	qres, err := cli.ABCIQueryWithOptions(
 		qpath, data, opts2)
 	if err != nil {

gnovm/pkg/gnomod/fetch.go

@@ -12,7 +12,11 @@ func queryChain(remote string, qpath string, data []byte) (res *abci.ResponseQue
 		// Height: height, XXX
 		// Prove: false, XXX
 	}
-	cli := client.NewHTTP(remote, "/websocket")
+	cli, err := client.NewHTTPClient(remote)
+	if err != nil {
+		return nil, err
+	}
+
 	qres, err := cli.ABCIQueryWithOptions(qpath, data, opts2)
 	if err != nil {
 		return nil, err

go.mod

@@ -4,6 +4,7 @@ go 1.21
 
 require (
 	dario.cat/mergo v1.0.0
+	github.com/btcsuite/btcd/btcec/v2 v2.3.3
 	github.com/btcsuite/btcd/btcutil v1.1.5
 	github.com/cockroachdb/apd/v3 v3.2.1
 	github.com/cosmos/ledger-cosmos-go v0.13.3
@@ -26,6 +27,7 @@ require (
 	github.com/pmezard/go-difflib v1.0.0
 	github.com/rogpeppe/go-internal v1.12.0
 	github.com/rs/cors v1.10.1
+	github.com/rs/xid v1.5.0
 	github.com/stretchr/testify v1.9.0
 	github.com/syndtr/goleveldb v1.0.1-0.20210819022825-2ae1ddf74ef7
 	go.etcd.io/bbolt v1.3.9
@@ -49,29 +51,25 @@ require (
 
 require (
 	github.com/cenkalti/backoff/v4 v4.3.0 // indirect
+	github.com/gdamore/encoding v1.0.0 // indirect
 	github.com/go-logr/logr v1.4.1 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
-	github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 // indirect
-	go.opentelemetry.io/otel/trace v1.25.0 // indirect
-	go.opentelemetry.io/proto/otlp v1.1.0 // indirect
-	google.golang.org/genproto/googleapis/api v0.0.0-20240227224415-6ceb2ff114de // indirect
-)
-
-require (
-	github.com/btcsuite/btcd/btcec/v2 v2.3.3
-	github.com/gdamore/encoding v1.0.0 // indirect
 	github.com/golang/snappy v0.0.4 // indirect
 	github.com/gorilla/securecookie v1.1.1 // indirect
 	github.com/gorilla/sessions v1.2.1 // indirect
+	github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 // indirect
 	github.com/lucasb-eyer/go-colorful v1.2.0 // indirect
 	github.com/nxadm/tail v1.4.11 // indirect
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/rivo/uniseg v0.4.3 // indirect
 	github.com/zondax/hid v0.9.2 // indirect
 	github.com/zondax/ledger-go v0.14.3 // indirect
+	go.opentelemetry.io/otel/trace v1.25.0 // indirect
+	go.opentelemetry.io/proto/otlp v1.1.0 // indirect
 	golang.org/x/sync v0.7.0 // indirect
 	golang.org/x/sys v0.18.0 // indirect
 	golang.org/x/text v0.14.0 // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20240227224415-6ceb2ff114de // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20240401170217-c3f982113cda // indirect
 	google.golang.org/grpc v1.63.0 // indirect
 )