diff --git a/peer/cwtchprofilestorage.go b/peer/cwtchprofilestorage.go index b9ea334..fe2fe70 100644 --- a/peer/cwtchprofilestorage.go +++ b/peer/cwtchprofilestorage.go @@ -681,6 +681,7 @@ func (cps *CwtchProfileStorage) GetMostRecentMessages(conversation int, channel } } +// PurgeConversationChannel deletes all message for a conversation channel. func (cps *CwtchProfileStorage) PurgeConversationChannel(conversation int, channel int) error { conversationStmt, err := cps.db.Prepare(fmt.Sprintf(purgeMessagesFromConversationSQLStmt, conversation, channel)) if err != nil {