fixing comments

Author: or-else

server/db/adapter.go

@@ -115,16 +115,17 @@ type Adapter interface {
 	OwnTopics(uid t.Uid) ([]string, error)
 	// ChannelsForUser loads a slice of topic names where the user is a channel reader and notifications (P) are enabled.
 	ChannelsForUser(uid t.Uid) ([]string, error)
-	// TopicShare creates topc subscriptions
+	// TopicShare creates topic subscriptions.
 	TopicShare(subs []*t.Subscription) error
-	// TopicDelete deletes topic, subscription, messages
+	// TopicDelete deletes topic, subscriptions, messages.
 	TopicDelete(topic string, isChan, hard bool) error
 	// TopicUpdateOnMessage increments Topic's or User's SeqId value and updates TouchedAt timestamp.
 	TopicUpdateOnMessage(topic string, msg *t.Message) error
 	// TopicUpdate updates topic record.
 	TopicUpdate(topic string, update map[string]any) error
 	// TopicOwnerChange updates topic's owner
 	TopicOwnerChange(topic string, newOwner t.Uid) error
+
 	// Topic subscriptions
 
 	// SubscriptionGet reads a subscription of a user to a topic

server/db/mongodb/adapter.go

@@ -1821,7 +1821,7 @@ func (a *adapter) ChannelsForUser(uid t.Uid) ([]string, error) {
 	return names, err
 }
 
-// TopicShare creates topic subscriptions
+// TopicShare creates topic subscriptions.
 func (a *adapter) TopicShare(subs []*t.Subscription) error {
 	// Assign Ids.
 	for i := 0; i < len(subs); i++ {
@@ -1847,7 +1847,7 @@ func (a *adapter) TopicShare(subs []*t.Subscription) error {
 	return nil
 }
 
-// TopicDelete deletes topic, subscription, messages
+// TopicDelete deletes topic, subscriptions, messages.
 func (a *adapter) TopicDelete(topic string, isChan, hard bool) error {
 	filter := b.M{}
 	if isChan {

server/db/mysql/adapter.go

@@ -2039,7 +2039,7 @@ func (a *adapter) TopicShare(shares []*t.Subscription) error {
 	return tx.Commit()
 }
 
-// TopicDelete deletes specified topic.
+// TopicDelete deletes topic, subscriptions, messages.
 func (a *adapter) TopicDelete(topic string, isChan, hard bool) error {
 	ctx, cancel := a.getContextForTx()
 	if cancel != nil {

server/db/postgres/adapter.go

@@ -1935,7 +1935,7 @@ func (a *adapter) TopicShare(shares []*t.Subscription) error {
 	return tx.Commit(ctx)
 }
 
-// TopicDelete deletes specified topic.
+// TopicDelete deletes topic, subscriptions, messages.
 func (a *adapter) TopicDelete(topic string, isChan, hard bool) error {
 	ctx, cancel := a.getContextForTx()
 	if cancel != nil {

server/db/rethinkdb/adapter.go

@@ -1564,7 +1564,7 @@ func (a *adapter) TopicShare(shares []*t.Subscription) error {
 	return err
 }
 
-// TopicDelete deletes topic.
+// TopicDelete deletes topic, subscriptions, messages.
 func (a *adapter) TopicDelete(topic string, isChan, hard bool) error {
 	var err error
 	if err = a.subsDelForTopic(topic, isChan, hard); err != nil {