Disable in groups

add_message_id for the new table. get_callback_id now gets id from
message_id table. Removed the null case from add_vote. Creating post no
longer adds an entry to poll table. It instead adds an entry to
message_ids table via add_message_id function

.gitignore

@@ -95,3 +95,4 @@ ENV/
 .ropeproject
 
 config.py
+chanbot.sqlite

README.md

@@ -1,2 +1,3 @@
 # Channel-Poll-Bot
 
+A bot to hold polling in [@quadnite_\_pfp](https://t.me/quadnite_pfp)

bot.py

@@ -1,25 +1,139 @@
 #!/usr/bin/env python3
 # coding=utf-8
 
+import logging
 import config
 import sqlite3
-from telegram.ext import Updater, MessageHandler, Filters
+from telegram.ext import Updater, MessageHandler, CallbackQueryHandler, Filters
+from telegram import InlineKeyboardButton, InlineKeyboardMarkup
+
+logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - \
+                    %(message)s', level=logging.INFO)
 
 
-def main(bot, update, db):
+def get_callback_id(db):
+    cursor = db.cursor()
+    query = ('SELECT max(callback) FROM message_ids')
+    cursor.execute(query)
+    return int(cursor.fetchone()[0]) + 1
+
+
+def add_message_id(db, message_id, callback):
+    cursor = db.cursor()
+    query = ("INSERT INTO message_ids(callback, message_id) values(?,?)")
+    cursor.execute(query, (callback, message_id))
+    db.commit()
+
+
+def add_vote(db, callback_id, user=None):
+    user_id = user.id
+    name = str(user.first_name)
+    if user.last_name:
+        name += " " + str(user.last_name)
+
+    cursor = db.cursor()
+    query = ("INSERT INTO poll(callback, user_id, name) values(?,?,?)")
+    cursor.execute(query, (callback_id, user_id, name))
+    db.commit()
+
+
+def delete_vote(db, callback_id, user):
+    user_id = user.id
+    query = "DELETE FROM poll WHERE callback=? AND user_id=?"
+    cursor.execute(query, (callback_id, user_id))
+    db.commit()
+
+
+def check_vote(db, callback_id, user):
+    user_id = user.id
+    cursor = db.cursor()
+    query = ("SELECT * FROM poll WHERE callback=? AND user_id=?")
+    cursor.execute(query, (callback_id, user_id))
+    if cursor.fetchone():
+        return True
+    else:
+        return False
+
+
+def update_message(bot, db, callback_id):
+    cursor = db.cursor()
+    query = "SELECT message_id FROM message_ids WHERE callback = ?"
+    cursor.execute(query, (callback_id,))
+    message_id = cursor.fetchone()[0]
+    query = "SELECT count(user_id) FROM poll WHERE callback = ?"
+    cursor.execute(query, (callback_id,))
+    count = cursor.fetchone()[0]
+    keyboard = InlineKeyboardMarkup([[InlineKeyboardButton(
+                                    text=f"❤️   {count}",
+                                    callback_data=callback_id)]])
+    bot.edit_message_reply_markup(chat_id=config.channel_id,
+                                  message_id=message_id,
+                                  reply_markup=keyboard)
+
+
+def send_stats(bot, update, db, tag):
+    cursor = db.cursor()
+    query = ("SELECT user_id, name FROM poll NATURAL JOIN message_ids WHERE "
+             "message_id = ?")
+    cursor.execute(query, (update.message.forward_from_message_id,))
+    voters = []
+    for row in cursor:
+        voters.append(row)
+    if len(voters) == 0:
+        bot.send_message(chat_id=update.message.chat_id, text="No Votes")
+    else:
+        text = "Voters\n"
+        for i in voters:
+            if tag:
+                text += f"<a href='tg://user?id={i[0]}'>{i[1]}</a>\n"
+            else:
+                text += f"{i[1]}\n"
+        bot.send_message(chat_id=update.message.chat_id, text=text,
+                         parse_mode="HTML")
+
+
+def post(bot, update, db):
     chat_id = update.message.chat_id
+    user_id = update.message.from_user.id
+    if (update.message.forward_from_chat and
+       update.message.forward_from_chat.id == config.channel_id and
+       user_id in config.allowed_users):
+        tag = (chat_id == user_id)
+        send_stats(bot, update, db, tag)
+        return
+    if chat_id < 0:
+        return
     if chat_id in config.allowed_users:
-        pass
+        callback_id = get_callback_id(db)
+        photo = update.message.photo[0]
+        file_id = photo.file_id
+        keyboard = InlineKeyboardMarkup([[InlineKeyboardButton(text="❤️",
+                                        callback_data=callback_id)]])
+        reply = bot.send_photo(chat_id=config.channel_id, photo=file_id,
+                               reply_markup=keyboard)
+        add_message_id(db, reply.message_id, callback_id)
     else:
         bot.send_message(chat_id=chat_id, text="Not Authorized")
 
 
+def click(bot, update, db):
+    user = update.callback_query.from_user
+    callback_id = update.callback_query.data
+    if not check_vote(db, callback_id, user):
+        add_vote(db, callback_id, user)
+    else:
+        delete_vote(db, callback_id, user)
+    update_message(bot, db, callback_id)
+    bot.answer_callback_query(update.callback_query.id)
+
+
 updater = Updater(token=config.api_key)
 dispatcher = updater.dispatcher
 
 db = sqlite3.connect("chanbot.sqlite", check_same_thread=False)
 cursor = db.cursor()
 
-dispatcher.add_handler(MessageHandler(Filters.photo, lambda x, y: main(x,
+dispatcher.add_handler(MessageHandler(Filters.photo, lambda x, y: post(x,
                                       y, db)))
+dispatcher.add_handler(CallbackQueryHandler(lambda x, y: click(x, y, db)))
 updater.start_polling()

schema.sql

@@ -0,0 +1,3 @@
+CREATE TABLE IF NOT EXISTS poll(callback int NOT NULL, user_id int, name varchar, UNIQUE(callback, user_id));
+CREATE TABLE IF NOT EXISTS message_ids(callback int PRIMARY KEY, message_id int NOT NULL UNIQUE);
+INSERT INTO message_ids values(0, 0);