mathdatech/tootbot
1
0
Fork 0
mirror of https://github.com/cquest/tootbot.git synced 2025-02-17 08:18:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

better thread handling

Browse Source
This commit is contained in:
cquest 2023-04-28 12:37:27 +02:00
parent e6ec0b20d7
commit dfde209171
1 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
tootbot.py
View File

@ -230,25 +230,23 @@ else:
# print('Quoted:', c) # print('Quoted:', c)
continue continue
# check if this tweet has been processed
# new id from status link to support threads
id = t['link'].split('/')[-1]
db.execute('SELECT * FROM tweets WHERE (tweet like ? or tweet = ?) AND twitter = ? and mastodon = ? and instance = ?', (id+'%', t['id'], source, mastodon, instance)) # noqa
if db.fetchone():
continue
# detect threads # detect threads
in_reply_to = None in_reply_to = None
if 'conversation_id' in t and t['conversation_id'] not in t['link']: if 'conversation_id' in t and t['conversation_id'] not in t['link']:
db.execute('SELECT toot FROM tweets WHERE tweet = ? AND twitter = ?', (t['conversation_id'], source)) # noqa db.execute('SELECT toot FROM tweets WHERE tweet like ? AND twitter = ? ORDER BY tweet DESC LIMIT 1', ('% '+t['conversation_id'], source)) # noqa
thread = db.fetchone() thread = db.fetchone()
if thread: if thread:
print("Thread :", t['conversation_id'], t['link'], thread[0]) in_reply_to = thread[0].split()[-1]
in_reply_to = thread[0] print("Thread :", t['conversation_id'],
t['link'], thread[0], in_reply_to)
# check if this tweet has been processed
id = t['id'] # old id
db.execute('SELECT * FROM tweets WHERE tweet = ? AND twitter = ? and mastodon = ? and instance = ?', (id, source, mastodon, instance)) # noqa
if db.fetchone():
continue
id = t['link'].split('/')[-1] # new id from status link to support threads
db.execute('SELECT * FROM tweets WHERE tweet = ? AND twitter = ? and mastodon = ? and instance = ?', (id, source, mastodon, instance)) # noqa
if db.fetchone():
continue
if c[-1] == "…": if c[-1] == "…":
continue continue
@ -364,7 +362,7 @@ else:
#break #break
if "id" in toot: if "id" in toot:
db.execute("INSERT INTO tweets VALUES ( ? , ? , ? , ? , ? )", (id, toot["id"], source, mastodon, instance)) db.execute("INSERT INTO tweets VALUES ( ? , ? , ? , ? , ? )", (id+' '+t['conversation_id'], toot["id"], source, mastodon, instance))
sql.commit() sql.commit()
print(source, ": tweet created at",t['created_at']) print(source, ": tweet created at",t['created_at'])