Fix high-throughput sample (#1351)

Build failures because the startFabric.sh script specified that the
chaincode required initialization, which is both legacy behavior and is
unnecessary.

The chaincode is updated to use the Contract API instead of the legacy /
low-level chaincode API. The client application is also simplified.

Signed-off-by: Mark S. Lewis <Mark.S.Lewis@outlook.com>

Author: bestbeforetoday

.github/workflows/test-high-throughput.yaml

@@ -35,9 +35,14 @@ jobs:
           go run . manyUpdates testvar1 100 +
           go run . prune testvar1
           go run . get testvar1
-          go run . update testvar2 100 +
+          go run . update testvar1 100 +
+          go run . get testvar1
+          go run . delete testvar1
           go run . manyUpdatesTraditional testvar2 100 +
-          go run . delete testvar2
+          go run . getstandard testvar2
+          go run . updatestandard testvar2 100 +
+          go run . getstandard testvar2
+          go run . delstandard testvar2
 
       - name: Stop Fabric
         working-directory: high-throughput

high-throughput/README.md

@@ -35,7 +35,7 @@ Hyperledger Fabric, however, careful considerations need to be given to the data
 Let's look at some concrete use cases and how an organization might implement high-throughput storage. These cases will try and explore some of the
 advantages and disadvantages of such a system, and how to overcome them.
 
-#### Example 1 (IOT): Boxer Construction Analysts
+### Example 1 (IOT): Boxer Construction Analysts
 
 Boxer Construction Analysts is an IOT company focused on enabling real-time monitoring of large, expensive assets (machinery) on commercial
 construction projects. They've partnered with the only construction vehicle company in New York, Condor Machines Inc., to provide a reliable,
@@ -59,7 +59,7 @@ eventually be committed to the ledger in the order they were received. Additiona
 by a dashboard to provide live monitoring data. The only difference the engineers have to pay attention to in this case is to make sure the sensors can
 send deltas from the previous reading, rather than fixed readings.
 
-#### Example 2 (Balance Transfer): Robinson Credit Co.
+### Example 2 (Balance Transfer): Robinson Credit Co.
 
 Robinson Credit Co. provides credit and financial services to large businesses. As such, their accounts are large, complex, and accessed by many
 people at once at any time of the day. They want to switch to blockchain, but are having trouble keeping up with the number of deposits and
@@ -167,29 +167,19 @@ The application will query the variable after submitting the transaction. The re
 
 We will now see what happens when you try to run 1000 concurrent updates using a traditional transaction. Run the following command to create a variable named `testvar2`:
 
-```
-go run . update testvar2 100 +
-```
-
-The variable will have a value of 100:
-
-```
-2020/10/27 18:01:45 Value of variable testvar2 :  100
-```
-
-Now lets try to update `testvar2` 1000 times in parallel:
-
 ```
 go run . manyUpdatesTraditional testvar2 100 +
 ```
 
-When the program ends, you may see that none of the updates succeeded.
+When the program ends, you should see that many of the updates failed and that the value is much lower than expected.
 
 ```
-2020/10/27 18:03:15 Final value of variable testvar2 :  100
+2025/09/12 10:59:30 submitting 1000 concurrent updates...
+2025/09/12 10:59:31 998 submit failures.
+2025/09/12 10:59:31 Value of variable testvar2: 200
 ```
 
-The transactions failed because multiple transactions in each block updated the same key. Because of these transactions generated read/write conflicts, the transactions included in each block were rejected in the validation stage.
+The transactions failed because multiple transactions in each block updated the same key concurrently. Because of this, these transactions generated read/write conflicts and the transactions included in each block were rejected in the validation stage.
 
 You can can examine the peer logs to view the messages generated by the rejected blocks:
 

high-throughput/application-go/app.go

@@ -9,11 +9,14 @@ package main
 import (
 	"log"
 	"os"
+	"sync"
+	"sync/atomic"
 	"time"
 
 	"github.com/hyperledger/fabric-gateway/pkg/client"
 	"github.com/hyperledger/fabric-gateway/pkg/hash"
-	f "github.com/hyperledger/fabric-samples/high-throughput/application-go/functions"
+	gatewaypb "github.com/hyperledger/fabric-protos-go-apiv2/gateway"
+	"google.golang.org/grpc/status"
 )
 
 func main() {
@@ -22,7 +25,7 @@ func main() {
 
 	if len(os.Args) <= 2 {
 		log.Println("Usage: function variableName")
-		log.Fatalf("functions: update manyUpdates manyUpdatesTraditional get prune delete")
+		log.Fatalf("functions: update delete prune get manyUpdates updatestandard delstandard getstandard manyUpdatesTraditional")
 	} else if (os.Args[1] == "update" || os.Args[1] == "manyUpdates" || os.Args[1] == "manyUpdatesTraditional") && len(os.Args) < 5 {
 		log.Fatalf("error: provide value and operation")
 	} else if len(os.Args) == 3 {
@@ -56,38 +59,117 @@ func main() {
 	contract := gateway.GetNetwork("mychannel").GetContract("bigdatacc")
 
 	// Handle different functions
-	if function == "update" {
-		result, err := f.Update(contract, function, variableName, change, sign)
-		if err != nil {
-			log.Fatalf("error: %v", err)
-		}
-		log.Println("Value of variable", string(variableName), ": ", string(result))
+	switch function {
+	case "update":
+		update(contract, variableName, change, sign)
+	case "updatestandard":
+		updateStandard(contract, variableName, change, sign)
+	case "delete":
+		delete(contract, variableName)
+	case "prune":
+		prune(contract, variableName)
+	case "delstandard":
+		delStandard(contract, variableName)
+	case "get":
+		get(contract, variableName)
+	case "getstandard":
+		getStandard(contract, variableName)
+	case "manyUpdates":
+		manyUpdates(contract, "Update", variableName, change, sign)
+		get(contract, variableName)
+	case "manyUpdatesTraditional":
+		manyUpdates(contract, "UpdateStandard", variableName, change, sign)
+		getStandard(contract, variableName)
+	default:
+		log.Fatalln("Unkown function:", function)
+	}
+}
 
-	} else if function == "delete" || function == "prune" || function == "delstandard" {
-		result, err := f.DeletePrune(contract, function, variableName)
-		if err != nil {
-			log.Fatalf("error: %v", err)
-		}
-		log.Println(string(result))
-	} else if function == "get" || function == "getstandard" {
-		result, err := f.Query(contract, function, variableName)
-		if err != nil {
-			log.Fatalf("error: %v", err)
-		}
-		log.Println("Value of variable", string(variableName), ": ", string(result))
-	} else if function == "manyUpdates" {
-		log.Println("submitting 1000 concurrent updates...")
-		result, err := f.ManyUpdates(contract, "update", variableName, change, sign)
-		if err != nil {
-			log.Fatalf("error: %v", err)
-		}
-		log.Println("Final value of variable", string(variableName), ": ", string(result))
-	} else if function == "manyUpdatesTraditional" {
-		log.Println("submitting 1000 concurrent updates...")
-		result, err := f.ManyUpdates(contract, "putstandard", variableName, change, sign)
-		if err != nil {
-			log.Fatalf("error: %v", err)
+func update(contract *client.Contract, variableName, change, sign string) {
+	result, err := contract.SubmitTransaction("Update", variableName, change, sign)
+	failOnError(err)
+	log.Println(string(result))
+	get(contract, variableName)
+}
+
+func updateStandard(contract *client.Contract, variableName, change, sign string) {
+	result, err := contract.SubmitTransaction("UpdateStandard", variableName, change, sign)
+	failOnError(err)
+	log.Printf("Value of variable %s: %s\n", variableName, result)
+}
+
+func delete(contract *client.Contract, variableName string) {
+	result, err := contract.SubmitTransaction("Delete", variableName)
+	failOnError(err)
+	log.Println(string(result))
+}
+
+func prune(contract *client.Contract, variableName string) {
+	result, err := contract.SubmitTransaction("Prune", variableName)
+	failOnError(err)
+	log.Println(string(result))
+}
+
+func delStandard(contract *client.Contract, variableName string) {
+	_, err := contract.SubmitTransaction("DelStandard", variableName)
+	failOnError(err)
+	log.Printf("Deleted %s.\n", variableName)
+}
+
+func get(contract *client.Contract, variableName string) {
+	result, err := contract.EvaluateTransaction("Get", variableName)
+	failOnError(err)
+	log.Printf("Value of variable %s: %s\n", variableName, result)
+}
+
+func getStandard(contract *client.Contract, variableName string) {
+	result, err := contract.EvaluateTransaction("GetStandard", variableName)
+	failOnError(err)
+	log.Printf("Value of variable %s: %s\n", variableName, result)
+}
+
+func manyUpdates(contract *client.Contract, function, variableName, change, sign string) {
+	log.Println("submitting 1000 concurrent updates...")
+
+	var failCount atomic.Uint32
+	var wg sync.WaitGroup
+	for range 1000 {
+		wg.Add(1)
+		go func() {
+			defer wg.Done()
+			_, err := contract.SubmitTransaction(function, variableName, change, sign)
+			if err != nil {
+				failCount.Add(1)
+			}
+		}()
+	}
+
+	wg.Wait()
+
+	n := failCount.Load()
+	if n > 0 {
+		log.Printf("%v submit failures.", n)
+	}
+}
+
+func failOnError(err error) {
+	if err == nil {
+		return
+	}
+
+	details := status.Convert(err).Details()
+	if len(details) > 0 {
+		log.Println("Error Details:")
+
+		for _, detail := range details {
+			switch detail := detail.(type) {
+			case *gatewaypb.ErrorDetail:
+				log.Printf("- address: %s\n  mspId: %s\n  message: %s\n", detail.Address, detail.MspId, detail.Message)
+			default:
+				log.Printf("- %s", detail)
+			}
 		}
-		log.Println("Final value of variable", string(variableName), ": ", string(result))
 	}
+
+	log.Fatalf("error: %v", err)
 }

high-throughput/application-go/functions/deletePrune.go

@@ -4,11 +4,11 @@ go 1.23.0
 
 require (
 	github.com/hyperledger/fabric-gateway v1.8.0
+	github.com/hyperledger/fabric-protos-go-apiv2 v0.3.7
 	google.golang.org/grpc v1.73.0
 )
 
 require (
-	github.com/hyperledger/fabric-protos-go-apiv2 v0.3.7 // indirect
 	github.com/miekg/pkcs11 v1.1.1 // indirect
 	golang.org/x/crypto v0.40.0 // indirect
 	golang.org/x/net v0.42.0 // indirect