PyBitmessage-2021-04-27/src/helper_sent.py

49 lines
1.9 KiB
Python
Raw Permalink Normal View History

2019-10-07 13:58:12 +00:00
"""
2019-10-09 13:27:51 +00:00
Insert values into sent table
2019-10-07 13:58:12 +00:00
"""
2020-11-05 20:32:13 +00:00
import time
import uuid
2020-11-05 20:32:13 +00:00
from addresses import decodeAddress
from bmconfigparser import BMConfigParser
2020-11-05 20:32:13 +00:00
from helper_ackPayload import genAckPayload
2019-12-23 09:49:03 +00:00
from helper_sql import sqlExecute
2019-10-09 13:27:51 +00:00
2020-11-09 15:15:28 +00:00
# pylint: disable=too-many-arguments
def insert(msgid=None, toAddress='[Broadcast subscribers]', fromAddress=None, subject=None,
message=None, status='msgqueued', ripe=None, ackdata=None, sentTime=None,
lastActionTime=None, sleeptill=0, retryNumber=0, encoding=2, ttl=None, folder='sent'):
2019-10-09 13:27:51 +00:00
"""Perform an insert into the `sent` table"""
# pylint: disable=unused-variable
2020-11-09 15:15:28 +00:00
# pylint: disable-msg=too-many-locals
valid_addr = True
2020-11-09 15:15:28 +00:00
if not ripe or not ackdata:
addr = fromAddress if toAddress == '[Broadcast subscribers]' else toAddress
new_status, addressVersionNumber, streamNumber, new_ripe = decodeAddress(addr)
valid_addr = True if new_status == 'success' else False
2020-11-09 15:15:28 +00:00
if not ripe:
ripe = new_ripe
if not ackdata:
stealthLevel = BMConfigParser().safeGetInt(
'bitmessagesettings', 'ackstealthlevel')
new_ackdata = genAckPayload(streamNumber, stealthLevel)
ackdata = new_ackdata
if valid_addr:
msgid = msgid if msgid else uuid.uuid4().bytes
sentTime = sentTime if sentTime else int(time.time()) # sentTime (this doesn't change)
lastActionTime = lastActionTime if lastActionTime else int(time.time())
2020-11-09 15:15:28 +00:00
ttl = ttl if ttl else BMConfigParser().getint('bitmessagesettings', 'ttl')
2020-11-09 15:15:28 +00:00
t = (msgid, toAddress, ripe, fromAddress, subject, message, ackdata,
sentTime, lastActionTime, sleeptill, status, retryNumber, folder,
encoding, ttl)
sqlExecute('''INSERT INTO sent VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)''', *t)
return ackdata
else:
return None