remove local sub store

Signed-off-by: Jack Ding <[email protected]>

v2/routes.go

@@ -78,15 +78,7 @@ func (s *Server) createSubscription(w http.ResponseWriter, r *http.Request) {
 	sub.SetID(id)
 	sub.SetVersion(API_VERSION)
 	sub.SetURILocation(fmt.Sprintf("http://localhost:%d%s%s/%s", s.port, s.apiPath, "subscriptions", sub.ID)) //nolint:errcheck
-
-	// TODO: cleanup: local pubsub is no longer needed since we are using configMap
-	newSub, err := s.pubSubAPI.CreateSubscription(sub)
-	if err != nil {
-		respondWithStatusCode(w, http.StatusNotFound, fmt.Sprintf("error creating subscription %v", err))
-		localmetrics.UpdateSubscriptionCount(localmetrics.FAILCREATE, 1)
-		return
-	}
-	addr := newSub.GetResource()
+	addr := sub.GetResource()
 
 	// this is placeholder not sending back to report
 	out := channel.DataChan{
@@ -119,7 +111,7 @@ func (s *Server) createSubscription(w http.ResponseWriter, r *http.Request) {
 	}
 
 	restClient := restclient.New()
-	out.Data.SetID(newSub.ID) // set ID to the subscriptionID
+	out.Data.SetID(sub.ID) // set ID to the subscriptionID
 	status, err := restClient.PostCloudEvent(sub.EndPointURI, *out.Data)
 	if err != nil {
 		respondWithStatusCode(w, http.StatusBadRequest,
@@ -139,7 +131,7 @@ func (s *Server) createSubscription(w http.ResponseWriter, r *http.Request) {
 	subs := subscriber.New(s.getClientIDFromURI(endPointURI))
 	_ = subs.SetEndPointURI(endPointURI)
 
-	subs.AddSubscription(newSub)
+	subs.AddSubscription(sub)
 	subs.Action = channel.NEW
 	cevent, _ := subs.CreateCloudEvents()
 	cevent.SetSource(addr)
@@ -165,7 +157,7 @@ func (s *Server) createSubscription(w http.ResponseWriter, r *http.Request) {
 		_ = out.Data.SetData(cloudevents.ApplicationJSON, updatedObj)
 		log.Infof("subscription created successfully.")
 		localmetrics.UpdateSubscriptionCount(localmetrics.ACTIVE, 1)
-		respondWithJSON(w, http.StatusCreated, newSub)
+		respondWithJSON(w, http.StatusCreated, sub)
 	}
 
 	s.dataOut <- &out