                                   [[:db/add [:thread/id thread-id]
                                     :thread/mentioned [:user/id user-id]]
                                    [:db/add [:user/id user-id]
-                                    :user/subscribed-thread  [:thread/id thread-id]]
+                                    :user/subscribed-thread [:thread/id thread-id]]
                                    [:db/add [:user/id user-id]
-                                    :user/open-thread  [:thread/id thread-id]]])
+                                    :user/open-thread [:thread/id thread-id]]])
                                 mentioned-user-ids)
         ; open thread for users already subscribed to thread
         txs-for-tag-subscribers (map

                                     :thread/tag [:tag/id tag-id]]]
                                   (mapcat (fn [user-id]
                                             [[:db/add [:user/id user-id]
                                               :user/subscribed-thread [:thread/id thread-id]]
                                              [:db/add [:user/id user-id]
                                               :user/open-thread [:thread/id thread-id]]])
                                           (get-users-subscribed-to-tag tag-id))))
                               mentioned-tag-ids)
        ; subscribe and open thread for users mentioned

                                 :thread/id thread-id
                                 :thread/group [:group/id group-id]}])))

  (let [; for users subscribed to mentioned tags, open and subscribe them to
        ; the thread
        txs-for-tag-mentions (mapcat
                               (fn [tag-id]
                                 (into
