messages.clj

(s/defn last-n-conversation-messages
  ([cassandra conversation]
   (last-n-conversation-messages cassandra
                                 conversation
                                 max-recent-messages))
  ([cassandra
    conversation
    n]
   (ddo [:let [[org-id con-id] (t/extract-uber-key-value conv.ent/Conversations
                                                         conversation)]
         msgs (cm/select
               cassandra
               conv.ent/ConversationMessages
               [:org_id :conversation_id]
               [org-id con-id]
               {:limit n})]
     (return
      (filter
       (comp not :deleted)
       msgs)))))