refactor: move and rename helpers (#125)

Split primitives and helpers to their own functions. All primitives now
take only connect request objects. Many helpers were renamed to reduce
confusion with their primitives counterparts.

Signed-off-by: Chris Gianelloni <wolf31o2@blinklabs.io>

Author: wolf31o2

examples/query/main.go

@@ -6,6 +6,7 @@ import (
 	"log"
 	"os"
 
+	"connectrpc.com/connect"
 	"github.com/blinklabs-io/gouroboros/ledger/common"
 	"github.com/utxorpc/go-codegen/utxorpc/v1alpha/cardano"
 	"github.com/utxorpc/go-codegen/utxorpc/v1alpha/query"
@@ -63,7 +64,7 @@ func main() {
 
 func readParams(client *utxorpc.UtxorpcClient) {
 	fmt.Println("Connecting to utxorpc host:", client.URL())
-	resp, err := client.ReadParams()
+	resp, err := client.GetProtocolParameters()
 	if err != nil {
 		utxorpc.HandleError(err)
 	}
@@ -199,7 +200,7 @@ func searchUtxos(
 	}
 
 	fmt.Println("connecting to utxorpc host:", client.URL())
-	resp, err := client.SearchUtxos(searchRequest)
+	resp, err := client.SearchUtxos(connect.NewRequest(searchRequest))
 	if err != nil {
 		utxorpc.HandleError(err)
 	}

examples/submit/main.go

@@ -55,7 +55,7 @@ func main() {
 // Modified submitTx to return transaction references
 func submitTx(client *utxorpc.UtxorpcClient, txCbor string) (string, error) {
 	fmt.Println("Connecting to utxorpc host:", client.URL())
-	resp, err := client.SubmitTx(txCbor)
+	resp, err := client.SubmitTransaction(txCbor)
 	if err != nil {
 		var connectErr *connect.Error
 		if errors.As(err, &connectErr) {
@@ -89,7 +89,7 @@ func submitTx(client *utxorpc.UtxorpcClient, txCbor string) (string, error) {
 }
 
 func readMempool(client *utxorpc.UtxorpcClient) {
-	resp, err := client.ReadMempool()
+	resp, err := client.GetMempoolTransactions()
 	if err != nil {
 		utxorpc.HandleError(err)
 	}
@@ -105,7 +105,7 @@ func waitForTx(
 
 	fmt.Println("Connecting to utxorpc host:", client.URL())
 	// Open a streaming connection to wait for transaction confirmation
-	stream, err := client.WaitForTx(txRef)
+	stream, err := client.WaitForTransaction(txRef)
 	if err != nil {
 		return fmt.Errorf("failed to open waitForTx stream: %w", err)
 	}
@@ -136,7 +136,7 @@ func waitForTx(
 
 func watchMempool(client *utxorpc.UtxorpcClient) {
 	fmt.Println("Connecting to utxorpc host:", client.URL())
-	stream, err := client.WatchMempool()
+	stream, err := client.WatchMempoolTransactions()
 	if err != nil {
 		utxorpc.HandleError(err)
 	}

examples/sync/main.go

@@ -40,7 +40,7 @@ func fetchBlock(
 	blockIndex int64,
 ) {
 	fmt.Println("connecting to utxorpc host:", client.URL())
-	resp, err := client.FetchBlock(blockHash, blockIndex)
+	resp, err := client.GetBlockByRef(blockHash, blockIndex)
 	if err != nil {
 		utxorpc.HandleError(err)
 	}
@@ -58,7 +58,7 @@ func followTip(
 	blockIndex int64,
 ) {
 	fmt.Println("connecting to utxorpc host:", client.URL())
-	stream, err := client.FollowTip(blockHash, blockIndex)
+	stream, err := client.WatchBlocksByRef(blockHash, blockIndex)
 	if err != nil {
 		utxorpc.HandleError(err)
 		return