import logging

from telethon import TelegramClient, events
from telethon.errors import ChannelPrivateError


logging.basicConfig(
    format='[%(levelname) 5s/%(asctime)s] %(name)s: %(message)s',
    level=logging.WARNING
)


with open('data/tg_api_id.txt') as f:
    api_id = f.read().strip()

with open('data/tg_app_api_hash.txt') as f:
    api_hash = f.read().strip()

channel_link = 'https://t.me/redakciya_channel'
recipient = 'https://t.me/kazakov123'

client = TelegramClient('data/session.session', api_id, api_hash)


@client.on(events.NewMessage(chats=channel_link))
async def on_new_message(event):
    if '#ньюсдня' in event.raw_text:
        print(event.message)
    else:
        print('@@@ other message: ')
        print(event.message)
    await client.forward_messages(
        entity=recipient,
        messages=event.message.message,
        from_peer=channel_link
    )


async def check_channel():
    try:
        channel = await client.get_entity(channel_link)
        print(f'Channel open: {channel.title}')
        async for msg in client.iter_messages(entity=channel, limit=100):
            if msg.message.lower().find('#ньюсдня') != -1:
                print(f'Last message:')
                print(msg.message)
                break
        print(f'Listening for new messages...')
    except ChannelPrivateError:
        print("The channel is private and you don't seem to have access.")
    except ValueError as e:
        print(f"An error occurred: {e}")


client.start()
client.loop.run_until_complete(check_channel())
client.run_until_disconnected()