uploading: by drag

.gitattributes

@@ -33,3 +33,4 @@ saved_model/**/* filter=lfs diff=lfs merge=lfs -text
 *.zip filter=lfs diff=lfs merge=lfs -text
 *.zst filter=lfs diff=lfs merge=lfs -text
 *tfevents* filter=lfs diff=lfs merge=lfs -text
+assest/about.jpg filter=lfs diff=lfs merge=lfs -text

.github/workflows/pylint.yml

@@ -0,0 +1,31 @@
+name: pyLint
+on: push
+jobs:
+  PEP8:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+      - name: Setup Python
+        uses: actions/setup-python@v1
+        with:
+          python-version: 3.10.x
+      - name: Install Python lint libraries
+        run: |
+          pip install autopep8 autoflake isort black
+      - name: Check for showstoppers
+        run: autopep8 --verbose --in-place --recursive --aggressive --aggressive .
+      - name: Remove unused imports and variables
+        run: autoflake --in-place --recursive --remove-all-unused-imports --remove-unused-variables --ignore-init-module-imports .
+      - name: lint with isort and black
+        run: |
+          isort .
+          black --fast .
+      # commit changes
+      - uses: stefanzweifel/git-auto-commit-action@v4
+        with:
+          commit_message: 'pyLint: auto-fixes'
+          commit_options: '--no-verify'
+          repository: .
+          commit_user_name: kaif-00z
+          commit_user_email: 88398455+kaif-00z@users.noreply.github.com
+          commit_author: kaif-00z <88398455+kaif-00z@users.noreply.github.com>

.gitignore

@@ -0,0 +1,3 @@
+.env
+__pycache__/
+test.py

.sample.env

@@ -0,0 +1,20 @@
+# Mandatory Environment Variable
+
+BOT_TOKEN=
+MAIN_CHANNEL=-1001111
+LOG_CHANNEL=-1001111
+CLOUD_CHANNEL=-1001111
+MONGO_SRV=
+OWNER=1872074304
+BACKUP_CHANNEL=-1001111
+
+# Optional Environment Variable
+
+API_ID=
+API_HASH=
+FORCESUB_CHANNEL_LINK=
+FORCESUB_CHANNEL=
+SESSION=
+SEND_SCHEDULE=
+THUMBNAIL=
+CRF=

Dockerfile

@@ -0,0 +1,11 @@
+FROM python:3.10.4-slim-buster
+
+WORKDIR /usr/src/app
+RUN chmod 777 /usr/src/app
+
+RUN apt-get -qq update && apt-get -qq install -y git wget pv jq python3-dev mediainfo gcc aria2 libsm6 libxext6 libfontconfig1 libxrender1 libgl1-mesa-glx ffmpeg
+
+COPY . .
+RUN pip3 install --no-cache-dir -r requirements.txt
+
+CMD ["bash","run.sh"]

LICENSE

@@ -0,0 +1,674 @@
+                    GNU GENERAL PUBLIC LICENSE
+                       Version 3, 29 June 2007
+
+ Copyright (C) 2007 Free Software Foundation, Inc. <https://fsf.org/>
+ Everyone is permitted to copy and distribute verbatim copies
+ of this license document, but changing it is not allowed.
+
+                            Preamble
+
+  The GNU General Public License is a free, copyleft license for
+software and other kinds of works.
+
+  The licenses for most software and other practical works are designed
+to take away your freedom to share and change the works.  By contrast,
+the GNU General Public License is intended to guarantee your freedom to
+share and change all versions of a program--to make sure it remains free
+software for all its users.  We, the Free Software Foundation, use the
+GNU General Public License for most of our software; it applies also to
+any other work released this way by its authors.  You can apply it to
+your programs, too.
+
+  When we speak of free software, we are referring to freedom, not
+price.  Our General Public Licenses are designed to make sure that you
+have the freedom to distribute copies of free software (and charge for
+them if you wish), that you receive source code or can get it if you
+want it, that you can change the software or use pieces of it in new
+free programs, and that you know you can do these things.
+
+  To protect your rights, we need to prevent others from denying you
+these rights or asking you to surrender the rights.  Therefore, you have
+certain responsibilities if you distribute copies of the software, or if
+you modify it: responsibilities to respect the freedom of others.
+
+  For example, if you distribute copies of such a program, whether
+gratis or for a fee, you must pass on to the recipients the same
+freedoms that you received.  You must make sure that they, too, receive
+or can get the source code.  And you must show them these terms so they
+know their rights.
+
+  Developers that use the GNU GPL protect your rights with two steps:
+(1) assert copyright on the software, and (2) offer you this License
+giving you legal permission to copy, distribute and/or modify it.
+
+  For the developers' and authors' protection, the GPL clearly explains
+that there is no warranty for this free software.  For both users' and
+authors' sake, the GPL requires that modified versions be marked as
+changed, so that their problems will not be attributed erroneously to
+authors of previous versions.
+
+  Some devices are designed to deny users access to install or run
+modified versions of the software inside them, although the manufacturer
+can do so.  This is fundamentally incompatible with the aim of
+protecting users' freedom to change the software.  The systematic
+pattern of such abuse occurs in the area of products for individuals to
+use, which is precisely where it is most unacceptable.  Therefore, we
+have designed this version of the GPL to prohibit the practice for those
+products.  If such problems arise substantially in other domains, we
+stand ready to extend this provision to those domains in future versions
+of the GPL, as needed to protect the freedom of users.
+
+  Finally, every program is threatened constantly by software patents.
+States should not allow patents to restrict development and use of
+software on general-purpose computers, but in those that do, we wish to
+avoid the special danger that patents applied to a free program could
+make it effectively proprietary.  To prevent this, the GPL assures that
+patents cannot be used to render the program non-free.
+
+  The precise terms and conditions for copying, distribution and
+modification follow.
+
+                       TERMS AND CONDITIONS
+
+  0. Definitions.
+
+  "This License" refers to version 3 of the GNU General Public License.
+
+  "Copyright" also means copyright-like laws that apply to other kinds of
+works, such as semiconductor masks.
+
+  "The Program" refers to any copyrightable work licensed under this
+License.  Each licensee is addressed as "you".  "Licensees" and
+"recipients" may be individuals or organizations.
+
+  To "modify" a work means to copy from or adapt all or part of the work
+in a fashion requiring copyright permission, other than the making of an
+exact copy.  The resulting work is called a "modified version" of the
+earlier work or a work "based on" the earlier work.
+
+  A "covered work" means either the unmodified Program or a work based
+on the Program.
+
+  To "propagate" a work means to do anything with it that, without
+permission, would make you directly or secondarily liable for
+infringement under applicable copyright law, except executing it on a
+computer or modifying a private copy.  Propagation includes copying,
+distribution (with or without modification), making available to the
+public, and in some countries other activities as well.
+
+  To "convey" a work means any kind of propagation that enables other
+parties to make or receive copies.  Mere interaction with a user through
+a computer network, with no transfer of a copy, is not conveying.
+
+  An interactive user interface displays "Appropriate Legal Notices"
+to the extent that it includes a convenient and prominently visible
+feature that (1) displays an appropriate copyright notice, and (2)
+tells the user that there is no warranty for the work (except to the
+extent that warranties are provided), that licensees may convey the
+work under this License, and how to view a copy of this License.  If
+the interface presents a list of user commands or options, such as a
+menu, a prominent item in the list meets this criterion.
+
+  1. Source Code.
+
+  The "source code" for a work means the preferred form of the work
+for making modifications to it.  "Object code" means any non-source
+form of a work.
+
+  A "Standard Interface" means an interface that either is an official
+standard defined by a recognized standards body, or, in the case of
+interfaces specified for a particular programming language, one that
+is widely used among developers working in that language.
+
+  The "System Libraries" of an executable work include anything, other
+than the work as a whole, that (a) is included in the normal form of
+packaging a Major Component, but which is not part of that Major
+Component, and (b) serves only to enable use of the work with that
+Major Component, or to implement a Standard Interface for which an
+implementation is available to the public in source code form.  A
+"Major Component", in this context, means a major essential component
+(kernel, window system, and so on) of the specific operating system
+(if any) on which the executable work runs, or a compiler used to
+produce the work, or an object code interpreter used to run it.
+
+  The "Corresponding Source" for a work in object code form means all
+the source code needed to generate, install, and (for an executable
+work) run the object code and to modify the work, including scripts to
+control those activities.  However, it does not include the work's
+System Libraries, or general-purpose tools or generally available free
+programs which are used unmodified in performing those activities but
+which are not part of the work.  For example, Corresponding Source
+includes interface definition files associated with source files for
+the work, and the source code for shared libraries and dynamically
+linked subprograms that the work is specifically designed to require,
+such as by intimate data communication or control flow between those
+subprograms and other parts of the work.
+
+  The Corresponding Source need not include anything that users
+can regenerate automatically from other parts of the Corresponding
+Source.
+
+  The Corresponding Source for a work in source code form is that
+same work.
+
+  2. Basic Permissions.
+
+  All rights granted under this License are granted for the term of
+copyright on the Program, and are irrevocable provided the stated
+conditions are met.  This License explicitly affirms your unlimited
+permission to run the unmodified Program.  The output from running a
+covered work is covered by this License only if the output, given its
+content, constitutes a covered work.  This License acknowledges your
+rights of fair use or other equivalent, as provided by copyright law.
+
+  You may make, run and propagate covered works that you do not
+convey, without conditions so long as your license otherwise remains
+in force.  You may convey covered works to others for the sole purpose
+of having them make modifications exclusively for you, or provide you
+with facilities for running those works, provided that you comply with
+the terms of this License in conveying all material for which you do
+not control copyright.  Those thus making or running the covered works
+for you must do so exclusively on your behalf, under your direction
+and control, on terms that prohibit them from making any copies of
+your copyrighted material outside their relationship with you.
+
+  Conveying under any other circumstances is permitted solely under
+the conditions stated below.  Sublicensing is not allowed; section 10
+makes it unnecessary.
+
+  3. Protecting Users' Legal Rights From Anti-Circumvention Law.
+
+  No covered work shall be deemed part of an effective technological
+measure under any applicable law fulfilling obligations under article
+11 of the WIPO copyright treaty adopted on 20 December 1996, or
+similar laws prohibiting or restricting circumvention of such
+measures.
+
+  When you convey a covered work, you waive any legal power to forbid
+circumvention of technological measures to the extent such circumvention
+is effected by exercising rights under this License with respect to
+the covered work, and you disclaim any intention to limit operation or
+modification of the work as a means of enforcing, against the work's
+users, your or third parties' legal rights to forbid circumvention of
+technological measures.
+
+  4. Conveying Verbatim Copies.
+
+  You may convey verbatim copies of the Program's source code as you
+receive it, in any medium, provided that you conspicuously and
+appropriately publish on each copy an appropriate copyright notice;
+keep intact all notices stating that this License and any
+non-permissive terms added in accord with section 7 apply to the code;
+keep intact all notices of the absence of any warranty; and give all
+recipients a copy of this License along with the Program.
+
+  You may charge any price or no price for each copy that you convey,
+and you may offer support or warranty protection for a fee.
+
+  5. Conveying Modified Source Versions.
+
+  You may convey a work based on the Program, or the modifications to
+produce it from the Program, in the form of source code under the
+terms of section 4, provided that you also meet all of these conditions:
+
+    a) The work must carry prominent notices stating that you modified
+    it, and giving a relevant date.
+
+    b) The work must carry prominent notices stating that it is
+    released under this License and any conditions added under section
+    7.  This requirement modifies the requirement in section 4 to
+    "keep intact all notices".
+
+    c) You must license the entire work, as a whole, under this
+    License to anyone who comes into possession of a copy.  This
+    License will therefore apply, along with any applicable section 7
+    additional terms, to the whole of the work, and all its parts,
+    regardless of how they are packaged.  This License gives no
+    permission to license the work in any other way, but it does not
+    invalidate such permission if you have separately received it.
+
+    d) If the work has interactive user interfaces, each must display
+    Appropriate Legal Notices; however, if the Program has interactive
+    interfaces that do not display Appropriate Legal Notices, your
+    work need not make them do so.
+
+  A compilation of a covered work with other separate and independent
+works, which are not by their nature extensions of the covered work,
+and which are not combined with it such as to form a larger program,
+in or on a volume of a storage or distribution medium, is called an
+"aggregate" if the compilation and its resulting copyright are not
+used to limit the access or legal rights of the compilation's users
+beyond what the individual works permit.  Inclusion of a covered work
+in an aggregate does not cause this License to apply to the other
+parts of the aggregate.
+
+  6. Conveying Non-Source Forms.
+
+  You may convey a covered work in object code form under the terms
+of sections 4 and 5, provided that you also convey the
+machine-readable Corresponding Source under the terms of this License,
+in one of these ways:
+
+    a) Convey the object code in, or embodied in, a physical product
+    (including a physical distribution medium), accompanied by the
+    Corresponding Source fixed on a durable physical medium
+    customarily used for software interchange.
+
+    b) Convey the object code in, or embodied in, a physical product
+    (including a physical distribution medium), accompanied by a
+    written offer, valid for at least three years and valid for as
+    long as you offer spare parts or customer support for that product
+    model, to give anyone who possesses the object code either (1) a
+    copy of the Corresponding Source for all the software in the
+    product that is covered by this License, on a durable physical
+    medium customarily used for software interchange, for a price no
+    more than your reasonable cost of physically performing this
+    conveying of source, or (2) access to copy the
+    Corresponding Source from a network server at no charge.
+
+    c) Convey individual copies of the object code with a copy of the
+    written offer to provide the Corresponding Source.  This
+    alternative is allowed only occasionally and noncommercially, and
+    only if you received the object code with such an offer, in accord
+    with subsection 6b.
+
+    d) Convey the object code by offering access from a designated
+    place (gratis or for a charge), and offer equivalent access to the
+    Corresponding Source in the same way through the same place at no
+    further charge.  You need not require recipients to copy the
+    Corresponding Source along with the object code.  If the place to
+    copy the object code is a network server, the Corresponding Source
+    may be on a different server (operated by you or a third party)
+    that supports equivalent copying facilities, provided you maintain
+    clear directions next to the object code saying where to find the
+    Corresponding Source.  Regardless of what server hosts the
+    Corresponding Source, you remain obligated to ensure that it is
+    available for as long as needed to satisfy these requirements.
+
+    e) Convey the object code using peer-to-peer transmission, provided
+    you inform other peers where the object code and Corresponding
+    Source of the work are being offered to the general public at no
+    charge under subsection 6d.
+
+  A separable portion of the object code, whose source code is excluded
+from the Corresponding Source as a System Library, need not be
+included in conveying the object code work.
+
+  A "User Product" is either (1) a "consumer product", which means any
+tangible personal property which is normally used for personal, family,
+or household purposes, or (2) anything designed or sold for incorporation
+into a dwelling.  In determining whether a product is a consumer product,
+doubtful cases shall be resolved in favor of coverage.  For a particular
+product received by a particular user, "normally used" refers to a
+typical or common use of that class of product, regardless of the status
+of the particular user or of the way in which the particular user
+actually uses, or expects or is expected to use, the product.  A product
+is a consumer product regardless of whether the product has substantial
+commercial, industrial or non-consumer uses, unless such uses represent
+the only significant mode of use of the product.
+
+  "Installation Information" for a User Product means any methods,
+procedures, authorization keys, or other information required to install
+and execute modified versions of a covered work in that User Product from
+a modified version of its Corresponding Source.  The information must
+suffice to ensure that the continued functioning of the modified object
+code is in no case prevented or interfered with solely because
+modification has been made.
+
+  If you convey an object code work under this section in, or with, or
+specifically for use in, a User Product, and the conveying occurs as
+part of a transaction in which the right of possession and use of the
+User Product is transferred to the recipient in perpetuity or for a
+fixed term (regardless of how the transaction is characterized), the
+Corresponding Source conveyed under this section must be accompanied
+by the Installation Information.  But this requirement does not apply
+if neither you nor any third party retains the ability to install
+modified object code on the User Product (for example, the work has
+been installed in ROM).
+
+  The requirement to provide Installation Information does not include a
+requirement to continue to provide support service, warranty, or updates
+for a work that has been modified or installed by the recipient, or for
+the User Product in which it has been modified or installed.  Access to a
+network may be denied when the modification itself materially and
+adversely affects the operation of the network or violates the rules and
+protocols for communication across the network.
+
+  Corresponding Source conveyed, and Installation Information provided,
+in accord with this section must be in a format that is publicly
+documented (and with an implementation available to the public in
+source code form), and must require no special password or key for
+unpacking, reading or copying.
+
+  7. Additional Terms.
+
+  "Additional permissions" are terms that supplement the terms of this
+License by making exceptions from one or more of its conditions.
+Additional permissions that are applicable to the entire Program shall
+be treated as though they were included in this License, to the extent
+that they are valid under applicable law.  If additional permissions
+apply only to part of the Program, that part may be used separately
+under those permissions, but the entire Program remains governed by
+this License without regard to the additional permissions.
+
+  When you convey a copy of a covered work, you may at your option
+remove any additional permissions from that copy, or from any part of
+it.  (Additional permissions may be written to require their own
+removal in certain cases when you modify the work.)  You may place
+additional permissions on material, added by you to a covered work,
+for which you have or can give appropriate copyright permission.
+
+  Notwithstanding any other provision of this License, for material you
+add to a covered work, you may (if authorized by the copyright holders of
+that material) supplement the terms of this License with terms:
+
+    a) Disclaiming warranty or limiting liability differently from the
+    terms of sections 15 and 16 of this License; or
+
+    b) Requiring preservation of specified reasonable legal notices or
+    author attributions in that material or in the Appropriate Legal
+    Notices displayed by works containing it; or
+
+    c) Prohibiting misrepresentation of the origin of that material, or
+    requiring that modified versions of such material be marked in
+    reasonable ways as different from the original version; or
+
+    d) Limiting the use for publicity purposes of names of licensors or
+    authors of the material; or
+
+    e) Declining to grant rights under trademark law for use of some
+    trade names, trademarks, or service marks; or
+
+    f) Requiring indemnification of licensors and authors of that
+    material by anyone who conveys the material (or modified versions of
+    it) with contractual assumptions of liability to the recipient, for
+    any liability that these contractual assumptions directly impose on
+    those licensors and authors.
+
+  All other non-permissive additional terms are considered "further
+restrictions" within the meaning of section 10.  If the Program as you
+received it, or any part of it, contains a notice stating that it is
+governed by this License along with a term that is a further
+restriction, you may remove that term.  If a license document contains
+a further restriction but permits relicensing or conveying under this
+License, you may add to a covered work material governed by the terms
+of that license document, provided that the further restriction does
+not survive such relicensing or conveying.
+
+  If you add terms to a covered work in accord with this section, you
+must place, in the relevant source files, a statement of the
+additional terms that apply to those files, or a notice indicating
+where to find the applicable terms.
+
+  Additional terms, permissive or non-permissive, may be stated in the
+form of a separately written license, or stated as exceptions;
+the above requirements apply either way.
+
+  8. Termination.
+
+  You may not propagate or modify a covered work except as expressly
+provided under this License.  Any attempt otherwise to propagate or
+modify it is void, and will automatically terminate your rights under
+this License (including any patent licenses granted under the third
+paragraph of section 11).
+
+  However, if you cease all violation of this License, then your
+license from a particular copyright holder is reinstated (a)
+provisionally, unless and until the copyright holder explicitly and
+finally terminates your license, and (b) permanently, if the copyright
+holder fails to notify you of the violation by some reasonable means
+prior to 60 days after the cessation.
+
+  Moreover, your license from a particular copyright holder is
+reinstated permanently if the copyright holder notifies you of the
+violation by some reasonable means, this is the first time you have
+received notice of violation of this License (for any work) from that
+copyright holder, and you cure the violation prior to 30 days after
+your receipt of the notice.
+
+  Termination of your rights under this section does not terminate the
+licenses of parties who have received copies or rights from you under
+this License.  If your rights have been terminated and not permanently
+reinstated, you do not qualify to receive new licenses for the same
+material under section 10.
+
+  9. Acceptance Not Required for Having Copies.
+
+  You are not required to accept this License in order to receive or
+run a copy of the Program.  Ancillary propagation of a covered work
+occurring solely as a consequence of using peer-to-peer transmission
+to receive a copy likewise does not require acceptance.  However,
+nothing other than this License grants you permission to propagate or
+modify any covered work.  These actions infringe copyright if you do
+not accept this License.  Therefore, by modifying or propagating a
+covered work, you indicate your acceptance of this License to do so.
+
+  10. Automatic Licensing of Downstream Recipients.
+
+  Each time you convey a covered work, the recipient automatically
+receives a license from the original licensors, to run, modify and
+propagate that work, subject to this License.  You are not responsible
+for enforcing compliance by third parties with this License.
+
+  An "entity transaction" is a transaction transferring control of an
+organization, or substantially all assets of one, or subdividing an
+organization, or merging organizations.  If propagation of a covered
+work results from an entity transaction, each party to that
+transaction who receives a copy of the work also receives whatever
+licenses to the work the party's predecessor in interest had or could
+give under the previous paragraph, plus a right to possession of the
+Corresponding Source of the work from the predecessor in interest, if
+the predecessor has it or can get it with reasonable efforts.
+
+  You may not impose any further restrictions on the exercise of the
+rights granted or affirmed under this License.  For example, you may
+not impose a license fee, royalty, or other charge for exercise of
+rights granted under this License, and you may not initiate litigation
+(including a cross-claim or counterclaim in a lawsuit) alleging that
+any patent claim is infringed by making, using, selling, offering for
+sale, or importing the Program or any portion of it.
+
+  11. Patents.
+
+  A "contributor" is a copyright holder who authorizes use under this
+License of the Program or a work on which the Program is based.  The
+work thus licensed is called the contributor's "contributor version".
+
+  A contributor's "essential patent claims" are all patent claims
+owned or controlled by the contributor, whether already acquired or
+hereafter acquired, that would be infringed by some manner, permitted
+by this License, of making, using, or selling its contributor version,
+but do not include claims that would be infringed only as a
+consequence of further modification of the contributor version.  For
+purposes of this definition, "control" includes the right to grant
+patent sublicenses in a manner consistent with the requirements of
+this License.
+
+  Each contributor grants you a non-exclusive, worldwide, royalty-free
+patent license under the contributor's essential patent claims, to
+make, use, sell, offer for sale, import and otherwise run, modify and
+propagate the contents of its contributor version.
+
+  In the following three paragraphs, a "patent license" is any express
+agreement or commitment, however denominated, not to enforce a patent
+(such as an express permission to practice a patent or covenant not to
+sue for patent infringement).  To "grant" such a patent license to a
+party means to make such an agreement or commitment not to enforce a
+patent against the party.
+
+  If you convey a covered work, knowingly relying on a patent license,
+and the Corresponding Source of the work is not available for anyone
+to copy, free of charge and under the terms of this License, through a
+publicly available network server or other readily accessible means,
+then you must either (1) cause the Corresponding Source to be so
+available, or (2) arrange to deprive yourself of the benefit of the
+patent license for this particular work, or (3) arrange, in a manner
+consistent with the requirements of this License, to extend the patent
+license to downstream recipients.  "Knowingly relying" means you have
+actual knowledge that, but for the patent license, your conveying the
+covered work in a country, or your recipient's use of the covered work
+in a country, would infringe one or more identifiable patents in that
+country that you have reason to believe are valid.
+
+  If, pursuant to or in connection with a single transaction or
+arrangement, you convey, or propagate by procuring conveyance of, a
+covered work, and grant a patent license to some of the parties
+receiving the covered work authorizing them to use, propagate, modify
+or convey a specific copy of the covered work, then the patent license
+you grant is automatically extended to all recipients of the covered
+work and works based on it.
+
+  A patent license is "discriminatory" if it does not include within
+the scope of its coverage, prohibits the exercise of, or is
+conditioned on the non-exercise of one or more of the rights that are
+specifically granted under this License.  You may not convey a covered
+work if you are a party to an arrangement with a third party that is
+in the business of distributing software, under which you make payment
+to the third party based on the extent of your activity of conveying
+the work, and under which the third party grants, to any of the
+parties who would receive the covered work from you, a discriminatory
+patent license (a) in connection with copies of the covered work
+conveyed by you (or copies made from those copies), or (b) primarily
+for and in connection with specific products or compilations that
+contain the covered work, unless you entered into that arrangement,
+or that patent license was granted, prior to 28 March 2007.
+
+  Nothing in this License shall be construed as excluding or limiting
+any implied license or other defenses to infringement that may
+otherwise be available to you under applicable patent law.
+
+  12. No Surrender of Others' Freedom.
+
+  If conditions are imposed on you (whether by court order, agreement or
+otherwise) that contradict the conditions of this License, they do not
+excuse you from the conditions of this License.  If you cannot convey a
+covered work so as to satisfy simultaneously your obligations under this
+License and any other pertinent obligations, then as a consequence you may
+not convey it at all.  For example, if you agree to terms that obligate you
+to collect a royalty for further conveying from those to whom you convey
+the Program, the only way you could satisfy both those terms and this
+License would be to refrain entirely from conveying the Program.
+
+  13. Use with the GNU Affero General Public License.
+
+  Notwithstanding any other provision of this License, you have
+permission to link or combine any covered work with a work licensed
+under version 3 of the GNU Affero General Public License into a single
+combined work, and to convey the resulting work.  The terms of this
+License will continue to apply to the part which is the covered work,
+but the special requirements of the GNU Affero General Public License,
+section 13, concerning interaction through a network will apply to the
+combination as such.
+
+  14. Revised Versions of this License.
+
+  The Free Software Foundation may publish revised and/or new versions of
+the GNU General Public License from time to time.  Such new versions will
+be similar in spirit to the present version, but may differ in detail to
+address new problems or concerns.
+
+  Each version is given a distinguishing version number.  If the
+Program specifies that a certain numbered version of the GNU General
+Public License "or any later version" applies to it, you have the
+option of following the terms and conditions either of that numbered
+version or of any later version published by the Free Software
+Foundation.  If the Program does not specify a version number of the
+GNU General Public License, you may choose any version ever published
+by the Free Software Foundation.
+
+  If the Program specifies that a proxy can decide which future
+versions of the GNU General Public License can be used, that proxy's
+public statement of acceptance of a version permanently authorizes you
+to choose that version for the Program.
+
+  Later license versions may give you additional or different
+permissions.  However, no additional obligations are imposed on any
+author or copyright holder as a result of your choosing to follow a
+later version.
+
+  15. Disclaimer of Warranty.
+
+  THERE IS NO WARRANTY FOR THE PROGRAM, TO THE EXTENT PERMITTED BY
+APPLICABLE LAW.  EXCEPT WHEN OTHERWISE STATED IN WRITING THE COPYRIGHT
+HOLDERS AND/OR OTHER PARTIES PROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY
+OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, BUT NOT LIMITED TO,
+THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+PURPOSE.  THE ENTIRE RISK AS TO THE QUALITY AND PERFORMANCE OF THE PROGRAM
+IS WITH YOU.  SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF
+ALL NECESSARY SERVICING, REPAIR OR CORRECTION.
+
+  16. Limitation of Liability.
+
+  IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING
+WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS
+THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY
+GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF THE
+USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED TO LOSS OF
+DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY YOU OR THIRD
+PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER PROGRAMS),
+EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE POSSIBILITY OF
+SUCH DAMAGES.
+
+  17. Interpretation of Sections 15 and 16.
+
+  If the disclaimer of warranty and limitation of liability provided
+above cannot be given local legal effect according to their terms,
+reviewing courts shall apply local law that most closely approximates
+an absolute waiver of all civil liability in connection with the
+Program, unless a warranty or assumption of liability accompanies a
+copy of the Program in return for a fee.
+
+                     END OF TERMS AND CONDITIONS
+
+            How to Apply These Terms to Your New Programs
+
+  If you develop a new program, and you want it to be of the greatest
+possible use to the public, the best way to achieve this is to make it
+free software which everyone can redistribute and change under these terms.
+
+  To do so, attach the following notices to the program.  It is safest
+to attach them to the start of each source file to most effectively
+state the exclusion of warranty; and each file should have at least
+the "copyright" line and a pointer to where the full notice is found.
+
+    <one line to give the program's name and a brief idea of what it does.>
+    Copyright (C) <year>  <name of author>
+
+    This program is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    This program is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+Also add information on how to contact you by electronic and paper mail.
+
+  If the program does terminal interaction, make it output a short
+notice like this when it starts in an interactive mode:
+
+    <program>  Copyright (C) <year>  <name of author>
+    This program comes with ABSOLUTELY NO WARRANTY; for details type `show w'.
+    This is free software, and you are welcome to redistribute it
+    under certain conditions; type `show c' for details.
+
+The hypothetical commands `show w' and `show c' should show the appropriate
+parts of the General Public License.  Of course, your program's commands
+might be different; for a GUI interface, you would use an "about box".
+
+  You should also get your employer (if you work as a programmer) or school,
+if any, to sign a "copyright disclaimer" for the program, if necessary.
+For more information on this, and how to apply and follow the GNU GPL, see
+<https://www.gnu.org/licenses/>.
+
+  The GNU General Public License does not permit incorporating your program
+into proprietary programs.  If your program is a subroutine library, you
+may consider it more useful to permit linking proprietary applications with
+the library.  If this is what you want to do, use the GNU Lesser General
+Public License instead of this License.  But first, please read
+<https://www.gnu.org/licenses/why-not-lgpl.html>.

app.json

@@ -0,0 +1,96 @@
+{
+    "name": "AutoAnimeBot",
+    "description": "Upload Ongoing Animes In Negligible Size... Automatically",
+    "logo": "https://graph.org/file/ad1b25807b81cdf1dff65.jpg",
+    "keywords": ["Telegram","python", "anime","Compressor","Encoder", "ongoing"],
+    "repository": "https://github.com/kaif-00z/AutoAnimeBot",
+    "success_url": "https://t.me/BotsBakery",
+    "stack": "container",
+    "env": {
+        "API_ID": {
+            "description": "You api id, from my.telegram.org",
+            "value": ""
+        },
+
+        "API_HASH": {
+            "description": "You api hash, from my.telegram.org",
+            "value": ""
+        },
+
+        "BOT_TOKEN": {
+            "description": "Make a bot from @BotFather, and enter it's api token here.",
+            "value": ""
+        },
+
+        "SESSION": {
+            "description": "Telethon Session String",
+            "value": "",
+            "required": false
+        },
+
+        "OWNER": {
+            "description": "Get ur Id Of Telegram nd Paste Here.",
+            "value": ""
+        },
+
+        "MONGO_SRV": {
+            "description": "Mongo SRV from mongo db.",
+            "value": ""
+        },
+
+        "MAIN_CHANNEL": {
+            "description": "ID of Your Main Channel.",
+            "value": ""
+        },
+
+        "BACKUP_CHANNEL": {
+            "description": "If You Want Button Upload On Main Channel Don't Forget To Add Backup Channel becoz anime will be save in backup channel",
+            "value": ""
+        },
+
+        "LOG_CHANNEL": {
+            "description": "Channel ID Where You Can Check Status Of Tasks.",
+            "value": ""
+        },
+
+        "CLOUD_CHANNEL": {
+            "description": "Channel ID Where Bot Will Upload Samples And Screen Shots.",
+            "value": ""
+        },
+
+        "FORCESUB_CHANNEL": {
+            "description": "Channel ID For ForceSub",
+            "value": "",
+            "required": false
+        },
+
+        "FORCESUB_CHANNEL_LINK": {
+            "description": "Channel Link Of ForceSub",
+            "value": "",
+            "required": false
+        },
+
+        "SEND_SCHEDULE": {
+            "description": "Keep it True If You Want Anime Airing Time Else False.",
+            "value": "True",
+            "required": false
+        },
+
+        "RESTART_EVERDAY": {
+            "description": "If You Are In Heroku Then Keep it False.",
+            "value": "False",
+            "required": false
+        },
+
+        "THUMBNAIL": {
+            "description": "Put Link of any picture.",
+            "value": "https://graph.org/file/ad1b25807b81cdf1dff65.jpg",
+            "required": false
+        },
+        "CRF": {
+            "description": "Less CRF == High Quality, More Size , More CRF == Low Quality, Less Size, CRF Range = 20-51",
+            "value": "27",
+            "required": false
+        }
+    }
+}

auto_env_gen.py

@@ -0,0 +1,188 @@
+import asyncio
+import random
+import sys
+from traceback import format_exc
+
+from telethon import TelegramClient
+from telethon.sessions import StringSession
+from telethon.tl.functions.channels import CreateChannelRequest
+from telethon.tl.functions.contacts import UnblockRequest
+
+DATA = {}
+ENV = """
+API_ID={}
+API_HASH={}
+BOT_TOKEN={}
+SESSION={}
+MAIN_CHANNEL={}
+LOG_CHANNEL={}
+CLOUD_CHANNEL={}
+BACKUP_CHANNEL={}
+MONGO_SRV={}
+OWNER={}
+FORCESUB_CHANNEL={}
+FORCESUB_CHANNEL_LINK={}
+"""
+
+
+async def generate_session_string():
+    api_id = int(input("Enter your API_ID: "))
+    api_hash = input("Enter your API_HASH: ")
+    if api_id and api_hash:
+        async with TelegramClient(StringSession(), api_id, api_hash) as client:
+            DATA["api_id"] = api_id
+            DATA["api_hash"] = api_hash
+            DATA["session"] = str(client.session.save())
+            return (str(client.session.save()), api_id, api_hash)
+    print("API_ID and HASH Not Found!")
+    sys.exit(1)
+
+
+def get_mongo():
+    srv = input("Enter your Mongo SRV: ")
+    if srv.strip():
+        DATA["mongo_srv"] = srv
+        return True
+    DATA["mongo_srv"] = ""
+    return False
+
+
+def get_forcesub():
+    fsub_id = input(
+        "Enter ID of Channel Where You Want ForceSub\nNOTE: Bot Is Admin In That Channel: "
+    )
+    fsub_link = input("Enter Invite Link From Which Subs Will Join The FSUB Channel: ")
+    if fsub_id and fsub_link:
+        DATA["fsub_id"] = fsub_id
+        DATA["fsub_link"] = fsub_link
+        return True
+    DATA["fsub_link"] = ""
+    DATA["fsub_id"] = ""
+    return False
+
+
+async def create_channel(client, title):
+    try:
+        r = await client(
+            CreateChannelRequest(
+                title=title,
+                about="Made By https://github.com/kaif-00z/AutoAnimeBot",
+                megagroup=False,
+            )
+        )
+
+        created_chat_id = r.chats[0].id
+        return f"-100{created_chat_id}"
+    except BaseException:
+        print("Unable to Create Channel...")
+        sys.exit(1)
+
+
+def generate_env():
+    txt = ENV.format(
+        DATA["api_id"],
+        DATA["api_hash"],
+        DATA["bot_token"],
+        DATA["session"],
+        DATA["Ongoing Anime 2024"],
+        DATA["Ongoing Anime Logs"],
+        DATA["Ongoing Anime Samples And SS"],
+        DATA["Ongoing Anime Backup"],
+        DATA["mongo_srv"],
+        DATA["owner_id"],
+        DATA["fsub_id"],
+        DATA["fsub_link"],
+    )
+    with open(".env", "w") as f:
+        f.write(txt.strip())
+    print("Succesfully Generated .env File Don't Forget To Save It! For Future Uses.")
+
+
+async def auto_maker():
+    string_session, api_id, api_hash = await generate_session_string()
+    print(string_session)
+    async with TelegramClient(
+        StringSession(string_session), api_id, api_hash
+    ) as client:
+        print("Creating Bot Account...")
+        who = await client.get_me()
+        DATA["owner_id"] = who.id
+        name = who.first_name + "'s Auto Anime Bot"
+        if who.username:
+            username = who.username + "_anime_bot"
+        else:
+            username = "ongoing_anime_" + (str(who.id))[5:] + "_bot"
+        bf = "@BotFather"
+        await client(UnblockRequest(bf))
+        await client.send_message(bf, "/cancel")
+        await asyncio.sleep(1)
+        await client.send_message(bf, "/newbot")
+        await asyncio.sleep(1)
+        isdone = (await client.get_messages(bf, limit=1))[0].text
+        if isdone.startswith("That I cannot do.") or "20 bots" in isdone:
+            print(
+                "You Already Made 20 Bots In Your Current Account. You Have To Deleted One Bot To Run This Script."
+            )
+            sys.exit(1)
+        await client.send_message(bf, name)
+        await asyncio.sleep(1)
+        isdone = (await client.get_messages(bf, limit=1))[0].text
+        if not isdone.startswith("Good."):
+            print(
+                "Please make a Bot from @BotFather and add it's token in BOT_TOKEN, as an env var and restart me."
+            )
+            sys.exit(1)
+        await client.send_message(bf, username)
+        await asyncio.sleep(1)
+        isdone = (await client.get_messages(bf, limit=1))[0].text
+        await client.send_read_acknowledge("botfather")
+        if isdone.startswith("Sorry,"):
+            ran = random.randint(1, 100)
+            username = "ongoing_anime_" + (str(who.id))[6:] + str(ran) + "_bot"
+            await client.send_message(bf, username)
+            await asyncio.sleep(1)
+            isdone = (await client.get_messages(bf, limit=1))[0].text
+        if isdone.startswith("Done!"):
+            bot_token = isdone.split("`")[1]
+            DATA["bot_token"] = bot_token
+            print("Succesfully Created Bot Account...")
+        print("Creating Channels...")
+        for ch_name in [
+            "Ongoing Anime Logs",
+            "Ongoing Anime 2024",
+            "Ongoing Anime Samples And SS",
+            "Ongoing Anime Backup",
+        ]:
+            try:
+                chat_id = await create_channel(client, ch_name)
+                await asyncio.sleep(3)
+                await client.edit_admin(
+                    int(chat_id),
+                    username,
+                    post_messages=True,
+                    edit_messages=True,
+                    delete_messages=True,
+                    ban_users=True,
+                    pin_messages=True,
+                    add_admins=True,
+                )
+                DATA[ch_name] = chat_id
+            except BaseException:
+                print("Error While Creating Channel And Promoting Bot..")
+                print(format_exc())
+                sys.exit(1)
+        print("Succesfully Created Channel...")
+        print("Now If You Wana Skip Upcoming Inputs You Can Just Press Enter!!")
+        db = get_mongo()
+        if not db:
+            print("Generating .env Without Mongo SRV. Now You Have To Add it Manually!")
+        fsub = get_forcesub()
+        if not fsub:
+            print(
+                "Generating .env Without FSUB Configs. Now You May Have To Add it Manually!"
+            )
+            print("NOTE: Fsub config is optional!!!")
+        generate_env()
+
+
+asyncio.run(auto_maker())

bot.py

@@ -0,0 +1,204 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2024 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+from traceback import format_exc
+
+from telethon import Button, events
+
+from core.bot import Bot
+from core.executors import Executors
+from database import DataBase
+from functions.info import AnimeInfo
+from functions.schedule import ScheduleTasks, Var
+from functions.tools import Tools, asyncio
+from functions.utils import AdminUtils
+from libs.ariawarp import Torrent
+from libs.logger import LOGS, Reporter
+from libs.subsplease import SubsPlease
+
+tools = Tools()
+tools.init_dir()
+bot = Bot()
+dB = DataBase()
+subsplease = SubsPlease(dB)
+torrent = Torrent()
+schedule = ScheduleTasks(bot)
+admin = AdminUtils(dB, bot)
+
+
+@bot.on(
+    events.NewMessage(
+        incoming=True, pattern="^/start ?(.*)", func=lambda e: e.is_private
+    )
+)
+async def _start(event):
+    xnx = await event.reply("`Please Wait...`")
+    msg_id = event.pattern_match.group(1)
+    await dB.add_broadcast_user(event.sender_id)
+    if Var.FORCESUB_CHANNEL and Var.FORCESUB_CHANNEL_LINK:
+        is_user_joined = await bot.is_joined(Var.FORCESUB_CHANNEL, event.sender_id)
+        if is_user_joined:
+            pass
+        else:
+            return await xnx.edit(
+                f"**Please Join The Following Channel To Use This Bot 🫡**",
+                buttons=[
+                    [Button.url("🚀 JOIN CHANNEL", url=Var.FORCESUB_CHANNEL_LINK)],
+                    [
+                        Button.url(
+                            "♻️ REFRESH",
+                            url=f"https://t.me/{((await bot.get_me()).username)}?start={msg_id}",
+                        )
+                    ],
+                ],
+            )
+    if msg_id:
+        if msg_id.isdigit():
+            msg = await bot.get_messages(Var.BACKUP_CHANNEL, ids=int(msg_id))
+            await event.reply(msg)
+        else:
+            items = await dB.get_store_items(msg_id)
+            if items:
+                for id in items:
+                    msg = await bot.get_messages(Var.CLOUD_CHANNEL, ids=id)
+                    await event.reply(file=[i for i in msg])
+    else:
+        if event.sender_id == Var.OWNER:
+            return await xnx.edit(
+                "** <                ADMIN PANEL                 > **",
+                buttons=admin.admin_panel(),
+            )
+        await event.reply(
+            f"**Enjoy Ongoing Anime's Best Encode 24/7 🫡**",
+            buttons=[
+                [
+                    Button.url("👨‍💻 DEV", url="t.me/kaif_00z"),
+                    Button.url(
+                        "💖 OPEN SOURCE",
+                        url="https://github.com/kaif-00z/AutoAnimeBot/",
+                    ),
+                ]
+            ],
+        )
+    await xnx.delete()
+
+
+@bot.on(
+    events.NewMessage(incoming=True, pattern="^/about", func=lambda e: e.is_private)
+)
+async def _(e):
+    await admin._about(e)
+
+
+@bot.on(events.callbackquery.CallbackQuery(data="slog"))
+async def _(e):
+    await admin._logs(e)
+
+
+@bot.on(events.callbackquery.CallbackQuery(data="sret"))
+async def _(e):
+    await admin._restart(e, schedule)
+
+
+@bot.on(events.callbackquery.CallbackQuery(data="entg"))
+async def _(e):
+    await admin._encode_t(e)
+
+
+@bot.on(events.callbackquery.CallbackQuery(data="butg"))
+async def _(e):
+    await admin._btn_t(e)
+
+
+@bot.on(events.callbackquery.CallbackQuery(data="scul"))
+async def _(e):
+    await admin._sep_c_t(e)
+
+
+@bot.on(events.callbackquery.CallbackQuery(data="cast"))
+async def _(e):
+    await admin.broadcast_bt(e)
+
+
+@bot.on(events.callbackquery.CallbackQuery(data="bek"))
+async def _(e):
+    await e.edit(buttons=admin.admin_panel())
+
+
+async def anime(data):
+    try:
+        torr = [data.get("480p"), data.get("720p"), data.get("1080p")]
+        anime_info = AnimeInfo(torr[0].title)
+        poster = await tools._poster(bot, anime_info)
+        if await dB.is_separate_channel_upload():
+            chat_info = await tools.get_chat_info(bot, anime_info, dB)
+            await poster.edit(
+                buttons=[
+                    [
+                        Button.url(
+                            f"EPISODE {anime_info.data.get('episode_number', '')}".strip(),
+                            url=chat_info["invite_link"],
+                        )
+                    ]
+                ]
+            )
+            poster = await tools._poster(bot, anime_info, chat_info["chat_id"])
+        btn = [[]]
+        original_upload = await dB.is_original_upload()
+        button_upload = await dB.is_button_upload()
+        for i in torr:
+            try:
+                filename = f"downloads/{i.title}"
+                reporter = Reporter(bot, i.title)
+                await reporter.alert_new_file_founded()
+                await torrent.download_magnet(i.link, "./downloads/")
+                exe = Executors(
+                    bot,
+                    dB,
+                    {
+                        "original_upload": original_upload,
+                        "button_upload": button_upload,
+                    },
+                    filename,
+                    AnimeInfo(i.title),
+                    reporter,
+                )
+                result, _btn = await exe.execute()
+                if result:
+                    if _btn:
+                        if len(btn[0]) == 2:
+                            btn.append([_btn])
+                        else:
+                            btn[0].append(_btn)
+                        await poster.edit(buttons=btn)
+                    asyncio.ensure_future(exe.further_work())
+                    continue
+                await reporter.report_error(_btn, log=True)
+                await reporter.msg.delete()
+            except BaseException:
+                await reporter.report_error(str(format_exc()), log=True)
+                await reporter.msg.delete()
+    except BaseException:
+        LOGS.error(str(format_exc()))
+
+
+try:
+    bot.loop.run_until_complete(subsplease.on_new_anime(anime))
+    bot.run()
+except KeyboardInterrupt:
+    subsplease._exit()

core/bot.py

@@ -0,0 +1,203 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+# little bit inspired from pyUltroid.BaseClient
+
+import asyncio
+import sys
+from logging import Logger
+from traceback import format_exc
+
+from pyrogram import Client, utils
+from telethon import TelegramClient
+from telethon.errors import (
+    AccessTokenExpiredError,
+    AccessTokenInvalidError,
+    ApiIdInvalidError,
+    AuthKeyDuplicatedError,
+)
+from telethon.errors.rpcerrorlist import UserNotParticipantError
+from telethon.sessions import StringSession
+from telethon.tl.functions.channels import (
+    CreateChannelRequest,
+    EditPhotoRequest,
+    GetParticipantRequest,
+)
+from telethon.tl.functions.messages import ExportChatInviteRequest
+
+from functions.config import Var
+from libs.logger import LOGS, TelethonLogger
+
+
+class Bot(TelegramClient):
+    def __init__(
+        self,
+        api_id=None,
+        api_hash=None,
+        bot_token=None,
+        logger: Logger = LOGS,
+        log_attempt=True,
+        exit_on_error=True,
+        *args,
+        **kwargs,
+    ):
+        self._handle_error = exit_on_error
+        self._log_at = log_attempt
+        self.logger = logger
+        kwargs["api_id"] = api_id or Var.API_ID
+        kwargs["api_hash"] = api_hash or Var.API_HASH
+        kwargs["base_logger"] = TelethonLogger
+        utils.MIN_CHANNEL_ID = -1009147483647
+        super().__init__(None, **kwargs)
+        self.pyro_client = Client(
+            name="pekka",
+            api_id=kwargs["api_id"],
+            api_hash=kwargs["api_hash"],
+            bot_token=bot_token or Var.BOT_TOKEN,
+            in_memory=True,
+        )
+        self.user_client = None
+        if Var.SESSION:
+            self.user_client = TelegramClient(
+                StringSession(Var.SESSION), kwargs["api_id"], kwargs["api_hash"]
+            )
+        self.run_in_loop(self.start_client(bot_token=bot_token or Var.BOT_TOKEN))
+
+    def __repr__(self):
+        return "<AutoAnimeBot.Client :\n bot: {}\n>".format(self._bot)
+
+    async def start_client(self, **kwargs):
+        """function to start client"""
+        if self._log_at:
+            self.logger.info("Trying to login.")
+        try:
+            await self.start(**kwargs)
+            if self.user_client:
+                await self.user_client.start()
+            await self.pyro_client.start()
+        except ApiIdInvalidError:
+            self.logger.critical("API ID and API_HASH combination does not match!")
+            sys.exit(1)
+        except (AuthKeyDuplicatedError, EOFError):
+            if self._handle_error:
+                self.logger.critical("String session expired. Create new!")
+                sys.exit(1)
+            self.logger.critical("String session expired.")
+        except (AccessTokenExpiredError, AccessTokenInvalidError):
+            self.logger.critical(
+                "Bot token is expired or invalid. Create new from @Botfather and add in BOT_TOKEN env variable!"
+            )
+            sys.exit(1)
+        self.me = await self.get_me()
+        if self.me.bot:
+            me = f"@{self.me.username}"
+        if self._log_at:
+            self.logger.info(f"Logged in as {me}")
+            if self.user_client:
+                user_me = await self.user_client.get_me()
+                self.logger.info(f"Logged in as @{user_me.username}")
+        self._bot = await self.is_bot()
+
+    async def upload_anime(self, file, caption, thumb=None, is_button=False):
+        if not self.pyro_client.is_connected:
+            try:
+                await self.pyro_client.connect()
+            except ConnectionError:
+                pass
+        post = await self.pyro_client.send_document(
+            Var.BACKUP_CHANNEL if is_button else Var.MAIN_CHANNEL,
+            file,
+            caption=f"`{caption}`",
+            force_document=True,
+            thumb=thumb or "thumb.jpg",
+        )
+        return post
+
+    async def upload_poster(self, file, caption, channel_id=None):
+        post = await self.send_file(
+            channel_id if channel_id else Var.MAIN_CHANNEL,
+            file=file,
+            caption=caption or "",
+        )
+        return post
+
+    async def is_joined(self, channel_id, user_id):
+        try:
+            await self(GetParticipantRequest(channel=channel_id, participant=user_id))
+            return True
+        except UserNotParticipantError:
+            return False
+
+    async def create_channel(self, title: str, logo=None):
+        try:
+            r = await self.user_client(
+                CreateChannelRequest(
+                    title=title,
+                    about="Powered By github.com/kaif-00z/AutoAnimeBot",
+                    megagroup=False,
+                )
+            )
+            created_chat_id = r.chats[0].id
+            chat_id = int(f"-100{created_chat_id}")
+            await asyncio.sleep(2)
+            await self.user_client.edit_admin(
+                int(chat_id),
+                f"{((await self.get_me()).username)}",
+                post_messages=True,
+                edit_messages=True,
+                delete_messages=True,
+                ban_users=True,
+                pin_messages=True,
+                add_admins=True,
+            )
+            if logo:
+                try:
+                    await self.user_client(
+                        EditPhotoRequest(
+                            chat_id, (await self.user_client.upload_file(logo))
+                        )
+                    )
+                except BaseException:
+                    pass
+            return chat_id
+        except BaseException:
+            LOGS.error(format_exc())
+
+    async def generate_invite_link(self, channel_id):
+        try:
+            data = await self.user_client(
+                ExportChatInviteRequest(
+                    peer=channel_id,
+                    title=f"Generated By Ongoing Anime Bot",
+                    request_needed=False,
+                    usage_limit=None,
+                )
+            )
+            return data.link
+        except BaseException:
+            LOGS.error(format_exc())
+
+    def run_in_loop(self, function):
+        return self.loop.run_until_complete(function)
+
+    def run(self):
+        self.run_until_disconnected()
+
+    def add_handler(self, func, *args, **kwargs):
+        if func in [_[0] for _ in self.list_event_handlers()]:
+            return
+        self.add_event_handler(func, *args, **kwargs)

core/executors.py

@@ -0,0 +1,153 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+import asyncio
+import os
+import secrets
+import shutil
+from glob import glob
+from traceback import format_exc
+
+from telethon import Button
+
+from core.bot import LOGS, Bot, Var
+from database import DataBase
+from functions.info import AnimeInfo
+from functions.tools import Tools
+from libs.logger import Reporter
+
+
+class Executors:
+    def __init__(
+        self,
+        bot: Bot,
+        dB: DataBase,
+        configurations: dict,
+        input_file: str,
+        info: AnimeInfo,
+        reporter: Reporter,
+    ):
+        self.is_original = configurations.get("original_upload")
+        self.is_button = configurations.get("button_upload")
+        self.anime_info = info
+        self.bot = bot
+        self.input_file = input_file
+        self.tools = Tools()
+        self.db = dB
+        self.reporter = reporter
+        self.msg_id = None
+        self.output_file = None
+
+    async def execute(self):
+        try:
+            rename = await self.anime_info.rename(self.is_original)
+            self.output_file = f"encode/{rename}"
+            thumb = await self.tools.cover_dl((await self.anime_info.get_poster()))
+            if self.is_original:
+                await self.reporter.started_renaming()
+                succ, out = await self.tools.rename_file(
+                    self.input_file, self.output_file
+                )
+                if not succ:
+                    return False, out
+            else:
+                _log_msg = await self.reporter.started_compressing()
+                succ, _new_msg = await self.tools.compress(
+                    self.input_file, self.output_file, _log_msg
+                )
+                if not succ:
+                    return False, _new_msg
+                self.reporter.msg = _new_msg
+            await self.reporter.started_uploading()
+            if self.is_button:
+                msg = await self.bot.upload_anime(
+                    self.output_file, rename, thumb or "thumb.jpg", is_button=True
+                )
+                btn = Button.url(
+                    f"{self.anime_info.data.get('video_resolution')}",
+                    url=f"https://t.me/{((await self.bot.get_me()).username)}?start={msg.id}",
+                )
+                self.msg_id = msg.id
+                return True, btn
+            msg = await self.bot.upload_anime(
+                self.output_file, rename, thumb or "thumb.jpg"
+            )
+            self.msg_id = msg.id
+            return True, []
+        except BaseException:
+            await self.reporter.report_error(str(format_exc()), log=True)
+            return False, str(format_exc())
+
+    def run_further_work(self):
+        asyncio.run(self.further_work())
+
+    async def further_work(self):
+        try:
+            if self.msg_id:
+                await self.reporter.started_gen_ss()
+                msg = await self.bot.get_messages(
+                    Var.BACKUP_CHANNEL if self.is_button else Var.MAIN_CHANNEL,
+                    ids=self.msg_id,
+                )
+                btn = [
+                    [],
+                ]
+                link_info = await self.tools.mediainfo(self.output_file, self.bot)
+                if link_info:
+                    btn.append(
+                        [
+                            Button.url(
+                                "📜 MediaInfo",
+                                url=link_info,
+                            )
+                        ]
+                    )
+                    await msg.edit(buttons=btn)
+                _hash = secrets.token_hex(nbytes=7)
+                ss_path, sp_path = await self.tools.gen_ss_sam(_hash, self.output_file)
+                if ss_path and sp_path:
+                    ss = await self.bot.send_message(
+                        Var.CLOUD_CHANNEL,
+                        file=glob(f"{ss_path}/*") or ["assest/poster_not_found.jpg"],
+                    )
+                    sp = await self.bot.send_message(
+                        Var.CLOUD_CHANNEL,
+                        file=sp_path,
+                        thumb="thumb.jpg",
+                        force_document=True,
+                    )
+                    await self.db.store_items(_hash, [[i.id for i in ss], [sp.id]])
+                    btn.append(
+                        [
+                            Button.url(
+                                "📺 Sample & ScreenShots",
+                                url=f"https://t.me/{((await self.bot.get_me()).username)}?start={_hash}",
+                            )
+                        ]
+                    )
+                    await msg.edit(buttons=btn)
+                    await self.reporter.all_done()
+                    try:
+                        shutil.rmtree(_hash)
+                        os.remove(sp_path)
+                        os.remove(self.input_file)
+                        os.remove(self.output_file)
+                    except BaseException:
+                        LOGS.error(str(format_exc()))
+        except BaseException:
+            await self.reporter.report_error(str(format_exc()), log=True)

database/__init__.py

@@ -0,0 +1,127 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+import sys
+from traceback import format_exc
+
+from motor.motor_asyncio import AsyncIOMotorClient
+
+from functions.config import Var
+from libs.logger import LOGS
+
+
+class DataBase:
+    def __init__(self):
+        try:
+            LOGS.info("Trying To Connect With MongoDB")
+            self.client = AsyncIOMotorClient(Var.MONGO_SRV)
+            self.file_info_db = self.client["ONGOINGANIME"]["fileInfo"]
+            self.channel_info_db = self.client["ONGOINGANIME"]["animeChannelInfo"]
+            self.opts_db = self.client["ONGOINGANIME"]["opts"]
+            self.file_store_db = self.client["ONGOINGANIME"]["fileStore"]
+            self.broadcast_db = self.client["ONGOINGANIME"]["broadcastInfo"]
+            LOGS.info("Successfully Connected With MongoDB")
+        except Exception as error:
+            LOGS.exception(format_exc())
+            LOGS.critical(str(error))
+            sys.exit(1)
+
+    async def add_anime(self, uid):
+        data = await self.file_info_db.find_one({"_id": uid})
+        if not data:
+            await self.file_info_db.insert_one({"_id": uid})
+
+    async def toggle_separate_channel_upload(self):
+        data = await self.opts_db.find_one({"_id": "SEPARATE_CHANNEL_UPLOAD"})
+        if (data or {}).get("switch"):
+            _data = False
+        else:
+            _data = True
+        await self.opts_db.update_one(
+            {"_id": "SEPARATE_CHANNEL_UPLOAD"}, {"$set": {"switch": _data}}, upsert=True
+        )
+
+    async def is_separate_channel_upload(self):
+        data = await self.opts_db.find_one({"_id": "SEPARATE_CHANNEL_UPLOAD"})
+        return (data or {}).get("switch") or False
+
+    async def toggle_original_upload(self):
+        data = await self.opts_db.find_one({"_id": "OG_UPLOAD"})
+        if (data or {}).get("switch"):
+            _data = False
+        else:
+            _data = True
+        await self.opts_db.update_one(
+            {"_id": "OG_UPLOAD"}, {"$set": {"switch": _data}}, upsert=True
+        )
+
+    async def is_original_upload(self):
+        data = await self.opts_db.find_one({"_id": "OG_UPLOAD"})
+        return (data or {}).get("switch") or False
+
+    async def toggle_button_upload(self):
+        data = await self.opts_db.find_one({"_id": "BUTTON_UPLOAD"})
+        if data and (data or {}).get("switch"):
+            _data = False
+        else:
+            _data = True
+        await self.opts_db.update_one(
+            {"_id": "BUTTON_UPLOAD"}, {"$set": {"switch": _data}}, upsert=True
+        )
+
+    async def is_button_upload(self):
+        data = await self.opts_db.find_one({"_id": "BUTTON_UPLOAD"})
+        return (data or {}).get("switch") or False
+
+    async def is_anime_uploaded(self, uid):
+        data = await self.file_info_db.find_one({"_id": uid})
+        if data:
+            return True
+        return False
+
+    async def add_anime_channel_info(self, title, _data):
+        await self.channel_info_db.update_one(
+            {"_id": title}, {"$set": {"data": _data}}, upsert=True
+        )
+
+    async def get_anime_channel_info(self, title):
+        data = await self.channel_info_db.find_one({"_id": title})
+        if (data or {}).get(title):
+            return data["data"]
+        return {}
+
+    async def store_items(self, _hash, _list):
+        # in case
+        await self.file_store_db.update_one(
+            {"_id": _hash}, {"$set": {"data": _list}}, upsert=True
+        )
+
+    async def get_store_items(self, _hash):
+        data = await self.file_store_db.find_one({"_id": _hash})
+        if (data or {}).get("data"):
+            return data["data"]
+        return []
+
+    async def add_broadcast_user(self, user_id):
+        data = await self.broadcast_db.find_one({"_id": user_id})
+        if not data:
+            await self.broadcast_db.insert_one({"_id": user_id})
+
+    async def get_broadcast_user(self):
+        data = self.broadcast_db.find()
+        return [i["_id"] for i in (await data.to_list(length=None))]

functions/config.py

@@ -0,0 +1,61 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+from decouple import config
+
+
+class Var:
+    # Version
+
+    __version__ = "v0.0.8"
+
+    # Telegram Credentials
+
+    API_ID = config("API_ID", default=6, cast=int)
+    API_HASH = config("API_HASH", default="eb06d4abfb49dc3eeb1aeb98ae0f581e")
+    BOT_TOKEN = config("BOT_TOKEN", default=None)
+    SESSION = config("SESSION", default=None)
+
+    # Database Credentials
+
+    MONGO_SRV = config("MONGO_SRV", default=None)
+
+    # Channels Ids
+
+    BACKUP_CHANNEL = config("BACKUP_CHANNEL", default=0, cast=int)
+    MAIN_CHANNEL = config("MAIN_CHANNEL", cast=int)
+    LOG_CHANNEL = config("LOG_CHANNEL", cast=int)
+    CLOUD_CHANNEL = config("CLOUD_CHANNEL", cast=int)
+    FORCESUB_CHANNEL = config("FORCESUB_CHANNEL", default=0, cast=int)
+    OWNER = config("OWNER", default=0, cast=int)
+
+    # Other Configs
+
+    THUMB = config(
+        "THUMBNAIL", default="https://graph.org/file/ad1b25807b81cdf1dff65.jpg"
+    )
+    FFMPEG = config("FFMPEG", default="ffmpeg")
+    CRF = config("CRF", default="27")
+    SEND_SCHEDULE = config("SEND_SCHEDULE", default=False, cast=bool)
+    RESTART_EVERDAY = config("RESTART_EVERDAY", default=True, cast=bool)
+    LOG_ON_MAIN = config("LOG_ON_MAIN", default=False, cast=bool)
+    FORCESUB_CHANNEL_LINK = config("FORCESUB_CHANNEL_LINK", default="", cast=str)
+
+    # Dev Configs
+
+    DEV_MODE = config("DEV_MODE", default=False, cast=bool)

functions/info.py

@@ -0,0 +1,128 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+from traceback import format_exc
+
+import anitopy
+
+from libs.kitsu import RawAnimeInfo
+from libs.logger import LOGS
+
+
+class AnimeInfo:
+    def __init__(self, name):
+        self.kitsu = RawAnimeInfo()
+        self.CAPTION = """
+**{}
+━━━━━━━━━━━━━━━
+‣ Language:** `Japanese [ESub]`
+**‣ Quality:** `480p|720p|1080p`
+**‣ Season:** `{}`
+**‣ Episode:** `{}`
+**━━━━━━━━━━━━━━━**
+"""
+        self.proper_name = self.get_proper_name_for_func(name)
+        self.name = name
+        self.data = anitopy.parse(name)
+
+    async def get_english(self):
+        anime_name = self.data.get("anime_title")
+        try:
+            anime = (await self.kitsu.search(self.proper_name)) or {}
+            return anime.get("english_title") or anime_name
+        except BaseException:
+            LOGS.error(str(format_exc()))
+            return anime_name.strip()
+
+    async def get_poster(self):
+        try:
+            if self.proper_name:
+                anime_poster = await self.kitsu.search(self.proper_name)
+                return anime_poster.get("poster_img") or None
+        except BaseException:
+            LOGS.error(str(format_exc()))
+
+    async def get_cover(self):
+        try:
+            if self.proper_name:
+                anime_poster = await self.kitsu.search(self.proper_name)
+                if anime_poster.get("anilist_id"):
+                    return anime_poster.get("anilist_poster")
+                return None
+        except BaseException:
+            LOGS.error(str(format_exc()))
+
+    async def get_caption(self):
+        try:
+            if self.proper_name or self.data:
+                return self.CAPTION.format(
+                    (await self.get_english()),
+                    str(self.data.get("anime_season") or 1).zfill(2),
+                    (
+                        str(self.data.get("episode_number")).zfill(2)
+                        if self.data.get("episode_number")
+                        else "N/A"
+                    ),
+                )
+        except BaseException:
+            LOGS.error(str(format_exc()))
+            return ""
+
+    async def rename(self, original=False):
+        try:
+            anime_name = self.data.get("anime_title")
+            if anime_name and self.data.get("episode_number"):
+                return (
+                    f"[S{self.data.get('anime_season') or 1}-{self.data.get('episode_number') or ''}] {(await self.get_english())} [{self.data.get('video_resolution')}].mkv".replace(
+                        "‘", ""
+                    )
+                    .replace("’", "")
+                    .strip()
+                )
+            if anime_name:
+                return (
+                    f"{(await self.get_english())} [{self.data.get('video_resolution')}].mkv".replace(
+                        "‘", ""
+                    )
+                    .replace("’", "")
+                    .strip()
+                )
+            return self.name
+        except Exception as error:
+            LOGS.error(str(error))
+            LOGS.exception(format_exc())
+            return self.name
+
+    def get_proper_name_for_func(self, name):
+        try:
+            data = anitopy.parse(name)
+            anime_name = data.get("anime_title")
+            if anime_name and data.get("episode_number"):
+                return (
+                    f"{anime_name} S{data.get('anime_season')} {data.get('episode_title')}"
+                    if data.get("anime_season") and data.get("episode_title")
+                    else (
+                        f"{anime_name} S{data.get('anime_season')}"
+                        if data.get("anime_season")
+                        else anime_name
+                    )
+                )
+            return anime_name
+        except Exception as error:
+            LOGS.error(str(error))
+            LOGS.exception(format_exc())

functions/schedule.py

@@ -0,0 +1,63 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+
+import json
+import os
+import sys
+
+from apscheduler.schedulers.asyncio import AsyncIOScheduler
+
+from functions.config import Var
+from functions.info import AnimeInfo
+from functions.tools import Tools
+from libs.logger import LOGS, TelegramClient
+
+
+class ScheduleTasks:
+    def __init__(self, bot: TelegramClient):
+        self.tools = Tools()
+        self.bot = bot
+        if Var.SEND_SCHEDULE or Var.RESTART_EVERDAY:
+            self.sch = AsyncIOScheduler(timezone="Asia/Kolkata")
+            if Var.SEND_SCHEDULE:
+                self.sch.add_job(
+                    self.anime_timing, "cron", hour=0, minute=30
+                )  # 12:30 AM IST
+            if Var.RESTART_EVERDAY:
+                self.sch.add_job(self.restart, "cron", hour=2, minute=1)  # 2:01 AM IST
+            self.sch.start()
+
+    async def anime_timing(self):
+        try:
+            _res = await self.tools.async_searcher(
+                "https://subsplease.org/api/?f=schedule&h=true&tz=Asia/Kolkata"
+            )
+            xx = json.loads(_res)
+            xxx = xx["schedule"]
+            text = "**📆 Anime AirTime Today** `[IST]`\n\n"
+            for i in xxx:
+                info = AnimeInfo(i["title"])
+                text += f'`[{i["time"]}]` -  [{(await info.get_english())}](https://subsplease.org/shows/{i["page"]})\n'
+            mssg = await self.bot.send_message(Var.MAIN_CHANNEL, text)
+            await mssg.pin(notify=True)
+        except Exception as error:
+            LOGS.error(str(error))
+
+    def restart(self):
+        os.execl(sys.executable, sys.executable, "bot.py")

functions/tools.py

@@ -0,0 +1,329 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+import asyncio
+import json
+import math
+import os
+import re
+import shutil
+import subprocess
+import time
+from traceback import format_exc
+
+import aiofiles
+import aiohttp
+import requests
+from html_telegraph_poster import TelegraphPoster
+from telethon.errors.rpcerrorlist import MessageNotModifiedError
+
+from functions.config import Var
+from libs.logger import LOGS
+
+
+class Tools:
+    def __init__(self):
+        if Var.DEV_MODE:
+            self.ffmpeg_threads = int(os.cpu_count() or 0) + 2
+        else:
+            self.ffmpeg_threads = 2
+
+    async def async_searcher(
+        self,
+        url: str,
+        post: bool = None,
+        headers: dict = None,
+        params: dict = None,
+        json: dict = None,
+        data: dict = None,
+        ssl=None,
+        re_json: bool = False,
+        re_content: bool = False,
+        real: bool = False,
+        *args,
+        **kwargs,
+    ):
+        async with aiohttp.ClientSession(headers=headers) as client:
+            if post:
+                data = await client.post(
+                    url, json=json, data=data, ssl=ssl, *args, **kwargs
+                )
+            else:
+                data = await client.get(url, params=params, ssl=ssl, *args, **kwargs)
+            if re_json:
+                return await data.json()
+            if re_content:
+                return await data.read()
+            if real:
+                return data
+            return await data.text()
+
+    async def cover_dl(self, link):
+        try:
+            if not link:
+                return None
+            image = await self.async_searcher(link, re_content=True)
+            fn = f"thumbs/{link.split('/')[-1]}"
+            if not fn.endswith((".jpg" or ".png")):
+                fn += ".jpg"
+            async with aiofiles.open(fn, "wb") as file:
+                await file.write(image)
+            return fn
+        except Exception as error:
+            LOGS.exception(format_exc())
+            LOGS.error(str(error))
+
+    async def mediainfo(self, file, bot):
+        try:
+            process = await asyncio.create_subprocess_shell(
+                f"mediainfo '''{file}''' --Output=HTML",
+                stdout=asyncio.subprocess.PIPE,
+                stderr=asyncio.subprocess.PIPE,
+            )
+            stdout, stderr = await process.communicate()
+            out = stdout.decode()
+            client = TelegraphPoster(use_api=True)
+            client.create_api_token("Mediainfo")
+            page = client.post(
+                title="Mediainfo",
+                author=((await bot.get_me()).first_name),
+                author_url=f"https://t.me/{((await bot.get_me()).username)}",
+                text=out,
+            )
+            return page.get("url")
+        except Exception as error:
+            LOGS.exception(format_exc())
+            LOGS.error(str(error))
+
+    async def _poster(self, bot, anime_info, channel_id=None):
+        thumb = await self.cover_dl((await anime_info.get_cover()))
+        caption = await anime_info.get_caption()
+        return await bot.upload_poster(
+            thumb or "assest/poster_not_found.jpg",
+            caption,
+            channel_id if channel_id else None,
+        )
+
+    async def get_chat_info(self, bot, anime_info, dB):
+        try:
+            chat_info = await dB.get_anime_channel_info(anime_info.proper_name)
+            if not chat_info:
+                chat_id = await bot.create_channel(
+                    (await anime_info.get_english()),
+                    (await self.cover_dl((await anime_info.get_poster()))),
+                )
+                invite_link = await bot.generate_invite_link(chat_id)
+                chat_info = {"chat_id": chat_id, "invite_link": invite_link}
+                await dB.add_anime_channel_info(anime_info.proper_name, chat_info)
+            return chat_info
+        except BaseException:
+            LOGS.error(str(format_exc()))
+
+    def init_dir(self):
+        if not os.path.exists("thumb.jpg"):
+            content = requests.get(Var.THUMB).content
+            with open("thumb.jpg", "wb") as f:
+                f.write(content)
+        if not os.path.isdir("encode/"):
+            os.mkdir("encode/")
+        if not os.path.isdir("thumbs/"):
+            os.mkdir("thumbs/")
+        if not os.path.isdir("downloads/"):
+            os.mkdir("downloads/")
+
+    def hbs(self, size):
+        if not size:
+            return ""
+        power = 2**10
+        raised_to_pow = 0
+        dict_power_n = {0: "B", 1: "K", 2: "M", 3: "G", 4: "T", 5: "P"}
+        while size > power:
+            size /= power
+            raised_to_pow += 1
+        return str(round(size, 2)) + " " + dict_power_n[raised_to_pow] + "B"
+
+    def ts(self, milliseconds: int) -> str:
+        seconds, milliseconds = divmod(int(milliseconds), 1000)
+        minutes, seconds = divmod(seconds, 60)
+        hours, minutes = divmod(minutes, 60)
+        days, hours = divmod(hours, 24)
+        tmp = (
+            ((str(days) + "d:") if days else "")
+            + ((str(hours) + "h:") if hours else "")
+            + ((str(minutes) + "m:") if minutes else "")
+            + ((str(seconds) + "s:") if seconds else "")
+            + ((str(milliseconds) + "ms:") if milliseconds else "")
+        )
+        return tmp[:-1]
+
+    async def rename_file(self, dl, out):
+        try:
+            os.rename(dl, out)
+        except BaseException:
+            return False, format_exc()
+        return True, out
+
+    async def bash_(self, cmd, run_code=0):
+        process = await asyncio.create_subprocess_shell(
+            cmd,
+            stdout=asyncio.subprocess.PIPE,
+            stderr=asyncio.subprocess.PIPE,
+        )
+        stdout, stderr = await process.communicate()
+        err = stderr.decode().strip() or None
+        out = stdout.decode().strip()
+        if not run_code and err:
+            if match := re.match("\\/bin\\/sh: (.*): ?(\\w+): not found", err):
+                return out, f"{match.group(2).upper()}_NOT_FOUND"
+        return out, err
+
+    async def frame_counts(self, dl):
+        _x, _y = await self.bash_(
+            f'mediainfo --fullscan """{dl}""" | grep "Frame count"'
+        )
+        if _y and _y.endswith("NOT_FOUND"):
+            LOGS.error(f"ERROR: `{_y}`")
+            return False
+        return _x.split(":")[1].split("\n")[0]
+
+    async def compress(self, dl, out, log_msg):
+        total_frames = await self.frame_counts(dl)
+        if not total_frames:
+            return False, "Unable to Count The Frames!"
+        _progress = f"progress-{time.time()}.txt"
+        cmd = f'''{Var.FFMPEG} -hide_banner -loglevel quiet -progress """{_progress}""" -i """{dl}""" -metadata "Encoded By"="https://github.com/kaif-00z/AutoAnimeBot/" -preset ultrafast -c:v libx265 -crf {Var.CRF} -map 0:v -c:a aac -map 0:a -c:s copy -map 0:s? -threads {self.ffmpeg_threads} """{out}""" -y'''
+        process = await asyncio.create_subprocess_shell(
+            cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE
+        )
+        d_time = time.time()
+        while process.returncode != 0:
+            await asyncio.sleep(5)
+            with open(_progress, "r+") as fil:
+                text = fil.read()
+                frames = re.findall("frame=(\\d+)", text)
+                size = re.findall("total_size=(\\d+)", text)
+                speed = 0
+                if not os.path.exists(out) or os.path.getsize(out) == 0:
+                    return False, "Unable To Encode This Video!"
+                if len(frames):
+                    elapse = int(frames[-1])
+                if len(size):
+                    size = int(size[-1])
+                    per = elapse * 100 / int(total_frames)
+                    time_diff = time.time() - int(d_time)
+                    speed = round(elapse / time_diff, 2)
+                if int(speed) != 0:
+                    some_eta = ((int(total_frames) - elapse) / speed) * 1000
+                    text = f"**Successfully Downloaded The Anime**\n\n **File Name:** ```{dl.split('/')[-1]}```\n\n**STATUS:** \n"
+                    progress_str = "`[{0}{1}] {2}%\n\n`".format(
+                        "".join("●" for _ in range(math.floor(per / 5))),
+                        "".join("" for _ in range(20 - math.floor(per / 5))),
+                        round(per, 2),
+                    )
+                    e_size = f"{self.hbs(size)} of ~{self.hbs((size / per) * 100)}"
+                    eta = f"~{self.ts(some_eta)}"
+                    try:
+                        _new_log_msg = await log_msg.edit(
+                            text
+                            + progress_str
+                            + "`"
+                            + e_size
+                            + "`"
+                            + "\n\n`"
+                            + eta
+                            + "`"
+                        )
+                    except MessageNotModifiedError:
+                        pass
+        try:
+            os.remove(_progress)
+        except BaseException:
+            pass
+        return True, _new_log_msg
+
+    async def genss(self, file):
+        process = subprocess.Popen(
+            # just for better codefactor rating :)
+            [shutil.which("mediainfo"), file, "--Output=JSON"],
+            stdout=subprocess.PIPE,
+            stderr=subprocess.STDOUT,
+        )
+        stdout, stderr = process.communicate()
+        out = stdout.decode().strip()
+        z = json.loads(out)
+        p = z["media"]["track"][0]["Duration"]
+        return int(p.split(".")[-2])
+
+    def stdr(self, seconds: int) -> str:
+        minutes, seconds = divmod(seconds, 60)
+        hours, minutes = divmod(minutes, 60)
+        if len(str(minutes)) == 1:
+            minutes = "0" + str(minutes)
+        if len(str(hours)) == 1:
+            hours = "0" + str(hours)
+        if len(str(seconds)) == 1:
+            seconds = "0" + str(seconds)
+        dur = (
+            ((str(hours) + ":") if hours else "00:")
+            + ((str(minutes) + ":") if minutes else "00:")
+            + ((str(seconds)) if seconds else "")
+        )
+        return dur
+
+    async def duration_s(self, file):
+        tsec = await self.genss(file)
+        x = round(tsec / 5)
+        y = round(tsec / 5 + 30)
+        pin = self.stdr(x)
+        if y < tsec:
+            pon = self.stdr(y)
+        else:
+            pon = self.stdr(tsec)
+        return pin, pon
+
+    async def gen_ss_sam(self, _hash, filename):
+        try:
+            ss_path, sp_path = None, None
+            os.mkdir(_hash)
+            tsec = await self.genss(filename)
+            fps = 10 / tsec
+            ncmd = f"ffmpeg -i '{filename}' -vf fps={fps} -vframes 10 '{_hash}/pic%01d.png'"
+            process = await asyncio.create_subprocess_shell(
+                ncmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE
+            )
+            await process.communicate()
+            ss, dd = await self.duration_s(filename)
+            __ = filename.split(".mkv")[-2]
+            out = __ + "_sample.mkv"
+            _ncmd = f'ffmpeg -i """{filename}""" -preset ultrafast -ss {ss} -to {dd} -c:v libx265 -crf 27 -map 0:v -c:a aac -map 0:a -c:s copy -map 0:s? """{out}""" -y'
+            process = await asyncio.create_subprocess_shell(
+                _ncmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE
+            )
+            stdout, stderr = await process.communicate()
+            er = stderr.decode().strip()
+            try:
+                if er:
+                    if not os.path.exists(out) or os.path.getsize(out) == 0:
+                        LOGS.error(str(er))
+                        return (ss_path, sp_path)
+            except BaseException:
+                pass
+            return _hash, out
+        except Exception as error:
+            LOGS.error(str(error))
+            LOGS.exception(format_exc())

functions/utils.py

@@ -0,0 +1,179 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+import platform
+from datetime import datetime as dt
+
+from pyrogram import __version__ as _p_v
+from telethon import Button
+from telethon import __version__ as _t_v
+from telethon import events
+
+from core.bot import Bot, Var, asyncio
+from database import DataBase
+from functions.tools import Tools
+
+ABOUT = """
+**⏱ Uptime** : `{}`
+**💡 Version** : `{}`
+**👥 Users** : `{}`
+**🗃️ Documents** : `{}`
+
+• **🐍 Python**: `{}`
+• **✈️ Telethon**: `{}`
+• **🏔️ Pyrogram**: `{}`
+• **💻 Server**: `{}`
+• **📖 Source Code** : {}
+
+~ **Developer**  __@Kaif_00z __
+"""
+
+
+class AdminUtils:
+    def __init__(self, dB: DataBase, bot: Bot):
+        self.db = dB
+        self.bot = bot
+        self.tools = Tools()
+        self.python_version = platform.python_version()
+        self.system = f"{platform.system()}-{platform.release()}"
+        self.telethon_version = _t_v
+        self.pyrogram_version = _p_v
+        self.started_at = dt.now()
+
+    def admin_panel(self):
+        btn = [
+            [
+                Button.inline("📜 LOGS", data="slog"),
+                Button.inline("♻️ Restart", data="sret"),
+            ],
+            [
+                Button.inline("🎞️ Encode [Toogle]", data="entg"),
+            ],
+            [Button.inline("🔘 Button Upload [Toogle]", data="butg")],
+            [Button.inline("🗃️ Separate Channel Upload [Toogle]", data="scul")],
+            [Button.inline("🔊 Broadcast", data="cast")],
+        ]
+        return btn
+
+    def back_btn(self):
+        return [[Button.inline("🔙", data="bek")]]
+
+    async def _logs(self, e):
+        await e.delete()
+        await e.reply(
+            file="AutoAnimeBot.log", thumb="thumb.jpg", buttons=self.back_btn()
+        )
+
+    async def _restart(self, e, schedule):
+        await e.reply("`Restarting...`")
+        schedule.restart()
+
+    async def _encode_t(self, e):
+        if await self.db.is_original_upload():
+            await self.db.toggle_original_upload()
+            return await e.edit(
+                "`Successfully On The Compression`", buttons=self.back_btn()
+            )
+        await self.db.toggle_original_upload()
+        return await e.edit(
+            "`Successfully Off The Compression`", buttons=self.back_btn()
+        )
+
+    async def _btn_t(self, e):
+        if await self.db.is_separate_channel_upload():
+            return await e.edit(
+                "`You Can't On/Off The Button Upload When Seprate Channel Is Enabled`",
+                buttons=self.back_btn(),
+            )
+        if await self.db.is_button_upload():
+            await self.db.toggle_button_upload()
+            return await e.edit(
+                "`Successfully Off The Button Upload`", buttons=self.back_btn()
+            )
+        await self.db.toggle_button_upload()
+        return await e.edit("`Successfully On The Upload`", buttons=self.back_btn())
+
+    async def _sep_c_t(self, e):
+        if Var.SESSION:
+            if await self.db.is_button_upload():
+                if await self.db.is_separate_channel_upload():
+                    await self.db.toggle_separate_channel_upload()
+                    return await e.edit(
+                        "`Successfully Off The Separate Channel Upload`",
+                        buttons=self.back_btn(),
+                    )
+                await self.db.toggle_separate_channel_upload()
+                return await e.edit(
+                    "`Successfully On The Separate Channel Upload`",
+                    buttons=self.back_btn(),
+                )
+            else:
+                return await e.edit(
+                    "`To Use The Separate Channel Upload First You Have To Enable Button Upload`",
+                    buttons=self.back_btn(),
+                )
+        else:
+            return await e.edit(
+                "`To Use The Separate Channel Upload First You Have To Add SESSION Variable in The Bot",
+                buttons=self.back_btn(),
+            )
+
+    async def broadcast_bt(self, e):
+        users = await self.db.get_broadcast_user()
+        await e.edit("**Please Use This Feature Responsibly ⚠️**")
+        await e.reply(
+            f"**Send a single Message To Broadcast 😉**\n\n**There are** `{len(users)}` **Users Currently Using Me👉🏻**.\n\nSend /cancel to Cancel Process."
+        )
+        async with e.client.conversation(e.sender_id) as cv:
+            reply = cv.wait_event(events.NewMessage(from_users=e.sender_id))
+            repl = await reply
+            await e.delete()
+            if repl.text and repl.text.startswith("/cancel"):
+                return await repl.reply("`Broadcast Cancelled`")
+        sent = await repl.reply("`🗣️ Broadcasting Your Post...`")
+        done, er = 0, 0
+        for user in users:
+            try:
+                if repl.poll:
+                    await repl.forward_to(int(user))
+                else:
+                    await e.client.send_message(int(user), repl.message)
+                await asyncio.sleep(0.2)
+                done += 1
+            except BaseException as ex:
+                er += 1
+                print(ex)
+        await sent.edit(
+            f"**Broadcast Completed To** `{done}` **Users.**\n**Error in** `{er}` **Users.**"
+        )
+
+    async def _about(self, e):
+        total_docs = await self.db.file_store_db.count_documents({})
+        total_users = await self.db.broadcast_db.count_documents({})
+        text = ABOUT.format(
+            self.tools.ts(int((dt.now() - self.started_at).seconds) * 1000),
+            Var.__version__,
+            total_users,
+            total_docs,
+            self.python_version,
+            self.telethon_version,
+            self.pyrogram_version,
+            self.system,
+            "[OngoingAnimeBot](https://github.com/Kaif-00z/AutoAnimeBot)",
+        )
+        await e.reply(text, file="assest/about.jpg", link_preview=False)

heroku.yml

@@ -0,0 +1,5 @@
+build:
+  docker:
+    worker: Dockerfile
+run:
+  worker: bash run.sh

libs/ariawarp.py

@@ -0,0 +1,38 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+import asyncio
+
+
+class Torrent:
+    def __init__(self) -> None:
+        self.cmd = """aria2c '''{link}''' -x 10 -j 10 --seed-time=0 -d '{path}'"""
+
+    async def bash(self, cmd):
+        process = await asyncio.create_subprocess_shell(
+            cmd,
+            stdout=asyncio.subprocess.PIPE,
+            stderr=asyncio.subprocess.PIPE,
+        )
+        stdout, stderr = await process.communicate()
+        err = stderr.decode().strip() or None
+        out = stdout.decode().strip()
+        return out, err
+
+    async def download_magnet(self, link: str, path: str):
+        await self.bash(self.cmd.format(link=link, path=path))

libs/kitsu.py

@@ -0,0 +1,159 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+import aiohttp
+from AnilistPython import Anilist
+
+
+class RawAnimeInfo:
+    def __init__(self):
+        self.anilist = Anilist()
+
+    async def search(self, query: str):
+        raw_data = ((await self.searcher(query)) or {}).get("data") or {}
+        try:
+            _raw_data = await self.search_anilist(raw_data.get("id"))
+        except BaseException:
+            _raw_data = {}
+        if not raw_data:
+            data = {}  # self.alt_anilist(query)
+            return data
+        data = {}
+        data["anime_id"] = raw_data.get("id")
+        data["english_title"] = raw_data.get("attributes", {}).get("titles", {}).get(
+            "en"
+        ) or raw_data.get("attributes", {}).get("titles", {}).get("en_jp")
+        data["japanese_title"] = (
+            raw_data.get("attributes", {}).get("titles", {}).get("ja_jp")
+        )
+        data["description"] = raw_data.get("attributes", {}).get("description")
+        data["total_eps"] = raw_data.get("attributes", {}).get("episodeCount") or "N/A"
+        data["poster_img"] = (
+            raw_data.get("attributes", {}).get("posterImage", {}).get("original")
+        )
+        # anilist score will be better i guess
+        # data["score"] = raw_data.get("attributes", {}).get("averageRating") or "N/A"
+        data["type"] = raw_data.get("attributes", {}).get("showType") or "TV"
+        data["runtime"] = raw_data.get("attributes", {}).get("episodeLength") or 24
+        return {**(data if data else {}), **(_raw_data if _raw_data else {})}
+
+    async def searcher(
+        self,
+        query: str,
+    ):
+        async with aiohttp.ClientSession() as client:
+            try:
+                data = await client.get(
+                    f"https://kitsu.io/api/edge/anime?filter%5Btext%5D={query.replace(' ', '%20')}"
+                )
+                links = (await data.json())["data"]
+                for index in range(len(links)):
+                    res_data = await self.re_searcher(links[index]["links"]["self"])
+                    if res_data["data"]["attributes"]["status"] == "tba":
+                        continue
+                    if "current" != res_data["data"]["attributes"]["status"]:
+                        if (
+                            res_data["data"]["attributes"]["endDate"]
+                            or res_data["data"]["attributes"]["startDate"]
+                        ):
+                            if "2025" not in (
+                                res_data["data"]["attributes"]["endDate"] or ""
+                            ):
+                                if all(
+                                    year
+                                    not in (
+                                        res_data["data"]["attributes"]["startDate"]
+                                        or ""
+                                    )
+                                    for year in ["2024", "2025"]
+                                ):
+                                    continue
+                    return res_data
+            except BaseException:
+                raise ValueError("Kitsu: Search Link Not Found")
+
+    async def re_searcher(self, link: str):
+        if not link:
+            raise ValueError("Kitsu: Link Not Found")
+        async with aiohttp.ClientSession() as client:
+            try:
+                data = await client.get(link)
+                return await data.json()
+            except BaseException:
+                raise ValueError("Kitsu: Link Not Found")
+
+    async def search_anilist(self, kitsu_id):
+        if not kitsu_id:
+            raise ValueError("Kitsu: ID Not Found")
+        async with aiohttp.ClientSession() as client:
+            try:
+                _data = {}
+                res = await client.get(
+                    f"https://kitsu.io/api/edge/anime/{kitsu_id}/mappings"
+                )
+                data = (await res.json())["data"]
+                for maps in data:
+                    if (
+                        maps.get("attributes", {}).get("externalSite")
+                        == "anilist/anime"
+                    ):
+                        _data["anilist_id"] = maps.get("attributes", {}).get(
+                            "externalId"
+                        )
+                        _data["anilist_poster"] = (
+                            f"https://img.anili.st/media/{_data['anilist_id']}"
+                        )
+                        __data = self.anilist_result(_data["anilist_id"])
+                        return {**_data, **__data}
+            except BaseException:
+                raise ValueError("Kitsu: Mapping Failed")
+
+    def anilist_result(self, anilist_id):
+        try:
+            data = self.anilist.get_anime_with_id(anilist_id)
+            return {
+                "genres": data.get("genres"),
+                "next_airing_ep": data.get("next_airing_ep"),
+                "season": data.get("season"),
+                "starting_time": data.get("starting_time"),
+                "ending_time": data.get("ending_time"),
+                "score": data.get("average_score") or "N/A",
+            }
+        except BaseException:
+            return {}
+
+    def alt_anilist(self, anime_name):
+        data = self.anilist.get_anime(anime_name)
+        _id = self.anilist.get_anime_id(anime_name)
+        return {
+            "anilist_id": _id,
+            "genres": data.get("genres"),
+            "next_airing_ep": data.get("next_airing_ep") or {},
+            "season": data.get("season"),
+            "starting_time": data.get("starting_time"),
+            "ending_time": data.get("ending_time"),
+            "score": data.get("average_score") or "N/A",
+            "english_title": data.get("name_english"),
+            "japanese_title": data.get("name_romaji"),
+            "description": data.get("desc"),
+            "total_eps": data.get("airing_episodes") or "N/A",
+            "poster_img": data.get("banner_image"),
+            "type": data.get("airing_format") or "TV",
+            "runtime": 24,
+            "anilist_poster": f"https://img.anili.st/media/{_id}",
+        }

libs/logger.py

@@ -0,0 +1,117 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+import asyncio
+import logging
+from traceback import format_exc
+
+from telethon import TelegramClient
+from telethon.errors.rpcerrorlist import FloodWaitError
+
+from functions.config import Var
+
+logging.basicConfig(
+    format="%(asctime)s || %(name)s [%(levelname)s] : %(message)s",
+    handlers=[
+        logging.FileHandler("AutoAnimeBot.log", mode="w", encoding="utf-8"),
+        logging.StreamHandler(),
+    ],
+    level=logging.INFO,
+    datefmt="%m/%d/%Y, %H:%M:%S",
+)
+LOGS = logging.getLogger("AutoAnimeBot")
+TelethonLogger = logging.getLogger("Telethon")
+TelethonLogger.setLevel(logging.INFO)
+
+LOGS.info(
+    f"""
+                        Auto Anime Bot
+                ©️ t.me/kAiF_00z (github.com/kaif-00z)
+                        {Var.__version__} (original)
+                             (2023-25)
+                       [All Rigth Reserved]
+
+    """
+)
+
+
+class Reporter:
+    def __init__(self, client: TelegramClient, file_name: str):
+        self.client: TelegramClient = client
+        self.file_name = file_name
+        self.msg = None
+
+    async def alert_new_file_founded(self):
+        await self.awake()
+        msg = await self.client.send_message(
+            Var.MAIN_CHANNEL if Var.LOG_ON_MAIN else Var.LOG_CHANNEL,
+            f"**New Anime Released**\n\n **File Name:** ```{self.file_name}```\n\n**STATUS:** `Downloading...`",
+        )
+        self.msg = msg
+
+    async def started_compressing(self):
+        self.msg = await self.msg.edit(
+            f"**Successfully Downloaded The Anime**\n\n **File Name:** ```{self.file_name}```\n\n**STATUS:** `Encoding...`",
+        )
+        return self.msg
+
+    async def started_renaming(self):
+        self.msg = await self.msg.edit(
+            f"**Successfully Downloaded The Anime**\n\n **File Name:** ```{self.file_name}```\n\n**STATUS:** `Renaming...`",
+        )
+
+    async def started_uploading(self):
+        self.msg = await self.msg.edit(
+            f"**Successfully Encoded The Anime**\n\n **File Name:** ```{self.file_name}```\n\n**STATUS:** `Uploading...`"
+        )
+
+    async def started_gen_ss(self):
+        self.msg = await self.msg.edit(
+            f"**Successfully Uploaded The Anime**\n\n **File Name:** ```{self.file_name}```\n\n**STATUS:** `Generating Sample And Screen Shot...`"
+        )
+
+    async def all_done(self):
+        try:
+            self.msg = await self.msg.edit(
+                f"**Successfully Completed All Task Related To The Anime**\n\n **File Name:** ```{self.file_name}```\n\n**STATUS:** `DONE`"
+            )
+        except BaseException:
+            pass  # ValueError Sometimes From telethon
+        if Var.LOG_ON_MAIN:
+            await self.msg.delete()
+
+    async def awake(self):  # in case
+        if not self.client.is_connected():
+            await self.client.connect()
+
+    async def report_error(self, msg, log=False):
+        txt = f"[ERROR] {msg}"
+        if log:
+            LOGS.error(txt[0])
+        try:
+            await self.client.send_message(Var.LOG_CHANNEL, f"```{txt[:4096]}```")
+        except FloodWaitError as fwerr:
+            await self.client.disconnect()
+            LOGS.info("Sleeping Becoz Of Floodwait...")
+            await asyncio.sleep(fwerr.seconds + 10)
+            await self.client.connect()
+        except ConnectionError:
+            await self.client.connect()
+        except Exception as err:
+            LOGS.exception(format_exc())
+            LOGS.error(str(err))

libs/subsplease.py

@@ -0,0 +1,92 @@
+#    This file is part of the AutoAnime distribution.
+#    Copyright (c) 2025 Kaif_00z
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, version 3.
+#
+#    This program is distributed in the hope that it will be useful, but
+#    WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+#    General Public License for more details.
+#
+# License can be found in <
+# https://github.com/kaif-00z/AutoAnimeBot/blob/main/LICENSE > .
+
+# if you are using this following code then don't forgot to give proper
+# credit to t.me/kAiF_00z (github.com/kaif-00z)
+
+import asyncio
+import hashlib
+import shutil
+import sys
+from itertools import count
+from traceback import format_exc
+
+import anitopy
+from feedparser import parse
+
+from database import LOGS, DataBase
+
+
+class SubsPlease:
+    def __init__(self, dB: DataBase):
+        self.db = dB
+
+    def digest(self, string: str):
+        return hashlib.sha256(string.encode()).hexdigest()
+
+    def _exit(self):
+        LOGS.info("Stopping The Bot...")
+        try:
+            [shutil.rmtree(fold) for fold in ["downloads", "thumbs", "encode"]]
+        except BaseException:
+            LOGS.error(format_exc())
+        sys.exit(0)
+
+    def rss_feed_data(self):
+        try:
+            return (
+                parse("https://subsplease.org/rss/?r=1080"),
+                parse("https://subsplease.org/rss/?r=720"),
+                parse("https://subsplease.org/rss/?r=sd"),
+            )
+        except KeyboardInterrupt:
+            self._exit()
+        except BaseException:
+            LOGS.error(format_exc())
+            return None, None, None
+
+    async def feed_optimizer(self):
+        d1080, d720, d480 = self.rss_feed_data()
+        if not d1080 or not d720 or not d480:
+            return None
+        for i in range(2, -1, -1):
+            try:
+                f1080, f720, f480 = d1080.entries[i], d720.entries[i], d480.entries[i]
+                a1080, a720, a480 = (
+                    (anitopy.parse(f1080.title)).get("anime_title"),
+                    (anitopy.parse(f720.title)).get("anime_title"),
+                    (anitopy.parse(f480.title)).get("anime_title"),
+                )
+                if a1080 == a720 == a480:
+                    if (
+                        "[Batch]" in f1080.title
+                        or "[Batch]" in f720.title
+                        or "[Batch]" in f480.title
+                    ):
+                        continue
+                    uid = self.digest(f1080.title + f720.title + f480.title)
+                    if not await self.db.is_anime_uploaded(uid):
+                        return {"uid": uid, "1080p": f1080, "720p": f720, "480p": f480}
+            except BaseException:
+                LOGS.error(format_exc())
+                return None
+
+    async def on_new_anime(self, function):
+        for i in count():
+            data = await self.feed_optimizer()
+            if data:
+                await function(data)
+                await self.db.add_anime(data.get("uid"))
+            await asyncio.sleep(5)

ongoing-anime

@@ -0,0 +1 @@
+Subproject commit 0ed0019f35e7aaabcc0c7903f4ba329b6edb5869

pkg.sh

@@ -0,0 +1,2 @@
+sudo apt install -y mediainfo ffmpeg wget gcc python3-pip python3 aria2
+pip3 install -U -r requirements.txt

requirements.txt

@@ -0,0 +1,15 @@
+python-decouple
+motor[srv]==3.2.0
+dnspython
+lxml_html_clean
+aiohttp
+aiofiles
+apscheduler==3.10.1
+feedparser
+https://github.com/New-dev0/Telethon/archive/platy.zip
+pyrofork==2.2.11
+tgcrypto
+AnilistPython==0.1.3
+anitopy
+git+https://github.com/kaif-00z/html-telegraph-poster
+pytz

run.sh

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