(self, data)
| 95 | break |
| 96 | |
| 97 | def checkackdata(self, data): |
| 98 | # Let's check whether this is a message acknowledgement bound for us. |
| 99 | if len(data) < 32: |
| 100 | return |
| 101 | |
| 102 | # bypass nonce and time, retain object type/version/stream + body |
| 103 | readPosition = 16 |
| 104 | |
| 105 | if data[readPosition:] in shared.ackdataForWhichImWatching: |
| 106 | logger.info('This object is an acknowledgement bound for me.') |
| 107 | del shared.ackdataForWhichImWatching[data[readPosition:]] |
| 108 | sqlExecute('UPDATE sent SET status=?, lastactiontime=? WHERE ackdata=?', |
| 109 | 'ackreceived', |
| 110 | int(time.time()), |
| 111 | data[readPosition:]) |
| 112 | queues.UISignalQueue.put(('updateSentItemStatusByAckdata', (data[readPosition:], tr._translate("MainWindow",'Acknowledgement of the message received %1').arg(l10n.formatTimestamp())))) |
| 113 | else: |
| 114 | logger.debug('This object is not an acknowledgement bound for me.') |
| 115 | |
| 116 | |
| 117 | def processgetpubkey(self, data): |
no test coverage detected