Implement HasTopic.HasTopic

pubsub/pubsub.go

@@ -144,6 +144,22 @@ func (p *PubSub) Unlisten(topic string, params ...interface{}) {
 	}
 }
 
+// HasTopic returns true if topic present.
+func (p *PubSub) HasTopic(topic string, params ...interface{}) bool {
+	p.Lock()
+	defer p.Unlock()
+
+	t := p.Topic(topic, params...)
+
+	for _, c := range p.Connections {
+		if c.HasTopic(t) {
+			return true
+		}
+	}
+
+	return false
+}
+
 // Topic generate correct topic for API.
 // Params can be as number or string.
 //

pubsub/pubsub_test.go

@@ -71,6 +71,16 @@ var _ = Describe("PubSub", func() {
 			})
 		})
 
+		Context("HasTopic", func() {
+			It("checks topics", func() {
+				Expect(len(ps.Connections)).To(Equal(0))
+
+				ps.Listen("community-points-channel-v1", 1)
+				Expect(ps.HasTopic("unknown")).To(BeFalse())
+				Expect(ps.HasTopic("community-points-channel-v1", 1)).To(BeTrue())
+			})
+		})
+
 		Context("Topic", func() {
 			It("generate correct topic", func() {
 				Expect(ps.Topic("channel-bits-events-v1.123")).To(Equal("channel-bits-events-v1.123"))