Method sendMsg

src/class_singleWorker.py:529–882

(self)

        

    def sendMsg(self):
        # Reset just in case
        sqlExecute(
            '''UPDATE sent SET status='msgqueued' WHERE status IN ('doingpubkeypow', 'doingmsgpow')''')
        queryreturn = sqlQuery(
            '''SELECT toaddress, fromaddress, subject, message, ackdata, status, ttl, retrynumber, encodingtype FROM sent WHERE (status='msgqueued' or status='forcepow') and folder='sent' ''')
        for row in queryreturn: # while we have a msg that needs some work
            toaddress, fromaddress, subject, message, ackdata, status, TTL, retryNumber, encoding = row
            toStatus, toAddressVersionNumber, toStreamNumber, toRipe = decodeAddress(
                toaddress)
            fromStatus, fromAddressVersionNumber, fromStreamNumber, fromRipe = decodeAddress(
                fromaddress)
            
            # We may or may not already have the pubkey for this toAddress. Let's check.
            if status == 'forcepow':
                # if the status of this msg is 'forcepow' then clearly we have the pubkey already
                # because the user could not have overridden the message about the POW being
                # too difficult without knowing the required difficulty.
                pass
            elif status == 'doingmsgpow':
                # We wouldn't have set the status to doingmsgpow if we didn't already have the pubkey
                # so let's assume that we have it.
                pass
            # If we are sending a message to ourselves or a chan then we won't need an entry in the pubkeys table; we can calculate the needed pubkey using the private keys in our keys.dat file.
            elif BMConfigParser().has_section(toaddress):
                sqlExecute(
                    '''UPDATE sent SET status='doingmsgpow' WHERE toaddress=? AND status='msgqueued' ''',
                    toaddress)
                status='doingmsgpow'
            elif status == 'msgqueued':
                # Let's see if we already have the pubkey in our pubkeys table
                queryreturn = sqlQuery(
                    '''SELECT address FROM pubkeys WHERE address=?''', toaddress)
                if queryreturn != []:  # If we have the needed pubkey in the pubkey table already, 
                    # set the status of this msg to doingmsgpow
                    sqlExecute(
                        '''UPDATE sent SET status='doingmsgpow' WHERE toaddress=? AND status='msgqueued' ''',
                        toaddress)
                    status = 'doingmsgpow'
                    # mark the pubkey as 'usedpersonally' so that we don't delete it later. If the pubkey version
                    # is >= 4 then usedpersonally will already be set to yes because we'll only ever have 
                    # usedpersonally v4 pubkeys in the pubkeys table.
                    sqlExecute(
                        '''UPDATE pubkeys SET usedpersonally='yes' WHERE address=?''',
                        toaddress)
                else:  # We don't have the needed pubkey in the pubkeys table already.
                    if toAddressVersionNumber <= 3:
                        toTag = ''
                    else:
                        toTag = hashlib.sha512(hashlib.sha512(encodeVarint(toAddressVersionNumber)+encodeVarint(toStreamNumber)+toRipe).digest()).digest()[32:]
                    if toaddress in state.neededPubkeys or toTag in state.neededPubkeys:
                        # We already sent a request for the pubkey
                        sqlExecute(
                            '''UPDATE sent SET status='awaitingpubkey', sleeptill=? WHERE toaddress=? AND status='msgqueued' ''', 
                            int(time.time()) + 2.5*24*60*60,
                            toaddress)
                        queues.UISignalQueue.put(('updateSentItemStatusByToAddress', (
                            toaddress, tr._translate("MainWindow",'Encryption key was requested earlier.'))))