poc

Signed-off-by: Jack Ding <jackding@gmail.com>
jzding · May 20, 2024 · cbba0cf · cbba0cf
1 parent d3ce1fc
commit cbba0cf
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/v2/routes.go b/v2/routes.go
@@ -51,6 +51,7 @@ import (
 //	400: badReq
 //	204: noContent
 func (s *Server) createSubscription(w http.ResponseWriter, r *http.Request) {
+	log.Printf("DZK in V2 createSubscription")
 	defer r.Body.Close()
 	var response *http.Response
 	bodyBytes, err := io.ReadAll(r.Body)
@@ -64,6 +65,7 @@ func (s *Server) createSubscription(w http.ResponseWriter, r *http.Request) {
 		localmetrics.UpdateSubscriptionCount(localmetrics.FAILCREATE, 1)
 		return
 	}
+	log.Printf("DZK sub=%v", sub)
 	if sub.GetEndpointURI() != "" {
 		response, err = s.HTTPClient.Post(sub.GetEndpointURI(), cloudevents.ApplicationJSON, nil)
 		if err != nil {
@@ -84,6 +86,7 @@ func (s *Server) createSubscription(w http.ResponseWriter, r *http.Request) {
 	sub.SetID(uuid.New().String())
 	_ = sub.SetURILocation(fmt.Sprintf("http://localhost:%d%s%s/%s", s.port, s.apiPath, "subscriptions", sub.ID)) //nolint:errcheck
 
+	log.Printf("DZK sub2=%v", sub)
 	newSub, err := s.pubSubAPI.CreateSubscription(sub)
 	if err != nil {
 		log.Printf("error creating subscription %v", err)