zsh/tg-bot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

updated content match message with all possible matches and contextes

Browse Source
This commit is contained in:
afolivieri 2024-10-11 12:08:13 +03:00
parent 99d6675688
commit 451412973c
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
streaming_overseer.py
View File

@ -123,17 +123,20 @@ async def main():
async def handler(event): async def handler(event):
try: try:
message_content = event.message.message if event.message else "" message_content = event.message.message if event.message else ""
words = []
contexts = []
for word, pattern in word_patterns.items(): for word, pattern in word_patterns.items():
for match in pattern.finditer(message_content): for match in pattern.finditer(message_content):
start_pos = max(match.start() - 20, 0) start_pos = max(match.start() - 20, 0)
end_pos = min(match.end() + 20, len(message_content)) end_pos = min(match.end() + 20, len(message_content))
context = message_content[start_pos:end_pos] context = message_content[start_pos:end_pos]
await client.send_message(channel_id, f"Keyword Match: {word}\nContext: {context}") words.append(word)
contexts.append(context)
await client.send_message(channel_id, f"Keyword Match: {', '.join(words)}\nContext: {', '.join(contexts)}")
await asyncio.sleep(0.1) await asyncio.sleep(0.1)
await event.message.forward_to(channel_id) await event.message.forward_to(channel_id)
await asyncio.sleep(0.5) await asyncio.sleep(0.5)
print(f'Forwarded Message: {message_content}') print(f'Forwarded Message: {message_content}')
break
except Exception as e: except Exception as e:
logging.error(f"Error in message handler: {e}") logging.error(f"Error in message handler: {e}")