Patch 1

Dockerfile

@@ -0,0 +1,11 @@
+FROM python:3.10.8-slim-buster
+
+RUN apt update && apt upgrade -y
+RUN apt install git -y
+COPY requirements.txt /requirements.txt
+
+RUN cd /
+RUN pip3 install -U pip && pip3 install -U -r requirements.txt
+RUN mkdir /ForwardBot
+WORKDIR /ForwardBot
+RUN python3 bot.py

Procfile

@@ -0,0 +1 @@
+web: python3 bot.py

README.md

@@ -1,2 +1,30 @@
 # File-Forward-Bot
-File-Forward-Bot
+#Not Yet Completed !
+<details><summary>Deploy To Render</summary>
+<br>
+<b>
+Use these commands:
+<br>
+<br>
+• Build Command: <code>pip3 install -U -r requirements.txt</code>
+<br>
+<br>
+• Start Command: <code>python3 bot.py</code>
+<br>
+<br>
+Go to https://uptimerobot.com/ and add a monitor to keep your bot alive.
+<br>
+<br>
+Use these settings when adding a monitor:</b>
+<br>
+<br>
+<img src="https://telegra.ph/file/a79a156e44f43c9833b50.jpg" alt="render template">
+<br>
+<br>
+<b>Click on the below button to deploy directly to render ↓</b>
+<br>
+<br>
+<a href="https://render.com/deploy?repo=https://github.com/Joelkb/File-Forward-Bot/tree/web">
+<img src="https://render.com/images/deploy-to-render-button.svg" alt="Deploy to Render">
+</a>
+</details>

app.json

@@ -0,0 +1,57 @@
+{
+    "name": "File-Forward-Bot",
+    "description": "Use this bot to forward all files from one channel to other even if its private or public.",
+    "stack": "container",
+    "keywords": [
+      "telegram",
+      "auto-forward-bot",
+      "forward-bot",
+      "forward",
+      "best",
+      "indian",
+      "pyrogram",
+      "media",
+      "export",
+      "channel",
+      "file-forward",
+      "media-forward"
+    ],
+    "website": "https://github.com/Joelkb/File-Forward-Bot",
+    "repository": "https://github.com/Joelkb/File-Forward-Bot",
+    "env": {
+        "BOT_TOKEN": {
+            "description": "Your bot token.",
+            "required": true
+        },
+        "API_ID": {
+            "description": "Get this value from https://my.telegram.org",
+            "required": true
+        },
+        "API_HASH": {
+            "description": "Get this value from https://my.telegram.org",
+            "required": true
+        },
+        "TARGET_DB": {
+            "description": "ID of channel which you want the bot to send all files to.",
+            "required": true
+        },
+        "ADMINS": {
+            "description": "ID of Admin. Separate multiple Admins by space.",
+            "required": true
+        },
+        "LOG_CHANNEL": {
+            "description": "Bot Logs,Give a channel id with -100xxxxxxx",
+            "required": true
+        }
+    },
+    "addons": [],
+    "buildpacks": [{
+        "url": "heroku/python"
+    }],
+    "formation": {
+        "worker": {
+            "quantity": 1,
+            "size": "eco"
+        }
+    }
+}

bot.py

@@ -0,0 +1,97 @@
+from pyrogram import Client, __version__
+from pyrogram.raw.all import layer
+from datetime import date, datetime
+from vars import SESSION, API_HASH, API_ID, BOT_TOKEN, LOG_CHANNEL, PORT
+from typing import Union, Optional, AsyncGenerator
+from script import scripts
+from pyrogram import types
+from utils import temp_utils
+from aiohttp import web
+from plugins import web_server
+import logging
+import pytz
+import logging.config
+
+#Get logging configuration
+logging.config.fileConfig('logging.conf')
+logging.getLogger().setLevel(logging.INFO)
+logging.getLogger("pyrogram").setLevel(logging.ERROR)
+
+
+class Bot(Client):
+
+    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):
+        await super().start()
+        me = await self.get_me()
+        temp_utils.ME = me.id
+        temp_utils.USER_NAME = me.username
+        temp_utils.BOT_NAME = me.first_name
+        self.username = '@' + me.username
+        logging.info(f"{me.first_name} with for Pyrogram v{__version__} (Layer {layer}) started on {me.username}.")
+        tz = pytz.timezone('Asia/Kolkata')
+        today = date.today()
+        now = datetime.now(tz)
+        time = now.strftime("%H:%M:%S %p")
+        await self.send_message(chat_id=LOG_CHANNEL, text=scripts.RESTART_TXT.format(today, time))
+        app = web.AppRunner(await web_server())
+        await app.setup()
+        bind_address = "0.0.0.0"
+        await web.TCPSite(app, bind_address, PORT).start()
+
+    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
+
+
+app = Bot()
+app.run()

heroku.yml

@@ -0,0 +1,3 @@
+build:
+  docker:
+      worker: Dockerfile

logging.conf

@@ -0,0 +1,32 @@
+[loggers]
+keys=root
+
+[handlers]
+keys=consoleHandler,fileHandler
+
+[formatters]
+keys=consoleFormatter,fileFormatter
+
+[logger_root]
+level=DEBUG
+handlers=consoleHandler,fileHandler
+
+[handler_consoleHandler]
+class=StreamHandler
+level=INFO
+formatter=consoleFormatter
+args=(sys.stdout,)
+
+[handler_fileHandler]
+class=FileHandler
+level=ERROR
+formatter=fileFormatter
+args=('Logs.txt','w',)
+
+[formatter_consoleFormatter]
+format=%(asctime)s - %(lineno)d - %(name)s - %(module)s - %(levelname)s - %(message)s
+datefmt=%I:%M:%S %p
+
+[formatter_fileFormatter]
+format=[%(asctime)s:%(name)s:%(lineno)d:%(levelname)s] %(message)s
+datefmt=%m/%d/%Y %I:%M:%S %p

plugins/__init__.py

@@ -0,0 +1,8 @@
+from aiohttp import web
+from .route import routes
+
+
+async def web_server():
+    web_app = web.Application(client_max_size=30000000)
+    web_app.add_routes(routes)
+    return web_app

plugins/callbacks.py

@@ -0,0 +1,63 @@
+from pyrogram.types import CallbackQuery, InlineKeyboardButton, InlineKeyboardMarkup
+from pyrogram import Client
+from script import scripts
+from utils import temp_utils
+import logging
+from .commands import start_forward
+
+logger = logging.getLogger(__name__)
+logger.setLevel(logging.ERROR)
+
+@Client.on_callback_query()
+async def query_handler(bot: Client, query: CallbackQuery):
+    if query.data == "close":
+        await query.message.delete()
+    elif query.data == "about":
+        btn = [[
+            InlineKeyboardButton("Go Back", callback_data="home"),
+            InlineKeyboardButton("Close", callback_data="close")
+        ]]
+        await query.message.edit_text(
+            text=scripts.ABOUT_TXT.format(temp_utils.BOT_NAME),
+            disable_web_page_preview=True,
+            reply_markup=InlineKeyboardMarkup(btn)
+        )
+    elif query.data == "home":
+        btn = [[
+            InlineKeyboardButton("About", callback_data="about"),
+            InlineKeyboardButton("Souce Code", callback_data="source")
+        ],[
+            InlineKeyboardButton("Close", callback_data="close"),
+            InlineKeyboardButton("Help", callback_data="help")
+        ]]
+        await query.message.edit_text(
+            text=scripts.START_TXT.format(query.from_user.mention, temp_utils.USER_NAME, temp_utils.BOT_NAME),
+            disable_web_page_preview=True,
+            reply_markup=InlineKeyboardMarkup(btn)
+        )
+    elif query.data == "source":
+        btn = [[
+            InlineKeyboardButton("Go Back", callback_data="home"),
+            InlineKeyboardButton("Close", callback_data="close")
+        ]]
+        await query.message.edit_text(
+            text=scripts.SOURCE_TXT,
+            disable_web_page_preview=True,
+            reply_markup=InlineKeyboardMarkup(btn)
+        )
+    elif query.data == "cancel_forward":
+        temp_utils.CANCEL = True
+    elif query.data == "help":
+        btn = [[
+            InlineKeyboardButton("Go Back", callback_data="home"),
+            InlineKeyboardButton("Close", callback_data="close")
+        ]]
+        await query.message.edit_text(
+            text=scripts.HELP_TXT.format(temp_utils.BOT_NAME),
+            disable_web_page_preview=True,
+            reply_markup=InlineKeyboardMarkup(btn)
+        )
+    elif query.data.startswith("forward"):
+        ident, source_chat_id, last_msg_id = query.data.split("#")
+        await query.message.delete()
+        await start_forward(bot, query.from_user.id, source_chat_id, last_msg_id)