minor

dasf_broker/consumers.py

@@ -87,10 +87,9 @@ class TopicProducer(JsonWebsocketConsumer):
                 app_settings.DASF_CREATE_TOPIC_ON_MESSAGE
                 and self.user.has_perm("dasf_broker.add_dasftopic")
             ):
-                topic = DASFTopic.objects.create(
-                    slug=self.dasf_topic_slug, consumer=self.user
-                )
+                topic = DASFTopic.objects.create(slug=self.dasf_topic_slug)
                 assign_perm("can_produce", self.user, topic)
+                assign_perm("can_consume", self.user, topic)
             elif not app_settings.DASF_CREATE_TOPIC_ON_MESSAGE:
                 ack["result"] = f"Topic {self.dasf_topic_slug} does not exist."
             else:
@@ -106,13 +105,10 @@ class TopicProducer(JsonWebsocketConsumer):
             if PropertyKeys.RESPONSE_TOPIC in props:
                 response_topic, created = DASFTopic.objects.get_or_create(
                     slug=props[PropertyKeys.RESPONSE_TOPIC],
-                    consumer=self.user,
                     is_response_topic=True,
                 )
                 if created:
-                    for user in get_users_with_perms(
-                        topic, "dasf_broker.can_consume"
-                    ):
+                    for user in get_users_with_perms(topic, "can_consume"):
                         assign_perm("can_produce", user, response_topic)
 
             async_to_sync(self.channel_layer.group_send)(