small fix (#26)

* updated README

* improved %words command

* new words scanner

* fix test

* concurrent fast analysis

* fast analysis if fresh

* better memory handling

* fix "stuck" bug

* updated README

* improved %words command

* small fix

.gitignore

@@ -2,4 +2,7 @@
 venv
 __pycache__
 .env
-error_*
+error_*
+*.log
+/logs/
+.vscode

Dockerfile

@@ -0,0 +1,17 @@
+FROM python
+
+# Create app directory
+WORKDIR /usr/src/app
+
+VOLUME ["/usr/src/app/logs"]
+
+COPY requirements.txt ./
+
+RUN pip install -r requirements.txt
+
+RUN touch logs/guilds.log && ln -s logs/guilds.log guilds.log
+
+# Bundle app source
+COPY . .
+
+CMD [ "sh", "-c", "python src/main.py" ]

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>.

README.md

@@ -1,15 +1,61 @@
+![Python Version >= 3.7](https://img.shields.io/badge/python-%3E=3.7%20-blue)
 [![Scc Count Badge](https://sloc.xyz/github/klemek/discord-analyst/?category=code)](https://github.com/boyter/scc/#badges-beta)
 [![Language grade: Python](https://img.shields.io/lgtm/grade/python/g/Klemek/discord-analyst.svg?logo=lgtm&logoWidth=18)](https://lgtm.com/projects/g/Klemek/discord-analyst/context:python)
 [![Total alerts](https://img.shields.io/lgtm/alerts/g/Klemek/discord-analyst.svg?logo=lgtm&logoWidth=18)](https://lgtm.com/projects/g/Klemek/discord-analyst/alerts/)
+[![Discord Bots](https://top.gg/api/widget/status/643808410495615006.svg)](https://top.gg/bot/643808410495615006)
 
 # Discord Analyst
 
-When you need statistics about your discord server
+#### 📈 Gives you precisions you never asked for.
 
-* `%help (command)` - info about commands
-* `%info` - version and uptime
-* `%emotes` - gives you a full ranking of the server emotes by usage
-  *  Be more specific by adding some `@member` or `#channel` in arguments
+![preview](https://user-images.githubusercontent.com/12103162/111427226-1823ac80-86f6-11eb-9581-fada2db43143.png)
+
+## All commands
+```
+* %help (command) - info about commands
+* %info - version and uptime
+* %scan - full analysis
+* %freq - frequency analysis
+* %compo - composition analysis
+* %pres - presence analysis
+* %first - read first message
+* %rand - read a random message
+* %last - read last message
+* %emojis - rank emotes by their usage
+  * arguments:
+    * <n> - top <n> emojis, default is 20
+    * all - list all common emojis in addition to this guild's
+    * members - show top member for each emote
+    * sort:usage/reaction - other sorting methods
+* %mentions - rank mentions by their usage
+  * arguments:
+    * <n> - top <n> mentions, default is 10
+    * all - show role/channel/everyone/here mentions
+* %mentioned - rank specific user mentions by their usage
+  * arguments:
+    * <n> - top <n> mentions, default is 10
+* %msg - rank users by their messages
+  * arguments:
+    * <n> - top <n> messages, default is 10
+* %chan - rank channels by their messages
+  * arguments:
+    * <n> - top <n> channels, default is 10
+* %react - rank users by their reactions
+  * arguments:
+    * <n> - top <n> messages, default is 10
+* %words - rank words by their usage
+  * arguments:
+    * <n> - words containings <n> or more letters, default is 3
+    * <n2> - top <n2> words, default is 10
+* %cancel - cancel current analysis (not launched with fast)
+
+* Common arguments:
+    * @member/me: filter for one or more member
+    * #channel/here: filter for one or more channel
+    * all/everyone - include bots messages
+    * fast: only read cache
+    * fresh: does not read cache
+```
 
 ## Running this bot
 
@@ -41,11 +87,57 @@ You will need:
 **4. Launch bot**
 
 ```
-python3 bot.py
+python3 src/main.py
 ```
 
+## Recommended permissions
+
+- [x] View Channels
+- [x] Read Message History
+- [x] Send Messages
+
+> On large servers, you should disable "Send Messages" and enable it on an read-only channel where only administrators can launch commands. The bot can't be triggered elsewhere if it can't answer.
+
+## Already hosted bot
+
+[![Discord Bots](https://top.gg/api/widget/643808410495615006.svg)](https://top.gg/bot/643808410495615006)
+
 ## Changelog
 
+* **v1.12**
+  * more scans: `%words`
+  * concurrent `fast` analysis
+  * assume `fast` if last analysis is fresh
+  * better memory handling
+  * bug fix
+* **v1.11**
+  * more scans: `%first`, `%rand`, `%last`
+  * streak computing in `%pres`
+* **v1.10**
+  * multithreading for queries
+  * bug fix
+* **v1.9**:
+  * `all/everyone` to include bots in scans
+  * `fresh` to not use previously cached data
+  * bug fix
+* **v1.8**:
+  * more scans: `%msg`, `%chan`
+  * bug fix
+* **v1.7**:
+  * emojis percents
+  * emojis other sorting
+  * mentions/mentioned ranking
+  * `%cancel`
+* **v1.6**:
+  * more scans: `%scan`, `%freq`, `%compo`, `%pres`
+  * huge bug fix
+* **v1.5**:
+  * top <n> emotes
+  * bug fix
+* **v1.4**:
+  * integrate miniscord
+  * insane speed with bot-side logging
+  * bug fix
 * **v1.3**: revert to v1.1 and update requirements
 * **v1.2**: don't quit on occasional exception
 * **v1.1**:

bot.py

@@ -1,92 +0,0 @@
-import os
-import discord
-from datetime import datetime
-from dotenv import load_dotenv
-
-# Custom libs
-import emotes
-import help
-from utils import debug
-
-VERSION = "1.3"
-t0 = datetime.now()
-
-# Loading token
-load_dotenv()
-token = os.getenv('DISCORD_TOKEN')
-
-client = discord.Client()
-
-
-async def info(message, args):
-    """
-    Computes the %info command
-
-    :param message: message sent
-    :type message: :class:`discord.Message`
-    :param args: arguments of the command
-    :type args: list[:class:`str`]
-    """
-    await message.channel.send(f"```Discord Analyst v{VERSION} started at {t0:%Y-%m-%d %H:%M}```")
-
-
-COMMANDS = {
-    "%help": help.compute,
-    "%emotes": emotes.compute,
-    "%info": info
-}
-
-
-@client.event
-async def on_ready():
-    """
-    Called when client is connected
-    """
-    # Change status
-    await client.change_presence(
-        activity=discord.Game(f"v{VERSION} | %help"),
-        status=discord.Status.online
-    )
-    # Debug connected guilds
-    print(f'{client.user} v{VERSION} has connected to Discord\nto the following guilds:')
-    for guild in client.guilds:
-        print(f'- {guild.name}(id: {guild.id})')
-
-
-@client.event
-async def on_message(message):
-    """
-    Called when a message is sent to any channel on any guild
-
-    :param message: message sent
-    :type message: discord.Message
-    """
-
-    # Ignore self messages
-    if message.author == client.user:
-        return
-
-    args = message.content.split(" ")
-
-    if len(args) < 1 or args[0] not in COMMANDS:
-        return
-
-    debug(message, f"command '{message.content}'")
-
-    # Check if bot can respond on current channel or DM user
-    permissions = message.channel.permissions_for(message.guild.me)
-    if not permissions.send_messages:
-        debug(message, f"missing 'send_messages' permission")
-        await message.author.create_dm()
-        await message.author.dm_channel.send(
-            f"Hi, this bot doesn\'t have the permission to send a message to"
-            f" #{message.channel} in server '{message.guild}'")
-        return
-
-    # Redirect to the correct command
-    await COMMANDS[args[0]](message, args)
-
-
-print(f"Current PID: {os.getpid()}")
-
-client.run(token)

emotes.py

@@ -1,391 +0,0 @@
-from datetime import datetime
-import discord
-import re
-
-# Custom libs
-import help
-from utils import debug, aggregate, no_duplicate
-
-# CONSTANTS
-
-CHUNK_SIZE = 10000
-
-
-# MAIN
-
-async def compute(message, args):
-    """
-    Computes the %emotes command
-
-    :param message: message sent
-    :type message: :class:`discord.Message`
-    :param args: arguments of the command
-    :type args: list[:class:`str`]
-    """
-
-    guild = message.guild
-
-    # If "%emotes help" redirect to "%help emotes"
-    if len(args) > 1 and args[1] == "help":
-        await help.compute(message, ["%help", "emotes"])
-        return
-
-    # Create emotes dict from custom emojis of the guild
-    emotes = {str(emoji): Emote(emoji) for emoji in guild.emojis}
-
-    # Get selected channels or all of them if no channel arguments
-    channels = no_duplicate(message.channel_mentions)
-    full = len(channels) == 0
-    if full:
-        channels = guild.text_channels
-
-    # Get selected members
-    members = no_duplicate(message.mentions)
-
-    # Start computing data
-    async with message.channel.typing():
-        nm = 0  # number of messages treated
-        nmm = 0  # number of impacted messages
-        nc = 0  # number of channel treated
-        t0 = datetime.now()
-        # Show custom progress message and keep it to update it later
-        progress = await message.channel.send(f"```starting analysis...```")
-        # Analyse every channel selected
-        for channel in channels:
-            nm1, nmm1 = await analyse_channel(channel, emotes, members, progress, nm, nc)
-            # If treatment was successful, increase numbers
-            if nm1 >= 0:
-                nm += nm1
-                nmm += nmm1
-                nc += 1
-        # Delete custom progress message
-        await progress.delete()
-        # Display results
-        await tell_results(get_intro(emotes, full, channels, members, nmm, nc),
-                           emotes, message.channel, nmm, allow_unused=full and len(members) == 0, show_life=False)
-        dt = (datetime.now() - t0).total_seconds()
-        debug(message, f"response sent {dt} s -> {nm / dt} m/s")
-
-
-# CLASSES
-
-class Emote:
-    """
-    Custom class to store emotes data
-
-    :param emoji: source discord emoji
-    :type emoji: :class:`discord.Emoji`
-    :ivar emoji: discord emoji
-    :vartype emoji: discord.Emoji
-    :ivar usages: number of usages in messages
-    :vartype usages: int
-    :ivar reactions: number of reactions below messages (always 0 if member specified)
-    :vartype reactions: int
-    :ivar last_used: date of last use
-    :vartype last_used: datetime
-    """
-
-    def __init__(self, emoji):
-        self.emoji = emoji
-        self.usages = 0
-        self.reactions = 0
-        self.last_used = None
-
-    def update_use(self, date):
-        """
-        Update last use date if more recent
-
-        :param date: date of use
-        :type date: datetime
-        """
-        if self.last_used is None or date > self.last_used:
-            self.last_used = date
-
-    def used(self):
-        """
-        :return: If this emote was used ever
-        :rtype: bool
-        """
-        return self.usages > 0 or self.reactions > 0
-
-    def score(self):
-        """
-        :return: Score of this emote to be sorted
-        :rtype: float
-        """
-        # Score is compose of usages + reactions
-        # When 2 emotes have the same score, the days since last use is stored in the digits
-        # (more recent first)
-        return self.usages + self.reactions + 1 / (100000 * (self.use_days() + 1))
-
-    def life_days(self):
-        """
-        :return: Days since creation
-        :rtype: int
-        """
-        return (datetime.today() - self.emoji.created_at).days
-
-    def use_days(self):
-        """
-        :return: Days since last use
-        :rtype: int
-        """
-        # If never used, use creation date instead
-        if self.last_used is None:
-            return self.life_days()
-        else:
-            return (datetime.today() - self.last_used).days
-
-
-# ANALYSIS
-
-async def analyse_channel(channel, emotes, members, progress, nm0, nc):
-    """
-    Analyses a given channel
-
-    :param channel: channel to analyse
-    :type channel: discord.TextChannel
-    :param emotes: known emotes
-    :type emotes: dict[str, Emote]
-    :param members: selected members or empty for all
-    :type members: list[discord.Member]
-    :param progress: custom progress message (already sent)
-    :type progress: discord.Message
-    :param nm0: number of already analysed messages
-    :type nm0: int
-    :param nc: number of already analysed channels
-    :type nc: int
-    :return: nm, nc (-1 on exception)
-    :rtype: int, int
-    """
-    nm = 0
-    nmm = 0
-    try:
-        messages = [None]
-        while len(messages) >= CHUNK_SIZE or messages[-1] is None:
-            messages = await channel.history(limit=CHUNK_SIZE, before=messages[-1]).flatten()
-            for m in messages:
-                # If author is not bot or included in the selection (empty list is all)
-                if not m.author.bot and (len(members) == 0 or m.author in members):
-                    # Find all emotes un the current message in the form "<:emoji:123456789>"
-                    # Filter for known emotes
-                    found = [name for name in re.findall(r"(<:\w+:\d+>)", m.content) if name in emotes]
-                    # For each emote, update its usage
-                    for name in found:
-                        emotes[name].usages += 1
-                        emotes[name].update_use(m.created_at)
-                    # Count this message as impacted
-                    nmm += 1
-                # For each reaction of this message, test if known emote and update when it's the case
-                for reaction in m.reactions:
-                    name = str(reaction.emoji)
-                    # reaction.emoji can be only str, we don't want that
-                    if not (isinstance(reaction.emoji, str)) and name in emotes:
-                        if len(members) == 0:
-                            emotes[name].reactions += reaction.count
-                            emotes[name].update_use(m.created_at)
-                        """ else:
-                            users = await reaction.users().flatten()
-                            for member in members:
-                                if member in users:
-                                    emotes[name].reactions += 1
-                                    emotes[name].update_use(m.created_at)"""
-            nm += len(messages)
-            await progress.edit(content=f"```{nm0 + nm:,} messages and {nc} channels analysed```")
-        return nm, nmm
-    except discord.errors.HTTPException:
-        # When an exception occurs (like Forbidden) sent -1
-        return -1, -1
-
-
-# RESULTS
-
-async def tell_results(intro, emotes, channel, nmm, *, allow_unused, show_life):
-    """
-    Send the full results message
-
-    :param intro: introduction sentence (from get_intro)
-    :type intro: str
-    :param emotes: known emotes
-    :type emotes: dict[str, Emote]
-    :param channel: where to send the message (original message channel)
-    :type channel: discord.TextChannel
-    :param nmm: number of impacted messages
-    :type nmm: int
-    :param allow_unused: show unused emotes
-    :type allow_unused: bool
-    :param show_life: show emotes life span
-    :type show_life: bool
-    """
-    names = [name for name in emotes]
-    names.sort(key=lambda name: emotes[name].score(), reverse=True)
-    res = [intro]
-    res += [
-        f"{get_place(names.index(name))} {name} - "
-        f"{get_usage(emotes[name])}"
-        f"{get_reactions(emotes[name])}"
-        f"{get_life(emotes[name], show_life)}"
-        f"{get_last_used(emotes[name])}"
-        for name in names if allow_unused or emotes[name].used()]
-    res += [get_total(emotes, nmm)]
-    response = ""
-    for r in res:
-        if len(response + "\n" + r) > 2000:
-            await channel.send(response)
-            response = ""
-        response += "\n" + r
-    if len(response) > 0:
-        await channel.send(response)
-
-
-def get_intro(emotes, full, channels, members, nmm, nc):
-    """
-    Get the introduction sentence of the response
-
-    :param emotes: known emotes
-    :type emotes: dict[str, Emote]
-    :param full: if the scan contained all channels
-    :type full: bool
-    :param channels: channels selected (ignored if full is True)
-    :type channels: list[discord.TextChannel]
-    :param members: members selected (empty for all)
-    :type members: list[discord.Member]
-    :param nmm: number of messages impacted
-    :type nmm: int
-    :param nc: number of channels analysed
-    :type nc: int
-    :return: the correct intro sentence
-    :rtype: str
-    """
-    # Show all data (members, channels) when it's less than 5 units
-    if len(members) == 0:
-        # Full scan of the server
-        if full:
-            return f"{len(emotes)} emotes in this server ({nc} channels, {nmm:,} messages):"
-        elif len(channels) < 5:
-            return f"{aggregate([c.mention for c in channels])} emotes usage in {nmm:,} messages:"
-        else:
-            return f"These {len(channels)} channels emotes usage in {nmm:,} messages:"
-    elif len(members) < 5:
-        if full:
-            return f"{aggregate([m.mention for m in members])} emotes usage in {nmm:,} messages:"
-        elif len(channels) < 5:
-            return f"{aggregate([m.mention for m in members])} on {aggregate([c.mention for c in channels])} " \
-                   f"emotes usage in {nmm:,} messages:"
-        else:
-            return f"{aggregate([m.mention for m in members])} on these {len(channels)} channels " \
-                   f"emotes usage in {nmm:,} messages:"
-    else:
-        if full:
-            return f"These {len(members)} members emotes usage in {nmm:,} messages:"
-        elif len(channels) < 5:
-            return f"These {len(members)} members on {aggregate([c.mention for c in channels])} " \
-                   f"emotes usage in {nmm:,} messages:"
-        else:
-            return f"These {len(members)} members on these {len(channels)} channels " \
-                   f"emotes usage in {nmm:,} messages:"
-
-
-def get_place(i):
-    """
-    Get the correct rank displayed (1st to 3rd have an emoji)
-
-    :param i: index
-    :type i: int
-    :return: rank string
-    :rtype: str
-    """
-    if i == 0:
-        return ":first_place:"
-    if i == 1:
-        return ":second_place:"
-    if i == 2:
-        return ":third_place:"
-    return f"**#{i + 1}**"
-
-
-def get_usage(emote):
-    """
-    Get the correct usage displayed
-
-    :type emote: Emote
-    :return: usage description
-    :rtype: str
-    """
-    if emote.usages == 0 and emote.reactions == 0:
-        return "never used "
-    elif emote.usages == 1:
-        return "1 time "
-    else:
-        return f"{emote.usages:,} times "
-
-
-def get_reactions(emote):
-    """
-    Get the correct reactions displayed
-
-    :return: reactions description
-    :rtype: str
-    """
-    if emote.reactions == 0:
-        return ""
-    elif emote.reactions == 1:
-        return "and 1 reaction "
-    else:
-        return f"and {emote.reactions:,} reactions "
-
-
-def get_life(emote, show_life):
-    """
-    Get the correct life span displayed
-
-    :type emote: Emote
-    :param show_life: disable if False
-    :type show_life: bool
-    :return: life description
-    :rtype: str
-    """
-    if not show_life:
-        return ""
-    else:
-        return f"(in {emote.life_days()} days) "
-
-
-def get_last_used(emote):
-    """
-    Get the correct "last used" displayed
-
-    :type emote: Emote
-    :return: last usage description
-    :rtype: str
-    """
-    if emote.usages == 0 and emote.reactions == 0:
-        return ""
-    elif emote.use_days() == 0:
-        return "(last used today)"
-    elif emote.use_days() == 1:
-        return "(last used yesterday)"
-    else:
-        return f"(last used {emote.use_days()} days ago)"
-
-
-def get_total(emotes, nmm):
-    """
-    Get the total of all emotes used
-
-    :param emotes: known emotes
-    :type emotes: dict[str, Emote]
-    :param nmm: number of messages impacted
-    :type nmm: int
-    :return: total sentence
-    :rtype: str
-    """
-    nu = 0
-    nr = 0
-    for name in emotes:
-        nu += emotes[name].usages
-        nr += emotes[name].reactions
-    if nr > 0:
-        return f"Total: {nu:,} times ({nu / nmm:.4f} / message) and {nr:,} reactions"
-    else:
-        return f"Total: {nu:,} times ({nu / nmm:.4f} / message)"

help.py

@@ -1,31 +0,0 @@
-
-
-async def compute(message, args):
-    """
-    Computes the %help command
-
-    :param message: message sent
-    :type message: discord.Message
-    :param args: arguments of the command
-    :type args: list[str]
-    """
-
-    # Select correct response to send
-
-    response = "Discord Analyst commands:\n" \
-               "```\n" \
-               "%help (command) : Info on commands\n" \
-               "%info : This bot info\n" \
-               "%emotes : Emotes analysis\n" \
-               "```"
-
-    if len(args) > 1 and args[1] == "emotes":
-        response = "Emotes Analysis:\n" \
-                   "```\n" \
-                   "%emotes : Rank emotes by their usage\n" \
-                   "%emotes @user : // for a specific user\n" \
-                   "%emotes #channel : // for a specific channel\n" \
-                   "(Add more @user or #channel to be more selective)\n" \
-                   "```"
-
-    await message.channel.send(response)

requirements.txt

@@ -1,2 +1,3 @@
 discord.py
 python-dotenv
+git+git://github.com/Klemek/miniscord.git

src/data_types/__init__.py

@@ -0,0 +1,6 @@
+from .emote import Emote, get_emote_dict
+from .frequency import Frequency
+from .composition import Composition
+from .presence import Presence
+from .counter import Counter
+from .history import History

src/data_types/composition.py

@@ -0,0 +1,71 @@
+from typing import List
+from collections import defaultdict
+
+from utils import percent, top_key, plural, precise, val_sum
+
+
+class Composition:
+    def __init__(self):
+        self.total_characters = 0
+        self.plain_text = 0
+        self.emote_msg = 0
+        self.emote_only = 0
+        self.emotes = defaultdict(int)
+        self.edited = 0
+        self.everyone = 0
+        self.answers = 0
+        self.images = 0
+        self.tts = 0
+        self.mentions = 0
+        self.mention_msg = 0
+        self.links = 0
+        self.link_msg = 0
+        self.spoilers = 0
+
+    def to_string(self, msg_count: int) -> List[str]:
+        ret = []
+        ret += [
+            f"- **avg. characters / message**: {self.total_characters/msg_count:.2f}"
+        ]
+        if self.plain_text > 0:
+            ret += [
+                f"- **plain text messages**: {self.plain_text:,} ({percent(self.plain_text/msg_count)})"
+            ]
+        if self.edited > 0:
+            ret += [
+                f"- **edited messages**: {self.edited:,} ({percent(self.edited/msg_count)})"
+            ]
+        if self.everyone > 0:
+            ret += [
+                f"- **@\u200beveryone**: {self.everyone:,} ({percent(self.everyone/msg_count)})"
+            ]
+        if self.mentions > 0:
+            ret += [
+                f"- **mentions**: {self.mentions:,} (in {percent(self.mention_msg/msg_count)} of msg, avg. {precise(self.mentions/msg_count)}/msg)",
+            ]
+        if self.answers > 0:
+            ret += [
+                f"- **answers**: {self.answers:,} ({percent(self.answers/msg_count)})"
+            ]
+        total_emotes = val_sum(self.emotes)
+        if total_emotes > 0:
+            top_emote = top_key(self.emotes)
+            ret += [
+                f"- **emojis**: {total_emotes:,} (in {percent(self.emote_msg/msg_count)} of msg, avg. {precise(total_emotes/msg_count)}/msg)",
+                f"- **most used emoji**: {top_emote} ({plural(self.emotes[top_emote], 'time')}, {percent(self.emotes[top_emote]/total_emotes)})",
+            ]
+            if self.emote_only > 0:
+                ret += [
+                    f"- **emoji-only messages**: {self.emote_only:,} ({percent(self.emote_only/msg_count)})"
+                ]
+        if self.images > 0:
+            ret += [f"- **images**: {self.images:,} ({percent(self.images/msg_count)})"]
+        if self.links > 0:
+            ret += [f"- **links**: {self.links:,} ({percent(self.link_msg/msg_count)})"]
+        if self.spoilers > 0:
+            ret += [
+                f"- **spoilers**: {self.spoilers:,} ({percent(self.spoilers/msg_count)})"
+            ]
+        if self.tts > 0:
+            ret += [f"- **tts messages**: {self.tts:,} ({percent(self.tts/msg_count)})"]
+        return ret

src/data_types/counter.py

@@ -0,0 +1,63 @@
+from typing import Optional, Callable
+from datetime import datetime
+from collections import defaultdict
+
+# Custom libs
+
+from utils import plural, from_now, percent, val_sum, top_key
+
+
+class Counter:
+    def __init__(self):
+        self.usages = defaultdict(int)
+        self.last_used = None
+
+    def update_use(self, count: int, date: datetime, item: int = 0):
+        self.usages[item] += count
+        if self.last_used is None or date > self.last_used:
+            self.last_used = date
+
+    def score(self) -> float:
+        # Score is compose of usages + reactions
+        # When 2 emotes have the same score,
+        # the days since last use is stored in the digits
+        # (more recent first)
+        return self.all_usages() + 1 / (
+            100000 * ((datetime.today() - self.last_used).days + 1)
+        )
+
+    def all_usages(self) -> int:
+        return val_sum(self.usages)
+
+    def to_string(
+        self,
+        i: int,
+        name: str,
+        *,
+        total_usage: int,
+        counted: str = "time",
+        transform: Optional[Callable[[int], str]] = None,
+    ) -> str:
+        # place
+        output = ""
+        if i == 0:
+            output += ":first_place:"
+        elif i == 1:
+            output += ":second_place:"
+        elif i == 2:
+            output += ":third_place:"
+        else:
+            output += f"**#{i + 1}**"
+        sum = val_sum(self.usages)
+        output += f" {name} - {plural(sum, counted)} ({percent(sum/total_usage)}, last {from_now(self.last_used)})"
+        top_item = top_key(self.usages)
+        if top_item != 0 and transform is not None:
+            if self.usages[top_item] == sum:
+                output += f" (all{transform(top_item)})"
+            else:
+                output += f" ({self.usages[top_item]:,}{transform(top_item)}, {percent(self.usages[top_item]/sum)})"
+        return output
+
+    @staticmethod
+    def total(d: dict) -> int:
+        return sum([val_sum(counter.usages) for counter in d.values()])

src/data_types/emote.py

@@ -0,0 +1,106 @@
+from typing import List, Optional, Dict
+from datetime import datetime
+from collections import defaultdict
+import discord
+
+# Custom libs
+
+from utils import mention, plural, from_now, top_key, percent
+
+
+class Emote:
+    """
+    Custom class to store emotes data
+    """
+
+    def __init__(self, emoji: Optional[discord.Emoji] = None):
+        self.emoji = emoji
+        self.usages = 0
+        self.reactions = 0
+        self.last_used = None
+        self.members = defaultdict(int)
+
+    def update_use(self, date: datetime, members_id: List[int]):
+        """
+        Update last use date if more recent and last member
+        """
+        if self.last_used is None or date > self.last_used:
+            self.last_used = date
+        for member_id in members_id:
+            self.members[member_id] += 1
+
+    def used(self) -> bool:
+        return self.usages > 0 or self.reactions > 0
+
+    def score(self, *, usage_weight: int = 1, react_weight: int = 1) -> float:
+        # Score is compose of usages + reactions
+        # When 2 emotes have the same score,
+        # the days since last use is stored in the digits
+        # (more recent first)
+        return (
+            self.usages * usage_weight
+            + self.reactions * react_weight
+            + 1 / (100000 * (self.use_days() + 1))
+        )
+
+    def life_days(self) -> int:
+        return (datetime.today() - self.emoji.created_at).days
+
+    def use_days(self) -> int:
+        # If never used, use creation date instead
+        if self.last_used is None:
+            return self.life_days()
+        else:
+            return (datetime.today() - self.last_used).days
+
+    def get_top_member(self) -> int:
+        return top_key(self.members)
+
+    def to_string(
+        self,
+        i: int,
+        name: str,
+        *,
+        total_usage: int,
+        total_react: int,
+        show_life: bool,
+        show_members: bool,
+    ) -> str:
+        # place
+        output = ""
+        if i == 0:
+            output += ":first_place:"
+        elif i == 1:
+            output += ":second_place:"
+        elif i == 2:
+            output += ":third_place:"
+        else:
+            output += f"**#{i + 1}**"
+        output += f" {name} - "
+        if not self.used():
+            output += "never used"
+        else:
+            if self.usages > 0:
+                output += f"{plural(self.usages, 'time')} ({percent(self.usages/total_usage)})"
+            if self.usages > 0 and self.reactions > 0:
+                output += " and "
+            if self.reactions >= 1:
+                output += f"{plural(self.reactions, 'reaction')} ({percent(self.reactions/total_react)})"
+            output += f" (last used {from_now(self.last_used)})"
+            if show_members:
+                top_member = self.get_top_member()
+                total = self.usages + self.reactions
+                if total == self.members[top_member]:
+                    output += f" (all by {mention(top_member)})"
+                else:
+                    output += f" ({self.members[top_member]} by {mention(top_member)}, {percent(self.members[top_member]/total)})"
+        if show_life and not self.default:
+            output += f" (in {plural(self.life_days(), 'day')})"
+        return output
+
+
+def get_emote_dict(guild: discord.Guild) -> Dict[str, Emote]:
+    emotes = defaultdict(Emote)
+    for emoji in guild.emojis:
+        emotes[str(emoji)] = Emote(emoji)
+    return emotes

src/data_types/frequency.py

@@ -0,0 +1,74 @@
+from typing import List
+from datetime import timedelta
+import calendar
+
+from utils import (
+    str_date,
+    str_datetime,
+    from_now,
+    plural,
+    percent,
+    precise,
+    top_key,
+    mention,
+)
+
+
+class Frequency:
+    def __init__(self):
+        self.dates = []
+        self.longest_break = timedelta(seconds=0)
+        self.longest_break_start = None
+        self.week = {i: 0 for i in range(7)}
+        self.day = {i: 0 for i in range(24)}
+        self.busiest_day = None
+        self.busiest_day_count = 0
+        self.busiest_hour = None
+        self.busiest_hour_count = 0
+        self.streaks = []
+        self.last_author = None
+        self.last_streak_start = None
+        self.last_streak_author = None
+        self.longest_streak = None
+        self.longest_streak_start = None
+        self.longest_streak_author = None
+
+    def to_string(
+        self,
+        *,
+        member_specific: bool,
+    ) -> List[str]:
+        delta = self.dates[-1] - self.dates[0]
+        total_msg = len(self.dates)
+        busiest_weekday = top_key(self.week)
+        busiest_hour = top_key(self.day)
+        n_weekdays = delta.days // 7
+        if (
+            self.dates[0].weekday() <= busiest_weekday
+            and self.dates[-1].weekday() >= busiest_weekday
+        ):
+            n_weekdays += 1
+        n_hours = delta.days
+        if self.dates[0].hour <= busiest_hour and self.dates[-1].hour >= busiest_hour:
+            n_hours += 1
+        ret = [
+            f"- **earliest message**: {str_datetime(self.dates[0])} ({from_now(self.dates[0])})",
+            f"- **latest message**: {str_datetime(self.dates[-1])} ({from_now(self.dates[-1])})",
+            f"- **messages/day**: {precise(total_msg/delta.days, precision=3)}",
+            f"- **busiest day of week**: {calendar.day_name[busiest_weekday]} (~{precise(self.week[busiest_weekday]/n_weekdays, precision=3)} msg, {percent(self.week[busiest_weekday]/total_msg)})",
+            f"- **busiest day ever**: {str_date(self.busiest_day)} ({from_now(self.busiest_day)}, {self.busiest_day_count} msg)",
+            f"- **messages/hour**: {precise(total_msg*3600/delta.total_seconds(), precision=3)}",
+            f"- **busiest hour of day**: {busiest_hour:0>2}:00 (~{precise(self.day[busiest_hour]/n_hours, precision=3)} msg, {percent(self.day[busiest_hour]/total_msg)})",
+            f"- **busiest hour ever**: {str_datetime(self.busiest_hour)} ({from_now(self.busiest_hour)}, {self.busiest_hour_count} msg)",
+            f"- **longest break**: {plural(round(self.longest_break.total_seconds()/3600), 'hour')} ({plural(self.longest_break.days,'day')}) from {str_datetime(self.longest_break_start)} ({from_now(self.longest_break_start)})",
+            f"- **avg. streak**: {precise(sum(self.streaks)/len(self.streaks), precision=3)} msg",
+        ]
+        if member_specific:
+            ret += [
+                f"- **longest streak**: {self.longest_streak:,} msg from {str_datetime(self.longest_streak_start)} ({from_now(self.longest_streak_start)})"
+            ]
+        else:
+            ret += [
+                f"- **longest streak**: {mention(self.longest_streak_author)} ({self.longest_streak:,} msg from {str_datetime(self.longest_streak_start)}, {from_now(self.longest_streak_start)})"
+            ]
+        return ret

src/data_types/history.py

@@ -0,0 +1,39 @@
+from typing import List
+import random
+
+# Custom libs
+
+from utils import mention, from_now, str_datetime, message_link
+
+
+class History:
+    def __init__(self):
+        self.messages = []
+
+    def to_string(self, *, type: str) -> List[str]:
+        if len(self.messages) == 0:
+            return ["There was no messages matching your filters"]
+        message = None
+        intro = None
+        if type == "first":
+            self.messages.sort(key=lambda m: m.created_at)
+            message = self.messages[0]
+            intro = f"First message out of {len(self.messages):,}"
+        elif type == "last":
+            self.messages.sort(key=lambda m: m.created_at, reverse=True)
+            message = self.messages[0]
+            intro = f"Last message out of {len(self.messages):,}"
+        elif type == "random":
+            message = random.choice(self.messages)
+            intro = f"Random message out of {len(self.messages):,}"
+
+        text = ["> " + line for line in message.content.splitlines()]
+        if message.attachment:
+            text += ["> <image>" if message.image else "> <attachment>"]
+
+        return [
+            intro,
+            f"{str_datetime(message.created_at)} ({from_now(message.created_at)}) {mention(message.author)} said:",
+            *text,
+            f"<{message_link(message)}>",
+        ]

src/data_types/presence.py

@@ -0,0 +1,98 @@
+from typing import List, Optional
+from collections import defaultdict
+
+
+from utils import mention, channel_mention, plural, percent, top_key, val_sum
+
+
+class Presence:
+    def __init__(self):
+        self.messages = defaultdict(int)
+        self.reactions = defaultdict(int)
+        self.used_reaction = defaultdict(int)
+        self.channel_usage = defaultdict(int)
+        self.channel_total = defaultdict(int)
+        self.mentions = defaultdict(int)
+        self.mention_others = defaultdict(int)
+        self.mention_count = defaultdict(int)
+
+    def to_string(
+        self,
+        msg_count: int,
+        total_msg: int,
+        *,
+        chan_count: Optional[int],
+        show_top_channel: bool,
+        member_specific: bool,
+    ) -> List[str]:
+        ret = []
+        if chan_count is None:
+            type = "server's"
+        elif chan_count == 1:
+            type = "channel's"
+        else:
+            type = "channels'"
+        if member_specific:
+            ret += [
+                f"- **messages**: {msg_count:,} ({percent(msg_count/total_msg)} of {type})"
+            ]
+        else:
+            top_member = top_key(self.messages)
+            ret += [
+                f"- **top messages**:  {mention(top_member)} ({self.messages[top_member]:,} msg, {percent(self.messages[top_member]/val_sum(self.messages))})"
+            ]
+        if show_top_channel:
+            top_channel = top_key(self.channel_usage)
+            channel_sum = val_sum(self.channel_usage)
+            found_in = sorted(
+                self.channel_usage,
+                key=lambda k: self.channel_usage[k] / self.channel_total[k],
+            )[-1]
+            ret += [
+                f"- **most visited channel**: {channel_mention(top_channel)} ({self.channel_usage[top_channel]:,} msg, {percent(self.channel_usage[top_channel]/channel_sum)})",
+            ]
+            if member_specific:
+                ret += [
+                    f"- **most contributed channel**: {channel_mention(found_in)} ({self.channel_usage[found_in]:,} msg, {percent(self.channel_usage[found_in]/self.channel_total[found_in])} of {type})"
+                ]
+        if member_specific:
+            if len(self.mentions) > 0:
+                top_mention = top_key(self.mentions)
+                mention_sum = val_sum(self.mentions)
+                ret += [
+                    f"- **was mentioned**: {plural(mention_sum, 'time')} ({percent(mention_sum/val_sum(self.mention_count))} of {type})",
+                    f"- **mostly mentioned by**: {mention(top_mention)} ({plural(self.mentions[top_mention], 'time')}, {percent(self.mentions[top_mention]/mention_sum)})",
+                ]
+        if len(self.mention_others) > 0:
+            top_mention = top_key(self.mention_others)
+            mention_sum = val_sum(self.mention_others)
+            if member_specific:
+                ret += [
+                    f"- **mentioned others**: {plural(mention_sum, 'time')} ({percent(mention_sum/val_sum(self.mention_count))} of {type})",
+                    f"- **mostly mentioned**: {mention(top_mention)} ({plural(self.mention_others[top_mention], 'time')}, {percent(self.mention_others[top_mention]/mention_sum)})",
+                ]
+            else:
+                top_member = top_key(self.mention_count)
+                ret += [
+                    f"- **mentioned**: {plural(mention_sum, 'time')} ({mention(top_member)}, {percent(self.mention_count[top_member]/val_sum(self.mention_count))})",
+                    f"- **top mentions**: {mention(top_member)} ({plural(self.mention_count[top_member], 'time')}, {percent(self.mention_count[top_member]/val_sum(self.mention_count))})",
+                    f"- **most mentioned**: {mention(top_mention)} ({plural(self.mention_others[top_mention], 'time')}, {percent(self.mention_others[top_mention]/mention_sum)})",
+                ]
+        if len(self.reactions) > 0:
+            total_used = val_sum(self.reactions)
+            top_reaction = top_key(self.reactions)
+            ret += [
+                f"- **reactions**: {plural(total_used, 'time')}",
+                f"- **most used reaction**: {top_reaction} ({plural(self.reactions[top_reaction], 'time')}, {percent(self.reactions[top_reaction]/total_used)})",
+            ]
+            if member_specific:
+                ret[
+                    -2
+                ] += f" ({percent(total_used/val_sum(self.used_reaction))} of {type})"
+            else:
+                top_member = top_key(self.used_reaction)
+                ret.insert(
+                    -1,
+                    f"- **top reactions**: {mention(top_member)} ({plural(self.used_reaction[top_member], 'time')}, {percent(self.used_reaction[top_member]/val_sum(self.used_reaction))})",
+                )
+        return ret

src/logs/__init__.py

@@ -0,0 +1,3 @@
+from .message_log import MessageLog
+from .channel_logs import ChannelLogs
+from .guild_logs import GuildLogs, ALREADY_RUNNING, CANCELLED

src/logs/channel_logs.py

@@ -0,0 +1,90 @@
+from typing import Union, Tuple, Any
+import discord
+
+from . import MessageLog
+from utils import FakeMessage
+
+CHUNK_SIZE = 2000
+FORMAT = 3
+
+
+class ChannelLogs:
+    def __init__(self, channel: Union[discord.TextChannel, dict], guild: Any):
+        self.guild = guild
+        if isinstance(channel, discord.TextChannel):
+            self.id = channel.id
+            self.name = channel.name
+            self.last_message_id = None
+            self.format = FORMAT
+            self.messages = []
+        elif isinstance(channel, dict):
+            self.format = channel["format"] if "format" in channel else None
+            if not self.is_format():
+                return
+            self.id = int(channel["id"])
+            self.name = channel["name"]
+            self.last_message_id = (
+                int(channel["last_message_id"])
+                if channel["last_message_id"] is not None
+                else None
+            )
+            self.messages = [
+                MessageLog(message, self) for message in channel["messages"]
+            ]
+
+    def is_format(self):
+        return self.format == FORMAT
+
+    async def load(self, channel: discord.TextChannel) -> Tuple[int, int]:
+        self.name = channel.name
+        self.channel = channel
+        try:
+            if self.last_message_id is not None:  # append
+                tmp_message_id = None
+                while (
+                    self.last_message_id != channel.last_message_id
+                    and self.last_message_id != tmp_message_id
+                ):
+                    tmp_message_id = self.last_message_id
+                    async for message in channel.history(
+                        limit=CHUNK_SIZE,
+                        after=FakeMessage(self.last_message_id),
+                        oldest_first=True,
+                    ):
+                        self.last_message_id = message.id
+                        m = MessageLog(message, self)
+                        await m.load(message)
+                        self.messages.insert(0, m)
+                    yield len(self.messages), False
+            else:  # first load
+                last_message_id = None
+                done = 0
+                sanity_check = len(await channel.history(limit=1).flatten())
+                if sanity_check == 1:
+                    while done >= CHUNK_SIZE or last_message_id is None:
+                        done = 0
+                        async for message in channel.history(
+                            limit=CHUNK_SIZE,
+                            before=FakeMessage(last_message_id)
+                            if last_message_id is not None
+                            else None,
+                            oldest_first=False,
+                        ):
+                            done += 1
+                            last_message_id = message.id
+                            m = MessageLog(message, self)
+                            await m.load(message)
+                            self.messages += [m]
+                        yield len(self.messages), False
+                    self.last_message_id = channel.last_message_id
+        except discord.errors.HTTPException:
+            yield -1, True
+            return  # When an exception occurs (like Forbidden)
+        yield len(self.messages), True
+
+    def dict(self) -> dict:
+        channel = dict(self.__dict__)
+        channel.pop("channel", None)
+        channel.pop("guild", None)
+        channel["messages"] = [message.dict() for message in self.messages]
+        return channel

src/logs/guild_logs.py

@@ -0,0 +1,324 @@
+from typing import List, Tuple
+import os
+import discord
+import json
+import gzip
+from datetime import datetime
+import time
+import logging
+import asyncio
+import threading
+
+
+from . import ChannelLogs
+from utils import code_message, delta, deltas
+
+
+LOG_DIR = "logs"
+
+current_analysis = []
+current_analysis_lock = threading.Lock()
+
+
+ALREADY_RUNNING = -100
+CANCELLED = -200
+
+MIN_MODIFICATION_TIME = 5 * 60
+
+
+class Worker:
+    def __init__(self, channel_log: ChannelLogs, channel: discord.TextChannel):
+        self.channel_log = channel_log
+        self.channel = channel
+        self.start_msg = len(channel_log.messages)
+        self.total_msg = self.start_msg
+        self.queried_msg = 0
+        self.done = False
+        self.cancelled = False
+        self.loop = asyncio.get_event_loop()
+
+    def start(self):
+        asyncio.run_coroutine_threadsafe(self.process(), self.loop)
+
+    async def process(self):
+        async for count, done in self.channel_log.load(self.channel):
+            if count > 0:
+                self.queried_msg = count - self.start_msg
+                self.total_msg = count
+            self.done = done
+            if self.cancelled:
+                return
+
+
+class GuildLogs:
+    def __init__(self, guild: discord.Guild):
+        self.id = guild.id
+        self.guild = guild
+        self.log_file = os.path.join(LOG_DIR, f"{guild.id}.logz")
+        self.channels = {}
+        self.locked = False
+
+    def __enter__(self):
+        return self
+
+    def __exit__(self, type, value, tb):
+        del self.channels
+        del self.guild
+        if self.locked:
+            self.unlock()
+
+    def dict(self) -> dict:
+        return {id: self.channels[id].dict() for id in self.channels}
+
+    def check_cancelled(self) -> bool:
+        return self.locked and self.log_file not in current_analysis
+
+    def lock(self) -> bool:
+        self.locked = True
+        current_analysis_lock.acquire()
+        if self.log_file in current_analysis:
+            current_analysis_lock.release()
+            return False
+        current_analysis.append(self.log_file)
+        current_analysis_lock.release()
+        return True
+
+    def unlock(self):
+        self.locked = False
+        current_analysis_lock.acquire()
+        if self.log_file in current_analysis:
+            current_analysis.remove(self.log_file)
+        current_analysis_lock.release()
+
+    async def load(
+        self,
+        progress: discord.Message,
+        target_channels: List[discord.TextChannel] = [],
+        *,
+        fast: bool,
+        fresh: bool,
+    ) -> Tuple[int, int]:
+        self.locked = False
+        if not fast and not self.lock():
+            return ALREADY_RUNNING, 0
+        t00 = datetime.now()
+        # read logs
+        if not os.path.exists(LOG_DIR):
+            os.mkdir(LOG_DIR)
+        last_time = None
+        if os.path.exists(self.log_file):
+            channels = {}
+            try:
+                last_time = os.path.getmtime(self.log_file)
+                gziped_data = None
+                await code_message(progress, "Reading saved history (1/4)...")
+                t0 = datetime.now()
+                with open(self.log_file, mode="rb") as f:
+                    gziped_data = f.read()
+                logging.info(f"log {self.guild.id} > read in {delta(t0):,}ms")
+                if self.check_cancelled():
+                    return CANCELLED, 0
+                await code_message(progress, "Reading saved history (2/4)...")
+                t0 = datetime.now()
+                json_data = gzip.decompress(gziped_data)
+                del gziped_data
+                logging.info(
+                    f"log {self.guild.id} > gzip decompress in {delta(t0):,}ms"
+                )
+                if self.check_cancelled():
+                    return CANCELLED, 0
+                await code_message(progress, "Reading saved history (3/4)...")
+                t0 = datetime.now()
+                channels = json.loads(json_data)
+                del json_data
+                logging.info(f"log {self.guild.id} > json parse in {delta(t0):,}ms")
+                if self.check_cancelled():
+                    return CANCELLED, 0
+                await code_message(progress, "Reading saved history (4/4)...")
+                t0 = datetime.now()
+                self.channels = {
+                    int(id): ChannelLogs(channels[id], self) for id in channels
+                }
+                # remove invalid format
+                self.channels = {
+                    id: self.channels[id]
+                    for id in self.channels
+                    if self.channels[id].is_format()
+                }
+                logging.info(f"log {self.guild.id} > loaded in {delta(t0):,}ms")
+            except json.decoder.JSONDecodeError:
+                logging.error(f"log {self.guild.id} > invalid JSON")
+            except IOError:
+                logging.error(f"log {self.guild.id} > cannot read")
+        else:
+            fast = False
+
+        if len(target_channels) == 0:
+            target_channels = (
+                self.channels.values() if fast else self.guild.text_channels
+            )
+        elif fast:
+            # select already loaded channels only
+            target_channels_tmp = [
+                channel for channel in target_channels if channel.id in self.channels
+            ]
+            if len(target_channels_tmp) == 0:
+                fast = False
+            else:
+                target_channels = target_channels_tmp
+
+        # assume fast if file is fresh
+        if (
+            not fast
+            and not fresh
+            and last_time is not None
+            and (time.time() - last_time) < MIN_MODIFICATION_TIME
+        ):
+            invalid_target_channels = [
+                channel
+                for channel in target_channels
+                if channel.id not in self.channels
+            ]
+            if len(invalid_target_channels) == 0:
+                fast = True
+                if self.locked:
+                    self.unlock()
+
+        total_msg = 0
+        total_chan = 0
+        if fast:
+            target_channels_id = [channel.id for channel in target_channels]
+            total_msg = sum(
+                [
+                    len(channel.messages)
+                    for channel in self.channels.values()
+                    if channel.id in target_channels_id
+                ]
+            )
+            total_chan = len(target_channels)
+        else:
+            if not self.locked and not self.lock():
+                return ALREADY_RUNNING, 0
+            # load channels
+            t0 = datetime.now()
+            loading_new = 0
+            queried_msg = 0
+            total_chan = 0
+            max_chan = len(target_channels)
+            if self.check_cancelled():
+                return CANCELLED, 0
+            workers = []
+            for channel in target_channels:
+                if channel.id not in self.channels or fresh:
+                    loading_new += 1
+                    self.channels[channel.id] = ChannelLogs(channel, self)
+                workers += [Worker(self.channels[channel.id], channel)]
+            warning_msg = "(this might take a while)"
+            if len(target_channels) > 5 and loading_new > 5:
+                warning_msg = "(most channels are new, this will take a long while)"
+            elif loading_new > 0:
+                warning_msg = "(some channels are new, this might take a long while)"
+            await code_message(
+                progress,
+                f"Reading new history...\n0 messages in 0/{max_chan:,} channels\n{warning_msg}",
+            )
+            for worker in workers:
+                worker.start()
+            done = False
+            while not done:
+                if self.check_cancelled():
+                    for worker in workers:
+                        worker.cancelled = True
+                    return CANCELLED, 0
+
+                await asyncio.sleep(0.5)
+
+                remaining = [
+                    worker.channel.name for worker in workers if not worker.done
+                ]
+                total_chan = max_chan - len(remaining)
+                queried_msg = sum([worker.queried_msg for worker in workers])
+                total_msg = sum([worker.total_msg for worker in workers])
+
+                if total_chan == max_chan:
+                    done = True
+
+                remaining_msg = ""
+
+                if len(remaining) <= 5:
+                    remaining_msg = "\nRemaining: " + ", ".join(remaining)
+
+                await code_message(
+                    progress,
+                    f"Reading new history...\n{total_msg:,} messages in {total_chan:,}/{max_chan:,} channels ({round(queried_msg/deltas(t0)):,}m/s)\n{warning_msg}{remaining_msg}",
+                )
+            logging.info(
+                f"log {self.guild.id} > queried in {delta(t0):,}ms -> {queried_msg / deltas(t0):,.3f} m/s"
+            )
+            # write logs
+            real_total_msg = sum(
+                [len(channel.messages) for channel in self.channels.values()]
+            )
+            real_total_chan = len(self.channels)
+            if self.check_cancelled():
+                return CANCELLED, 0
+            await code_message(
+                progress,
+                f"Saving history (1/3)...\n{real_total_msg:,} messages in {real_total_chan:,} channels",
+            )
+            t0 = datetime.now()
+            json_data = bytes(json.dumps(self.dict()), "utf-8")
+            logging.info(
+                f"log {self.guild.id} > json dump in {delta(t0):,}ms -> {real_total_msg / deltas(t0):,.3f} m/s"
+            )
+            if self.check_cancelled():
+                return CANCELLED, 0
+            await code_message(
+                progress,
+                f"Saving history (2/3)...\n{real_total_msg:,} messages in {real_total_chan:,} channels",
+            )
+            t0 = datetime.now()
+            gziped_data = gzip.compress(json_data)
+            del json_data
+            logging.info(
+                f"log {self.guild.id} > gzip in {delta(t0):,}ms -> {real_total_msg / deltas(t0):,.3f} m/s"
+            )
+            if self.check_cancelled():
+                return CANCELLED, 0
+            await code_message(
+                progress,
+                f"Saving history (3/3)...\n{real_total_msg:,} messages in {real_total_chan:,} channels",
+            )
+            t0 = datetime.now()
+            with open(self.log_file, mode="wb") as f:
+                f.write(gziped_data)
+            del gziped_data
+            logging.info(
+                f"log {self.guild.id} > saved in {delta(t0):,}ms -> {real_total_msg / deltas(t0):,.3f} m/s"
+            )
+        if self.check_cancelled():
+            return CANCELLED, 0
+        await code_message(
+            progress,
+            f"Analysing...\n{total_msg:,} messages in {total_chan:,} channels",
+        )
+        logging.info(f"log {self.guild.id} > TOTAL TIME: {delta(t00):,}ms")
+        if self.locked:
+            current_analysis_lock.acquire()
+            current_analysis.remove(self.log_file)
+            current_analysis_lock.release()
+        return total_msg, total_chan
+
+    @staticmethod
+    async def cancel(client: discord.client, message: discord.Message, *args: str):
+        logs = GuildLogs(message.guild)
+        current_analysis_lock.acquire()
+        if logs.log_file in current_analysis:
+            current_analysis.remove(logs.log_file)
+            current_analysis_lock.release()
+        else:
+            current_analysis_lock.release()
+            await message.channel.send(
+                f"No cancellable analysis are currently running on this server",
+                reference=message,
+            )

src/logs/message_log.py

@@ -0,0 +1,87 @@
+from typing import Union, Any
+import discord
+from datetime import datetime
+
+from utils import is_extension
+
+IMAGE_FORMAT = [".gif", ".gifv", ".png", ".jpg", ".jpeg", ".bmp"]
+EMBED_IMAGES = ["image", "gifv"]
+
+
+class MessageLog:
+    def __init__(self, message: Union[discord.Message, dict], channel: Any):
+        self.channel = channel
+        if isinstance(message, discord.Message):
+            self.id = message.id
+            self.created_at = message.created_at
+            self.edited_at = message.edited_at
+            self.author = message.author.id
+            self.pinned = message.pinned
+            self.mention_everyone = message.mention_everyone
+            self.tts = message.tts
+            self.bot = message.author.bot or message.author.system
+            self.content = message.content
+            self.mentions = message.raw_mentions
+            if message.reference is not None:
+                self.reference = message.reference.message_id
+                if message.reference.resolved is not None:
+                    try:
+                        self.mentions += [message.reference.resolved.author.id]
+                    except AttributeError:
+                        pass
+            else:
+                self.reference = None
+            self.role_mentions = message.raw_role_mentions
+            self.channel_mentions = message.raw_channel_mentions
+            self.image = False
+            self.attachment = len(message.attachments) > 0
+            self.embed = len(message.embeds) > 0
+            for attachment in message.attachments:
+                if is_extension(attachment.filename, IMAGE_FORMAT):
+                    self.image = True
+                    break
+            else:
+                for embed in message.embeds:
+                    if embed.type in EMBED_IMAGES:
+                        self.image = True
+                        break
+            self.reactions = {}
+        elif isinstance(message, dict):
+            self.id = int(message["id"])
+            self.created_at = datetime.fromisoformat(message["created_at"])
+            self.edited_at = (
+                datetime.fromisoformat(message["edited_at"])
+                if message["edited_at"] is not None
+                else None
+            )
+            self.author = int(message["author"])
+            self.pinned = message["pinned"]
+            self.mention_everyone = message["mention_everyone"]
+            self.tts = message["tts"]
+            self.reference = (
+                int(message["reference"]) if message["reference"] is not None else None
+            )
+            self.bot = message["bot"]
+            self.content = message["content"]
+            self.mentions = [int(m) for m in message["mentions"]]
+            self.role_mentions = [int(m) for m in message["role_mentions"]]
+            self.channel_mentions = [int(m) for m in message["channel_mentions"]]
+            self.image = message["image"]
+            self.embed = message["embed"]
+            self.attachment = message["attachment"]
+            self.reactions = message["reactions"]
+
+    async def load(self, message: discord.Message):
+        for reaction in message.reactions:
+            self.reactions[str(reaction.emoji)] = []
+            async for user in reaction.users():
+                self.reactions[str(reaction.emoji)] += [user.id]
+
+    def dict(self) -> dict:
+        message = dict(self.__dict__)
+        message.pop("channel", None)
+        message["created_at"] = self.created_at.isoformat()
+        message["edited_at"] = (
+            self.edited_at.isoformat() if self.edited_at is not None else None
+        )
+        return message

src/main.py

@@ -0,0 +1,133 @@
+import sys
+from miniscord import Bot
+import logging
+
+if sys.version_info < (3, 7):
+    print("Please upgrade your Python version to 3.7.0 or higher")
+    sys.exit(1)
+
+from utils import emojis
+from scanners import (
+    EmotesScanner,
+    FullScanner,
+    FrequencyScanner,
+    CompositionScanner,
+    PresenceScanner,
+    MentionsScanner,
+    MentionedScanner,
+    MessagesScanner,
+    ChannelsScanner,
+    ReactionsScanner,
+    FirstScanner,
+    RandomScanner,
+    LastScanner,
+    WordsScanner,
+)
+from logs import GuildLogs
+
+logging.basicConfig(
+    format="[%(asctime)s][%(levelname)s][%(module)s] %(message)s", level=logging.INFO
+)
+
+emojis.load_emojis()
+
+bot = Bot(
+    "Discord Analyst",
+    "1.12",
+    alias="%",
+)
+
+bot.log_calls = True
+
+bot.register_command(
+    "(cancel|stop)",
+    GuildLogs.cancel,
+    "cancel: stop current analysis (not launched with fast)",
+    "```\n" + "%cancel: Stop current analysis (not launched with fast)\n" + "```",
+)
+bot.register_command(
+    "last",
+    lambda *args: LastScanner().compute(*args),
+    "last: read last message",
+    LastScanner.help(),
+)
+bot.register_command(
+    "rand(om)?",
+    lambda *args: RandomScanner().compute(*args),
+    "rand: read a random message",
+    RandomScanner.help(),
+)
+bot.register_command(
+    "first",
+    lambda *args: FirstScanner().compute(*args),
+    "first: read first message",
+    FirstScanner.help(),
+)
+bot.register_command(
+    "words",
+    lambda *args: WordsScanner().compute(*args),
+    "words: rank words by their usage",
+    WordsScanner.help(),
+)
+bot.register_command(
+    "mentioned",
+    lambda *args: MentionedScanner().compute(*args),
+    "mentioned: rank specific user mentions by their usage",
+    MentionedScanner.help(),
+)
+bot.register_command(
+    "(mentions?)",
+    lambda *args: MentionsScanner().compute(*args),
+    "mentions: rank mentions by their usage",
+    MentionsScanner.help(),
+)
+bot.register_command(
+    "(emojis?|emotes?)",
+    lambda *args: EmotesScanner().compute(*args),
+    "emojis: rank emojis by their usage",
+    EmotesScanner.help(),
+)
+bot.register_command(
+    "(react(ions?)?)",
+    lambda *args: ReactionsScanner().compute(*args),
+    "react: rank users by their reactions",
+    ReactionsScanner.help(),
+)
+bot.register_command(
+    "(channels?|chan)",
+    lambda *args: ChannelsScanner().compute(*args),
+    "chan: rank channels by their messages",
+    ChannelsScanner.help(),
+)
+bot.register_command(
+    "(messages?|msg)",
+    lambda *args: MessagesScanner().compute(*args),
+    "msg: rank users by their messages",
+    MessagesScanner.help(),
+)
+bot.register_command(
+    "pres(ence)?",
+    lambda *args: PresenceScanner().compute(*args),
+    "pres: presence analysis",
+    PresenceScanner.help(),
+)
+bot.register_command(
+    "compo(sition)?",
+    lambda *args: CompositionScanner().compute(*args),
+    "compo: composition analysis",
+    CompositionScanner.help(),
+)
+bot.register_command(
+    "freq(ency)?",
+    lambda *args: FrequencyScanner().compute(*args),
+    "freq: frequency analysis",
+    FrequencyScanner.help(),
+)
+bot.register_command(
+    "(full|scan)",
+    lambda *args: FullScanner().compute(*args),
+    "scan: full analysis",
+    FullScanner.help(),
+)
+
+bot.start()

src/scanners/__init__.py

@@ -0,0 +1,14 @@
+from .emotes_scanner import EmotesScanner
+from .frequency_scanner import FrequencyScanner
+from .composition_scanner import CompositionScanner
+from .presence_scanner import PresenceScanner
+from .full_scanner import FullScanner
+from .mentions_scanner import MentionsScanner
+from .mentioned_scanner import MentionedScanner
+from .messages_scanner import MessagesScanner
+from .channels_scanner import ChannelsScanner
+from .reactions_scanner import ReactionsScanner
+from .first_scanner import FirstScanner
+from .last_scanner import LastScanner
+from .random_scanner import RandomScanner
+from .words_scanner import WordsScanner

src/scanners/channels_scanner.py

@@ -0,0 +1,91 @@
+from typing import Dict, List
+from collections import defaultdict
+import discord
+
+
+# Custom libs
+
+from logs import ChannelLogs, MessageLog
+from .scanner import Scanner
+from data_types import Counter
+from utils import COMMON_HELP_ARGS, mention, channel_mention
+
+
+class ChannelsScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%chan: Rank channels by their messages\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* <n> - top <n>, default is 10\n"
+            + "* all/everyone - include bots\n"
+            + "Example: %chan 10 @user\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            has_digit_args=True,
+            valid_args=["all", "everyone"],
+            help=ChannelsScanner.help(),
+            intro_context="Channels",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        # get max emotes to view
+        self.top = 10
+        for arg in args:
+            if arg.isdigit():
+                self.top = int(arg)
+        self.all_messages = "all" in args or "everyone" in args
+        # Create mentions dict
+        self.messages = defaultdict(Counter)
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return ChannelsScanner.analyse_message(
+            channel.id,
+            message,
+            self.messages,
+            self.raw_members,
+            all_messages=self.all_messages,
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        names = [name for name in self.messages]
+        names.sort(key=lambda name: self.messages[name].score(), reverse=True)
+        names = names[: self.top]
+        usage_count = Counter.total(self.messages)
+        res = [intro]
+        res += [
+            self.messages[name].to_string(
+                names.index(name),
+                channel_mention(name),
+                total_usage=usage_count,
+                counted="message",
+                transform=lambda id: f" by {mention(id)}",
+            )
+            for name in names
+        ]
+        return res
+
+    @staticmethod
+    def analyse_message(
+        channel_id: int,
+        message: MessageLog,
+        messages: Dict[str, Counter],
+        raw_members: List[int],
+        *,
+        all_messages: bool,
+    ) -> bool:
+        impacted = False
+        if (
+            len(raw_members) == 0
+            and (not message.bot or all_messages)
+            or message.author in raw_members
+        ):
+            impacted = True
+            messages[channel_id].update_use(1, message.created_at, message.author)
+        return impacted

src/scanners/composition_scanner.py

@@ -0,0 +1,125 @@
+from typing import List
+import re
+import discord
+
+
+# Custom libs
+
+from .scanner import Scanner
+from data_types import Composition
+from logs import ChannelLogs, MessageLog
+from utils import emojis, COMMON_HELP_ARGS
+
+
+class CompositionScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%compo: Show composition statistics\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* all/everyone - include bots\n"
+            + "Example: %compo #mychannel1 @user\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            valid_args=["all", "everyone"],
+            help=CompositionScanner.help(),
+            intro_context="Composition",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        self.compo = Composition()
+        self.all_messages = "all" in args or "everyone" in args
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        ret = CompositionScanner.analyse_message(
+            message, self.compo, self.raw_members, all_messages=self.all_messages
+        )
+        return ret
+
+    def get_results(self, intro: str) -> List[str]:
+        res = [intro]
+        res += self.compo.to_string(self.msg_count)
+        return res
+
+    @staticmethod
+    def analyse_message(
+        message: MessageLog,
+        compo: Composition,
+        raw_members: List[int],
+        *,
+        all_messages: bool,
+    ) -> bool:
+        impacted = False
+        # If author is included in the selection (empty list is all)
+        if (
+            (not message.bot or all_messages)
+            and len(raw_members) == 0
+            or message.author in raw_members
+        ):
+            impacted = True
+            compo.total_characters += len(message.content)
+
+            emotes_found = emojis.regex.findall(message.content)
+            without_emote = message.content
+            for name in emotes_found:
+                if name in emojis.unicode_list or re.match(
+                    r"(<a?:[\w\-\~]+:\d+>|:[\w\\-\~]+:)", name
+                ):
+                    compo.emotes[name] += 1
+                    i = without_emote.index(name)
+                    without_emote = without_emote[:i] + without_emote[i + len(name) :]
+            if len(message.content.strip()) > 0 and len(without_emote.strip()) == 0:
+                compo.emote_only += 1
+            if len(emotes_found) > 0:
+                compo.emote_msg += 1
+
+            links_found = re.findall(r"https?:\/\/", message.content)
+            compo.links += len(links_found)
+            if len(links_found) > 0:
+                compo.link_msg += 1
+
+            mentions = (
+                len(message.mentions)
+                + len(message.role_mentions)
+                + len(message.channel_mentions)
+            )
+            if message.mention_everyone:
+                compo.everyone += 1
+                mentions += 1
+            if mentions > 0:
+                compo.mentions += mentions
+                compo.mention_msg += 1
+
+            spoilers_found = re.findall(r"\|\|[^|]+\|\|", message.content)
+            if len(spoilers_found) > 0:
+                compo.spoilers += 1
+
+            if message.edited_at is not None:
+                compo.edited += 1
+            if message.reference is not None:
+                compo.answers += 1
+            if message.image:
+                compo.images += 1
+            if message.tts:
+                compo.tts += 1
+
+            if (
+                len(emotes_found) == 0
+                and message.reference is None
+                and not message.image
+                and len(message.mentions) == 0
+                and len(message.role_mentions) == 0
+                and len(message.channel_mentions) == 0
+                and not message.tts
+                and not message.mention_everyone
+                and not message.embed
+                and not message.attachment
+            ):
+                compo.plain_text += 1
+        return impacted

src/scanners/emotes_scanner.py

@@ -0,0 +1,149 @@
+from typing import Dict, List
+from collections import defaultdict
+import discord
+
+
+# Custom libs
+
+from logs import ChannelLogs, MessageLog
+from data_types import Emote, get_emote_dict
+from .scanner import Scanner
+from utils import emojis, COMMON_HELP_ARGS, plural, precise
+
+
+class EmotesScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%emojis: Rank emojis by their usage\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* <n> - top <n> emojis, default is 20\n"
+            + "* all - list all common emojis in addition to this guild's\n"
+            + "* members - show top member for each emojis\n"
+            + "* sort:usage/reaction - other sorting methods\n"
+            + "* everyone - include bots\n"
+            + "Example: %emojis 10 all #mychannel1 #mychannel2 @user\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            has_digit_args=True,
+            valid_args=["all", "members", "sort:usage", "sort:reaction", "everyone"],
+            help=EmotesScanner.help(),
+            intro_context="Emoji usage",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        guild = message.channel.guild
+        # get max emotes to view
+        self.top = 20
+        for arg in args:
+            if arg.isdigit():
+                self.top = int(arg)
+        # check other args
+        self.all_emojis = "all" in args
+        self.show_members = "members" in args and (
+            len(self.members) == 0 or len(self.members) > 1
+        )
+        # Create emotes dict from custom emojis of the guild
+        self.emotes = get_emote_dict(guild)
+        self.sort = None
+        if "sort:usage" in args:
+            self.sort = "usage"
+        elif "sort:reaction" in args:
+            self.sort = "reaction"
+        self.all_messages = "everyone" in args
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return EmotesScanner.analyse_message(
+            message,
+            self.emotes,
+            self.raw_members,
+            all_emojis=self.all_emojis,
+            all_messages=self.all_messages,
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        names = [name for name in self.emotes]
+        names.sort(
+            key=lambda name: self.emotes[name].score(
+                usage_weight=(0 if self.sort == "reaction" else 1),
+                react_weight=(0 if self.sort == "usage" else 1),
+            ),
+            reverse=True,
+        )
+        names = names[: self.top]
+        # Get the total of all emotes used
+        usage_count = 0
+        reaction_count = 0
+        for name in self.emotes:
+            usage_count += self.emotes[name].usages
+            reaction_count += self.emotes[name].reactions
+        res = [intro]
+        allow_unused = self.full and len(self.members) == 0
+        if self.sort is not None:
+            res += [f"(Sorted by {self.sort})"]
+        res += [
+            self.emotes[name].to_string(
+                names.index(name),
+                name,
+                total_usage=usage_count,
+                total_react=reaction_count,
+                show_life=False,
+                show_members=self.show_members or len(self.raw_members) == 0,
+            )
+            for name in names
+            if allow_unused or self.emotes[name].used()
+        ]
+        res += [
+            f"Total: {plural(usage_count,'time')} ({precise(usage_count/self.msg_count)}/msg)"
+        ]
+        if reaction_count > 0:
+            res[-1] += f" and {plural(reaction_count, 'reaction')}"
+        return res
+
+    @staticmethod
+    def analyse_message(
+        message: MessageLog,
+        emotes: Dict[str, Emote],
+        raw_members: List[int],
+        *,
+        all_emojis: bool,
+        all_messages: bool,
+    ) -> bool:
+        impacted = False
+        # If author is included in the selection (empty list is all)
+        if (
+            (not message.bot or all_messages)
+            and len(raw_members) == 0
+            or message.author in raw_members
+        ):
+            impacted = True
+            # Find all emotes un the current message in the form "<:emoji:123456789>"
+            # Filter for known emotes
+            found = emojis.regex.findall(message.content)
+            # For each emote, update its usage
+            for name in found:
+                if name not in emotes:
+                    if not all_emojis or name not in emojis.unicode_list:
+                        continue
+                emotes[name].usages += 1
+                emotes[name].update_use(message.created_at, [message.author])
+        # For each reaction of this message, test if known emote and update when it's the case
+        for name in message.reactions:
+            if name not in emotes:
+                if not all_emojis or name not in emojis.unicode_list:
+                    continue
+            if len(raw_members) == 0:
+                emotes[name].reactions += len(message.reactions[name])
+                emotes[name].update_use(message.created_at, message.reactions[name])
+            else:
+                for member in raw_members:
+                    if member in message.reactions[name]:
+                        emotes[name].reactions += 1
+                        emotes[name].update_use(message.created_at, [member])
+        return impacted

src/scanners/first_scanner.py

@@ -0,0 +1,19 @@
+from typing import List
+
+# Custom libs
+
+from .history_scanner import HistoryScanner
+
+
+class FirstScanner(HistoryScanner):
+    @staticmethod
+    def help() -> str:
+        return super(FirstScanner, FirstScanner).help(
+            cmd="first", text="Read first message"
+        )
+
+    def __init__(self):
+        super().__init__(help=FirstScanner.help())
+
+    def get_results(self, intro: str) -> List[str]:
+        return self.history.to_string(type="first")

src/scanners/frequency_scanner.py

@@ -0,0 +1,123 @@
+from typing import List
+from datetime import datetime
+import discord
+
+
+# Custom libs
+
+from .scanner import Scanner
+from data_types import Frequency
+from logs import ChannelLogs, MessageLog
+from utils import COMMON_HELP_ARGS
+
+
+class FrequencyScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%freq: Show frequency-related statistics\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* all/everyone - include bots\n"
+            + "Example: %freq #mychannel1 @user\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            valid_args=["all", "everyone"],
+            help=FrequencyScanner.help(),
+            intro_context="Frequency",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        self.freq = Frequency()
+        self.all_messages = "all" in args or "everyone" in args
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return FrequencyScanner.analyse_message(
+            message, self.freq, self.raw_members, all_messages=self.all_messages
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        FrequencyScanner.compute_results(self.freq)
+        res = [intro]
+        res += self.freq.to_string(
+            member_specific=self.member_specific,
+        )
+        return res
+
+    @staticmethod
+    def analyse_message(
+        message: MessageLog,
+        freq: Frequency,
+        raw_members: List[int],
+        *,
+        all_messages: bool
+    ) -> bool:
+        impacted = False
+        # If author is included in the selection (empty list is all)
+        if (
+            (not message.bot or all_messages)
+            and len(raw_members) == 0
+            or message.author in raw_members
+        ):
+            impacted = True
+            freq.dates += [message.created_at]
+            if message.author == freq.last_author:
+                freq.streaks[-1] += 1
+            else:
+                if len(freq.streaks) > 0 and (
+                    freq.longest_streak is None
+                    or freq.streaks[-1] > freq.longest_streak
+                ):
+                    freq.longest_streak = freq.streaks[-1]
+                    freq.longest_streak_start = freq.last_streak_start
+                    freq.longest_streak_author = freq.last_streak_author
+                freq.streaks += [1]
+                freq.last_streak_start = message.created_at
+                freq.last_streak_author = message.author
+        freq.last_author = message.author
+        return impacted
+
+    @staticmethod
+    def compute_results(freq: Frequency):
+        freq.dates.sort()
+        latest = freq.dates[0]
+        current_day = 0
+        current_day_date = freq.dates[0]
+        current_day_count = 0
+        current_hour_buffer = []
+        for date in freq.dates:
+            # calculate longest break
+            delay = date - latest
+            if delay > freq.longest_break:
+                freq.longest_break = delay
+                freq.longest_break_start = latest
+            latest = date
+            # calculate busiest weekday / hours
+            freq.week[date.weekday()] += 1
+            freq.day[date.hour] += 1
+            # calculate busiest day ever
+            start_delta = date - freq.dates[0]
+            if start_delta.days > current_day:
+                if current_day_count > freq.busiest_day_count:
+                    freq.busiest_day_count = current_day_count
+                    freq.busiest_day = current_day_date
+                current_day = start_delta.days
+                current_day_date = date
+                current_day_count = 0
+            else:
+                current_day_count += 1
+            # calculate busiest hour ever
+            while (
+                len(current_hour_buffer) > 0
+                and (date - current_hour_buffer[0]).total_seconds() > 3600
+            ):
+                current_hour_buffer.pop(0)
+            current_hour_buffer += [date]
+            if len(current_hour_buffer) > freq.busiest_hour_count:
+                freq.busiest_hour = current_hour_buffer[0]
+                freq.busiest_hour_count = len(current_hour_buffer)

src/scanners/full_scanner.py

@@ -0,0 +1,77 @@
+from typing import List
+import discord
+
+
+# Custom libs
+
+from .scanner import Scanner
+from . import FrequencyScanner, CompositionScanner, PresenceScanner
+from data_types import Frequency, Composition, Presence
+from logs import ChannelLogs, MessageLog
+from utils import COMMON_HELP_ARGS
+
+
+class FullScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%scan: Show full statistics\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* all/everyone - include bots\n"
+            + "Example: %scan #mychannel1 @user\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            valid_args=["all", "everyone"],
+            help=FullScanner.help(),
+            intro_context="Full analysis",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        self.freq = Frequency()
+        self.compo = Composition()
+        self.pres = Presence()
+        self.member_specific = len(self.members) > 0
+        self.all_messages = "all" in args or "everyone" in args
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        FrequencyScanner.analyse_message(
+            message, self.freq, self.raw_members, all_messages=self.all_messages
+        )
+        CompositionScanner.analyse_message(
+            message, self.compo, self.raw_members, all_messages=self.all_messages
+        )
+        PresenceScanner.analyse_message(
+            channel,
+            message,
+            self.pres,
+            self.raw_members,
+            all_messages=self.all_messages,
+        )
+        return (
+            (not message.bot or self.all_messages)
+            and len(self.raw_members) == 0
+            or message.author in self.raw_members
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        FrequencyScanner.compute_results(self.freq)
+        res = [intro]
+        res += ["__Frequency__:"]
+        res += self.freq.to_string(member_specific=self.member_specific)
+        res += ["__Composition__:"]
+        res += self.compo.to_string(self.msg_count)
+        res += ["__Presence__:"]
+        res += self.pres.to_string(
+            self.msg_count,
+            self.total_msg,
+            show_top_channel=len(self.channels) > 1,
+            member_specific=self.member_specific,
+            chan_count=len(self.channels) if not self.full else None,
+        )
+        return res

src/scanners/history_scanner.py

@@ -0,0 +1,70 @@
+from abc import ABC, abstractmethod
+from typing import List
+import discord
+
+# Custom libs
+
+from .scanner import Scanner
+from data_types import History
+from logs import ChannelLogs, MessageLog
+from utils import COMMON_HELP_ARGS
+
+
+class HistoryScanner(Scanner, ABC):
+    @staticmethod
+    def help(*, cmd: str, text: str) -> str:
+        return (
+            "```\n"
+            + f"%{cmd}: {text}\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* all/everyone - include bots\n"
+            + "Example: %{cmd} #mychannel1 @user\n"
+            + "```"
+        )
+
+    def __init__(self, *, help: str):
+        super().__init__(
+            has_digit_args=True,
+            valid_args=["all", "everyone"],
+            help=help,
+            intro_context="",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        self.history = History()
+        self.all_messages = "all" in args or "everyone" in args
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return HistoryScanner.analyse_message(
+            channel,
+            message,
+            self.history,
+            self.raw_members,
+            all_messages=self.all_messages,
+        )
+
+    @abstractmethod
+    def get_results(self, intro: str):
+        pass
+
+    @staticmethod
+    def analyse_message(
+        channel: ChannelLogs,
+        message: MessageLog,
+        history: History,
+        raw_members: List[int],
+        *,
+        all_messages: bool,
+    ) -> bool:
+        impacted = False
+        # If author is included in the selection (empty list is all)
+        if (
+            (not message.bot or all_messages)
+            and len(raw_members) == 0
+            or message.author in raw_members
+        ) and (message.content or message.attachment):
+            impacted = True
+            history.messages += [message]
+        return impacted

src/scanners/last_scanner.py

@@ -0,0 +1,19 @@
+from typing import List
+
+# Custom libs
+
+from .history_scanner import HistoryScanner
+
+
+class LastScanner(HistoryScanner):
+    @staticmethod
+    def help() -> str:
+        return super(LastScanner, LastScanner).help(
+            cmd="last", text="Read last message"
+        )
+
+    def __init__(self):
+        super().__init__(help=LastScanner.help())
+
+    def get_results(self, intro: str) -> List[str]:
+        return self.history.to_string(type="last")

src/scanners/mentioned_scanner.py

@@ -0,0 +1,96 @@
+from typing import Dict, List
+from collections import defaultdict
+import discord
+
+
+# Custom libs
+
+from logs import ChannelLogs, MessageLog
+from .scanner import Scanner
+from data_types import Counter
+from utils import COMMON_HELP_ARGS, plural, precise, mention, alt_mention
+
+
+class MentionedScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%mentioned: Rank specific user's mentions by their usage\n"
+            + "arguments:\n"
+            + "* @member/me - (required) one or more member\n"
+            + "\n".join(COMMON_HELP_ARGS.split("\n")[1:])
+            + "* <n> - top <n> mentions, default is 10\n"
+            + "* all - include bots mentions\n"
+            + "Example: %mentioned 10 @user\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            has_digit_args=True,
+            valid_args=["all"],
+            help=MentionedScanner.help(),
+            intro_context="Mentioned by members",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        # get max emotes to view
+        self.top = 10
+        for arg in args:
+            if arg.isdigit():
+                self.top = int(arg)
+        if len(self.members) == 0:
+            await message.channel.send(
+                "You need to mention at least one member or use `me`", reference=message
+            )
+            return False
+        self.all_mentions = "all" in args
+        # Create mentions dict
+        self.mentions = defaultdict(Counter)
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return MentionedScanner.analyse_message(
+            message, self.mentions, self.raw_members, all_mentions=self.all_mentions
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        names = [name for name in self.mentions]
+        names.sort(key=lambda name: self.mentions[name].score(), reverse=True)
+        names = names[: self.top]
+        # Get the total of all emotes used
+        usage_count = Counter.total(self.mentions)
+        res = [intro]
+        res += [
+            self.mentions[name].to_string(
+                names.index(name),
+                name,
+                total_usage=usage_count,
+            )
+            for name in names
+        ]
+        res += [
+            f"Total: {plural(usage_count,'time')} ({precise(usage_count/self.msg_count)}/msg)"
+        ]
+        return res
+
+    @staticmethod
+    def analyse_message(
+        message: MessageLog,
+        mentions: Dict[str, Counter],
+        raw_members: List[int],
+        *,
+        all_mentions: bool,
+    ) -> bool:
+        impacted = True
+        if not message.bot or all_mentions:
+            for member_id in message.mentions:
+                if member_id in raw_members:
+                    count = message.content.count(
+                        mention(member_id)
+                    ) + message.content.count(alt_mention(member_id))
+                    mentions[mention(message.author)].update_use(
+                        count, message.created_at
+                    )
+        return impacted

src/scanners/mentions_scanner.py

@@ -0,0 +1,129 @@
+from typing import Dict, List
+from collections import defaultdict
+import discord
+
+
+# Custom libs
+
+from logs import ChannelLogs, MessageLog
+from .scanner import Scanner
+from data_types import Counter
+from utils import (
+    COMMON_HELP_ARGS,
+    plural,
+    precise,
+    mention,
+    alt_mention,
+    role_mention,
+    channel_mention,
+)
+
+
+class MentionsScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%mentions: Rank mentions by their usage\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* <n> - top <n> mentions, default is 10\n"
+            + "* all - show role/channel/everyone/here mentions\n"
+            + "* everyone - include bots mentions\n"
+            + "Example: %mentions 10 #mychannel1 #mychannel2 @user\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            has_digit_args=True,
+            valid_args=["all", "everyone"],
+            help=MentionsScanner.help(),
+            intro_context="Mention usage",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        # get max emotes to view
+        self.top = 10
+        for arg in args:
+            if arg.isdigit():
+                self.top = int(arg)
+        # check other args
+        self.all_mentions = "all" in args
+        # Create mentions dict
+        self.mentions = defaultdict(Counter)
+        self.all_messages = "everyone" in args
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return MentionsScanner.analyse_message(
+            message,
+            self.mentions,
+            self.raw_members,
+            all_mentions=self.all_mentions,
+            all_messages=self.all_messages,
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        names = [name for name in self.mentions]
+        names.sort(key=lambda name: self.mentions[name].score(), reverse=True)
+        names = names[: self.top]
+        # Get the total of all emotes used
+        usage_count = Counter.total(self.mentions)
+        res = [intro]
+        res += [
+            self.mentions[name].to_string(
+                names.index(name),
+                name,
+                total_usage=usage_count,
+            )
+            for name in names
+        ]
+        res += [
+            f"Total: {plural(usage_count,'time')} ({precise(usage_count/self.msg_count)}/msg)"
+        ]
+        return res
+
+    @staticmethod
+    def analyse_message(
+        message: MessageLog,
+        mentions: Dict[str, Counter],
+        raw_members: List[int],
+        *,
+        all_mentions: bool,
+        all_messages: bool,
+    ) -> bool:
+        impacted = False
+        # If author is included in the selection (empty list is all)
+        if (
+            (not message.bot or all_messages)
+            and len(raw_members) == 0
+            or message.author in raw_members
+        ):
+            impacted = True
+            for member_id in message.mentions:
+                name = mention(member_id)
+                count = message.content.count(name) + message.content.count(
+                    alt_mention(member_id)
+                )
+                mentions[name].update_use(count, message.created_at)
+            if all_mentions:
+                for role_id in message.role_mentions:
+                    name = role_mention(role_id)
+                    mentions[name].update_use(
+                        message.content.count(name), message.created_at
+                    )
+                for channel_id in message.channel_mentions:
+                    name = channel_mention(channel_id)
+                    mentions[name].update_use(
+                        message.content.count(name), message.created_at
+                    )
+                if "@everyone" in message.content:
+                    mentions["@\u200beveryone"].update_use(
+                        message.content.count("@everyone"), message.created_at
+                    )
+                if "@here" in message.content:
+                    mentions["@\u200bhere"].update_use(
+                        message.content.count("@here"), message.created_at
+                    )
+        return impacted

src/scanners/messages_scanner.py

@@ -0,0 +1,91 @@
+from typing import Dict, List
+from collections import defaultdict
+import discord
+
+
+# Custom libs
+
+from logs import ChannelLogs, MessageLog
+from .scanner import Scanner
+from data_types import Counter
+from utils import COMMON_HELP_ARGS, mention, channel_mention
+
+
+class MessagesScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%msg: Rank users by their messages\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* <n> - top <n>, default is 10\n"
+            + "* all/everyone - include bots\n"
+            + "Example: %msg 10 #channel\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            has_digit_args=True,
+            valid_args=["all", "everyone"],
+            help=MessagesScanner.help(),
+            intro_context="Messages",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        # get max emotes to view
+        self.top = 10
+        for arg in args:
+            if arg.isdigit():
+                self.top = int(arg)
+        self.all_messages = "all" in args or "everyone" in args
+        # Create mentions dict
+        self.messages = defaultdict(Counter)
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return MessagesScanner.analyse_message(
+            channel.id,
+            message,
+            self.messages,
+            self.raw_members,
+            all_messages=self.all_messages,
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        names = [name for name in self.messages]
+        names.sort(key=lambda name: self.messages[name].score(), reverse=True)
+        names = names[: self.top]
+        usage_count = Counter.total(self.messages)
+        res = [intro]
+        res += [
+            self.messages[name].to_string(
+                names.index(name),
+                mention(name),
+                total_usage=usage_count,
+                counted="message",
+                transform=lambda id: f" in {channel_mention(id)}",
+            )
+            for name in names
+        ]
+        return res
+
+    @staticmethod
+    def analyse_message(
+        channel_id: int,
+        message: MessageLog,
+        messages: Dict[str, Counter],
+        raw_members: List[int],
+        *,
+        all_messages: bool,
+    ) -> bool:
+        impacted = False
+        if (
+            len(raw_members) == 0
+            and (not message.bot or all_messages)
+            or message.author in raw_members
+        ):
+            impacted = True
+            messages[message.author].update_use(1, message.created_at, channel_id)
+        return impacted

src/scanners/presence_scanner.py

@@ -0,0 +1,96 @@
+from typing import List
+import discord
+
+
+# Custom libs
+
+from .scanner import Scanner
+from data_types import Presence
+from logs import ChannelLogs, MessageLog
+from utils import COMMON_HELP_ARGS
+
+
+class PresenceScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%pres: Show presence statistics\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* all/everyone - include bots\n"
+            + "Example: %pres #mychannel1 @user\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            valid_args=["all", "everyone"],
+            help=PresenceScanner.help(),
+            intro_context="Presence",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        self.pres = Presence()
+        self.member_specific = len(self.members) > 0
+        self.all_messages = "all" in args or "everyone" in args
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return PresenceScanner.analyse_message(
+            channel,
+            message,
+            self.pres,
+            self.raw_members,
+            all_messages=self.all_messages,
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        res = [intro]
+        res += self.pres.to_string(
+            self.msg_count,
+            self.total_msg,
+            chan_count=len(self.channels) if not self.full else None,
+            show_top_channel=(len(self.channels) > 1),
+            member_specific=self.member_specific,
+        )
+        return res
+
+    @staticmethod
+    def analyse_message(
+        channel: ChannelLogs,
+        message: MessageLog,
+        pres: Presence,
+        raw_members: List[int],
+        *,
+        all_messages: bool,
+    ) -> bool:
+        impacted = False
+        # If author is included in the selection (empty list is all)
+        if (
+            (not message.bot or all_messages)
+            and len(raw_members) == 0
+            or message.author in raw_members
+        ):
+            impacted = True
+            pres.channel_usage[channel.id] += 1
+            for mention in message.mentions:
+                pres.mention_others[mention] += 1
+            pres.messages[message.author] += 1
+        pres.channel_total[channel.id] += 1
+        pres.mention_count[message.author] += len(message.mentions)
+        if len(raw_members) > 0:
+            for mention in message.mentions:
+                if mention in raw_members:
+                    pres.mentions[message.author] += 1
+            for reaction in message.reactions:
+                for member_id in message.reactions[reaction]:
+                    pres.used_reaction[member_id] += 1
+                    if member_id in raw_members:
+                        pres.reactions[reaction] += 1
+        else:
+            for reaction in message.reactions:
+                pres.reactions[reaction] += len(message.reactions[reaction])
+                for member_id in message.reactions[reaction]:
+                    pres.used_reaction[member_id] += 1
+        return impacted

src/scanners/random_scanner.py

@@ -0,0 +1,19 @@
+from typing import List
+
+# Custom libs
+
+from .history_scanner import HistoryScanner
+
+
+class RandomScanner(HistoryScanner):
+    @staticmethod
+    def help() -> str:
+        return super(RandomScanner, RandomScanner).help(
+            cmd="rand", text="Read a random message"
+        )
+
+    def __init__(self):
+        super().__init__(help=RandomScanner.help())
+
+    def get_results(self, intro: str) -> List[str]:
+        return self.history.to_string(type="random")

src/scanners/reactions_scanner.py

@@ -0,0 +1,82 @@
+from typing import Dict, List
+from collections import defaultdict
+import discord
+
+
+# Custom libs
+
+from logs import ChannelLogs, MessageLog
+from .scanner import Scanner
+from data_types import Counter
+from utils import COMMON_HELP_ARGS, mention, channel_mention
+
+
+class ReactionsScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%react: Rank users by their reactions\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* <n> - top <n>, default is 10\n"
+            + "Example: %react 10 #channel\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            has_digit_args=True,
+            help=ReactionsScanner.help(),
+            intro_context="Reactions",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        # get max emotes to view
+        self.top = 10
+        for arg in args:
+            if arg.isdigit():
+                self.top = int(arg)
+        # Create mentions dict
+        self.messages = defaultdict(Counter)
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return ReactionsScanner.analyse_message(
+            channel.id,
+            message,
+            self.messages,
+            self.raw_members,
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        names = [name for name in self.messages]
+        names.sort(key=lambda name: self.messages[name].score(), reverse=True)
+        names = names[: self.top]
+        usage_count = Counter.total(self.messages)
+        res = [intro]
+        res += [
+            self.messages[name].to_string(
+                names.index(name),
+                mention(name),
+                total_usage=usage_count,
+                counted="reaction",
+                transform=lambda id: f" in {channel_mention(id)}",
+            )
+            for name in names
+        ]
+        return res
+
+    @staticmethod
+    def analyse_message(
+        channel_id: int,
+        message: MessageLog,
+        messages: Dict[str, Counter],
+        raw_members: List[int],
+    ) -> bool:
+        impacted = True
+        for reaction in message.reactions:
+            for member_id in message.reactions[reaction]:
+                if len(raw_members) == 0 or member_id in raw_members:
+                    messages[member_id].update_use(1, message.created_at, channel_id)
+        return impacted

src/scanners/scanner.py

@@ -0,0 +1,178 @@
+from abc import ABC, abstractmethod
+from typing import List
+from datetime import datetime
+import logging
+import re
+import discord
+
+from utils import no_duplicate, get_intro, delta
+from logs import GuildLogs, ChannelLogs, MessageLog, ALREADY_RUNNING, CANCELLED
+
+
+class Scanner(ABC):
+    def __init__(
+        self,
+        *,
+        has_digit_args: bool = False,
+        valid_args: List[str] = [],
+        help: str,
+        intro_context: str,
+    ):
+        self.has_digit_args = has_digit_args
+        self.valid_args = valid_args
+        self.help = help
+        self.intro_context = intro_context
+
+        self.members = []
+        self.raw_members = []
+        self.full = False
+        self.channels = []
+
+        self.msg_count = 0
+        self.chan_count = 0
+
+    async def compute(
+        self, client: discord.client, message: discord.Message, *args: str
+    ):
+        args = list(args)
+        guild = message.guild
+        with GuildLogs(guild) as logs:
+            # If "%cmd help" redirect to "%help cmd"
+            if "help" in args:
+                await client.bot.help(client, message, "help", args[0])
+                return
+
+            # check args validity
+            str_channel_mentions = [
+                str(channel.id) for channel in message.channel_mentions
+            ]
+            str_mentions = [str(member.id) for member in message.mentions]
+            for i, arg in enumerate(args[1:]):
+                if re.match(r"^<@!?\d+>$", arg):
+                    arg = arg[3:-1] if "!" in arg else arg[2:-1]
+                elif re.match(r"^<#!?\d+>$", arg):
+                    arg = arg[3:-1] if "!" in arg else arg[2:-1]
+                if (
+                    arg not in self.valid_args + ["me", "here", "fast", "fresh"]
+                    and (not arg.isdigit() or not self.has_digit_args)
+                    and arg not in str_channel_mentions
+                    and arg not in str_mentions
+                ):
+                    await message.channel.send(
+                        f"Unrecognized argument: `{arg}`", reference=message
+                    )
+                    return
+
+            # Get selected channels or all of them if no channel arguments
+            self.channels = no_duplicate(message.channel_mentions)
+
+            # transform the "here" arg
+            if "here" in args:
+                self.channels += [message.channel]
+
+            self.full = len(self.channels) == 0
+            if self.full:
+                self.channels = guild.text_channels
+
+            # Get selected members
+            self.members = no_duplicate(message.mentions)
+            self.raw_members = no_duplicate(message.raw_mentions)
+
+            # transform the "me" arg
+            if "me" in args:
+                self.members += [message.author]
+                self.raw_members += [message.author.id]
+
+            if not await self.init(message, *args):
+                return
+
+            # Start computing data
+            async with message.channel.typing():
+                progress = await message.channel.send(
+                    "```Starting analysis...```",
+                    reference=message,
+                    allowed_mentions=discord.AllowedMentions.none(),
+                )
+                total_msg, total_chan = await logs.load(
+                    progress, self.channels, fast="fast" in args, fresh="fresh" in args
+                )
+                if total_msg == CANCELLED:
+                    await message.channel.send(
+                        "Operation cancelled by user",
+                        reference=message,
+                    )
+                elif total_msg == ALREADY_RUNNING:
+                    await message.channel.send(
+                        "An analysis is already running on this server, please be patient.",
+                        reference=message,
+                    )
+                else:
+                    self.msg_count = 0
+                    self.total_msg = 0
+                    self.chan_count = 0
+                    t0 = datetime.now()
+                    for channel in self.channels:
+                        if channel.id in logs.channels:
+                            channel_logs = logs.channels[channel.id]
+                            count = sum(
+                                [
+                                    self.compute_message(channel_logs, message_log)
+                                    for message_log in channel_logs.messages
+                                ]
+                            )
+                            self.total_msg += len(channel_logs.messages)
+                            self.msg_count += count
+                            self.chan_count += 1 if count > 0 else 0
+                    logging.info(f"scan {guild.id} > scanned in {delta(t0):,}ms")
+                    if self.total_msg == 0:
+                        await message.channel.send(
+                            "There are no messages found matching the filters",
+                            reference=message,
+                        )
+                    else:
+                        await progress.edit(content="```Computing results...```")
+                        # Display results
+                        t0 = datetime.now()
+                        results = self.get_results(
+                            get_intro(
+                                self.intro_context,
+                                self.full,
+                                self.channels,
+                                self.members,
+                                self.msg_count,
+                                self.chan_count,
+                            )
+                        )
+                        logging.info(f"scan {guild.id} > results in {delta(t0):,}ms")
+                        response = ""
+                        first = True
+                        for r in results:
+                            if len(response + "\n" + r) > 2000:
+                                await message.channel.send(
+                                    response,
+                                    reference=message if first else None,
+                                    allowed_mentions=discord.AllowedMentions.none(),
+                                )
+                                first = False
+                                response = ""
+                            response += "\n" + r
+                        if len(response) > 0:
+                            await message.channel.send(
+                                response,
+                                reference=message if first else None,
+                                allowed_mentions=discord.AllowedMentions.none(),
+                            )
+                # Delete custom progress message
+                await progress.delete()
+
+    @abstractmethod
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        pass
+
+    @abstractmethod
+    def compute_message(self, channel: ChannelLogs, message: MessageLog) -> bool:
+        pass
+
+    @abstractmethod
+    def get_results(self, intro: str) -> List[str]:
+        pass

src/scanners/words_scanner.py

@@ -0,0 +1,132 @@
+from typing import Dict, List
+from collections import defaultdict
+import discord
+import re
+
+# Custom libs
+
+from logs import ChannelLogs, MessageLog
+from .scanner import Scanner
+from data_types import Counter
+from utils import (
+    COMMON_HELP_ARGS,
+    plural,
+    precise,
+)
+
+
+class WordsScanner(Scanner):
+    @staticmethod
+    def help() -> str:
+        return (
+            "```\n"
+            + "%words: Rank words by their usage\n"
+            + "arguments:\n"
+            + COMMON_HELP_ARGS
+            + "* <n> - words containings <n> or more letters, default is 3\n"
+            + "* <n2> - top <n2> words, default is 10\n"
+            + "* everyone - include bots\n"
+            + "Example: %words 5 10 #mychannel1 #mychannel2 @user\n"
+            + "```"
+        )
+
+    def __init__(self):
+        super().__init__(
+            has_digit_args=True,
+            valid_args=["all", "everyone"],
+            help=WordsScanner.help(),
+            intro_context="Words ({}+ letters)",
+        )
+
+    async def init(self, message: discord.Message, *args: str) -> bool:
+        self.letters = None
+        self.top = None
+        for arg in args:
+            if arg.isdigit():
+                if self.letters is None:
+                    self.letters = int(arg)
+                elif self.top is None:
+                    self.top = int(arg)
+        if self.letters is None:
+            self.letters = 3
+        if self.top is None:
+            self.top = 10
+        self.words = defaultdict(Counter)
+        self.all_messages = "all" in args or "everyone" in args
+        return True
+
+    def compute_message(self, channel: ChannelLogs, message: MessageLog):
+        return WordsScanner.analyse_message(
+            message,
+            self.words,
+            self.raw_members,
+            all_messages=self.all_messages,
+            letters_threshold=self.letters,
+        )
+
+    def get_results(self, intro: str) -> List[str]:
+        words = [word for word in self.words]
+        words.sort(key=lambda word: self.words[word].score(), reverse=True)
+        words = words[: self.top]
+        # Get the total of all emotes used
+        usage_count = Counter.total(self.words)
+        print(len(self.words))
+        res = [intro.format(self.letters)]
+        res += [
+            self.words[word].to_string(
+                words.index(word),
+                f"`{word}`",
+                total_usage=usage_count,
+            )
+            for word in words
+        ]
+        res += [
+            f"Total: {plural(usage_count,'time')} ({precise(usage_count/self.msg_count)}/msg)"
+        ]
+        return res
+
+    special_cases = ["'s", "s"]
+
+    @staticmethod
+    def analyse_message(
+        message: MessageLog,
+        words: Dict[str, Counter],
+        raw_members: List[int],
+        *,
+        all_messages: bool,
+        letters_threshold: int,
+    ) -> bool:
+        impacted = False
+        # If author is included in the selection (empty list is all)
+        if (
+            (not message.bot or all_messages)
+            and len(raw_members) == 0
+            or message.author in raw_members
+        ):
+            impacted = True
+            content = " ".join(
+                [
+                    block
+                    for block in message.content.split()
+                    if not re.match(r"^\w+:\/\/", block)
+                ]
+            )
+            for word in re.split("[^\w\-':]", content):
+                m = re.match(
+                    r"(?!^:\w+:$)^[^\w]*((?![\d_])\w.*(?![\d_])\w)[^\w]*$", word
+                )
+                if m:
+                    word = m[1].lower()
+                    if len(word) >= letters_threshold:
+                        for case in WordsScanner.special_cases:
+                            if word.endswith(case) and word[: -len(case)] in words:
+                                word = word[: -len(case)]
+                                break
+                            if word + case in words:
+                                words[word] = words[word + case]
+                                del words[word + case]
+                                break
+                        words[word].update_use(
+                            message.content.count(word), message.created_at
+                        )
+        return impacted

src/utils/__init__.py

@@ -0,0 +1 @@
+from .utils import *

src/utils/emojis.py

@@ -0,0 +1,88 @@
+import re
+import json
+import logging
+
+from . import get_resource_path
+
+EXTRA_EMOJI = {
+    "thumbup": "1f44d",
+    "thumbdown": "1f44e",
+    "timer": "23f2-fe0f",
+    "cowboy": "1f920",
+    "clown": "1f921",
+    "newspaper2": "1f5de-fe0f",
+    "french_bread": "1f956",
+    "nerd": "1f913",
+    "zipper_mouth": "1f910",
+    "salad": "1f957",
+    "rolling_eyes": "1f644",
+    "basketball_player": "26f9-fe0f-200d-2642-fe0f",
+    "thinking": "1f914",
+    "e_mail": "2709-fe0f",
+    "slight_frown": "1f641",
+    "skull_crossbones": "2620-fe0f",
+    "hand_splayed": "1f590-fe0f",
+    "speaking_head": "1f5e3-fe0f",
+    "cross": "271d-fe0f",
+    "crayon": "1f58d-fe0f",
+    "head_bandage": "1f915",
+    "rofl": "1f923",
+    "flag_white": "1f3f3-fe0f",
+    "slight_smile": "1f642",
+    "fork_knife_plate": "1f37d-fe0f",
+    "robot": "1f916",
+    "hugging": "1f917",
+    "biohazard": "2623-fe0f",
+    "notepad_spiral": "1f5d2-fe0f",
+    "lifter": "1f3cb-fe0f-200d-2642-fe0f",
+    "race_car": "1f3ce-fe0f",
+    "left_facing_fist": "1f91b",
+    "right_facing_fist": "1f91c",
+    "tools": "1f6e0-fe0f",
+    "umbrella2": "2602-fe0f",
+    "upside_down": "2b07-fe0f",
+    "first_place": "1f947",
+    "dagger": "1f5e1-fe0f",
+    "fox": "1f98a",
+    "menorah": "1f54e",
+    "desktop": "1f5a5-fe0f",
+    "motorcycle": "1f3cd-fe0f",
+    "levitate": "1f574-fe0f",
+    "cheese": "1f9c0",
+    "fingers_crossed": "1f91e",
+    "frowning2": "1f626",
+    "microphone2": "1f399-fe0f",
+    "flag_black": "1f3f4",
+    "chair": "1FA91",
+    "champagne_glass": "1F942",
+    "raised_hand": "270B",
+    "knife": "1F52A",
+    "postal_horn": "1F4EF",
+    "punch": "1F44A",
+}
+
+global_list = {}
+unicode_list = []
+regex = re.compile("(<a?:[\\w\\-\\~]+:\\d+>|:[\\w\\-\\~]+:)")
+
+
+def load_emojis():
+    global global_list, unicode_list, regex
+    emoji_list = []
+    with open(get_resource_path("emoji.json"), mode="r") as f:
+        emoji_list = json.loads(f.readline().strip())
+    for emoji in EXTRA_EMOJI:
+        emoji_list += [{"short_name": emoji, "unified": EXTRA_EMOJI[emoji]}]
+    unicode_list_escaped = []
+    for emoji in emoji_list:
+        shortname = emoji["short_name"]
+        unified = emoji["unified"]
+        if unified is not None and shortname is not None:
+            unicode_escaped = "".join([f"\\U{c:0>8}" for c in unified.split("-")])
+            unicode = bytes(unicode_escaped, "ascii").decode("unicode-escape")
+            shortcode = shortname.replace("-", "_")
+            global_list[unicode] = f":{shortcode}:"
+            unicode_list += [unicode]
+            unicode_list_escaped += [unicode_escaped]
+    regex = re.compile(f"(<a?:\\w+:\\d+>|:\\w+:|{'|'.join(unicode_list_escaped)})")
+    logging.info(f"loaded {len(unicode_list)} emojis")

src/utils/utils.py

@@ -0,0 +1,224 @@
+from typing import List, Dict, Union, Optional, Any
+import os
+import logging
+import discord
+import math
+from datetime import datetime
+
+# OTHER
+
+COMMON_HELP_ARGS = (
+    ""
+    + "* @member/me - filter for one or more member\n"
+    + "* #channel/here - filter for one or more channel\n"
+    + "* fast - only read cache\n"
+    + "* fresh - does not read cache (long)\n"
+)
+
+
+def delta(t0: datetime):
+    return round((datetime.now() - t0).total_seconds() * 1000)
+
+
+def deltas(t0: datetime):
+    return (datetime.now() - t0).total_seconds()
+
+
+# DISCORD API
+
+
+def debug(message: discord.Message, txt: str):
+    logging.info(f"{message.guild} > #{message.channel}: {txt}")
+
+
+async def code_message(message: discord.Message, content: str):
+    await message.edit(content=f"```\n{content}\n```")
+
+
+def mention(member_id: int) -> str:
+    return f"<@{member_id}>"
+
+
+def alt_mention(member_id: int) -> str:
+    return f"<@!{member_id}>"
+
+
+def role_mention(role_id: int) -> str:
+    return f"<@&{role_id}>"
+
+
+def channel_mention(channel_id: int) -> str:
+    return f"<#{channel_id}>"
+
+
+def message_link(message: discord.Message) -> str:
+    return f"https://discord.com/channels/{message.channel.guild.id}/{message.channel.id}/{message.id}"
+
+
+class FakeMessage:
+    def __init__(self, id: int):
+        self.id = id
+
+
+# FILE
+
+
+def is_extension(filepath: str, ext_list: List[str]) -> bool:
+    filename, file_extension = os.path.splitext(filepath.lower())
+    return file_extension in ext_list
+
+
+def get_resource_path(filename: str) -> str:
+    return os.path.realpath(
+        os.path.join(os.path.dirname(__file__), "..", "resources", filename)
+    )
+
+
+# LISTS
+
+
+def no_duplicate(seq: list) -> list:
+    """
+    Remove any duplicates on a list
+
+    :param seq: original list
+    :type seq: list
+    :return: same list with no duplicates
+    :rtype: list
+    """
+    return list(dict.fromkeys(seq))
+
+
+# DICTS
+
+
+def top_key(d: Dict[Union[str, int], int]) -> Union[str, int]:
+    return sorted(d, key=lambda k: d[k])[-1]
+
+
+def val_sum(d: Dict[Any, int]) -> int:
+    return sum(d.values())
+
+
+# MESSAGE FORMATTING
+
+
+def aggregate(names: List[str]) -> str:
+    """
+    Aggregate names with , and &
+
+    Example : "a, b, c & d"
+    """
+    if len(names) == 0:
+        return ""
+    elif len(names) == 1:
+        return names[0]
+    else:
+        return ", ".join(names[:-1]) + " & " + names[-1]
+
+
+def plural(count: int, word: str) -> str:
+    return f"{count:,} {word}{'s' if count != 1 else ''}"
+
+
+def percent(p: float) -> str:
+    return f"{precise(100*p)}%"
+
+
+def precise(p: float, *, precision: int = 2) -> str:
+    if p == 0:
+        return "0"
+    precision = abs(min(0, math.ceil(math.log10(p)) - precision))
+    s = "{:." + str(precision) + "f}"
+    return s.format(p)
+
+
+# DATE FORMATTING
+
+
+def str_date(date: datetime) -> str:
+    return date.strftime("%d %b. %Y")  # 12 Jun. 2018
+
+
+def str_datetime(date: datetime) -> str:
+    return date.strftime("%H:%M, %d %b. %Y")  # 12:05, 12 Jun. 2018
+
+
+def from_now(src: Optional[datetime]) -> str:
+    if src is None:
+        return "never"
+    delay = datetime.utcnow() - src
+    seconds = delay.seconds
+    minutes = seconds // 60
+    hours = minutes // 60
+    if delay.days < 1:
+        if hours < 1:
+            if minutes == 0:
+                return "now"
+            elif minutes == 1:
+                return "a minute ago"
+            else:
+                return f"{minutes} minutes ago"
+        elif hours == 1:
+            return "an hour ago"
+        else:
+            return f"{hours} hours ago"
+    elif delay.days == 1:
+        return "yesterday"
+    else:
+        return f"{delay.days:,} days ago"
+
+
+# APP SPECIFIC
+
+
+def get_intro(
+    subject: str,
+    full: bool,
+    channels: List[discord.TextChannel],
+    members: List[discord.Member],
+    nmm: int,  # number of messages impacted
+    nc: int,  # number of impacted channels
+) -> str:
+    """
+    Get the introduction sentence of the response
+    """
+    # Show all data (members, channels) when it's less than 5 units
+    if len(members) == 0:
+        # Full scan of the server
+        if full:
+            return f"{subject} in this server ({nc} channels, {nmm:,} messages):"
+        elif len(channels) < 5:
+            return f"{aggregate([c.mention for c in channels])} {subject.lower()} in {nmm:,} messages:"
+        else:
+            return (
+                f"These {len(channels)} channels {subject.lower()} in {nmm:,} messages:"
+            )
+    elif len(members) < 5:
+        if full:
+            return f"{aggregate([m.mention for m in members])} {subject.lower()} in {nmm:,} messages:"
+        elif len(channels) < 5:
+            return (
+                f"{aggregate([m.mention for m in members])} on {aggregate([c.mention for c in channels])} "
+                f"{subject.lower()} in {nmm:,} messages:"
+            )
+        else:
+            return (
+                f"{aggregate([m.mention for m in members])} on these {len(channels)} channels "
+                f"{subject.lower()} in {nmm:,} messages:"
+            )
+    else:
+        if full:
+            return (
+                f"These {len(members)} members {subject.lower()} in {nmm:,} messages:"
+            )
+        elif len(channels) < 5:
+            return (
+                f"These {len(members)} members on {aggregate([c.mention for c in channels])} "
+                f"{subject.lower()} in {nmm:,} messages:"
+            )
+        else:
+            return (
+                f"These {len(members)} members on these {len(channels)} channels "
+                f"{subject.lower()} in {nmm:,} messages:"
+            )

utils.py

@@ -1,48 +0,0 @@
-# DISCORD API
-
-
-def debug(message, txt):
-    """
-    Print a log with the context of the current event
-
-    :param message: message that triggered the event
-    :type message: discord.Message
-    :param txt: text of the log
-    :type txt: str
-    """
-    print(f"{message.guild} > #{message.channel}: {txt}")
-
-
-# LISTS
-
-def no_duplicate(seq):
-    """
-    Remove any duplicates on a list
-
-    :param seq: original list
-    :type seq: list
-    :return: same list with no duplicates
-    :rtype: list
-    """
-    return list(dict.fromkeys(seq))
-
-
-# MESSAGE FORMATTING
-
-def aggregate(names):
-    """
-    Aggregate names with , and &
-
-    Example : "a, b, c & d"
-
-    :param names: list of names
-    :type names: list[str]
-    :return: correct aggregation
-    :rtype: str
-    """
-    if len(names) == 0:
-        return ""
-    elif len(names) == 1:
-        return names[0]
-    else:
-        return ", ".join(names[:-1]) + " & " + names[-1]