ticketfrei/ticketfrei3
8
1
Fork 0
Code Issues 11 Pull requests 2 Projects 1 Releases Wiki Activity

[twitter] Terminate bot if oauth not successful and fix initial since_id

Browse source
This commit is contained in:
Cathy Hu 2020-07-06 14:36:51 +02:00 committed by acipm
parent fae170ffb9
commit 2e4be2de15
1 changed files with 32 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
kibicara/platforms/twitter/bot.py
View file

@ -29,18 +29,36 @@ class TwitterBot(Censor):
self.dms_since_id = self.twitter_model.dms_since_id self.dms_since_id = self.twitter_model.dms_since_id
async def run(self): async def run(self):
await gather(self.poll(), self.push()) if self.twitter_model.successful_verified:
if self.twitter_model.mentions_since_id is None:
logger.debug('since_id is None in model, fetch newest mention id')
mentions = await self._poll_mentions()
if self.twitter_model.dms_since_id is None:
logger.debug('since_id is None in model, fetch newest dm id')
dms = await self._poll_direct_messages()
logger.debug('Starting Twitter bot: %s' % self.twitter_model.__dict__)
await gather(self.poll(), self.push())
else:
logger.debug('Twitter Bot not started: Oauth Handshake not completed')
async def poll(self): async def poll(self):
while True: while True:
messages = await self._poll_direct_messages() dms = await self._poll_direct_messages()
messages.extend(await self._poll_mentions()) logger.debug(
logger.debug('Polled messages: %s' % str(messages)) 'Polled dms (%s): %s' % (self.twitter_model.hood.name, str(dms))
)
mentions = await self._poll_mentions()
logger.debug(
'Polled mentions (%s): %s'
% (self.twitter_model.hood.name, str(mentions))
)
await self.twitter_model.update( await self.twitter_model.update(
dms_since_id=self.dms_since_id, mentions_since_id=self.mentions_since_id dms_since_id=self.dms_since_id, mentions_since_id=self.mentions_since_id
) )
for message in messages: for message in dms:
await self.publish(Message(message)) await self.publish(Message(message))
for message_id, message in mentions:
await self.publish(Message(message, twitter_mention_id=message_id))
await sleep(self.polling_interval_sec) await sleep(self.polling_interval_sec)
async def _poll_direct_messages(self): async def _poll_direct_messages(self):
@ -76,7 +94,7 @@ class TwitterBot(Censor):
filtered_text = await self._filter_text(mention.entities, mention.text) filtered_text = await self._filter_text(mention.entities, mention.text)
if not filtered_text: if not filtered_text:
continue continue
messages.append(filtered_text) messages.append((mention.id, filtered_text))
return messages return messages
async def _filter_text(self, entities, text): async def _filter_text(self, entities, text):
@ -97,11 +115,14 @@ class TwitterBot(Censor):
async def push(self): async def push(self):
while True: while True:
message = await self.receive() message = await self.receive()
print('Received' + message.text) logger.debug(
# TODO check if report is from twitter itself 'Received message from censor (%s): %s'
# _retweet(message_id) % (self.twitter_model.hood.name, message)
# else )
# _post_tweet(message) if hasattr(message, 'twitter_mention_id'):
await self._retweet(message.twitter_mention_id)
else:
await self._post_tweet(message.text)
async def _post_tweet(self, message): async def _post_tweet(self, message):
return await self.client.api.statuses.update.post(status=message) return await self.client.api.statuses.update.post(status=message)