93 lines
3.2 KiB
Python
93 lines
3.2 KiB
Python
#!/usr/bin/python3
|
|
"""Bitmessage AutoResponder"""
|
|
import base64
|
|
import configparser
|
|
import json
|
|
import os
|
|
import time
|
|
import xmlrpc.client
|
|
|
|
|
|
class BitmessageAutoresponder(): # pylint: disable=too-many-locals
|
|
"""Sending and receiving messages through autoresponder"""
|
|
config = configparser.ConfigParser()
|
|
db_var = os.path.join(os.environ["HOME"],
|
|
'.config/PyBitmessage/autoresponder.conf')
|
|
config.read(db_var)
|
|
apiport = config['sqlite3']['apiport']
|
|
apiinterface = config['sqlite3']['apiinterface']
|
|
apiusername = config['sqlite3']['apiusername']
|
|
apipassword = config['sqlite3']['apipassword']
|
|
api = xmlrpc.client.ServerProxy(
|
|
"http://%s:%s@%s:%s/"
|
|
% (apiusername, apipassword, apiinterface, apiport))
|
|
expire = 300
|
|
label = "Autoresponder"
|
|
|
|
def __init__(self):
|
|
self.addresses = {}
|
|
self.track = {}
|
|
|
|
def init_address(self):
|
|
"""generate random address if there isn't one"""
|
|
try:
|
|
addresses = json.loads(self.api.listAddresses2())['addresses']
|
|
if addresses:
|
|
return
|
|
except KeyError:
|
|
pass
|
|
self.api.createRandomAddress(base64.b64encode(self.label))
|
|
|
|
def loop(self):
|
|
"""Main loop"""
|
|
for i in json.loads(self.api.listAddresses2())['addresses']:
|
|
self.addresses[i['address']] = True
|
|
|
|
while True:
|
|
self.process_inbox_messages()
|
|
self.delete_outbox_messages()
|
|
time.sleep(10)
|
|
|
|
def process_inbox_messages(self):
|
|
"""Loop inbox and process messages"""
|
|
inboxmessages = json.loads(self.api.getAllInboxMessages())
|
|
inbox_var = inboxmessages.get('inboxMessages')
|
|
currenttime = time.time()
|
|
for values in inbox_var:
|
|
msgid = values.get('msgid')
|
|
toaddress = values.get('fromAddress')
|
|
fromaddress = values.get('toAddress')
|
|
subject = values.get('subject')
|
|
message = values.get('message')
|
|
try:
|
|
if time.time() < self.track[toaddress]:
|
|
continue
|
|
except KeyError:
|
|
pass
|
|
if toaddress in self.addresses:
|
|
continue
|
|
self.api.sendMessage(toaddress, fromaddress, subject, message)
|
|
self.api.trashMessage(msgid)
|
|
self.track[toaddress] = currenttime + self.expire
|
|
list_of_time_track = list(
|
|
key for (key, value)
|
|
in self.track.items() if value < currenttime)
|
|
for address in list_of_time_track:
|
|
self.track.pop(address)
|
|
|
|
def delete_outbox_messages(self):
|
|
"""Deleting Messages from outbox having status
|
|
ackreceived or msgsentnoackexpected"""
|
|
sentmessage = json.loads(self.api.getAllSentMessages())
|
|
sent_var = sentmessage.get('sentMessages')
|
|
for values in sent_var:
|
|
status_ack_rcvd = values.get('status')
|
|
ackdata = values.get('ackData')
|
|
if status_ack_rcvd in ('ackreceived', 'msgsentnoackexpected'):
|
|
self.api.trashSentMessageByAckData(ackdata)
|
|
|
|
|
|
if __name__ == '__main__':
|
|
BitmessageAutoresponder().init_address()
|
|
BitmessageAutoresponder().loop()
|