forked from LazyDeveloperr/LazyPrincess
-
Notifications
You must be signed in to change notification settings - Fork 35
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Super Verion 8 - stream feature + Fixed Bugs
no need to buy paid sources codes while LazyDeveloperr is here.... #rip_paid_developers 😍
- Loading branch information
1 parent
2273afe
commit 225954e
Showing
34 changed files
with
2,278 additions
and
162 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,99 +1,116 @@ | ||
| import logging | ||
| import logging.config | ||
|
|
||
| # Credit @LazyDeveloper. | ||
| # Please Don't remove credit. | ||
| # Born to make history @LazyDeveloper ! | ||
| # Thank you LazyDeveloper for helping us in this Journey | ||
| # 🥰 Thank you for giving me credit @LazyDeveloperr 🥰 | ||
| # for any error please contact me -> telegram@LazyDeveloperr or insta @LazyDeveloperr | ||
| # rip paid developers 🤣 - >> No need to buy paid source code while @LazyDeveloperr is here 😍😍 | ||
| # Get logging configurations | ||
| logging.config.fileConfig('logging.conf') | ||
| logging.getLogger().setLevel(logging.INFO) | ||
| logging.getLogger("pyrogram").setLevel(logging.ERROR) | ||
| logging.getLogger("imdbpy").setLevel(logging.ERROR) | ||
| logging.basicConfig( | ||
| level=logging.INFO, | ||
| format="%(asctime)s - %(name)s - %(levelname)s - %(message)s" | ||
| ) | ||
| logging.getLogger("aiohttp").setLevel(logging.ERROR) | ||
| logging.getLogger("aiohttp.web").setLevel(logging.ERROR) | ||
|
|
||
| from pyrogram import Client, __version__ | ||
| from pyrogram.raw.all import layer | ||
| from database.ia_filterdb import Media | ||
| from database.users_chats_db import db | ||
| from info import SESSION, API_ID, API_HASH, BOT_TOKEN, LOG_STR | ||
| from info import * | ||
| from utils import temp | ||
| from typing import Union, Optional, AsyncGenerator | ||
| from pyrogram import types | ||
| from aiohttp import web | ||
| from plugins import web_server | ||
|
|
||
| PORT = "8080" | ||
| import asyncio | ||
| from pyrogram import idle | ||
| from lazybot import LazyPrincessBot | ||
| from util.keepalive import ping_server | ||
| from lazybot.clients import initialize_clients | ||
|
|
||
| class Bot(Client): | ||
| PORT = "8080" | ||
| LazyPrincessBot.start() | ||
| loop = asyncio.get_event_loop() | ||
|
|
||
| def __init__(self): | ||
| super().__init__( | ||
| name=SESSION, | ||
| api_id=API_ID, | ||
| api_hash=API_HASH, | ||
| bot_token=BOT_TOKEN, | ||
| workers=50, | ||
| plugins={"root": "plugins"}, | ||
| sleep_threshold=5, | ||
| ) | ||
|
|
||
| async def start(self): | ||
| b_users, b_chats = await db.get_banned() | ||
| temp.BANNED_USERS = b_users | ||
| temp.BANNED_CHATS = b_chats | ||
| await super().start() | ||
| await Media.ensure_indexes() | ||
| me = await self.get_me() | ||
| temp.ME = me.id | ||
| temp.U_NAME = me.username | ||
| temp.B_NAME = me.first_name | ||
| self.username = '@' + me.username | ||
| app = web.AppRunner(await web_server()) | ||
| await app.setup() | ||
| bind_address = "0.0.0.0" | ||
| await web.TCPSite(app, bind_address, PORT).start() | ||
| logging.info(f"{me.first_name} with for Pyrogram v{__version__} (Layer {layer}) started on {me.username}.") | ||
| logging.info(LOG_STR) | ||
|
|
||
| async def stop(self, *args): | ||
| await super().stop() | ||
| logging.info("Bot stopped. Bye.") | ||
|
|
||
| async def iter_messages( | ||
| self, | ||
| chat_id: Union[int, str], | ||
| limit: int, | ||
| offset: int = 0, | ||
| ) -> Optional[AsyncGenerator["types.Message", None]]: | ||
| """Iterate through a chat sequentially. | ||
| This convenience method does the same as repeatedly calling :meth:`~pyrogram.Client.get_messages` in a loop, thus saving | ||
| you from the hassle of setting up boilerplate code. It is useful for getting the whole chat messages with a | ||
| single call. | ||
| Parameters: | ||
| chat_id (``int`` | ``str``): | ||
| Unique identifier (int) or username (str) of the target chat. | ||
| For your personal cloud (Saved Messages) you can simply use "me" or "self". | ||
| For a contact that exists in your Telegram address book you can use his phone number (str). | ||
| limit (``int``): | ||
| Identifier of the last message to be returned. | ||
| offset (``int``, *optional*): | ||
| Identifier of the first message to be returned. | ||
| Defaults to 0. | ||
| Returns: | ||
| ``Generator``: A generator yielding :obj:`~pyrogram.types.Message` objects. | ||
| Example: | ||
| .. code-block:: python | ||
| for message in app.iter_messages("pyrogram", 1, 15000): | ||
| print(message.text) | ||
| """ | ||
| current = offset | ||
| while True: | ||
| new_diff = min(200, limit - current) | ||
| if new_diff <= 0: | ||
| return | ||
| messages = await self.get_messages(chat_id, list(range(current, current+new_diff+1))) | ||
| for message in messages: | ||
| yield message | ||
| current += 1 | ||
| # async def iter_messages( | ||
| # client, | ||
| # chat_id: Union[int, str], | ||
| # limit: int, | ||
| # offset: int = 0, | ||
| # ) -> Optional[AsyncGenerator["types.Message", None]]: | ||
| # """Iterate through a chat sequentially. | ||
| # This convenience method does the same as repeatedly calling :meth:`~pyrogram.Client.get_messages` in a loop, thus saving | ||
| # you from the hassle of setting up boilerplate code. It is useful for getting the whole chat messages with a | ||
| # single call. | ||
| # Parameters: | ||
| # client (:obj:`pyrogram.Client`): | ||
| # The Pyrogram client instance. | ||
|
|
||
| # chat_id (``int`` | ``str``): | ||
| # Unique identifier (int) or username (str) of the target chat. | ||
| # For your personal cloud (Saved Messages) you can simply use "me" or "self". | ||
| # For a contact that exists in your Telegram address book you can use his phone number (str). | ||
|
|
||
| # limit (``int``): | ||
| # Identifier of the last message to be returned. | ||
|
|
||
| # offset (``int``, *optional*): | ||
| # Identifier of the first message to be returned. | ||
| # Defaults to 0. | ||
| # Returns: | ||
| # ``Generator``: A generator yielding :obj:`~pyrogram.types.Message` objects. | ||
| # Example: | ||
| # .. code-block:: python | ||
| # for message in iter_messages(client, "pyrogram", 1, 15000): | ||
| # print(message.text) | ||
| # """ | ||
| # current = offset | ||
| # while True: | ||
| # new_diff = min(200, limit - current) | ||
| # if new_diff <= 0: | ||
| # return | ||
| # messages = await client.get_messages(chat_id, list(range(current, current + new_diff + 1))) | ||
| # for message in messages: | ||
| # yield message | ||
| # current += 1 | ||
|
|
||
| async def Lazy_start(): | ||
| print('\n') | ||
| print(' Initalizing Telegram Bot ') | ||
| bot_info = await LazyPrincessBot.get_me() | ||
| LazyPrincessBot.username = bot_info.username | ||
| await initialize_clients() | ||
| if ON_HEROKU: | ||
| asyncio.create_task(ping_server()) | ||
| b_users, b_chats = await db.get_banned() | ||
| temp.BANNED_USERS = b_users | ||
| temp.BANNED_CHATS = b_chats | ||
| await Media.ensure_indexes() | ||
| me = await LazyPrincessBot.get_me() | ||
| temp.ME = me.id | ||
| temp.U_NAME = me.username | ||
| temp.B_NAME = me.first_name | ||
| LazyPrincessBot.username = '@' + me.username | ||
| app = web.AppRunner(await web_server()) | ||
| await app.setup() | ||
| bind_address = "0.0.0.0" if ON_HEROKU else BIND_ADRESS | ||
| await web.TCPSite(app, bind_address, PORT).start() | ||
| logging.info(f"{me.first_name} with for Pyrogram v{__version__} (Layer {layer}) started on {me.username}.") | ||
| logging.info(LOG_STR) | ||
| await idle() | ||
|
|
||
| app = Bot() | ||
| app.run() | ||
| if __name__ == '__main__': | ||
| try: | ||
| loop.run_until_complete(Lazy_start()) | ||
| except KeyboardInterrupt: | ||
| logging.info('----------------------- Service Stopped -----------------------') |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.