First functional beta

.gitignore

@@ -1,4 +1,195 @@
-token
+config.ini
 log
 *.pyc
 *.db
+.idea
+.vscode
+
+# Created by https://www.gitignore.io/api/linux,emacs,python
+
+### Emacs ###
+# -*- mode: gitignore; -*-
+*~
+\#*\#
+/.emacs.desktop
+/.emacs.desktop.lock
+*.elc
+auto-save-list
+tramp
+.\#*
+
+# Org-mode
+.org-id-locations
+*_archive
+
+# flymake-mode
+*_flymake.*
+
+# eshell files
+/eshell/history
+/eshell/lastdir
+
+# elpa packages
+/elpa/
+
+# reftex files
+*.rel
+
+# AUCTeX auto folder
+/auto/
+
+# cask packages
+.cask/
+dist/
+
+# Flycheck
+flycheck_*.el
+
+# server auth directory
+/server/
+
+# projectiles files
+.projectile
+projectile-bookmarks.eld
+
+# directory configuration
+.dir-locals.el
+
+# saveplace
+places
+
+# url cache
+url/cache/
+
+# cedet
+ede-projects.el
+
+# smex
+smex-items
+
+# company-statistics
+company-statistics-cache.el
+
+# anaconda-mode
+anaconda-mode/
+
+### Linux ###
+
+# temporary files which can be created if a process still has a handle open of a deleted file
+.fuse_hidden*
+
+# KDE directory preferences
+.directory
+
+# Linux trash folder which might appear on any partition or disk
+.Trash-*
+
+# .nfs files are created when an open file is removed but is still being accessed
+.nfs*
+
+### Python ###
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+.hypothesis/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# pyenv
+.python-version
+
+# celery beat schedule file
+celerybeat-schedule
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+
+bin/
+include/
+pip-selfcheck.json
+

README.md

@@ -7,4 +7,4 @@ Es necesario tener el archivo "token" para enviar mensajes con el bot.
 Es necesario instalar la librería [python-telegram-bot](https://github.com/leandrotoledo/python-telegram-bot), junto con algunos paquetes adicionales:
 
     # apt-get install python-libxml2
-    # pip install python-telegram-bot pyquery cssselect lxml
+    # pip install python-telegram-bot pyquery cssselect lxml emoji

auxilliary_methods.py

@@ -0,0 +1,112 @@
+#!/usr/bin/python3.5
+# -*- coding: utf-8 -*-
+
+from urllib.request import urlopen
+from pyquery import PyQuery
+import telegram
+from repository import find_user_by_telegram_user_id, check_user_permission
+from emoji import emojize
+from datetime import datetime
+import time
+import schedule
+import threading
+
+
+def get_who():
+
+    while True:
+        try:
+            url = 'https://sugus.eii.us.es/en_sugus.html'
+            #html = AssertionErrorurlopen(url).read()
+            html = urlopen(url).read()
+            pq = PyQuery(html)
+            break
+        except:
+            raise
+
+    ul = pq('ul.usuarios > li')
+    who = [w.text() for w in ul.items() if w.text() != "Parece que no hay nadie."]
+
+    return who
+
+
+def check_type_and_text_start(aText = None,
+                              aUName = None,
+                              cText = None,
+                              aType = None,
+                              cType = None,
+                              cUId = None,
+                              perm_required=None):
+    # Si perm_required es None y cUId no es None entonces se busca que el usuario esté en cualquier grupo
+
+    result = True
+
+    if cType is not None:
+        result = aType == cType
+    if cUId is not None:
+        if perm_required is None:  # Comprobar solo usuario y permiso
+            result = result and find_user_by_telegram_user_id(cUId)
+        else:  # Comprobar usuario y permisos
+            for a in perm_required:
+                if check_user_permission(cUId, a):
+                    result = result and True
+    if cText is not None:
+        result = result and aText.startswith(cText)
+
+    return result
+
+def check_permissions(user_id, required_perm):
+    return all([check_user_permission(user_id, perm) for perm in required_perm])
+
+def show_list(header, contains, positions = None):
+
+    result = [header + "\n"]
+
+    if contains:
+        if positions:
+            for a in contains:
+                a_ordered = [str(a[i]) for i in positions]
+                result.append("{} {}\n".format(emojize(":small_blue_diamond:", use_aliases=True), " ".join(a_ordered)))
+        else:
+            if isinstance(contains[0], str):
+                rows = ["{} {}\n".format(emojize(":small_blue_diamond:", use_aliases=True) ,a) for a in contains]
+            else:
+                rows = ["{} {}\n".format(emojize(":small_blue_diamond:", use_aliases=True) ," ".join(a)) for a in contains]
+            result += rows
+
+    return "".join(result)
+
+
+def check_date(date):
+    res = True
+
+    try:
+        if datetime.strptime(date, '%d-%m-%Y').date() < datetime.today().date():
+            res = False
+    except ValueError:
+        res = False
+    return res
+
+def extract_user_from_update(update):
+    try:
+        user = update.callback_query.from_user
+    except AttributeError:
+        user = update.message.from_user
+
+    return user
+
+
+def init_scheduler():
+    cease_continuous_run = threading.Event()
+
+    class ScheduleThread(threading.Thread):
+        @classmethod
+        def run(cls):
+            while not cease_continuous_run.is_set():
+                schedule.run_pending()
+                time.sleep(1)
+
+    continuous_thread = ScheduleThread()
+    continuous_thread.start()
+
+    return cease_continuous_run

config_sample.ini

@@ -0,0 +1,5 @@
+[Database]
+route = sugusBotDB.db
+[Telegram]
+token = XXXX
+id_admin = XXXX

conversation_session.py

@@ -0,0 +1,67 @@
+#!/usr/bin/python3.5
+# -*- coding: utf-8 -*-
+
+
+class conversation_session():
+    def __init__(self):
+        self.__inConversation = {}
+
+    @staticmethod
+    def __g_key(act_user, conversation_id=None):
+        # Generate the key based on actUser and conversationId
+        if conversation_id is None:
+            conversation_id = act_user.id
+
+        return str(act_user.id) + "-" + str(conversation_id)
+
+    def __add(self, key, options):
+        self.__inConversation[key] = options
+
+    def add_option(self, act_user, option, value, conversation_id=None):
+        """Añade el par de valores (option, value) para el usuario"""
+        key = self.__g_key(act_user, conversation_id)
+        if not self.get(act_user):
+            self.__inConversation[key] = {option: value}
+        else:
+            self.__inConversation[key][option] = value
+
+    def del_option(self, act_user, option, conversation_id=None):
+        """Elimina la opción 'option' del usuario"""
+        key = self.__g_key(act_user, conversation_id)
+        del self.__inConversation[key][option]
+
+    def empty(self, act_user, conversation_id=None):
+        """Elimina todas las opciones para el usuario"""
+        key = self.__g_key(act_user, conversation_id)
+        del self.__inConversation[key]
+
+    def get(self, act_user, conversation_id=None):
+        """Devuelve todas las opciones del usuario"""
+        key = self.__g_key(act_user, conversation_id)
+        try:
+            result = self.__inConversation[key]
+        except KeyError as error:
+            result = []
+            pass
+        return result
+
+    def contain_option(self, act_user, option, conversation_id=None, c_opt_value=None):
+        """Comprueba si existe la opción 'option' para el usuario"""
+        options = self.get(act_user, conversation_id)
+        if option in options:
+            if c_opt_value == options[option]:
+                return True
+            elif c_opt_value == None:
+                return True
+            else:
+                return False
+        else:
+            return False
+
+    def status(self, act_user, conversation_id=None):
+        """Dice si el usuario tiene alguna sesión en curso"""
+        key = self.__g_key(act_user, conversation_id)
+        if key in self.__inConversation:
+            return True
+        else:
+            return False