From 6f05bd0f85f712c6e616e7c587b7f66f8605d7f8 Mon Sep 17 00:00:00 2001 From: Peter Stuifzand Date: Tue, 19 Mar 2019 07:18:24 +0100 Subject: [PATCH] Filter on topic --- cmd/hubserver/storage/postgres.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/hubserver/storage/postgres.go b/cmd/hubserver/storage/postgres.go index 51380c2..689e57c 100644 --- a/cmd/hubserver/storage/postgres.go +++ b/cmd/hubserver/storage/postgres.go @@ -44,7 +44,7 @@ func (s *postgres) Unsubscribe(topic, callback string) error { } func (s *postgres) Subscribers(topic string) ([]Subscriber, error) { - rows, err := s.db.Query(`SELECT callback, lease_seconds, secret, created FROM "subscribers"`) + rows, err := s.db.Query(`SELECT callback, lease_seconds, secret, created FROM "subscribers" WHERE "topic" = $1`, topic) if err != nil { return nil, err }