1  """Helper Inbox performs inbox messages related operations"""
 2  
 3  from . import queues
 4  from .helper_sql import sqlExecute, sqlQuery
 5  
 6  
 7  def insert(t):
 8      """Perform an insert into the "inbox" table"""
 9      sqlExecute('''INSERT INTO inbox VALUES (?,?,?,?,?,?,?,?,?,?)''', *t)
10      # shouldn't emit changedInboxUnread and displayNewInboxMessage
11      # at the same time
12      # queues.UISignalQueue.put(('changedInboxUnread', None))
13  
14  
15  def trash(msgid):
16      """Mark a message in the `inbox` as `trash`"""
17      sqlExecute('''UPDATE inbox SET folder='trash' WHERE msgid=?''', msgid)
18      queues.UISignalQueue.put(('removeInboxRowByMsgid', msgid))
19  
20  
21  def delete(ack_data):
22      """Permanent delete message from trash"""
23      sqlExecute("DELETE FROM inbox WHERE msgid = ?", ack_data)
24  
25  
26  def undeleteMessage(msgid):
27      """Undelte the message"""
28      sqlExecute('''UPDATE inbox SET folder='inbox' WHERE msgid=?''', msgid)
29  
30  
31  def isMessageAlreadyInInbox(sigHash):
32      """Check for previous instances of this message"""
33      queryReturn = sqlQuery(
34          '''SELECT COUNT(*) FROM inbox WHERE sighash=?''', sigHash)
35      return queryReturn[0][0] != 0