Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Uncomment ch03 go client and add some fix #26

Open
wants to merge 5 commits into
base: master
Choose a base branch
from
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
194 changes: 100 additions & 94 deletions ch03/order-service/go/client/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,13 @@ package main

import (
"context"
"google.golang.org/grpc"
"io"
"log"
pb "ordermgt/client/ecommerce"
"time"

wrapper "github.com/golang/protobuf/ptypes/wrappers"
"google.golang.org/grpc"
)

const (
Expand All @@ -19,8 +22,8 @@ func main() {
log.Fatalf("did not connect: %v", err)
}
defer conn.Close()
client := pb.NewOrderManagementClient(conn)
ctx , cancel := context.WithTimeout(context.Background(), time.Second*5)
client := pb.NewOrderManagementClient(conn)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
defer cancel()

// Add Order
Expand All @@ -30,96 +33,99 @@ func main() {
log.Print("AddOrder Response -> ", res.Value)
}

// // Get Order
// retrievedOrder , err := client.GetOrder(ctx, &wrapper.StringValue{Value: "106"})
// log.Print("GetOrder Response -> : ", retrievedOrder)

// // Search Order : Server streaming scenario
// searchStream, _ := client.SearchOrders(ctx, &wrapper.StringValue{Value: "Google"})
// for {
// searchOrder, err := searchStream.Recv()
// if err == io.EOF {
// log.Print("EOF")
// break
// }

// if err == nil {
// log.Print("Search Result : ", searchOrder)
// }
// }

// // =========================================
// // Update Orders : Client streaming scenario
// updOrder1 := pb.Order{Id: "102", Items:[]string{"Google Pixel 3A", "Google Pixel Book"}, Destination:"Mountain View, CA", Price:1100.00}
// updOrder2 := pb.Order{Id: "103", Items:[]string{"Apple Watch S4", "Mac Book Pro", "iPad Pro"}, Destination:"San Jose, CA", Price:2800.00}
// updOrder3 := pb.Order{Id: "104", Items:[]string{"Google Home Mini", "Google Nest Hub", "iPad Mini"}, Destination:"Mountain View, CA", Price:2200.00}

// updateStream, err := client.UpdateOrders(ctx)

// if err != nil {
// log.Fatalf("%v.UpdateOrders(_) = _, %v", client, err)
// }

// // Updating order 1
// if err := updateStream.Send(&updOrder1); err != nil {
// log.Fatalf("%v.Send(%v) = %v", updateStream, updOrder1, err)
// }

// // Updating order 2
// if err := updateStream.Send(&updOrder2); err != nil {
// log.Fatalf("%v.Send(%v) = %v", updateStream, updOrder2, err)
// }

// // Updating order 3
// if err := updateStream.Send(&updOrder3); err != nil {
// log.Fatalf("%v.Send(%v) = %v", updateStream, updOrder3, err)
// }

// updateRes, err := updateStream.CloseAndRecv()
// if err != nil {
// log.Fatalf("%v.CloseAndRecv() got error %v, want %v", updateStream, err, nil)
// }
// log.Printf("Update Orders Res : %s", updateRes)

// // =========================================
// // Process Order : Bi-di streaming scenario
// streamProcOrder, err := client.ProcessOrders(ctx)
// if err != nil {
// log.Fatalf("%v.ProcessOrders(_) = _, %v", client, err)
// }

// if err := streamProcOrder.Send(&wrapper.StringValue{Value:"102"}); err != nil {
// log.Fatalf("%v.Send(%v) = %v", client, "102", err)
// }

// if err := streamProcOrder.Send(&wrapper.StringValue{Value:"103"}); err != nil {
// log.Fatalf("%v.Send(%v) = %v", client, "103", err)
// }

// if err := streamProcOrder.Send(&wrapper.StringValue{Value:"104"}); err != nil {
// log.Fatalf("%v.Send(%v) = %v", client, "104", err)
// }

// channel := make(chan struct{})
// go asncClientBidirectionalRPC(streamProcOrder, channel)
// time.Sleep(time.Millisecond * 1000)

// if err := streamProcOrder.Send(&wrapper.StringValue{Value:"101"}); err != nil {
// log.Fatalf("%v.Send(%v) = %v", client, "101", err)
// }
// if err := streamProcOrder.CloseSend(); err != nil {
// log.Fatal(err)
// }
// <- channel
// Get Order
retrievedOrder, err := client.GetOrder(ctx, &wrapper.StringValue{Value: "106"})
if err != nil {
log.Fatalf("%v.GetOrder(ctx, &wrapper.StringValue{Value: \"106\"}) = _, %v", client, err)
}
log.Print("GetOrder Response -> : ", retrievedOrder)

// Search Order : Server streaming scenario
searchStream, _ := client.SearchOrders(ctx, &wrapper.StringValue{Value: "Google"})
for {
searchOrder, err := searchStream.Recv()
if err == io.EOF {
log.Print("EOF")
break
}

if err == nil {
log.Print("Search Result : ", searchOrder)
}
}

// =========================================
// Update Orders : Client streaming scenario
updOrder1 := pb.Order{Id: "102", Items: []string{"Google Pixel 3A", "Google Pixel Book"}, Destination: "Mountain View, CA", Price: 1100.00}
updOrder2 := pb.Order{Id: "103", Items: []string{"Apple Watch S4", "Mac Book Pro", "iPad Pro"}, Destination: "San Jose, CA", Price: 2800.00}
updOrder3 := pb.Order{Id: "104", Items: []string{"Google Home Mini", "Google Nest Hub", "iPad Mini"}, Destination: "Mountain View, CA", Price: 2200.00}

updateStream, err := client.UpdateOrders(ctx)

if err != nil {
log.Fatalf("%v.UpdateOrders(_) = _, %v", client, err)
}

// Updating order 1
if err := updateStream.Send(&updOrder1); err != nil {
log.Fatalf("%v.Send(%v) = %v", updateStream, updOrder1, err)
}

// Updating order 2
if err := updateStream.Send(&updOrder2); err != nil {
log.Fatalf("%v.Send(%v) = %v", updateStream, updOrder2, err)
}

// Updating order 3
if err := updateStream.Send(&updOrder3); err != nil {
log.Fatalf("%v.Send(%v) = %v", updateStream, updOrder3, err)
}

updateRes, err := updateStream.CloseAndRecv()
if err != nil {
log.Fatalf("%v.CloseAndRecv() got error %v, want %v", updateStream, err, nil)
}
log.Printf("Update Orders Res : %s", updateRes)

// =========================================
// Process Order : Bi-di streaming scenario
streamProcOrder, err := client.ProcessOrders(ctx)
if err != nil {
log.Fatalf("%v.ProcessOrders(_) = _, %v", client, err)
}

if err := streamProcOrder.Send(&wrapper.StringValue{Value: "102"}); err != nil {
log.Fatalf("%v.Send(%v) = %v", client, "102", err)
}

if err := streamProcOrder.Send(&wrapper.StringValue{Value: "103"}); err != nil {
log.Fatalf("%v.Send(%v) = %v", client, "103", err)
}

if err := streamProcOrder.Send(&wrapper.StringValue{Value: "104"}); err != nil {
log.Fatalf("%v.Send(%v) = %v", client, "104", err)
}

channel := make(chan struct{})
go asncClientBidirectionalRPC(streamProcOrder, channel)
time.Sleep(time.Millisecond * 1000)

if err := streamProcOrder.Send(&wrapper.StringValue{Value: "101"}); err != nil {
log.Fatalf("%v.Send(%v) = %v", client, "101", err)
}
if err := streamProcOrder.CloseSend(); err != nil {
log.Fatal(err)
}
<-channel
}

//func asncClientBidirectionalRPC(streamProcOrder pb.OrderManagement_ProcessOrdersClient, c chan struct{}) {
// for {
// combinedShipment, errProcOrder := streamProcOrder.Recv()
// if errProcOrder == io.EOF {
// break
// }
// log.Printf("Combined shipment : ", combinedShipment.OrdersList)
// }
// <-c
//}
func asncClientBidirectionalRPC(streamProcOrder pb.OrderManagement_ProcessOrdersClient, c chan struct{}) {
for {
combinedShipment, errProcOrder := streamProcOrder.Recv()
if errProcOrder == io.EOF {
break
}
log.Printf("Combined shipment : %v", combinedShipment.OrdersList)
}
close(c)
}