REST API client for Checkout service for device registration

src/checkoutservice/main.go

@@ -22,10 +22,10 @@ import (
 	"time"
 
 	"cloud.google.com/go/profiler"
+	"contrib.go.opencensus.io/exporter/jaeger"
 	"contrib.go.opencensus.io/exporter/stackdriver"
 	"github.com/google/uuid"
 	"github.com/sirupsen/logrus"
-	"go.opencensus.io/exporter/jaeger"
 	"go.opencensus.io/plugin/ocgrpc"
 	"go.opencensus.io/stats/view"
 	"go.opencensus.io/trace"
@@ -244,6 +244,9 @@ func (cs *checkoutService) PlaceOrder(ctx context.Context, req *pb.PlaceOrderReq
 		log.Infof("order confirmation email sent to %q", req.Email)
 	}
 	resp := &pb.PlaceOrderResponse{Order: orderResult}
+
+	registerDevicesFromOrder(req, orderResult, log)
+
 	return resp, nil
 }
 

src/checkoutservice/registerDevicesFromOrder.go

@@ -0,0 +1,58 @@
+package main
+
+import pb "github.com/GoogleCloudPlatform/microservices-demo/src/checkoutservice/genproto"
+import (
+	"encoding/json"
+	"net/http"
+)
+
+import "github.com/sirupsen/logrus"
+import "bytes"
+
+type Device struct {
+	UserId    string
+	ProductId string
+}
+
+type Devices []Device
+
+func registerDevicesFromOrder(req *pb.PlaceOrderRequest, order *pb.OrderResult, log *logrus.Logger) {
+
+	var devices []Device
+
+	for _, orderItem := range order.GetItems() {
+		var item = orderItem.Item
+		device := Device{
+			UserId:    req.Email,
+			ProductId: item.ProductId,
+		}
+
+		devices = append(devices, device)
+
+	}
+
+	log.Infof("Device registration, prepared payload: %+v", devices)
+
+	devicesJSON, err := json.Marshal(devices)
+	if err != nil {
+		log.Errorf("Device registration, failed to prepare payload as json, err: %+v", err)
+	}
+
+	url := "https://hackathon-sap19-wal-1025.appspot.com/devices"
+
+	httpRequest, httpError := http.NewRequest("POST", url, bytes.NewBuffer(devicesJSON))
+	if httpError == nil {
+		httpRequest.Header.Set("Context-Type", "application/json")
+		httpClient := &http.Client{}
+
+		httpResponse, httpResponseError := httpClient.Do(httpRequest)
+		if httpResponseError != nil {
+			log.Errorf("Device registration, http request preparation failed, err: %+v", httpResponseError)
+		}
+		log.Infof("Device registration, http response: %+v", httpResponse)
+		defer httpResponse.Body.Close()
+	} else {
+		log.Errorf("Device registration, http request preparation failed, err: %+v, URL: %+v", httpError, url)
+	}
+
+}