try telethon

tg_app/channel_by_link.py

@@ -0,0 +1,59 @@
+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()
+
+

tg_app/quick_start.py

@@ -0,0 +1,70 @@
+from telethon import TelegramClient
+
+
+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()
+
+client = TelegramClient('data/session.session', api_id, api_hash)
+
+
+async def main():
+    # Getting information about yourself
+    me = await client.get_me()
+
+    # "me" is a user object. You can pretty-print
+    # any Telegram object with the "stringify" method:
+    print(me.stringify())
+
+    # When you print something, you see a representation of it.
+    # You can access all attributes of Telegram objects with
+    # the dot operator. For example, to get the username:
+    username = me.username
+    print(username)
+    print(me.phone)
+
+    # You can print all the dialogs/conversations that you are part of:
+    async for dialog in client.iter_dialogs():
+        print(dialog.name, 'has ID', dialog.id)
+
+    # You can send messages to yourself...
+    await client.send_message('me', 'Hello, myselff!')
+    # # ...to some chat ID
+    # await client.send_message(-100123456, 'Hello, group!')
+    # # ...to your contacts
+    # await client.send_message('+34600123123', 'Hello, friend!')
+    # # ...or even to any username
+    # await client.send_message('username', 'Testing Telethon!')
+
+    # You can, of course, use markdown in your messages:
+    message = await client.send_message(
+        'me',
+        'This message has **bold**, `code`, __italics__ and '
+        'a [nice website](https://example.com)!',
+        link_preview=False
+    )
+
+    # Sending a message returns the sent message object, which you can use
+    print(message.raw_text)
+
+    # You can reply to messages directly if you have a message object
+    await message.reply('Cool!')
+
+    # Or send files, songs, documents, albums...
+    # await client.send_file('me', '/home/me/Pictures/holidays.jpg')
+
+    # You can print the message history of any chat:
+    async for message in client.iter_messages('me'):
+        print(message.id, message.text)
+
+        # You can download media from messages, too!
+        # The method will return the path where the file was saved.
+        if message.photo:
+            path = await message.download_media()
+            print('File saved to', path)  # printed after download is done
+
+with client:
+    client.loop.run_until_complete(main())
+

tg_app/try_async_1.py

@@ -0,0 +1,41 @@
+import asyncio
+
+
+async def f1():
+    for _ in range(10):
+        print(1, end='', flush=True)
+        await asyncio.sleep(0.2)
+
+
+async def f2():
+    for _ in range(10):
+        print(2, end='', flush=True)
+        await asyncio.sleep(0.2)
+
+
+async def f12():
+    """ неверно, скрипт закончится без ожидания завершения f1() и f2() """
+    asyncio.create_task(f1())
+    asyncio.create_task(f2())
+
+
+async def f12wait():
+    """ дожидаемся завершения """
+    t1 = asyncio.create_task(f1())
+    t2 = asyncio.create_task(f2())
+    await t1
+    await t2
+
+
+async def main():
+    await f1()
+    print()
+    await f2()
+    print()
+    # await f12()
+    # print()
+    await f12wait()
+
+
+asyncio.run(main())
+

tg_app/try_async_2.py

@@ -0,0 +1,24 @@
+import asyncio
+
+
+async def f1():
+    for _ in range(10):
+        yield 1
+        await asyncio.sleep(0.2)
+
+
+async def f2():
+    for _ in range(10):
+        yield 2
+        await asyncio.sleep(0.2)
+
+
+async def main():
+    async for i in f1():
+        print(i, end='', flush=True)
+    async for i in f2():
+        print(i, end='', flush=True)
+
+
+asyncio.run(main())
+

tg_app/try_bot.py

@@ -0,0 +1,58 @@
+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()
+
+with open('data/tg_bot_token.txt') as f:
+    bot_token = f.read().strip()
+
+channel_link = 'https://t.me/redakciya_channel'
+
+
+client = TelegramClient('data/bot_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)
+
+
+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 Exception as e:
+        print(f"An error occurred: {e}")
+
+client.start(bot_token=bot_token)
+client.loop.run_until_complete(check_channel())
+client.run_until_disconnected()
+
+
+

tg_app/try_telethon.py

@@ -0,0 +1,13 @@
+from telethon import TelegramClient
+
+
+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()
+
+with TelegramClient('data/session.session', api_id, api_hash) as client:
+    client.loop.run_until_complete(client.send_message('me', 'Hello, myself!'))
+
+

tg_app/updates_events.py

@@ -0,0 +1,53 @@
+import logging
+
+from telethon import TelegramClient, events
+
+
+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()
+
+client = TelegramClient('data/session.session', api_id, api_hash)
+
+channel_of_interest_id = None
+
+
+async def main():
+    global channel_of_interest_id
+    async for dialog in client.iter_dialogs():
+        if dialog.name.lower().find('редакция') != -1:
+            channel_of_interest_id = dialog.id
+            print(f'Tracking channel "{dialog.name}" with id: {channel_of_interest_id}')
+            break
+
+    assert channel_of_interest_id is not None
+
+    async for msg in client.iter_messages(entity=channel_of_interest_id, limit=100):
+        if msg.message.lower().find('#ньюсдня') != -1:
+            print(msg.message)
+            break
+
+
+@client.on(events.NewMessage(incoming=True))
+async def my_event_handler(event):
+    chat = await event.get_chat()
+    sender = await event.get_sender()
+    chat_id = event.chat_id
+    sender_id = event.sender_id
+    print(event.stringify())
+    # if 'hello' in event.raw_text:
+    #     await event.reply('hi!')
+    # else:
+    #     await event.reply('what?')
+
+client.start()
+client.loop.run_until_complete(main())
+client.run_until_disconnected()