Use UUID URN by default for event IDs

hub/publish_test.go

@@ -221,7 +221,7 @@ func TestPublishGenerateUUID(t *testing.T) {
 		u := <-s.Receive()
 		require.NotNil(t, u)
 
-		_, err := uuid.FromString(u.ID)
+		_, err := uuid.FromString(strings.TrimPrefix(u.ID, "urn:uuid:"))
 		assert.Nil(t, err)
 	}()
 
@@ -244,7 +244,7 @@ func TestPublishGenerateUUID(t *testing.T) {
 	bodyBytes, _ := ioutil.ReadAll(resp.Body)
 	body := string(bodyBytes)
 
-	_, err := uuid.FromString(body)
+	_, err := uuid.FromString(strings.TrimPrefix(body, "urn:uuid:"))
 	assert.Nil(t, err)
 
 	wg.Wait()

hub/subscribe.go

@@ -249,7 +249,7 @@ func (h *Hub) dispatchSubscriptionUpdate(s *Subscriber, active bool) {
 
 	for k, topic := range s.Topics {
 		connection := &subscription{
-			ID:      "https://mercure.rocks/subscriptions/" + s.EscapedTopics[k] + "/" + s.ID,
+			ID:      "https://mercure.rocks/subscriptions/" + s.EscapedTopics[k] + "/" + s.EscapedID,
 			Type:    "https://mercure.rocks/Subscription",
 			Topic:   topic,
 			Active:  active,

hub/subscribe_test.go

@@ -394,7 +394,6 @@ func TestSubscriptionEvents(t *testing.T) {
 			ready := len(s.subscribers) == 2
 			s.RUnlock()
 
-			log.Info("Waiting for subscriber...")
 			if ready {
 				break
 			}

hub/subscriber.go

@@ -1,6 +1,8 @@
 package hub
 
 import (
+	"net/url"
+
 	"github.com/gofrs/uuid"
 	log "github.com/sirupsen/logrus"
 	"github.com/yosida95/uritemplate"
@@ -14,6 +16,7 @@ type updateSource struct {
 // Subscriber represents a client subscribed to a list of topics.
 type Subscriber struct {
 	ID             string
+	EscapedID      string
 	Claims         *claims
 	Targets        map[string]struct{}
 	Topics         []string
@@ -35,9 +38,10 @@ type Subscriber struct {
 }
 
 func newSubscriber(lastEventID string) *Subscriber {
-	id := uuid.Must(uuid.NewV4()).String()
+	id := "urn:uuid:" + uuid.Must(uuid.NewV4()).String()
 	s := &Subscriber{
 		ID:          id,
+		EscapedID:   url.QueryEscape(id),
 		LastEventID: lastEventID,
 		LogFields: log.Fields{
 			"subscriber_id": id,

hub/update.go

@@ -27,7 +27,7 @@ func newUpdate(event Event, topics []string, targets map[string]struct{}) *Updat
 		Targets: targets,
 	}
 	if u.ID == "" {
-		u.ID = uuid.Must(uuid.NewV4()).String()
+		u.ID = "urn:uuid:" + uuid.Must(uuid.NewV4()).String()
 	}
 
 	return u