chore: demo should panic when errors occur (#650)

* demo should panic

Signed-off-by: seeflood <[email protected]>

* go mod tidy

Signed-off-by: seeflood <[email protected]>

* fix

Signed-off-by: seeflood <[email protected]>

* fix

Signed-off-by: seeflood <[email protected]>

* fix minio error messages

Signed-off-by: seeflood <[email protected]>

* delete redundent demos

Signed-off-by: seeflood <[email protected]>

Author: seeflood

demo/bindings/main.go

@@ -12,8 +12,7 @@ import (
 func main() {
 	conn, err := grpc.Dial("127.0.0.1:34904", grpc.WithInsecure())
 	if err != nil {
-		fmt.Printf("conn build failed,err:%+v", err)
-		return
+		panic(err)
 	}
 
 	c := runtimev1pb.NewRuntimeClient(conn)

demo/configuration/common/client.go

@@ -101,8 +101,7 @@ func testSubscribeWithSDK(ctx context.Context, cli client.Client) {
 	go func() {
 		for resp := range ch {
 			if resp.Err != nil {
-				fmt.Println("subscribe failed", resp.Err)
-				continue
+				panic(resp.Err)
 			}
 			marshal, err := json.Marshal(resp.Item)
 			if err != nil {
@@ -193,9 +192,8 @@ func testSet(ctx context.Context, cli client.Client) {
 	saveRequest := &client.SaveConfigurationRequest{StoreName: storeName, AppId: appid}
 	saveRequest.Items = append(saveRequest.Items, item1)
 	saveRequest.Items = append(saveRequest.Items, item2)
-	if cli.SaveConfiguration(ctx, saveRequest) != nil {
-		fmt.Println("save key failed")
-		return
+	if err := cli.SaveConfiguration(ctx, saveRequest); err != nil {
+		panic(err)
 	}
 	fmt.Println("save key success")
 }
@@ -205,7 +203,7 @@ func testGet(ctx context.Context, cli client.Client) {
 	items, err := cli.GetConfiguration(ctx, getRequest)
 	//validate
 	if err != nil {
-		fmt.Printf("get configuration failed %+v \n", err)
+		panic(err)
 	}
 	for _, item := range items {
 		fmt.Printf("get configuration after save, %+v \n", item)
@@ -214,9 +212,8 @@ func testGet(ctx context.Context, cli client.Client) {
 
 func testDelete(ctx context.Context, cli client.Client) {
 	request := &client.ConfigurationRequestItem{StoreName: storeName, AppId: appid, Group: group, Label: "prod", Keys: []string{"key1", "haha"}}
-	if cli.DeleteConfiguration(ctx, request) != nil {
-		fmt.Println("delete key failed")
-		return
+	if err := cli.DeleteConfiguration(ctx, request); err != nil {
+		panic(err)
 	}
 	fmt.Printf("delete keys success\n")
 }

demo/file/client.go

@@ -24,39 +24,44 @@ const (
 )
 
 func TestGet(fileName string) {
+	// dial
 	conn, err := grpc.Dial("127.0.0.1:34904", grpc.WithInsecure())
 	if err != nil {
 		fmt.Printf("conn build failed,err:%+v", err)
-		return
+		panic(err)
 	}
 
+	// new client
 	c := runtimev1pb.NewRuntimeClient(conn)
+
+	// getFile
 	req := &runtimev1pb.GetFileRequest{StoreName: storeName, Name: fileName}
 	cli, err := c.GetFile(context.Background(), req)
 	if err != nil {
 		fmt.Printf("get file error: %+v", err)
-		return
+		panic(err)
 	}
 	pic := make([]byte, 0)
 	for {
 		resp, err := cli.Recv()
 		if err != nil {
-			fmt.Println("recv file failed")
 			if err.Error() != "EOF" {
+				fmt.Println("recv file failed")
 				panic(err)
 			}
 			break
 		}
 		pic = append(pic, resp.Data...)
 	}
+	fmt.Println("GetFile successfully. Result:")
 	fmt.Println(string(pic))
 }
 
 func TestPut(fileName string, value string) {
 	conn, err := grpc.Dial("127.0.0.1:34904", grpc.WithInsecure())
 	if err != nil {
 		fmt.Printf("conn build failed,err:%+v", err)
-		return
+		panic(err)
 	}
 	meta := make(map[string]string)
 	meta["storageType"] = storageType
@@ -65,21 +70,22 @@ func TestPut(fileName string, value string) {
 	stream, err := c.PutFile(context.TODO())
 	if err != nil {
 		fmt.Printf("put file failed:%+v", err)
-		return
+		panic(err)
 	}
 	req.Data = []byte(value)
 	stream.Send(req)
 	_, err = stream.CloseAndRecv()
 	if err != nil {
 		fmt.Printf("cannot receive response: %+v", err)
+		panic(err)
 	}
 }
 
 func TestList(bucketName string) {
 	conn, err := grpc.Dial("127.0.0.1:34904", grpc.WithInsecure())
 	if err != nil {
 		fmt.Printf("conn build failed,err:%+v", err)
-		return
+		panic(err)
 	}
 	meta := make(map[string]string)
 	meta["storageType"] = storageType
@@ -91,7 +97,7 @@ func TestList(bucketName string) {
 		resp, err := c.ListFile(context.Background(), listReq)
 		if err != nil {
 			fmt.Printf("list file fail, err: %+v", err)
-			return
+			panic(err)
 		}
 		marker = resp.Marker
 		if !resp.IsTruncated {
@@ -118,7 +124,7 @@ func TestDel(fileName string) {
 	_, err = c.DelFile(context.Background(), listReq)
 	if err != nil {
 		fmt.Printf("list file fail, err: %+v \n", err)
-		return
+		panic(err)
 	}
 	fmt.Printf("delete file success \n")
 }
@@ -127,7 +133,7 @@ func TestStat(fileName string) {
 	conn, err := grpc.Dial("127.0.0.1:34904", grpc.WithInsecure())
 	if err != nil {
 		fmt.Printf("conn build failed,err:%+v", err)
-		return
+		panic(err)
 	}
 	meta := make(map[string]string)
 	meta["storageType"] = storageType