diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..6fd0a37
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,41 @@
+# Compiled Lua sources
+luac.out
+
+# luarocks build files
+*.src.rock
+*.zip
+*.tar.gz
+
+# Object files
+*.o
+*.os
+*.ko
+*.obj
+*.elf
+
+# Precompiled Headers
+*.gch
+*.pch
+
+# Libraries
+*.lib
+*.a
+*.la
+*.lo
+*.def
+*.exp
+
+# Shared objects (inc. Windows DLLs)
+*.dll
+*.so
+*.so.*
+*.dylib
+
+# Executables
+*.exe
+*.out
+*.app
+*.i*86
+*.x86_64
+*.hex
+
diff --git a/LICENSE b/LICENSE
new file mode 100644
index 0000000..60e2afc
--- /dev/null
+++ b/LICENSE
@@ -0,0 +1,661 @@
+                    GNU AFFERO GENERAL PUBLIC LICENSE
+                       Version 3, 19 November 2007
+
+ Copyright (C) 2007 Free Software Foundation, Inc. <http://fsf.org/>
+ Everyone is permitted to copy and distribute verbatim copies
+ of this license document, but changing it is not allowed.
+
+                            Preamble
+
+  The GNU Affero General Public License is a free, copyleft license for
+software and other kinds of works, specifically designed to ensure
+cooperation with the community in the case of network server software.
+
+  The licenses for most software and other practical works are designed
+to take away your freedom to share and change the works.  By contrast,
+our General Public Licenses are 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.
+
+  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.
+
+  Developers that use our General Public Licenses protect your rights
+with two steps: (1) assert copyright on the software, and (2) offer
+you this License which gives you legal permission to copy, distribute
+and/or modify the software.
+
+  A secondary benefit of defending all users' freedom is that
+improvements made in alternate versions of the program, if they
+receive widespread use, become available for other developers to
+incorporate.  Many developers of free software are heartened and
+encouraged by the resulting cooperation.  However, in the case of
+software used on network servers, this result may fail to come about.
+The GNU General Public License permits making a modified version and
+letting the public access it on a server without ever releasing its
+source code to the public.
+
+  The GNU Affero General Public License is designed specifically to
+ensure that, in such cases, the modified source code becomes available
+to the community.  It requires the operator of a network server to
+provide the source code of the modified version running there to the
+users of that server.  Therefore, public use of a modified version, on
+a publicly accessible server, gives the public access to the source
+code of the modified version.
+
+  An older license, called the Affero General Public License and
+published by Affero, was designed to accomplish similar goals.  This is
+a different license, not a version of the Affero GPL, but Affero has
+released a new version of the Affero GPL which permits relicensing under
+this license.
+
+  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 Affero 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. Remote Network Interaction; Use with the GNU General Public License.
+
+  Notwithstanding any other provision of this License, if you modify the
+Program, your modified version must prominently offer all users
+interacting with it remotely through a computer network (if your version
+supports such interaction) an opportunity to receive the Corresponding
+Source of your version by providing access to the Corresponding Source
+from a network server at no charge, through some standard or customary
+means of facilitating copying of software.  This Corresponding Source
+shall include the Corresponding Source for any work covered by version 3
+of the GNU General Public License that is incorporated pursuant to the
+following paragraph.
+
+  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 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 work with which it is combined will remain governed by version
+3 of the GNU General Public License.
+
+  14. Revised Versions of this License.
+
+  The Free Software Foundation may publish revised and/or new versions of
+the GNU Affero 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 Affero 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 Affero 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 Affero 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) 2017  Naji
+
+    This program is free software: you can redistribute it and/or modify
+    it under the terms of the GNU Affero 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 Affero General Public License for more details.
+
+    You should have received a copy of the GNU Affero General Public License
+    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+Also add information on how to contact you by electronic and paper mail.
+
+  If your software can interact with users remotely through a computer
+network, you should also make sure that it provides a way for users to
+get its source.  For example, if your program is a web application, its
+interface could display a "Source" link that leads users to an archive
+of the code.  There are many ways you could offer source, and different
+solutions will be better for different programs; see section 13 for the
+specific requirements.
+
+  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 AGPL, see
+<http://www.gnu.org/licenses/>.
diff --git a/README.md b/README.md
index 08c768d..4f1ac88 100644
--- a/README.md
+++ b/README.md
@@ -1,2 +1,324 @@
-# tabchi
-حرفه ای ترین سورس ربات تبلیغاتی تبلیغگر (تبچی)
+<p align="center"> <img src="http://www.pic98.ir/upload/bniu_untitled-3.png" width="240">
+<h1><p align="center">تبلیغ‌گر
+<h2><p align="center">سرعت 💠 دقت 💠 قدرت
+<div align="center">
+    <a href="https://telegram.me/Naji_MessengerRobot">
+        <img src="http://upir.ir/951/guest/Untitled-5.png" hspace="10" width="150">
+    </a>
+    <a href="https://telegram.me/i_advansitor">
+        <img src="http://upir.ir/951/guest/Untitled-7.png" hspace="10" width="150">
+    </a>
+    <a href="https://telegram.me/i_naji">
+        <img src="http://upir.ir/951/guest/Untitled-6.png" width="150">
+    </a>
+</div>
+
+<h3><p dir="rtl">تبلیغ‌گر رباتی هوشمند, بسیار ساده و البته رایگان جهت امور تبلیغاتی در تلگرام است.<br>
+نوشته شده توسط <a href="https://telegram.me/i_naji">ناجی</a> برپایه اخرین نسخه <a href="https://valtman.name/telegram-cli">تلگرام</a>.
+<br>
+<h3 align="right"> <strong> نصب و راه‌اندازی</strong> 🚀
+</h3>
+<hr>
+<h4 dir="rtl">ابتدا سورس <em>ربات تبلیغ‌گر</em> را کپی کرده و پیش‌زمینه‌ها را نصب کنید.</h4>
+<h6>(موارد زیر را در ترمینال وارد کنید)</h6>
+<pre>
+<span>git clone https://github.com/i-naji/tabchi.git -b persian</span>
+<span>cd tabchi</span>
+<span>chmod +x bot</span>
+<span>./bot install</span>
+</pre>
+<h4 dir="rtl"> برای ساخت ربات جدید <strong>bot create/.</strong> را وارد کنید.
+</h4>
+<pre>
+<span>./bot create</span>
+</pre>
+<h4 dir="rtl">حال با توجه به شناسه ای که برای ربات جدید داده شده تبلیغ‌گر خود را راه‌اندازی کنید.
+<br>مثال:</h4>
+<h6 dir="rtl">در صورتی ک ردیس تنظیم نشده است آن را تنظیم کنید.</h6>
+<pre>
+<span>دستوری برای راه اندازی مجدد ردیس#</span>
+<span>sudo service redis-server restart</span>
+<span>دستوری برای راه اندازی ردیس#</span>
+<span>sudo service redis-server start</span>
+<span></span>
+<span>./bot 1</span>
+</pre>
+<h5 dir="rtl">توجه داشته باشید برای اولین بار که ربات را راه اندازی می‌کنید،از شما شناسه عددی مدیر ربات (شما و یا هرکس که می خواهید مدیر ربات شود) ، شماره ربات و کد ورود به حساب کاربری خواسته می‌شود.
+<h6 dir="rtl"> شما می توانید با استفاده از ربات <a href="https://telegram.me/id_probot">@ID_ProBot</a> شناسه عددی خود را بدست آورید.</h6>
+<h6 dir="rtl">از <a href="#help">راهنمای‌تبلیغ‌گر</a> برای آشنا شدن با طرز کار رباتتان استفاده کنید.</h6>
+<br>
+<h3 align="right"><strong>جلوگیری از قطع شدن عملکرد تبلیغ‌گر</strong>🛡
+<hr>
+<h4 dir="rtl">یکی از مشکلات کار با SSH، قطع شدن آن در زمان قطع اتصال اینترنت است.<br>وقتی اتصال اینترنت قطع می‌شود اجرای تمامی برنامه‌ها و فرامینی که در حال استفاده از SSH بودند، متوقف می‌شود. فرمان screen این‌جا به‌کمک شما می‌آید. کافی است این دستور را قبل از دستورراه‌اندازی تبلیغ‌گر قرار دهید.</h4>
+<h6 dir="rtl">مثال:</h6>
+<pre>
+<span><strong>screen ./bot 1</strong></span>
+</pre>
+<h4 dir="rtl">برای خارج شدن از محیط screen کلید‌های ترکیبی Ctrl+A و سپس کلید D را بفشارید.<br>برای مشاهده فهرست screen های موجود می‌توانید از دستور<strong>  screen -ls  </strong>  استفاده کنید.<br>این دستور فهرست تمامی screen های در حال اجرا را نمایش می‌دهد.<br>برای مشاهده screen اجرا‌شده، کافی است دستور زیر را وارد کنید:</h4>
+<pre>
+<span><strong>screen -r [screen name]</strong></span>
+</pre>
+<br>
+<h4 id="help" dir="rtl">&#x272F; راهنمای تبلیغ‌گر :</h4>
+<table style="width:100%" dir="rtl">
+  <tr>
+    <th colspan="3">مخصوص مدیر</th>
+  </tr>
+  <tr>
+    <th colspan="2">دستور</th>
+    <th>عملکرد</th>
+    <th></th>
+    <th>فقط در گروه (&#x2724;)<br>فقط در ریپلای (&#x21BB;)</th>
+    </tr>
+   <tr>
+    <td colspan="2">reload/</td>
+    <td align="center">بارگذاری مجدد ربات و راه‌اندازی دوباره</td>
+  </tr>
+  <tr>
+    <td colspan="2">بروزرسانی ربات</td>
+    <td align="center">بروزرسانی ربات به آخرین نسخه<br> و بارگذاری مجدد</td>
+  </tr>
+   <tr>
+    <td colspan="2">تازه سازی</td>
+    <td align="center">تازه سازی آمار تبیلغ‌گر<br>(حدکثر یک بار در روز)</td>
+  </tr>
+     <tr>
+    <td colspan="2">ریپورت</td>
+    <td align="center">اطلاع از وضعیت ریپورت ربات</td>
+  </tr>
+   <tr>
+    <td colspan="2">تازه سازی ربات</td>
+    <td align="center">تازه سازی اطلاعات فردی تبلیغ‎گر<br>بعد از تغییر در مشخصات فردی تبلیغ‎گر <br>مانند اسم انجام گیرد</td>
+  </tr>
+  <tr>
+    <td>افزودن مدیر</td>
+    <td>شناسه</td>
+    <td align="center">افزودن مدیر با شناسه وارد شد</td>
+  </tr>
+    <tr>
+    <td>افزودن مدیرکل</td>
+    <td>شناسه</td>
+    <td align="center">افزودن مدیرکل با شناسه وارد شد</td>
+  </tr>
+   <tr>
+    <td>حذف مدیر</td>
+    <td>شناسه</td>
+    <td align="center">حذف مدیر یا مدیر کل با شناسه خاص</td>
+  </tr>
+  <tr>
+    <td colspan="2">ترک کردن</td>
+    <td align="center">خارج شدن از گروه و حذف<br>از اطلاعات گروه‌ها</td>
+    <td align="center">&#x2724;</td>
+  </tr>
+  <tr>
+    <td colspan="2">افزودن همه مخاطبین</td>
+    <td align="center">افزودن تمام مخاطبین و افراد در گفت‌و‎گوی شخصی<br>به گروه</td>
+    <td align="center">&#x2724;</td>
+  </tr>
+  <tr>
+    <td colspan="2">شناسه من</td>
+    <td align="center">ارسال شناسه عددی شما</td>
+  </tr>
+  <tr>
+   <td>بگو</td>
+    <td>متن</td>
+    <td align="center">ارسال متن</td>
+    </tr>
+  <tr>
+  <tr>
+   <td>ارسال کن</td>
+    <td>"شناسه" متن</td>
+    <td align="center">ارسال متن به شناسه گروه یا فرد</td>
+    </tr>
+  <tr>
+   <td>تنظیم نام</td>
+    <td>"نام" نام‌خانوادگی</td>
+    <td align="center">تغییر نام</td>
+    </tr>
+      <tr>
+   <td>تنطیم نام کاربری</td>
+    <td>نام کاربری</td>
+    <td align="center">جایگزینی نام کاربری داده شده<br>(دفعات استفاده محدود در زمان کوتاه)</td>
+    </tr>
+    <tr>
+   <td colspan="2">حذف نام کاربری</td>
+    <td align="center">حذف نام کاربری<br>(دفعات استفاده محدود در زمان کوتاه)</td>
+    </tr>
+  <tr>
+   <td rowspan="2">افزودن با شماره</td>
+    <td>روشن</td>
+    <td rowspan="2" align="center">تغییر وضعیت اشتراک شماره تبلیغ‌گر<br>در جواب شماره به اشتراک گذاشته شده</td>
+    </tr>
+    <tr>
+    <td>خاموش</td>
+    </tr>
+     <tr>
+   <td rowspan="2">افزودن با پیام</td>
+    <td>روشن</td>
+    <td rowspan="2" align="center">تغییر وضعیت ارسال پیام در جواب<br>شماره به اشتراک گذاشته شده</td>
+    </tr>
+    <tr>
+    <td>خاموش</td>
+    </tr>
+    <tr>
+    <td>تنظیم پیام افزودن مخاطب</td>
+    <td>متن</td>
+    <td align="center">تنظیم متن داده شده به عنوان جواب<br>شماره به اشتراک گذاشته شده</td>
+  </tr>
+  <tr>
+   <td rowspan="2">پاسخگوی خودکار</td>
+    <td>روشن</td>
+    <td rowspan="2" align="center">تغییر وضعیت پاسخ ‌گویی خودکار </td>
+    </tr>
+    <tr>
+    <td>خاموش</td>
+    </tr>
+    <tr>
+   <td>تنظیم جواب</td>
+    <td>"متن" جواب</td>
+    <td align="center">تنظیم جوابی به عنوان پاسخ خودکار<br> به پیام وارد شده مطابق با متن</td>
+    </tr>
+    <tr>
+    <td>حذف جواب</td>
+    <td>متن</td>
+    <td align="center">حذف جواب مربوط به متن</td>
+  </tr>
+  <tr>
+    <td rowspan="6">لیست</td>
+    <td>مخاطبین</td>
+    <td align="center" rowspan="6">ارسال لیستی از مورد خواسته شده<br>در قالب پرونده متنی یا پیام</td>
+  </tr>
+  <tr>
+    <td>خصوصی</td>
+    </tr>
+    <tr>
+    <td>گروه</td>
+    </tr>
+    <tr>
+    <td>سوپرگروه</td>
+    </tr>
+    <tr>
+    <td>لینک</td>
+  </tr>
+  <tr>
+    <td>پاسخ های خودکار</td>
+  </tr>
+  <tr>
+    <td>مسدودیت</td>
+    <td>شناسه</td>
+    <td align="center">مسدود‌کردن(بلاک) کاربر با شناسه داده شده</td>
+  </tr>
+  <tr>
+    <td>رفع مسدودیت</td>
+    <td>شناسه</td>
+    <td align="center">رفع مسدودیت کاربر با شناسه داده شده</td>
+  </tr>
+  <tr>
+   <td rowspan="2">وضعیت مشاهده</td>
+    <td>روشن</td>
+    <td rowspan="2" align="center">خاموش و یا روشن‌کردن وضعیت مشاهده پیام‌ها<br>(فعال و غیر‌فعال‌کردن تیک دوم)</td>
+    </tr>
+    <tr>
+    <td>خاموش</td>
+    </tr>
+  <tr>
+    <td colspan="2">امار</td>
+    <td align="center">ارسال آمار و وضعیت تبلیغ‌گر</td>
+  </tr>
+    <tr>
+    <td colspan="2">وضعیت</td>
+    <td align="center">ارسال وضعیت اجرایی تبلیغ‌گر</td>
+  </tr>
+  <tr>
+    <td rowspan="4">ارسال به</td>
+    <td>همه</td>
+    <td rowspan="4" align="center">ارسال پیام جواب داده شده<br> به مورد خواسته شده</td>
+    <td rowspan="4">&#x21BB;</td>
+    </tr>
+    <tr>
+    <td>خصوصی</td>
+    </tr>
+    <tr>
+    <td>گروه</td>
+    </tr>
+    <tr>
+    <td>سوپرگروه</td>
+    </tr>
+  <tr>
+    <td>ارسال به سوپرگروه</td>
+    <td>متن</td>
+    <td align="center">ارسال متن داده شده به تمام سوپرگروه ها</td>
+  </tr>
+  <tr>
+    <td>ترک کردن</td>
+    <td>شناسه</td>
+    <td align="center">خروج از گروه با‌شناسه وارد شده<br>و حذف از اطلاعات گروه</td>
+  </tr>
+    <tr>
+    <td>افزودن به همه</td>
+    <td>شناسه</td>
+    <td align="center">دعوت کردن کاربر با شناسه وارد شده به تمامی<br>گروه ها و سوپرگروه ها</td>
+  </tr>
+  <tr>
+    <td colspan="2">راهنما</td>
+    <td align="center">دریافت راهنمای تبلیغ‌گر</td>
+  </tr>
+   <tr>
+    <th colspan="3">استفاده از اطلاعات تبچی</th>
+  </tr>
+  <tr>
+    <td colspan="2">همگام سازی با تبچی</td>
+    <td align="center">به <a href="https://telegram.me/i_advertiser/7">آموزش</a> موجود در کانال سر بزنید..</td>
+  </tr>
+</table>
+<h6 dir="rtl">اساس کار تبلیغ‌گر تشخیص لینک و عضویت در هر گروه‌ها و پیروی از دستورات تعیین شده است.</h6>
+<br>
+<h3 dir="rtl">نسخه &#x2780; :</h3>
+<hr>
+<h4 dir="rtl"><strong>امکاناتی که در نسخه &#x2780; افزوده خواهند شد + انتشار نسخه رسمی :</strong>
+<br>&#x25A3; پایه ای با برنامه نویسی خلاصه تر و سریعتر
+<br>&#x25A3; حذف و اضافه کردن عکس پروفایل
+<br>&#x25A3; عملیات ارسال رگباری
+<br>&#x25A3; چک کردن گروه‌ها و ثبت مجدد لیست امار
+</h4>
+<br>
+<h3 dir="rtl">در آینده :</h3>
+<hr>
+<h4 dir="rtl"><strong>امکاناتی که پروژه تبلیغ‌گر  بعد ها به خود خواهد دید</strong>
+<br>&#x25A3; تعیین حد مجاز برای عضویت در گروه ها
+<br>&#x25A3; خارج شدن از گروه در صورت اسپم
+<br>&#x25A3; مسدود کردن کاربر در صورت اسپم
+<br>&#x25A2; تغییر شماره توسط مدیر
+<br>&#x25A2; حذف حساب کاربری تبلیغ‎گر توسط مدیر
+<br>&#x25A2; افزودن و یا تغییر ایمیل تایید دو مرحله ای
+<br>&#x25A2; غیر فعال کردن دیگر نسشت ها
+<br>&#x25A2; عضویت در گروه ها با حداقل و یا حداکثر ظرفیت مشخص
+<br>&#x25A2; خارج شدن از گروه در صورت عدم فعالیت در بازه زمانی مشخص
+<br>&#x25A2; فرستادن نوع خاصی از رسانه دریافت شده به گروه مدیریت
+<br>&#x25A2; ربات کمک رسان با قابلیت سازماندهی(ارسال پیام در زمان خاص,کیبورد شیشه ای)
+<br>&#x25A2; سازماندهی چند تبلیغ‌گر جهت جلوگیری از عضویت در گروه های یکسان
+<br>&#x25A2; فرستادن پیام ها از یک گفت و گوی خصوصی خاص
+<br> .
+<br> .
+<br> .
+</h4>
+<br>
+<h4 dir="rtl"><strong>🆓بهترین سرور‌های رایگان</strong>
+<div align="center">
+    <a href="https://codeanywhere.com/">
+        <img src="http://upir.ir/951/guest/codeanywhere.png" width="150">
+    </a>
+    <a href="https://www.c9.io/">
+        <img src="http://upir.ir/951/guest/c9.png" hspace="20" width="150">
+    </a>
+    <a href="https://codenvy.io/dashboard/">
+        <img src="http://upir.ir/951/guest/codenvy.png" hspace="20" width="150">
+    </a>   
+</div>
+<br>
+<h2 dir="rtl">پشتیبانی
+<hr>
+<h4 dir="rtl">پذیرای انتقادات وپیشنهاداتان هستیم ♚ NajiTeam ♚ <a href="https://telegram.me/i_naji"> @i_naji </a> <a href="https://telegram.me/Naji_MessengerRobot"> @Naji_MessengerRobot</a>
+<br>راهنمای استفاده از تبلیغ‌گر بسیار ساده و قابل درک است<br>فیلم آموزشی نصب و اطلاع از آخرین اخبار تبلیغ‌گر در کانال ما 
+<a href="https://telegram.me/i_advertiser"> @i_advertiser</a>
+</h4>
diff --git a/bot b/bot
new file mode 100644
index 0000000..f857696
--- /dev/null
+++ b/bot
@@ -0,0 +1,268 @@
+#!/usr/bin/env bash
+
+## VARIABLES
+THIS_DIR=$(cd "$(dirname "$0")"; pwd)
+TDCLI='https://valtman.name/files/telegram-cli-1222'
+
+## Print Colorful
+# Print text in red
+prtred() {
+  printf '\e[1;31m%s\n\e[0;39;49m' "$@"
+}
+# Print text in green
+prtgrn() {
+  printf '\e[1;32m%s\n\e[0;39;49m' "$@"
+}
+# Print text in brown
+prtbrown() {
+  printf '\e[1;33m%s\n\e[0;39;49m' "$@"
+}
+# update data to the last version
+update() {
+  git fetch --all && git reset --hard origin/persian && git pull origin persian && chmod +x bot
+    prtgrn "
+      بروزرسانی اطلاعات با موفقیت انجام شد <<
+  >> Bot's source successfully updated
+"
+}
+# Create a new Bot
+create() {
+  name=bot
+  if [[ -e $name.lua ]] ; then
+      i=1
+      while [[ -e $name-$i.lua ]] ; do
+          let i++
+      done
+      name=$name-$i
+  fi
+  cat bot.lua >> "$name".lua
+  sed -i 's/BOT-ID/'$i'/g' "$name".lua
+    prtgrn "
+     ربات شماره "$i" ساخته شد <<
+  : رباتتان را با فرمان زیر اجرا کنید
+>> new bot seccessfuly created
+       bot number "$i"
+      run your bot by :"
+prtred "
+       ./bot "$i"
+"
+}
+# Create a new Bot manually
+createmanual() {
+   prtgrn '
+        برای ساخت ربات با شماره دلخواه، شماره دلخواه خود را وارد کنید <<
+  >> To creating a new bot manually, Inter the BOT-ID :
+'
+  read -rp ' ' ID
+    if [[ -e bot-"$ID".lua ]] ; then
+      prtred '
+     شماره ربات وارد شده از قبل وجود دارد <<
+  >> There is a bot with this number ID
+'
+      exit
+    else
+      if [[ "$ID" =~ ^[0-9]+$ ]] ; then
+        cat bot.lua >> bot-"$ID".lua
+        sed -i 's/BOT-ID/'$ID'/g' bot-"$ID".lua
+        prtgrn "
+     ربات شماره "$ID" ساخته شد <<
+    : رباتتان را با فرمان زیر اجرا کنید
+  >> new bot seccessfuly created
+       bot number "$ID"
+      run your bot by :"
+        prtred "
+             ./bot "$ID"
+      "
+      else
+        prtred "
+     شماره ربات را وارد کنید -- عدد
+  Inter the bot number --integer
+    "
+        exit
+      fi
+    fi
+}
+# Reset data to the last update
+fix() {
+  git reset --hard FETCH_HEAD
+  prtgrn '
+  بازیابی اطلاعات به آخرین آپدیت انجام شد <<
+  >> Database Reseted and Fixed
+'
+}
+# autolauncher
+autolaunch() {
+  while true ; do
+    for tablighgar in bot-*.lua ; do
+      tab="${tablighgar%.*}"
+      ltab="${tab/-/ }"
+      tmux kill-session -t $tab
+      for tg in ~/.telegram-cli/$tab/data/* ; do
+        rm -rf $tg/*
+      done
+      TMUX= tmux new-session -d -s $tab "./$ltab"
+      tmux detach -s $tab
+    done
+    echo -e " \n\e[1;32mربات ها راه اندازی شدند << \e[1;34m| Naji |\e[1;32m>> Bots are Running\n\e[0;39;49m"
+    sleep 1200
+  done 
+}
+# clear a bot
+clear() {
+  sudo service redis-server start
+  prtgrn '
+       : شماره شناسه تبلیغ‌گری که می‌خواهید پاک کنید را وارد کنید  <<
+  >> Inter the BOT-ID,that you wanna delete :
+'
+  read -rp ' ' ID
+  rm -rf ~/.telegram-cli/bot-"$ID"/data
+  rm -rf bot-"$ID".lua
+  redis-cli --raw keys "bot"$ID* | xargs redis-cli del
+  prtgrn '
+     ربات شماره '$ID' با موفقیت حذف شد <<
+  >> Bot number '$ID' seccessfuly deleted.
+'
+  exit
+}
+# install Bot
+install() {
+  prtgrn '
+         آیا قصد نصب پیش نیاز های ربات تبلیغ‌گر را دارید؟ بله|خیر <<
+  >> Do you want to install Essentials of Bot? (Y/N):
+'
+  read -rp ' ' install
+  case "$install" in
+    Y|y|بله)
+      prtgrn "
+         telegram-cli بارگیری <<
+ >> Fetching $TDCLI
+"
+      wget "$TDCLI" -O telegram-cli
+      chmod +x telegram-cli
+      prtgrn "
+     ارتقای اطلاعات قدیمی <<
+ >> Updating old packages
+"
+      sudo apt-get -y update && sudo apt-get -y upgrade 
+      prtgrn "
+        نصب بسته های پیش نیازی <<
+ >> Installing Essentials packages
+"
+      sudo apt-get --force-yes install git wget screen tmux libconfig9 libevent-dev libjansson4 libstdc++6 lua-socket lua5.2 liblua5.2 make unzip redis-server software-properties-common g++
+      sudo apt-get -y update && sudo apt-get -y upgrade
+      sudo add-apt-repository -y ppa:ubuntu-toolchain-r/test && sudo apt-get update && sudo apt-get install -y gcc-4.9 g++-4.9 && sudo update-alternatives —install /usr/bin/gcc gcc /usr/bin/gcc-4.9 60 —slave /usr/bin/g++ g++ /usr/bin/g++-4.9
+      prtgrn "
+ ارتقای بسته های نصب شده <<
+ >> Updating packages
+"
+      sudo apt-get -y update && sudo apt-get -y upgrade && sudo apt-get -y dist-upgrade && sudo apt-get -y autoremove
+      prtgrn "
+      redis راه اندازی مجدد  <<
+ >> Restarting redis service
+"
+      sudo service redis-server restart
+      prtgrn '
+      همگام سازی با جدیدترین نسخه تبلیغ‌گر << 
+ >> Fetching latest Bot source code
+ '
+      git pull
+      prtgrn '
+      نصب پیش نیاز های ربات تبلیغ‌گر با موفقیت انجام شد << 
+ >> Essentials of Tablighgar Bot successfully installed!
+ '
+      printf '\e[1;33mبسازید\e[1;32m ./bot create \e[1;33mربات تبلیغ‌گر خود را با دستور <<\e[1;33m%s\n >>Create Your bot with\e[1;32m ./bot create\e[0;39;49m%s\n'
+    ;;
+    N|n|خیر)
+      prtbrown '
+        لغو عملیات
+ Canceling the operation
+ '
+    ;;
+    *)
+      prtred '
+    دستور اشتباه
+  Wrong command
+ '
+      install
+    ;;
+  esac
+}
+# How to use this script
+usage() {
+printf "\e[1;36m"
+  cat <<EOF
+  
+                    $0 [موارد استفاده  : [گزینه ها <<
+                                        : گزینه ها
+        شماره             راه اندازی ربات با این شماره 
+  راه‌اندازی انتی کرش ربات‌با‌این‌شماره            aشماره
+   بازیابی اطلاعات از اخرین بروزرسانی             fix
+    نصب پیش نیاز های ربات تبلیغ‌گر           install
+      بروزرسانی به آخرین نسخه ربات            update
+                 ساخت ربات جدید           create
+       ساخت ربات جدید بصورت دستی        createmanual
+                   نمایش این متن            help
+   راه‌اندازی تمام ربات ها هر 20 دقیقه          autolaunch
+                  
+>> Usage: $0 [options]
+    Options:
+      createmanual      Create a new Bot manually
+      autolaunch        Launch all bots every 20 mins
+      NUMBER            Start bot whit this ID number
+      aNUMBER           Start bot whit this ID number in anticrash mod
+      install           Install of Bot
+      create            Create a new Bot
+      update            Update bot source code
+      help              Print this message
+      fix               Reseting data
+EOF
+printf "%s\n\e[0;39;49m"
+}
+## MAIN ------------------------------------------------------------------------
+# Make sure this script run inside Bot directory
+cd "$THIS_DIR" || exit
+case $1 in
+  update)
+    update
+  ;;
+  create)
+    create
+  ;;
+  install)
+    install
+  ;;
+  fix)
+    fix
+  ;;
+  autolaunch)
+    autolaunch
+  ;;
+  help)
+    usage
+  ;;
+  createmanual)
+    createmanual
+  ;;
+  a*)
+    id="${1/a/}"
+    if [ -a "$THIS_DIR"/bot-"$id".lua ]; then
+      screen -x -s bot-"$id" quit
+      while true ; do
+        screen -s bot-"$id" ./telegram-cli -p bot-"$id" -s bot-"$id".lua
+        sleep 10
+      done
+    else
+      usage
+    fi
+  ;;
+  clr)
+    clear
+  ;;
+  *)
+    if [ -a "$THIS_DIR"/bot-"$1".lua ]; then
+      ./telegram-cli -p bot-"$1" -s bot-"$1".lua
+    else
+    usage
+    fi
+  ;;
+esac
diff --git a/bot.lua b/bot.lua
new file mode 100644
index 0000000..51bdd25
--- /dev/null
+++ b/bot.lua
@@ -0,0 +1,702 @@
+redis = (loadfile "redis.lua")()
+redis = redis.connect('127.0.0.1', 6379)
+
+function dl_cb(arg, data)
+end
+function get_admin ()
+	if redis:get('botBOT-IDadminset') then
+		return true
+	else
+   		print("\n\27[32m  لازمه کارکرد صحیح ، فرامین و امورات مدیریتی ربات تبلیغ گر <<\n                    تعریف کاربری به عنوان مدیر است\n\27[34m                   ایدی خود را به عنوان مدیر وارد کنید\n\27[32m    شما می توانید از ربات زیر شناسه عددی خود را بدست اورید\n\27[34m        ربات:       @id_ProBot")
+    		print("\n\27[32m >> Tabchi Bot need a fullaccess user (ADMIN)\n\27[34m Imput Your ID as the ADMIN\n\27[32m You can get your ID of this bot\n\27[34m                 @id_ProBot")
+    		print("\n\27[36m                      : شناسه عددی ادمین را وارد کنید << \n >> Imput the Admin ID :\n\27[31m                 ")
+    		admin=io.read()
+		redis:del("botBOT-IDadmin")
+    		redis:sadd("botBOT-IDadmin", admin)
+		redis:set('botBOT-IDadminset',true)
+  	end
+  	return print("\n\27[36m     ADMIN ID |\27[32m ".. admin .." \27[36m| شناسه ادمین")
+end
+function get_bot (i, naji)
+	function bot_info (i, naji)
+		redis:set("botBOT-IDid",naji.id_)
+		if naji.first_name_ then
+			redis:set("botBOT-IDfname",naji.first_name_)
+		end
+		if naji.last_name_ then
+			redis:set("botBOT-IDlanme",naji.last_name_)
+		end
+		redis:set("botBOT-IDnum",naji.phone_number_)
+		return naji.id_
+	end
+	tdcli_function ({ID = "GetMe",}, bot_info, nil)
+end
+function reload(chat_id,msg_id)
+	loadfile("./bot-BOT-ID.lua")()
+	send(chat_id, msg_id, "<i>با موفقیت انجام شد.</i>")
+end
+function is_naji(msg)
+    local var = false
+	local hash = 'botBOT-IDadmin'
+	local user = msg.sender_user_id_
+    local Naji = redis:sismember(hash, user)
+	if Naji then
+		var = true
+	end
+	return var
+end
+function writefile(filename, input)
+	local file = io.open(filename, "w")
+	file:write(input)
+	file:flush()
+	file:close()
+	return true
+end
+function process_join(i, naji)
+	if naji.code_ == 429 then
+		local message = tostring(naji.message_)
+		local Time = message:match('%d+')
+		redis:setex("botBOT-IDmaxjoin", tonumber(Time), true)
+	else
+		redis:srem("botBOT-IDgoodlinks", i.link)
+		redis:sadd("botBOT-IDsavedlinks", i.link)
+	end
+end
+function process_link(i, naji)
+	if (naji.is_group_ or naji.is_supergroup_channel_) then
+		redis:srem("botBOT-IDwaitelinks", i.link)
+		redis:sadd("botBOT-IDgoodlinks", i.link)
+	elseif naji.code_ == 429 then
+		local message = tostring(naji.message_)
+		local Time = message:match('%d+')
+		redis:setex("botBOT-IDmaxlink", tonumber(Time), true)
+	else
+		redis:srem("botBOT-IDwaitelinks", i.link)
+	end
+end
+function find_link(text)
+	if text:match("https://telegram.me/joinchat/%S+") or text:match("https://t.me/joinchat/%S+") or text:match("https://telegram.dog/joinchat/%S+") then
+		local text = text:gsub("t.me", "telegram.me")
+		local text = text:gsub("telegram.dog", "telegram.me")
+		for link in text:gmatch("(https://telegram.me/joinchat/%S+)") do
+			if not redis:sismember("botBOT-IDalllinks", link) then
+				redis:sadd("botBOT-IDwaitelinks", link)
+				redis:sadd("botBOT-IDalllinks", link)
+			end
+		end
+	end
+end
+function add(id)
+	local Id = tostring(id)
+	if not redis:sismember("botBOT-IDall", id) then
+		if Id:match("^(%d+)$") then
+			redis:sadd("botBOT-IDusers", id)
+			redis:sadd("botBOT-IDall", id)
+		elseif Id:match("^-100") then
+			redis:sadd("botBOT-IDsupergroups", id)
+			redis:sadd("botBOT-IDall", id)
+		else
+			redis:sadd("botBOT-IDgroups", id)
+			redis:sadd("botBOT-IDall", id)
+		end
+	end
+	return true
+end
+function rem(id)
+	local Id = tostring(id)
+	if redis:sismember("botBOT-IDall", id) then
+		if Id:match("^(%d+)$") then
+			redis:srem("botBOT-IDusers", id)
+			redis:srem("botBOT-IDall", id)
+		elseif Id:match("^-100") then
+			redis:srem("botBOT-IDsupergroups", id)
+			redis:srem("botBOT-IDall", id)
+		else
+			redis:srem("botBOT-IDgroups", id)
+			redis:srem("botBOT-IDall", id)
+		end
+	end
+	return true
+end
+function send(chat_id, msg_id, text)
+	tdcli_function ({
+		ID = "SendMessage",
+		chat_id_ = chat_id,
+		reply_to_message_id_ = msg_id,
+		disable_notification_ = 1,
+		from_background_ = 1,
+		reply_markup_ = nil,
+		input_message_content_ = {
+			ID = "InputMessageText",
+			text_ = text,
+			disable_web_page_preview_ = 1,
+			clear_draft_ = 0,
+			entities_ = {},
+			parse_mode_ = {ID = "TextParseModeHTML"},
+		},
+	}, dl_cb, nil)
+end
+get_admin()
+function tdcli_update_callback(data)
+	if data.ID == "UpdateNewMessage" then
+		if not redis:get("botBOT-IDmaxlink") then
+			if redis:scard("botBOT-IDwaitelinks") ~= 0 then
+				local links = redis:smembers("botBOT-IDwaitelinks")
+				for x,y in pairs(links) do
+					if x == 11 then redis:setex("botBOT-IDmaxlink", 60, true) return end
+					tdcli_function({ID = "CheckChatInviteLink",invite_link_ = y},process_link, {link=y})
+				end
+			end
+		end
+		if not redis:get("botBOT-IDmaxjoin") then
+			if redis:scard("botBOT-IDgoodlinks") ~= 0 then 
+				local links = redis:smembers("botBOT-IDgoodlinks")
+				for x,y in pairs(links) do
+					tdcli_function({ID = "ImportChatInviteLink",invite_link_ = y},process_join, {link=y})
+					if x == 5 then redis:setex("botBOT-IDmaxjoin", 60, true) return end
+				end
+			end
+		end
+		local msg = data.message_
+		local bot_id = redis:get("botBOT-IDid") or get_bot()
+		if (msg.sender_user_id_ == 777000 or msg.sender_user_id_ == 178220800) then
+			for k,v in pairs(redis:smembers('botBOT-IDadmin')) do
+				tdcli_function({
+					ID = "ForwardMessages",
+					chat_id_ = v,
+					from_chat_id_ = msg.chat_id_,
+					message_ids_ = {[0] = msg.id_},
+					disable_notification_ = 0,
+					from_background_ = 1
+				}, dl_cb, nil)
+			end
+		end
+		if tostring(msg.chat_id_):match("^(%d+)") then
+			if not redis:sismember("botBOT-IDall", msg.chat_id_) then
+				redis:sadd("botBOT-IDusers", msg.chat_id_)
+				redis:sadd("botBOT-IDall", msg.chat_id_)
+			end
+		end
+		add(msg.chat_id_)
+		if msg.date_ < os.time() - 150 then
+			return false
+		end
+		if msg.content_.ID == "MessageText" then
+			local text = msg.content_.text_
+			local matches
+			find_link(text)
+			if is_naji(msg) then
+				if text:match("^(افزودن مدیر) (%d+)$") then
+					local matches = text:match("%d+")
+					if redis:sismember('botBOT-IDadmin', matches) then
+						return send(msg.chat_id_, msg.id_, "<i>کاربر مورد نظر در حال حاضر مدیر است.</i>")
+					elseif redis:sismember('botBOT-IDmod', msg.sender_user_id_) then
+						return send(msg.chat_id_, msg.id_, "شما دسترسی ندارید.")
+					else
+						redis:sadd('botBOT-IDadmin', matches)
+						redis:sadd('botBOT-IDmod', matches)
+						return send(msg.chat_id_, msg.id_, "<i>مقام کاربر به مدیر ارتقا یافت</i>")
+					end
+				elseif text:match("^(افزودن مدیرکل) (%d+)$") then
+					local matches = text:match("%d+")
+					if redis:sismember('botBOT-IDmod',msg.sender_user_id_) then
+						return send(msg.chat_id_, msg.id_, "شما دسترسی ندارید.")
+					end
+					if redis:sismember('botBOT-IDmod', matches) then
+						redis:srem("botBOT-IDmod",matches)
+						redis:sadd('botBOT-IDadmin'..tostring(matches),msg.sender_user_id_)
+						return send(msg.chat_id_, msg.id_, "مقام کاربر به مدیریت کل ارتقا یافت .")
+					elseif redis:sismember('botBOT-IDadmin',matches) then
+						return send(msg.chat_id_, msg.id_, 'درحال حاضر مدیر هستند.')
+					else
+						redis:sadd('botBOT-IDadmin', matches)
+						redis:sadd('botBOT-IDadmin'..tostring(matches),msg.sender_user_id_)
+						return send(msg.chat_id_, msg.id_, "کاربر به مقام مدیرکل منصوب شد.")
+					end
+				elseif text:match("^(حذف مدیر) (%d+)$") then
+					local matches = text:match("%d+")
+					if redis:sismember('botBOT-IDmod', msg.sender_user_id_) then
+						if tonumber(matches) == msg.sender_user_id_ then
+								redis:srem('botBOT-IDadmin', msg.sender_user_id_)
+								redis:srem('botBOT-IDmod', msg.sender_user_id_)
+							return send(msg.chat_id_, msg.id_, "شما دیگر مدیر نیستید.")
+						end
+						return send(msg.chat_id_, msg.id_, "شما دسترسی ندارید.")
+					end
+					if redis:sismember('botBOT-IDadmin', matches) then
+						if  redis:sismember('botBOT-IDadmin'..msg.sender_user_id_ ,matches) then
+							return send(msg.chat_id_, msg.id_, "شما نمی توانید مدیری که به شما مقام داده را عزل کنید.")
+						end
+						redis:srem('botBOT-IDadmin', matches)
+						redis:srem('botBOT-IDmod', matches)
+						return send(msg.chat_id_, msg.id_, "کاربر از مقام مدیریت خلع شد.")
+					end
+					return send(msg.chat_id_, msg.id_, "کاربر مورد نظر مدیر نمی باشد.")
+				elseif text:match("^(تازه سازی ربات)$") then
+					get_bot()
+					return send(msg.chat_id_, msg.id_, "<i>مشخصات فردی ربات بروز شد.</i>")
+				elseif text:match("ریپورت") then
+					tdcli_function ({
+						ID = "SendBotStartMessage",
+						bot_user_id_ = 178220800,
+						chat_id_ = 178220800,
+						parameter_ = 'start'
+					}, dl_cb, nil)
+				elseif text:match("^(/reload)$") then
+					return reload(msg.chat_id_,msg.id_)
+				elseif text:match("^بروزرسانی ربات$") then
+					io.popen("git fetch --all && git reset --hard origin/persian && git pull origin persian && chmod +x bot"):read("*all")
+					local text,ok = io.open("bot.lua",'r'):read('*a'):gsub("BOT%-ID",BOT-ID)
+					io.open("bot-BOT-ID.lua",'w'):write(text):close()
+					return reload(msg.chat_id_,msg.id_)
+				elseif text:match("^همگام سازی با تبچی$") then
+					local botid = BOT-ID - 1
+					redis:sunionstore("botBOT-IDall","tabchi:"..tostring(botid)..":all")
+					redis:sunionstore("botBOT-IDusers","tabchi:"..tostring(botid)..":pvis")
+					redis:sunionstore("botBOT-IDgroups","tabchi:"..tostring(botid)..":groups")
+					redis:sunionstore("botBOT-IDsupergroups","tabchi:"..tostring(botid)..":channels")
+					redis:sunionstore("botBOT-IDsavedlinks","tabchi:"..tostring(botid)..":savedlinks")
+					return send(msg.chat_id_, msg.id_, "<b>همگام سازی اطلاعات با تبچی شماره</b><code> "..tostring(botid).." </code><b>انجام شد.</b>")
+				elseif text:match("^(لیست) (.*)$") then
+					local matches = text:match("^لیست (.*)$")
+					local naji
+					if matches == "مخاطبین" then
+						return tdcli_function({
+							ID = "SearchContacts",
+							query_ = nil,
+							limit_ = 999999999
+						},
+						function (I, Naji)
+							local count = Naji.total_count_
+							local text = "مخاطبین : \n"
+							for i =0 , tonumber(count) - 1 do
+								local user = Naji.users_[i]
+								local firstname = user.first_name_ or ""
+								local lastname = user.last_name_ or ""
+								local fullname = firstname .. " " .. lastname
+								text = tostring(text) .. tostring(i) .. ". " .. tostring(fullname) .. " [" .. tostring(user.id_) .. "] = " .. tostring(user.phone_number_) .. "  \n"
+							end
+							writefile("botBOT-ID_contacts.txt", text)
+							tdcli_function ({
+								ID = "SendMessage",
+								chat_id_ = I.chat_id,
+								reply_to_message_id_ = 0,
+								disable_notification_ = 0,
+								from_background_ = 1,
+								reply_markup_ = nil,
+								input_message_content_ = {ID = "InputMessageDocument",
+								document_ = {ID = "InputFileLocal",
+								path_ = "botBOT-ID_contacts.txt"},
+								caption_ = "مخاطبین تبلیغ‌گر شماره BOT-ID"}
+							}, dl_cb, nil)
+							return io.popen("rm -rf botBOT-ID_contacts.txt"):read("*all")
+						end, {chat_id = msg.chat_id_})
+					elseif matches == "پاسخ های خودکار" then
+						local text = "<i>لیست پاسخ های خودکار :</i>\n\n"
+						local answers = redis:smembers("botBOT-IDanswerslist")
+						for k,v in pairs(answers) do
+							text = tostring(text) .. "<i>l" .. tostring(k) .. "l</i>  " .. tostring(v) .. " : " .. tostring(redis:hget("botBOT-IDanswers", v)) .. "\n"
+						end
+						if redis:scard('botBOT-IDanswerslist') == 0  then text = "<code>       EMPTY</code>" end
+						return send(msg.chat_id_, msg.id_, text)
+					elseif matches == "مسدود" then
+						naji = "botBOT-IDblockedusers"
+					elseif matches == "شخصی" then
+						naji = "botBOT-IDusers"
+					elseif matches == "گروه" then
+						naji = "botBOT-IDgroups"
+					elseif matches == "سوپرگروه" then
+						naji = "botBOT-IDsupergroups"
+					elseif matches == "لینک" then
+						naji = "botBOT-IDsavedlinks"
+					elseif matches == "مدیر" then
+						naji = "botBOT-IDadmin"
+					else
+						return true
+					end
+					local list =  redis:smembers(naji)
+					local text = tostring(matches).." : \n"
+					for i, v in pairs(list) do
+						text = tostring(text) .. tostring(i) .. "-  " .. tostring(v).."\n"
+					end
+					writefile(tostring(naji)..".txt", text)
+					tdcli_function ({
+						ID = "SendMessage",
+						chat_id_ = msg.chat_id_,
+						reply_to_message_id_ = 0,
+						disable_notification_ = 0,
+						from_background_ = 1,
+						reply_markup_ = nil,
+						input_message_content_ = {ID = "InputMessageDocument",
+							document_ = {ID = "InputFileLocal",
+							path_ = tostring(naji)..".txt"},
+						caption_ = "لیست "..tostring(matches).." های تبلیغ گر شماره BOT-ID"}
+					}, dl_cb, nil)
+					return io.popen("rm -rf "..tostring(naji)..".txt"):read("*all")
+				elseif text:match("^(وضعیت مشاهده) (.*)$") then
+					local matches = text:match("^وضعیت مشاهده (.*)$")
+					if matches == "روشن" then
+						redis:set("botBOT-IDmarkread", true)
+						return send(msg.chat_id_, msg.id_, "<i>وضعیت پیام ها  >>  خوانده شده ✔️✔️\n</i><code>(تیک دوم فعال)</code>")
+					elseif matches == "خاموش" then
+						redis:del("botBOT-IDmarkread")
+						return send(msg.chat_id_, msg.id_, "<i>وضعیت پیام ها  >>  خوانده نشده ✔️\n</i><code>(بدون تیک دوم)</code>")
+					end 
+				elseif text:match("^(افزودن با پیام) (.*)$") then
+					local matches = text:match("^افزودن با پیام (.*)$")
+					if matches == "روشن" then
+						redis:set("botBOT-IDaddmsg", true)
+						return send(msg.chat_id_, msg.id_, "<i>پیام افزودن مخاطب فعال شد</i>")
+					elseif matches == "خاموش" then
+						redis:del("botBOT-IDaddmsg")
+						return send(msg.chat_id_, msg.id_, "<i>پیام افزودن مخاطب غیرفعال شد</i>")
+					end
+				elseif text:match("^(افزودن با شماره) (.*)$") then
+					local matches = text:match("افزودن با شماره (.*)$")
+					if matches == "روشن" then
+						redis:set("botBOT-IDaddcontact", true)
+						return send(msg.chat_id_, msg.id_, "<i>ارسال شماره هنگام افزودن مخاطب فعال شد</i>")
+					elseif matches == "خاموش" then
+						redis:del("botBOT-IDaddcontact")
+						return send(msg.chat_id_, msg.id_, "<i>ارسال شماره هنگام افزودن مخاطب غیرفعال شد</i>")
+					end
+				elseif text:match("^(تنظیم پیام افزودن مخاطب) (.*)") then
+					local matches = text:match("^تنظیم پیام افزودن مخاطب (.*)")
+					redis:set("botBOT-IDaddmsgtext", matches)
+					return send(msg.chat_id_, msg.id_, "<i>پیام افزودن مخاطب ثبت  شد </i>:\n🔹 "..matches.." 🔹")
+				elseif text:match('^(تنظیم جواب) "(.*)" (.*)') then
+					local txt, answer = text:match('^تنظیم جواب "(.*)" (.*)')
+					redis:hset("botBOT-IDanswers", txt, answer)
+					redis:sadd("botBOT-IDanswerslist", txt)
+					return send(msg.chat_id_, msg.id_, "<i>جواب برای | </i>" .. tostring(txt) .. "<i> | تنظیم شد به :</i>\n" .. tostring(answer))
+				elseif text:match("^(حذف جواب) (.*)") then
+					local matches = text:match("^حذف جواب (.*)")
+					redis:hdel("botBOT-IDanswers", matches)
+					redis:srem("botBOT-IDanswerslist", matches)
+					return send(msg.chat_id_, msg.id_, "<i>جواب برای | </i>" .. tostring(matches) .. "<i> | از لیست جواب های خودکار پاک شد.</i>")
+				elseif text:match("^(پاسخگوی خودکار) (.*)$") then
+					local matches = text:match("^پاسخگوی خودکار (.*)$")
+					if matches == "روشن" then
+						redis:set("botBOT-IDautoanswer", true)
+						return send(msg.chat_id_, 0, "<i>پاسخگویی خودکار تبلیغ گر فعال شد</i>")
+					elseif matches == "خاموش" then
+						redis:del("botBOT-IDautoanswer")
+						return send(msg.chat_id_, 0, "<i>حالت پاسخگویی خودکار تبلیغ گر غیر فعال شد.</i>")
+					end
+				elseif text:match("^(تازه سازی)$")then
+					local list = {redis:smembers("botBOT-IDsupergroups"),redis:smembers("botBOT-IDgroups")}
+					tdcli_function({
+						ID = "SearchContacts",
+						query_ = nil,
+						limit_ = 999999999
+					}, function (i, naji)
+						redis:set("botBOT-IDcontacts", naji.total_count_)
+					end, nil)
+					for i, v in pairs(list) do
+							for a, b in pairs(v) do 
+								tdcli_function ({
+									ID = "GetChatMember",
+									chat_id_ = b,
+									user_id_ = bot_id
+								}, function (i,naji)
+									if  naji.ID == "Error" then rem(i.id) 
+									end
+								end, {id=b})
+							end
+					end
+					return send(msg.chat_id_,msg.id_,"<i>تازه‌سازی آمار تبلیغ‌گر شماره </i><code> BOT-ID </code> با موفقیت انجام شد.")
+				elseif text:match("^(وضعیت)$") then
+					local s = redis:get("botBOT-IDmaxjoin") and redis:ttl("botBOT-IDmaxjoin") or 0
+					local ss = redis:get("botBOT-IDmaxlink") and redis:ttl("botBOT-IDmaxlink") or 0
+					local msgadd = redis:get("botBOT-IDaddmsg") and "☑️" or "❎"
+					local numadd = redis:get("botBOT-IDaddcontact") and "✅" or "❎"
+					local txtadd = redis:get("botBOT-IDaddmsgtext") or  "اد‌دی گلم خصوصی پیام بده"
+					local autoanswer = redis:get("botBOT-IDautoanswer") and "✅" or "❎"
+					local wlinks = redis:scard("botBOT-IDwaitelinks")
+					local glinks = redis:scard("botBOT-IDgoodlinks")
+					local links = redis:scard("botBOT-IDsavedlinks")
+					local txt = "<i>⚙️ وضعیت اجرایی تبلیغ‌گر</i><code> BOT-ID </code>⛓\n\n" .. tostring(autoanswer) .."<code> حالت پاسخگویی خودکار 🗣 </code>\n" .. tostring(numadd) .. "<code> افزودن مخاطب با شماره 📞 </code>\n" .. tostring(msgadd) .. "<code> افزودن مخاطب با پیام 🗞</code>\n〰〰〰ا〰〰〰\n<code>📄 پیام افزودن مخاطب :</code>\n📍 " .. tostring(txtadd) .. " 📍\n〰〰〰ا〰〰〰\n<code>📁 لینک های ذخیره شده : </code><b>" .. tostring(links) .. "</b>\n<code>⏲	لینک های در انتظار عضویت : </code><b>" .. tostring(glinks) .. "</b>\n🕖   <b>" .. tostring(s) .. " </b><code>ثانیه تا عضویت مجدد</code>\n<code>❄️ لینک های در انتظار تایید : </code><b>" .. tostring(wlinks) .. "</b>\n🕑️   <b>" .. tostring(ss) .. " </b><code>ثانیه تا تایید لینک مجدد</code>\n 😼 سازنده : @i_naji"
+					return send(msg.chat_id_, 0, txt)
+				elseif text:match("^(امار)$") or text:match("^(آمار)$") then
+					local gps = redis:scard("botBOT-IDgroups")
+					local sgps = redis:scard("botBOT-IDsupergroups")
+					local usrs = redis:scard("botBOT-IDusers")
+					local links = redis:scard("botBOT-IDsavedlinks")
+					local glinks = redis:scard("botBOT-IDgoodlinks")
+					local wlinks = redis:scard("botBOT-IDwaitelinks")
+					tdcli_function({
+						ID = "SearchContacts",
+						query_ = nil,
+						limit_ = 999999999
+					}, function (i, naji)
+					redis:set("botBOT-IDcontacts", naji.total_count_)
+					end, nil)
+					local contacts = redis:get("botBOT-IDcontacts")
+					local text = [[
+<i>📈 وضعیت و آمار تبلیغ گر 📊</i>
+          
+<code>👤 گفت و گو های شخصی : </code>
+<b>]] .. tostring(usrs) .. [[</b>
+<code>👥 گروها : </code>
+<b>]] .. tostring(gps) .. [[</b>
+<code>🌐 سوپر گروه ها : </code>
+<b>]] .. tostring(sgps) .. [[</b>
+<code>📖 مخاطبین دخیره شده : </code>
+<b>]] .. tostring(contacts)..[[</b>
+<code>📂 لینک های ذخیره شده : </code>
+<b>]] .. tostring(links)..[[</b>
+ 😼 سازنده : @i_naji]]
+					return send(msg.chat_id_, 0, text)
+				elseif (text:match("^(ارسال به) (.*)$") and msg.reply_to_message_id_ ~= 0) then
+					local matches = text:match("^ارسال به (.*)$")
+					local naji
+					if matches:match("^(همه)$") then
+						naji = "botBOT-IDall"
+					elseif matches:match("^(خصوصی)") then
+						naji = "botBOT-IDusers"
+					elseif matches:match("^(گروه)$") then
+						naji = "botBOT-IDgroups"
+					elseif matches:match("^(سوپرگروه)$") then
+						naji = "botBOT-IDsupergroups"
+					else
+						return true
+					end
+					local list = redis:smembers(naji)
+					local id = msg.reply_to_message_id_
+					for i, v in pairs(list) do
+						tdcli_function({
+							ID = "ForwardMessages",
+							chat_id_ = v,
+							from_chat_id_ = msg.chat_id_,
+							message_ids_ = {[0] = id},
+							disable_notification_ = 1,
+							from_background_ = 1
+						}, dl_cb, nil)
+					end
+					return send(msg.chat_id_, msg.id_, "<i>با موفقیت فرستاده شد</i>")
+				elseif text:match("^(ارسال به سوپرگروه) (.*)") then
+					local matches = text:match("^ارسال به سوپرگروه (.*)")
+					local dir = redis:smembers("botBOT-IDsupergroups")
+					for i, v in pairs(dir) do
+						tdcli_function ({
+							ID = "SendMessage",
+							chat_id_ = v,
+							reply_to_message_id_ = 0,
+							disable_notification_ = 0,
+							from_background_ = 1,
+							reply_markup_ = nil,
+							input_message_content_ = {
+								ID = "InputMessageText",
+								text_ = matches,
+								disable_web_page_preview_ = 1,
+								clear_draft_ = 0,
+								entities_ = {},
+							parse_mode_ = nil
+							},
+						}, dl_cb, nil)
+					end
+                    			return send(msg.chat_id_, msg.id_, "<i>با موفقیت فرستاده شد</i>")
+				elseif text:match("^(مسدودیت) (%d+)$") then
+					local matches = text:match("%d+")
+					rem(tonumber(matches))
+					redis:sadd("botBOT-IDblockedusers",matches)
+					tdcli_function ({
+						ID = "BlockUser",
+						user_id_ = tonumber(matches)
+					}, dl_cb, nil)
+					return send(msg.chat_id_, msg.id_, "<i>کاربر مورد نظر مسدود شد</i>")
+				elseif text:match("^(رفع مسدودیت) (%d+)$") then
+					local matches = text:match("%d+")
+					add(tonumber(matches))
+					redis:srem("botBOT-IDblockedusers",matches)
+					tdcli_function ({
+						ID = "UnblockUser",
+						user_id_ = tonumber(matches)
+					}, dl_cb, nil)
+					return send(msg.chat_id_, msg.id_, "<i>مسدودیت کاربر مورد نظر رفع شد.</i>")	
+				elseif text:match('^(تنظیم نام) "(.*)" (.*)') then
+					local fname, lname = text:match('^تنظیم نام "(.*)" (.*)')
+					tdcli_function ({
+						ID = "ChangeName",
+						first_name_ = fname,
+						last_name_ = lname
+					}, dl_cb, nil)
+					return send(msg.chat_id_, msg.id_, "<i>نام جدید با موفقیت ثبت شد.</i>")
+				elseif text:match("^(تنظیم نام کاربری) (.*)") then
+					local matches = text:match("^تنظیم نام کاربری (.*)")
+						tdcli_function ({
+						ID = "ChangeUsername",
+						username_ = tostring(matches)
+						}, dl_cb, nil)
+					return send(msg.chat_id_, 0, '<i>تلاش برای تنظیم نام کاربری...</i>')
+				elseif text:match("^(حذف نام کاربری)$") then
+					tdcli_function ({
+						ID = "ChangeUsername",
+						username_ = ""
+					}, dl_cb, nil)
+					return send(msg.chat_id_, 0, '<i>نام کاربری با موفقیت حذف شد.</i>')
+				elseif text:match('^(ارسال کن) "(.*)" (.*)') then
+					local id, txt = text:match('^ارسال کن "(.*)" (.*)')
+					send(id, 0, txt)
+					return send(msg.chat_id_, msg.id_, "<i>ارسال شد</i>")
+				elseif text:match("^(بگو) (.*)") then
+					local matches = text:match("^بگو (.*)")
+					return send(msg.chat_id_, 0, matches)
+				elseif text:match("^(شناسه من)$") then
+					return send(msg.chat_id_, msg.id_, "<i>" .. msg.sender_user_id_ .."</i>")
+				elseif text:match("^(ترک کردن) (.*)$") then
+					local matches = text:match("^ترک کردن (.*)$") 	
+					send(msg.chat_id_, msg.id_, 'تبلیغ‌گر از گروه مورد نظر خارج شد')
+					tdcli_function ({
+						ID = "ChangeChatMemberStatus",
+						chat_id_ = matches,
+						user_id_ = bot_id,
+						status_ = {ID = "ChatMemberStatusLeft"},
+					}, dl_cb, nil)
+					return rem(matches)
+				elseif text:match("^(افزودن به همه) (%d+)$") then
+					local matches = text:match("%d+")
+					local list = {redis:smembers("botBOT-IDgroups"),redis:smembers("botBOT-IDsupergroups")}
+					for a, b in pairs(list) do
+						for i, v in pairs(b) do 
+							tdcli_function ({
+								ID = "AddChatMember",
+								chat_id_ = v,
+								user_id_ = matches,
+								forward_limit_ =  50
+							}, dl_cb, nil)
+						end	
+					end
+					return send(msg.chat_id_, msg.id_, "<i>کاربر مورد نظر به تمام گروه های من دعوت شد</i>")
+				elseif (text:match("^(انلاین)$") and not msg.forward_info_)then
+					return tdcli_function({
+						ID = "ForwardMessages",
+						chat_id_ = msg.chat_id_,
+						from_chat_id_ = msg.chat_id_,
+						message_ids_ = {[0] = msg.id_},
+						disable_notification_ = 0,
+						from_background_ = 1
+					}, dl_cb, nil)
+				elseif text:match("^(راهنما)$") then
+					local txt = '📍راهنمای دستورات تبلیغ گر📍\n\nانلاین\n<i>اعلام وضعیت تبلیغ گر ✔️</i>\n<code>❤️ حتی اگر تبلیغ‌گر شما دچار محدودیت ارسال پیام شده باشد بایستی به این پیام پاسخ دهد❤️</code>\n/reload\n<i>l🔄 بارگذاری مجدد ربات 🔄l</i>\n<code>I⛔️عدم استفاده بی جهت⛔️I</code>\nبروزرسانی ربات\n<i>بروزرسانی ربات به آخرین نسخه و بارگذاری مجدد 🆕</i>\n\nافزودن مدیر شناسه\n<i>افزودن مدیر جدید با شناسه عددی داده شده 🛂</i>\n\nافزودن مدیرکل شناسه\n<i>افزودن مدیرکل جدید با شناسه عددی داده شده 🛂</i>\n\n<code>(⚠️ تفاوت مدیر و مدیر‌کل دسترسی به اعطا و یا گرفتن مقام مدیریت است⚠️)</code>\n\nحذف مدیر شناسه\n<i>حذف مدیر یا مدیرکل با شناسه عددی داده شده ✖️</i>\n\nترک گروه\n<i>خارج شدن از گروه و حذف آن از اطلاعات گروه ها 🏃</i>\n\nافزودن همه مخاطبین\n<i>افزودن حداکثر مخاطبین و افراد در گفت و گوهای شخصی به گروه ➕</i>\n\nشناسه من\n<i>دریافت شناسه خود 🆔</i>\n\nبگو متن\n<i>دریافت متن 🗣</i>\n\nارسال کن "شناسه" متن\n<i>ارسال متن به شناسه گروه یا کاربر داده شده 📤</i>\n\nتنظیم نام "نام" فامیل\n<i>تنظیم نام ربات ✏️</i>\n\nتازه سازی ربات\n<i>تازه‌سازی اطلاعات فردی ربات🎈</i>\n<code>(مورد استفاده در مواردی همچون پس از تنظیم نام📍جهت بروزکردن نام مخاطب اشتراکی تبلیغ‌گر📍)</code>\n\nتنظیم نام کاربری اسم\n<i>جایگزینی اسم با نام کاربری فعلی(محدود در بازه زمانی کوتاه) 🔄</i>\n\nحذف نام کاربری\n<i>حذف کردن نام کاربری ❎</i>\n\nافزودن با شماره روشن|خاموش\n<i>تغییر وضعیت اشتراک شماره تبلیغ‌گر در جواب شماره به اشتراک گذاشته شده 🔖</i>\n\nافزودن با پیام روشن|خاموش\n<i>تغییر وضعیت ارسال پیام در جواب شماره به اشتراک گذاشته شده ℹ️</i>\n\nتنظیم پیام افزودن مخاطب متن\n<i>تنظیم متن داده شده به عنوان جواب شماره به اشتراک گذاشته شده 📨</i>\n\nلیست مخاطبین|خصوصی|گروه|سوپرگروه|پاسخ های خودکار|لینک|مدیر\n<i>دریافت لیستی از مورد خواسته شده در قالب پرونده متنی یا پیام 📄</i>\n\nمسدودیت شناسه\n<i>مسدود‌کردن(بلاک) کاربر با شناسه داده شده از گفت و گوی خصوصی 🚫</i>\n\nرفع مسدودیت شناسه\n<i>رفع مسدودیت کاربر با شناسه داده شده 💢</i>\n\nوضعیت مشاهده روشن|خاموش 👁\n<i>تغییر وضعیت مشاهده پیام‌ها توسط تبلیغ‌گر (فعال و غیر‌فعال‌کردن تیک دوم)</i>\n\nامار\n<i>دریافت آمار و وضعیت تبلیغ گر 📊</i>\n\nوضعیت\n<i>دریافت وضعیت اجرایی تبلیغ‌گر⚙️</i>\n\nتازه سازی\n<i>تازه‌سازی آمار تبلیغ‌گر🚀</i>\n<code>🎃مورد استفاده حداکثر یک بار در روز🎃</code>\n\nارسال به همه|خصوصی|گروه|سوپرگروه\n<i>ارسال پیام جواب داده شده به مورد خواسته شده 📩</i>\n<code>(😄توصیه ما عدم استفاده از همه و خصوصی😄)</code>\n\nارسال به سوپرگروه متن\n<i>ارسال متن داده شده به همه سوپرگروه ها ✉️</i>\n<code>(😜توصیه ما استفاده و ادغام دستورات بگو و ارسال به سوپرگروه😜)</code>\n\nتنظیم جواب "متن" جواب\n<i>تنظیم جوابی به عنوان پاسخ خودکار به پیام وارد شده مطابق با متن باشد 📝</i>\n\nحذف جواب متن\n<i>حذف جواب مربوط به متن ✖️</i>\n\nپاسخگوی خودکار روشن|خاموش\n<i>تغییر وضعیت پاسخگویی خودکار تبلیغ گر به متن های تنظیم شده 📯</i>\n\nافزودن به همه شناسه\n<i>افزودن کابر با شناسه وارد شده به همه گروه و سوپرگروه ها ➕➕</i>\n\nترک کردن شناسه\n<i>عملیات ترک کردن با استفاده از شناسه گروه 🏃</i>\n\nراهنما\n<i>دریافت همین پیام 🆘</i>\n〰〰〰ا〰〰〰\nهمگام سازی با تبچی\n<code>همگام سازی اطلاعات تبلیغ گر با اطلاعات تبچی از قبل نصب شده 🔃 (جهت این امر حتما به ویدیو آموزشی کانال مراجعه کنید)</code>\n〰〰〰ا〰〰〰\nسازنده : @I_Naji \nکانال : @I_Advertiser\n<i>آدرس سورس تبلیغ گر (کاملا فارسی) :</i>\nhttps://github.com/i-Naji/tabchi/tree/persian\n<code>آخرین اخبار و رویداد های تبلیغ گر را در کانال ما پیگیری کنید.</code>'
+					return send(msg.chat_id_,msg.id_, txt)
+				elseif tostring(msg.chat_id_):match("^-") then
+					if text:match("^(ترک کردن)$") then
+						rem(msg.chat_id_)
+						return tdcli_function ({
+							ID = "ChangeChatMemberStatus",
+							chat_id_ = msg.chat_id_,
+							user_id_ = bot_id,
+							status_ = {ID = "ChatMemberStatusLeft"},
+						}, dl_cb, nil)
+					elseif text:match("^(افزودن همه مخاطبین)$") then
+						tdcli_function({
+							ID = "SearchContacts",
+							query_ = nil,
+							limit_ = 999999999
+						},function(i, naji)
+							local users, count = redis:smembers("botBOT-IDusers"), naji.total_count_
+							for n=0, tonumber(count) - 1 do
+								tdcli_function ({
+									ID = "AddChatMember",
+									chat_id_ = i.chat_id,
+									user_id_ = naji.users_[n].id_,
+									forward_limit_ = 50
+								},  dl_cb, nil)
+							end
+							for n=1, #users do
+								tdcli_function ({
+									ID = "AddChatMember",
+									chat_id_ = i.chat_id,
+									user_id_ = users[n],
+									forward_limit_ = 50
+								},  dl_cb, nil)
+							end
+						end, {chat_id=msg.chat_id_})
+						return send(msg.chat_id_, msg.id_, "<i>در حال افزودن مخاطبین به گروه ...</i>")
+					end
+				end
+			end
+			if redis:sismember("botBOT-IDanswerslist", text) then
+				if redis:get("botBOT-IDautoanswer") then
+					if msg.sender_user_id_ ~= bot_id then
+						local answer = redis:hget("botBOT-IDanswers", text)
+						send(msg.chat_id_, 0, answer)
+					end
+				end
+			end
+		elseif msg.content_.ID == "MessageContact" then
+			local id = msg.content_.contact_.user_id_
+			if not redis:sismember("botBOT-IDaddedcontacts",id) then
+				redis:sadd("botBOT-IDaddedcontacts",id)
+				local first = msg.content_.contact_.first_name_ or "-"
+				local last = msg.content_.contact_.last_name_ or "-"
+				local phone = msg.content_.contact_.phone_number_
+				local id = msg.content_.contact_.user_id_
+				tdcli_function ({
+					ID = "ImportContacts",
+					contacts_ = {[0] = {
+							phone_number_ = tostring(phone),
+							first_name_ = tostring(first),
+							last_name_ = tostring(last),
+							user_id_ = id
+						},
+					},
+				}, dl_cb, nil)
+				if redis:get("botBOT-IDaddcontact") and msg.sender_user_id_ ~= bot_id then
+					local fname = redis:get("botBOT-IDfname")
+					local lnasme = redis:get("botBOT-IDlname") or ""
+					local num = redis:get("botBOT-IDnum")
+					tdcli_function ({
+						ID = "SendMessage",
+						chat_id_ = msg.chat_id_,
+						reply_to_message_id_ = msg.id_,
+						disable_notification_ = 1,
+						from_background_ = 1,
+						reply_markup_ = nil,
+						input_message_content_ = {
+							ID = "InputMessageContact",
+							contact_ = {
+								ID = "Contact",
+								phone_number_ = num,
+								first_name_ = fname,
+								last_name_ = lname,
+								user_id_ = bot_id
+							},
+						},
+					}, dl_cb, nil)
+				end
+			end
+			if redis:get("botBOT-IDaddmsg") then
+				local answer = redis:get("botBOT-IDaddmsgtext") or "اددی گلم خصوصی پیام بده"
+				send(msg.chat_id_, msg.id_, answer)
+			end
+		elseif msg.content_.ID == "MessageChatDeleteMember" and msg.content_.id_ == bot_id then
+			return rem(msg.chat_id_)
+		elseif msg.content_.ID == "MessageChatJoinByLink" and msg.sender_user_id_ == bot_id then
+			return add(msg.chat_id_)
+		elseif msg.content_.ID == "MessageChatAddMembers" then
+			for i = 0, #msg.content_.members_ do
+				if msg.content_.members_[i].id_ == bot_id then
+					add(msg.chat_id_)
+				end
+			end
+		elseif msg.content_.caption_ then
+			return find_link(msg.content_.caption_)
+		end
+		if redis:get("botBOT-IDmarkread") then
+			tdcli_function ({
+				ID = "ViewMessages",
+				chat_id_ = msg.chat_id_,
+				message_ids_ = {[0] = msg.id_} 
+			}, dl_cb, nil)
+		end
+	elseif data.ID == "UpdateOption" and data.name_ == "my_id" then
+		tdcli_function ({
+			ID = "GetChats",
+			offset_order_ = 9223372036854775807,
+			offset_chat_id_ = 0,
+			limit_ = 20
+		}, dl_cb, nil)
+	end
+end
diff --git a/redis.lua b/redis.lua
new file mode 100644
index 0000000..77aea79
--- /dev/null
+++ b/redis.lua
@@ -0,0 +1,1140 @@
+local redis = {
+    _VERSION     = 'redis-lua 2.0.4',
+    _DESCRIPTION = 'A Lua client library for the redis key value storage system.',
+    _COPYRIGHT   = 'Copyright (C) 2009-2012 Daniele Alessandri',
+}
+
+-- The following line is used for backwards compatibility in order to keep the `Redis`
+-- global module name. Using `Redis` is now deprecated so you should explicitly assign
+-- the module to a local variable when requiring it: `local redis = require('redis')`.
+Redis = redis
+
+local unpack = _G.unpack or table.unpack
+local network, request, response = {}, {}, {}
+
+local defaults = {
+    host        = '127.0.0.1',
+    port        = 6379,
+    tcp_nodelay = true,
+    path        = nil
+}
+
+local function merge_defaults(parameters)
+    if parameters == nil then
+        parameters = {}
+    end
+    for k, v in pairs(defaults) do
+        if parameters[k] == nil then
+            parameters[k] = defaults[k]
+        end
+    end
+    return parameters
+end
+
+local function parse_boolean(v)
+    if v == '1' or v == 'true' or v == 'TRUE' then
+        return true
+    elseif v == '0' or v == 'false' or v == 'FALSE' then
+        return false
+    else
+        return nil
+    end
+end
+
+local function toboolean(value) return value == 1 end
+
+local function sort_request(client, command, key, params)
+    --[[ params = {
+        by    = 'weight_*',
+        get   = 'object_*',
+        limit = { 0, 10 },
+        sort  = 'desc',
+        alpha = true,
+    } ]]
+    local query = { key }
+
+    if params then
+        if params.by then
+            table.insert(query, 'BY')
+            table.insert(query, params.by)
+        end
+
+        if type(params.limit) == 'table' then
+            -- TODO: check for lower and upper limits
+            table.insert(query, 'LIMIT')
+            table.insert(query, params.limit[1])
+            table.insert(query, params.limit[2])
+        end
+
+        if params.get then
+            if (type(params.get) == 'table') then
+                for _, getarg in pairs(params.get) do
+                    table.insert(query, 'GET')
+                    table.insert(query, getarg)
+                end
+            else
+                table.insert(query, 'GET')
+                table.insert(query, params.get)
+            end
+        end
+
+        if params.sort then
+            table.insert(query, params.sort)
+        end
+
+        if params.alpha == true then
+            table.insert(query, 'ALPHA')
+        end
+
+        if params.store then
+            table.insert(query, 'STORE')
+            table.insert(query, params.store)
+        end
+    end
+
+    request.multibulk(client, command, query)
+end
+
+local function zset_range_request(client, command, ...)
+    local args, opts = {...}, { }
+
+    if #args >= 1 and type(args[#args]) == 'table' then
+        local options = table.remove(args, #args)
+        if options.withscores then
+            table.insert(opts, 'WITHSCORES')
+        end
+    end
+
+    for _, v in pairs(opts) do table.insert(args, v) end
+    request.multibulk(client, command, args)
+end
+
+local function zset_range_byscore_request(client, command, ...)
+    local args, opts = {...}, { }
+
+    if #args >= 1 and type(args[#args]) == 'table' then
+        local options = table.remove(args, #args)
+        if options.limit then
+            table.insert(opts, 'LIMIT')
+            table.insert(opts, options.limit.offset or options.limit[1])
+            table.insert(opts, options.limit.count or options.limit[2])
+        end
+        if options.withscores then
+            table.insert(opts, 'WITHSCORES')
+        end
+    end
+
+    for _, v in pairs(opts) do table.insert(args, v) end
+    request.multibulk(client, command, args)
+end
+
+local function zset_range_reply(reply, command, ...)
+    local args = {...}
+    local opts = args[4]
+    if opts and (opts.withscores or string.lower(tostring(opts)) == 'withscores') then
+        local new_reply = { }
+        for i = 1, #reply, 2 do
+            table.insert(new_reply, { reply[i], reply[i + 1] })
+        end
+        return new_reply
+    else
+        return reply
+    end
+end
+
+local function zset_store_request(client, command, ...)
+    local args, opts = {...}, { }
+
+    if #args >= 1 and type(args[#args]) == 'table' then
+        local options = table.remove(args, #args)
+        if options.weights and type(options.weights) == 'table' then
+            table.insert(opts, 'WEIGHTS')
+            for _, weight in ipairs(options.weights) do
+                table.insert(opts, weight)
+            end
+        end
+        if options.aggregate then
+            table.insert(opts, 'AGGREGATE')
+            table.insert(opts, options.aggregate)
+        end
+    end
+
+    for _, v in pairs(opts) do table.insert(args, v) end
+    request.multibulk(client, command, args)
+end
+
+local function mset_filter_args(client, command, ...)
+    local args, arguments = {...}, {}
+    if (#args == 1 and type(args[1]) == 'table') then
+        for k,v in pairs(args[1]) do
+            table.insert(arguments, k)
+            table.insert(arguments, v)
+        end
+    else
+        arguments = args
+    end
+    request.multibulk(client, command, arguments)
+end
+
+local function hash_multi_request_builder(builder_callback)
+    return function(client, command, ...)
+        local args, arguments = {...}, { }
+        if #args == 2 then
+            table.insert(arguments, args[1])
+            for k, v in pairs(args[2]) do
+                builder_callback(arguments, k, v)
+            end
+        else
+            arguments = args
+        end
+        request.multibulk(client, command, arguments)
+    end
+end
+
+local function parse_info(response)
+    local info = {}
+    local current = info
+
+    response:gsub('([^\r\n]*)\r\n', function(kv)
+        if kv == '' then return end
+
+        local section = kv:match('^# (%w+)$')
+        if section then
+            current = {}
+            info[section:lower()] = current
+            return
+        end
+
+        local k,v = kv:match(('([^:]*):([^:]*)'):rep(1))
+        if k:match('db%d+') then
+            current[k] = {}
+            v:gsub(',', function(dbkv)
+                local dbk,dbv = kv:match('([^:]*)=([^:]*)')
+                current[k][dbk] = dbv
+            end)
+        else
+            current[k] = v
+        end
+    end)
+
+    return info
+end
+
+local function load_methods(proto, commands)
+    local client = setmetatable ({}, getmetatable(proto))
+
+    for cmd, fn in pairs(commands) do
+        if type(fn) ~= 'function' then
+            redis.error('invalid type for command ' .. cmd .. '(must be a function)')
+        end
+        client[cmd] = fn
+    end
+
+    for i, v in pairs(proto) do
+        client[i] = v
+    end
+
+    return client
+end
+
+local function create_client(proto, client_socket, commands)
+    local client = load_methods(proto, commands)
+    client.error = redis.error
+    client.network = {
+        socket = client_socket,
+        read   = network.read,
+        write  = network.write,
+    }
+    client.requests = {
+        multibulk = request.multibulk,
+    }
+    return client
+end
+
+-- ############################################################################
+
+function network.write(client, buffer)
+    local _, err = client.network.socket:send(buffer)
+    if err then client.error(err) end
+end
+
+function network.read(client, len)
+    if len == nil then len = '*l' end
+    local line, err = client.network.socket:receive(len)
+    if not err then return line else client.error('connection error: ' .. err) end
+end
+
+-- ############################################################################
+
+function response.read(client)
+    local payload = client.network.read(client)
+    local prefix, data = payload:sub(1, -#payload), payload:sub(2)
+
+    -- status reply
+    if prefix == '+' then
+        if data == 'OK' then
+            return true
+        elseif data == 'QUEUED' then
+            return { queued = true }
+        else
+            return data
+        end
+
+   -- error reply
+    elseif prefix == '-' then
+        return client.error('redis error: ' .. data)
+
+   -- integer reply
+    elseif prefix == ':' then
+        local number = tonumber(data)
+
+        if not number then
+            if res == 'nil' then
+                return nil
+            end
+            client.error('cannot parse '..res..' as a numeric response.')
+        end
+
+        return number
+
+   -- bulk reply
+    elseif prefix == '$' then
+        local length = tonumber(data)
+
+        if not length then
+            client.error('cannot parse ' .. length .. ' as data length')
+        end
+
+        if length == -1 then
+            return nil
+        end
+
+        local nextchunk = client.network.read(client, length + 2)
+
+        return nextchunk:sub(1, -3)
+
+   -- multibulk reply
+    elseif prefix == '*' then
+        local count = tonumber(data)
+
+        if count == -1 then
+            return nil
+        end
+
+        local list = {}
+        if count > 0 then
+            local reader = response.read
+            for i = 1, count do
+                list[i] = reader(client)
+            end
+        end
+        return list
+
+   -- unknown type of reply
+    else
+        return client.error('unknown response prefix: ' .. prefix)
+    end
+end
+
+-- ############################################################################
+
+function request.raw(client, buffer)
+    local bufferType = type(buffer)
+
+    if bufferType == 'table' then
+        client.network.write(client, table.concat(buffer))
+    elseif bufferType == 'string' then
+        client.network.write(client, buffer)
+    else
+        client.error('argument error: ' .. bufferType)
+    end
+end
+
+function request.multibulk(client, command, ...)
+    local args = {...}
+    local argsn = #args
+    local buffer = { true, true }
+
+    if argsn == 1 and type(args[1]) == 'table' then
+        argsn, args = #args[1], args[1]
+    end
+
+    buffer[1] = '*' .. tostring(argsn + 1) .. "\r\n"
+    buffer[2] = '$' .. #command .. "\r\n" .. command .. "\r\n"
+
+    local table_insert = table.insert
+    for _, argument in pairs(args) do
+        local s_argument = tostring(argument)
+        table_insert(buffer, '$' .. #s_argument .. "\r\n" .. s_argument .. "\r\n")
+    end
+
+    client.network.write(client, table.concat(buffer))
+end
+
+-- ############################################################################
+
+local function custom(command, send, parse)
+    command = string.upper(command)
+    return function(client, ...)
+        send(client, command, ...)
+        local reply = response.read(client)
+
+        if type(reply) == 'table' and reply.queued then
+            reply.parser = parse
+            return reply
+        else
+            if parse then
+                return parse(reply, command, ...)
+            end
+            return reply
+        end
+    end
+end
+
+local function command(command, opts)
+    if opts == nil or type(opts) == 'function' then
+        return custom(command, request.multibulk, opts)
+    else
+        return custom(command, opts.request or request.multibulk, opts.response)
+    end
+end
+
+local define_command_impl = function(target, name, opts)
+    local opts = opts or {}
+    target[string.lower(name)] = custom(
+        opts.command or string.upper(name),
+        opts.request or request.multibulk,
+        opts.response or nil
+    )
+end
+
+local undefine_command_impl = function(target, name)
+    target[string.lower(name)] = nil
+end
+
+-- ############################################################################
+
+local client_prototype = {}
+
+client_prototype.raw_cmd = function(client, buffer)
+    request.raw(client, buffer .. "\r\n")
+    return response.read(client)
+end
+
+-- obsolete
+client_prototype.define_command = function(client, name, opts)
+    define_command_impl(client, name, opts)
+end
+
+-- obsolete
+client_prototype.undefine_command = function(client, name)
+    undefine_command_impl(client, name)
+end
+
+client_prototype.quit = function(client)
+    request.multibulk(client, 'QUIT')
+    client.network.socket:shutdown()
+    return true
+end
+
+client_prototype.shutdown = function(client)
+    request.multibulk(client, 'SHUTDOWN')
+    client.network.socket:shutdown()
+end
+
+-- Command pipelining
+
+client_prototype.pipeline = function(client, block)
+    local requests, replies, parsers = {}, {}, {}
+    local table_insert = table.insert
+    local socket_write, socket_read = client.network.write, client.network.read
+
+    client.network.write = function(_, buffer)
+        table_insert(requests, buffer)
+    end
+
+    -- TODO: this hack is necessary to temporarily reuse the current
+    --       request -> response handling implementation of redis-lua
+    --       without further changes in the code, but it will surely
+    --       disappear when the new command-definition infrastructure
+    --       will finally be in place.
+    client.network.read = function() return '+QUEUED' end
+
+    local pipeline = setmetatable({}, {
+        __index = function(env, name)
+            local cmd = client[name]
+            if not cmd then
+                client.error('unknown redis command: ' .. name, 2)
+            end
+            return function(self, ...)
+                local reply = cmd(client, ...)
+                table_insert(parsers, #requests, reply.parser)
+                return reply
+            end
+        end
+    })
+
+    local success, retval = pcall(block, pipeline)
+
+    client.network.write, client.network.read = socket_write, socket_read
+    if not success then client.error(retval, 0) end
+
+    client.network.write(client, table.concat(requests, ''))
+
+    for i = 1, #requests do
+        local reply, parser = response.read(client), parsers[i]
+        if parser then
+            reply = parser(reply)
+        end
+        table_insert(replies, i, reply)
+    end
+
+    return replies, #requests
+end
+
+-- Publish/Subscribe
+
+do
+    local channels = function(channels)
+        if type(channels) == 'string' then
+            channels = { channels }
+        end
+        return channels
+    end
+
+    local subscribe = function(client, ...)
+        request.multibulk(client, 'subscribe', ...)
+    end
+    local psubscribe = function(client, ...)
+        request.multibulk(client, 'psubscribe', ...)
+    end
+    local unsubscribe = function(client, ...)
+        request.multibulk(client, 'unsubscribe')
+    end
+    local punsubscribe = function(client, ...)
+        request.multibulk(client, 'punsubscribe')
+    end
+
+    local consumer_loop = function(client)
+        local aborting, subscriptions = false, 0
+
+        local abort = function()
+            if not aborting then
+                unsubscribe(client)
+                punsubscribe(client)
+                aborting = true
+            end
+        end
+
+        return coroutine.wrap(function()
+            while true do
+                local message
+                local response = response.read(client)
+
+                if response[1] == 'pmessage' then
+                    message = {
+                        kind    = response[1],
+                        pattern = response[2],
+                        channel = response[3],
+                        payload = response[4],
+                    }
+                else
+                    message = {
+                        kind    = response[1],
+                        channel = response[2],
+                        payload = response[3],
+                    }
+                end
+
+                if string.match(message.kind, '^p?subscribe$') then
+                    subscriptions = subscriptions + 1
+                end
+                if string.match(message.kind, '^p?unsubscribe$') then
+                    subscriptions = subscriptions - 1
+                end
+
+                if aborting and subscriptions == 0 then
+                    break
+                end
+                coroutine.yield(message, abort)
+            end
+        end)
+    end
+
+    client_prototype.pubsub = function(client, subscriptions)
+        if type(subscriptions) == 'table' then
+            if subscriptions.subscribe then
+                subscribe(client, channels(subscriptions.subscribe))
+            end
+            if subscriptions.psubscribe then
+                psubscribe(client, channels(subscriptions.psubscribe))
+            end
+        end
+        return consumer_loop(client)
+    end
+end
+
+-- Redis transactions (MULTI/EXEC)
+
+do
+    local function identity(...) return ... end
+    local emptytable = {}
+
+    local function initialize_transaction(client, options, block, queued_parsers)
+        local table_insert = table.insert
+        local coro = coroutine.create(block)
+
+        if options.watch then
+            local watch_keys = {}
+            for _, key in pairs(options.watch) do
+                table_insert(watch_keys, key)
+            end
+            if #watch_keys > 0 then
+                client:watch(unpack(watch_keys))
+            end
+        end
+
+        local transaction_client = setmetatable({}, {__index=client})
+        transaction_client.exec  = function(...)
+            client.error('cannot use EXEC inside a transaction block')
+        end
+        transaction_client.multi = function(...)
+            coroutine.yield()
+        end
+        transaction_client.commands_queued = function()
+            return #queued_parsers
+        end
+
+        assert(coroutine.resume(coro, transaction_client))
+
+        transaction_client.multi = nil
+        transaction_client.discard = function(...)
+            local reply = client:discard()
+            for i, v in pairs(queued_parsers) do
+                queued_parsers[i]=nil
+            end
+            coro = initialize_transaction(client, options, block, queued_parsers)
+            return reply
+        end
+        transaction_client.watch = function(...)
+            client.error('WATCH inside MULTI is not allowed')
+        end
+        setmetatable(transaction_client, { __index = function(t, k)
+                local cmd = client[k]
+                if type(cmd) == "function" then
+                    local function queuey(self, ...)
+                        local reply = cmd(client, ...)
+                        assert((reply or emptytable).queued == true, 'a QUEUED reply was expected')
+                        table_insert(queued_parsers, reply.parser or identity)
+                        return reply
+                    end
+                    t[k]=queuey
+                    return queuey
+                else
+                    return cmd
+                end
+            end
+        })
+        client:multi()
+        return coro
+    end
+
+    local function transaction(client, options, coroutine_block, attempts)
+        local queued_parsers, replies = {}, {}
+        local retry = tonumber(attempts) or tonumber(options.retry) or 2
+        local coro = initialize_transaction(client, options, coroutine_block, queued_parsers)
+
+        local success, retval
+        if coroutine.status(coro) == 'suspended' then
+            success, retval = coroutine.resume(coro)
+        else
+            -- do not fail if the coroutine has not been resumed (missing t:multi() with CAS)
+            success, retval = true, 'empty transaction'
+        end
+        if #queued_parsers == 0 or not success then
+            client:discard()
+            assert(success, retval)
+            return replies, 0
+        end
+
+        local raw_replies = client:exec()
+        if not raw_replies then
+            if (retry or 0) <= 0 then
+                client.error("MULTI/EXEC transaction aborted by the server")
+            else
+                --we're not quite done yet
+                return transaction(client, options, coroutine_block, retry - 1)
+            end
+        end
+
+        local table_insert = table.insert
+        for i, parser in pairs(queued_parsers) do
+            table_insert(replies, i, parser(raw_replies[i]))
+        end
+
+        return replies, #queued_parsers
+    end
+
+    client_prototype.transaction = function(client, arg1, arg2)
+        local options, block
+        if not arg2 then
+            options, block = {}, arg1
+        elseif arg1 then --and arg2, implicitly
+            options, block = type(arg1)=="table" and arg1 or { arg1 }, arg2
+        else
+            client.error("Invalid parameters for redis transaction.")
+        end
+
+        if not options.watch then
+            watch_keys = { }
+            for i, v in pairs(options) do
+                if tonumber(i) then
+                    table.insert(watch_keys, v)
+                    options[i] = nil
+                end
+            end
+            options.watch = watch_keys
+        elseif not (type(options.watch) == 'table') then
+            options.watch = { options.watch }
+        end
+
+        if not options.cas then
+            local tx_block = block
+            block = function(client, ...)
+                client:multi()
+                return tx_block(client, ...) --can't wrap this in pcall because we're in a coroutine.
+            end
+        end
+
+        return transaction(client, options, block)
+    end
+end
+
+-- MONITOR context
+
+do
+    local monitor_loop = function(client)
+        local monitoring = true
+
+        -- Tricky since the payload format changed starting from Redis 2.6.
+        local pattern = '^(%d+%.%d+)( ?.- ?) ?"(%a+)" ?(.-)$'
+
+        local abort = function()
+            monitoring = false
+        end
+
+        return coroutine.wrap(function()
+            client:monitor()
+
+            while monitoring do
+                local message, matched
+                local response = response.read(client)
+
+                local ok = response:gsub(pattern, function(time, info, cmd, args)
+                    message = {
+                        timestamp = tonumber(time),
+                        client    = info:match('%d+.%d+.%d+.%d+:%d+'),
+                        database  = tonumber(info:match('%d+')) or 0,
+                        command   = cmd,
+                        arguments = args:match('.+'),
+                    }
+                    matched = true
+                end)
+
+                if not matched then
+                    client.error('Unable to match MONITOR payload: '..response)
+                end
+
+                coroutine.yield(message, abort)
+            end
+        end)
+    end
+
+    client_prototype.monitor_messages = function(client)
+        return monitor_loop(client)
+    end
+end
+
+-- ############################################################################
+
+local function connect_tcp(socket, parameters)
+    local host, port = parameters.host, tonumber(parameters.port)
+    local ok, err = socket:connect(host, port)
+    if not ok then
+        redis.error('could not connect to '..host..':'..port..' ['..err..']')
+    end
+    socket:setoption('tcp-nodelay', parameters.tcp_nodelay)
+    return socket
+end
+
+local function connect_unix(socket, parameters)
+    local ok, err = socket:connect(parameters.path)
+    if not ok then
+        redis.error('could not connect to '..parameters.path..' ['..err..']')
+    end
+    return socket
+end
+
+local function create_connection(parameters)
+    if parameters.socket then
+        return parameters.socket
+    end
+
+    local perform_connection, socket
+
+    if parameters.scheme == 'unix' then
+        perform_connection, socket = connect_unix, require('socket.unix')
+        assert(socket, 'your build of LuaSocket does not support UNIX domain sockets')
+    else
+        if parameters.scheme then
+            local scheme = parameters.scheme
+            assert(scheme == 'redis' or scheme == 'tcp', 'invalid scheme: '..scheme)
+        end
+        perform_connection, socket = connect_tcp, require('socket').tcp
+    end
+
+    return perform_connection(socket(), parameters)
+end
+
+-- ############################################################################
+
+function redis.error(message, level)
+    error(message, (level or 1) + 1)
+end
+
+function redis.connect(...)
+    local args, parameters = {...}, nil
+
+    if #args == 1 then
+        if type(args[1]) == 'table' then
+            parameters = args[1]
+        else
+            local uri = require('socket.url')
+            parameters = uri.parse(select(1, ...))
+            if parameters.scheme then
+                if parameters.query then
+                    for k, v in parameters.query:gmatch('([-_%w]+)=([-_%w]+)') do
+                        if k == 'tcp_nodelay' or k == 'tcp-nodelay' then
+                            parameters.tcp_nodelay = parse_boolean(v)
+                        end
+                    end
+                end
+            else
+                parameters.host = parameters.path
+            end
+        end
+    elseif #args > 1 then
+        local host, port = unpack(args)
+        parameters = { host = host, port = port }
+    end
+
+    local commands = redis.commands or {}
+    if type(commands) ~= 'table' then
+        redis.error('invalid type for the commands table')
+    end
+
+    local socket = create_connection(merge_defaults(parameters))
+    local client = create_client(client_prototype, socket, commands)
+
+    return client
+end
+
+function redis.command(cmd, opts)
+    return command(cmd, opts)
+end
+
+-- obsolete
+function redis.define_command(name, opts)
+    define_command_impl(redis.commands, name, opts)
+end
+
+-- obsolete
+function redis.undefine_command(name)
+    undefine_command_impl(redis.commands, name)
+end
+
+-- ############################################################################
+
+-- Commands defined in this table do not take the precedence over
+-- methods defined in the client prototype table.
+
+redis.commands = {
+    -- commands operating on the key space
+    exists           = command('EXISTS', {
+        response = toboolean
+    }),
+    del              = command('DEL'),
+    type             = command('TYPE'),
+    rename           = command('RENAME'),
+    renamenx         = command('RENAMENX', {
+        response = toboolean
+    }),
+    expire           = command('EXPIRE', {
+        response = toboolean
+    }),
+    pexpire          = command('PEXPIRE', {     -- >= 2.6
+        response = toboolean
+    }),
+    expireat         = command('EXPIREAT', {
+        response = toboolean
+    }),
+    pexpireat        = command('PEXPIREAT', {   -- >= 2.6
+        response = toboolean
+    }),
+    ttl              = command('TTL'),
+    pttl             = command('PTTL'),         -- >= 2.6
+    move             = command('MOVE', {
+        response = toboolean
+    }),
+    dbsize           = command('DBSIZE'),
+    persist          = command('PERSIST', {     -- >= 2.2
+        response = toboolean
+    }),
+    keys             = command('KEYS', {
+        response = function(response)
+            if type(response) == 'string' then
+                -- backwards compatibility path for Redis < 2.0
+                local keys = {}
+                response:gsub('[^%s]+', function(key)
+                    table.insert(keys, key)
+                end)
+                response = keys
+            end
+            return response
+        end
+    }),
+    randomkey        = command('RANDOMKEY', {
+        response = function(response)
+            if response == '' then
+                return nil
+            else
+                return response
+            end
+        end
+    }),
+    sort             = command('SORT', {
+        request = sort_request,
+    }),
+
+    -- commands operating on string values
+    set              = command('SET'),
+    setnx            = command('SETNX', {
+        response = toboolean
+    }),
+    setex            = command('SETEX'),        -- >= 2.0
+    psetex           = command('PSETEX'),       -- >= 2.6
+    mset             = command('MSET', {
+        request = mset_filter_args
+    }),
+    msetnx           = command('MSETNX', {
+        request  = mset_filter_args,
+        response = toboolean
+    }),
+    get              = command('GET'),
+    mget             = command('MGET'),
+    getset           = command('GETSET'),
+    incr             = command('INCR'),
+    incrby           = command('INCRBY'),
+    incrbyfloat      = command('INCRBYFLOAT', { -- >= 2.6
+        response = function(reply, command, ...)
+            return tonumber(reply)
+        end,
+    }),
+    decr             = command('DECR'),
+    decrby           = command('DECRBY'),
+    append           = command('APPEND'),       -- >= 2.0
+    substr           = command('SUBSTR'),       -- >= 2.0
+    strlen           = command('STRLEN'),       -- >= 2.2
+    setrange         = command('SETRANGE'),     -- >= 2.2
+    getrange         = command('GETRANGE'),     -- >= 2.2
+    setbit           = command('SETBIT'),       -- >= 2.2
+    getbit           = command('GETBIT'),       -- >= 2.2
+
+    -- commands operating on lists
+    rpush            = command('RPUSH'),
+    lpush            = command('LPUSH'),
+    llen             = command('LLEN'),
+    lrange           = command('LRANGE'),
+    ltrim            = command('LTRIM'),
+    lindex           = command('LINDEX'),
+    lset             = command('LSET'),
+    lrem             = command('LREM'),
+    lpop             = command('LPOP'),
+    rpop             = command('RPOP'),
+    rpoplpush        = command('RPOPLPUSH'),
+    blpop            = command('BLPOP'),        -- >= 2.0
+    brpop            = command('BRPOP'),        -- >= 2.0
+    rpushx           = command('RPUSHX'),       -- >= 2.2
+    lpushx           = command('LPUSHX'),       -- >= 2.2
+    linsert          = command('LINSERT'),      -- >= 2.2
+    brpoplpush       = command('BRPOPLPUSH'),   -- >= 2.2
+
+    -- commands operating on sets
+    sadd             = command('SADD'),
+    srem             = command('SREM'),
+    spop             = command('SPOP'),
+    smove            = command('SMOVE', {
+        response = toboolean
+    }),
+    scard            = command('SCARD'),
+    sismember        = command('SISMEMBER', {
+        response = toboolean
+    }),
+    sinter           = command('SINTER'),
+    sinterstore      = command('SINTERSTORE'),
+    sunion           = command('SUNION'),
+    sunionstore      = command('SUNIONSTORE'),
+    sdiff            = command('SDIFF'),
+    sdiffstore       = command('SDIFFSTORE'),
+    smembers         = command('SMEMBERS'),
+    srandmember      = command('SRANDMEMBER'),
+
+    -- commands operating on sorted sets
+    zadd             = command('ZADD'),
+    zincrby          = command('ZINCRBY'),
+    zrem             = command('ZREM'),
+    zrange           = command('ZRANGE', {
+        request  = zset_range_request,
+        response = zset_range_reply,
+    }),
+    zrevrange        = command('ZREVRANGE', {
+        request  = zset_range_request,
+        response = zset_range_reply,
+    }),
+    zrangebyscore    = command('ZRANGEBYSCORE', {
+        request  = zset_range_byscore_request,
+        response = zset_range_reply,
+    }),
+    zrevrangebyscore = command('ZREVRANGEBYSCORE', {    -- >= 2.2
+        request  = zset_range_byscore_request,
+        response = zset_range_reply,
+    }),
+    zunionstore      = command('ZUNIONSTORE', {         -- >= 2.0
+        request = zset_store_request
+    }),
+    zinterstore      = command('ZINTERSTORE', {         -- >= 2.0
+        request = zset_store_request
+    }),
+    zcount           = command('ZCOUNT'),
+    zcard            = command('ZCARD'),
+    zscore           = command('ZSCORE'),
+    zremrangebyscore = command('ZREMRANGEBYSCORE'),
+    zrank            = command('ZRANK'),                -- >= 2.0
+    zrevrank         = command('ZREVRANK'),             -- >= 2.0
+    zremrangebyrank  = command('ZREMRANGEBYRANK'),      -- >= 2.0
+
+    -- commands operating on hashes
+    hset             = command('HSET', {        -- >= 2.0
+        response = toboolean
+    }),
+    hsetnx           = command('HSETNX', {      -- >= 2.0
+        response = toboolean
+    }),
+    hmset            = command('HMSET', {       -- >= 2.0
+        request  = hash_multi_request_builder(function(args, k, v)
+            table.insert(args, k)
+            table.insert(args, v)
+        end),
+    }),
+    hincrby          = command('HINCRBY'),      -- >= 2.0
+    hincrbyfloat     = command('HINCRBYFLOAT', {-- >= 2.6
+        response = function(reply, command, ...)
+            return tonumber(reply)
+        end,
+    }),
+    hget             = command('HGET'),         -- >= 2.0
+    hmget            = command('HMGET', {       -- >= 2.0
+        request  = hash_multi_request_builder(function(args, k, v)
+            table.insert(args, v)
+        end),
+    }),
+    hdel             = command('HDEL'),        -- >= 2.0
+    hexists          = command('HEXISTS', {     -- >= 2.0
+        response = toboolean
+    }),
+    hlen             = command('HLEN'),         -- >= 2.0
+    hkeys            = command('HKEYS'),        -- >= 2.0
+    hvals            = command('HVALS'),        -- >= 2.0
+    hgetall          = command('HGETALL', {     -- >= 2.0
+        response = function(reply, command, ...)
+            local new_reply = { }
+            for i = 1, #reply, 2 do new_reply[reply[i]] = reply[i + 1] end
+            return new_reply
+        end
+    }),
+
+    -- connection related commands
+    ping             = command('PING', {
+        response = function(response) return response == 'PONG' end
+    }),
+    echo             = command('ECHO'),
+    auth             = command('AUTH'),
+    select           = command('SELECT'),
+
+    -- transactions
+    multi            = command('MULTI'),        -- >= 2.0
+    exec             = command('EXEC'),         -- >= 2.0
+    discard          = command('DISCARD'),      -- >= 2.0
+    watch            = command('WATCH'),        -- >= 2.2
+    unwatch          = command('UNWATCH'),      -- >= 2.2
+
+    -- publish - subscribe
+    subscribe        = command('SUBSCRIBE'),    -- >= 2.0
+    unsubscribe      = command('UNSUBSCRIBE'),  -- >= 2.0
+    psubscribe       = command('PSUBSCRIBE'),   -- >= 2.0
+    punsubscribe     = command('PUNSUBSCRIBE'), -- >= 2.0
+    publish          = command('PUBLISH'),      -- >= 2.0
+
+    -- redis scripting
+    eval             = command('EVAL'),         -- >= 2.6
+    evalsha          = command('EVALSHA'),      -- >= 2.6
+    script           = command('SCRIPT'),       -- >= 2.6
+
+    -- remote server control commands
+    bgrewriteaof     = command('BGREWRITEAOF'),
+    config           = command('CONFIG', {     -- >= 2.0
+        response = function(reply, command, ...)
+            if (type(reply) == 'table') then
+                local new_reply = { }
+                for i = 1, #reply, 2 do new_reply[reply[i]] = reply[i + 1] end
+                return new_reply
+            end
+
+            return reply
+        end
+    }),
+    client           = command('CLIENT'),       -- >= 2.4
+    slaveof          = command('SLAVEOF'),
+    save             = command('SAVE'),
+    bgsave           = command('BGSAVE'),
+    lastsave         = command('LASTSAVE'),
+    flushdb          = command('FLUSHDB'),
+    flushall         = command('FLUSHALL'),
+    monitor          = command('MONITOR'),
+    time             = command('TIME'),         -- >= 2.6
+    slowlog          = command('SLOWLOG', {     -- >= 2.2.13
+        response = function(reply, command, ...)
+            if (type(reply) == 'table') then
+                local structured = { }
+                for index, entry in ipairs(reply) do
+                    structured[index] = {
+                        id = tonumber(entry[1]),
+                        timestamp = tonumber(entry[2]),
+                        duration = tonumber(entry[3]),
+                        command = entry[4],
+                    }
+                end
+                return structured
+            end
+
+            return reply
+        end
+    }),
+    info             = command('INFO', {
+        response = parse_info,
+    }),
+}
+
+-- ############################################################################
+
+return redis