honour filter policies on SNS subscriptions

maxholman · Apr 16, 2021 · 1e39f6a · 1e39f6a
1 parent 9e6f7a8
commit 1e39f6a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/app/gosns/gosns.go b/app/gosns/gosns.go
@@ -505,6 +505,11 @@ func Publish(w http.ResponseWriter, req *http.Request) {
 			"subject":  subject,
 		}).Debug("Publish to Topic")
 		for _, subs := range app.SyncTopics.Topics[topicName].Subscriptions {
+
+			if subs.FilterPolicy != nil && !subs.FilterPolicy.IsSatisfiedBy(messageAttributes) {
+				continue
+			}
+
 			switch app.Protocol(subs.Protocol) {
 			case app.ProtocolSQS:
 				publishSQS(w, req, subs, messageBody, messageAttributes, subject, topicArn, topicName, messageStructure)