diff --git a/commands.py b/commands.py
index 5b001c8..c5ea1c2 100644
--- a/commands.py
+++ b/commands.py
@@ -1,9 +1,10 @@
-from telegram import Update, InlineKeyboardButton, InlineKeyboardMarkup
+from telegram import Update, InlineKeyboardButton, InlineKeyboardMarkup, LinkPreviewOptions
from telegram.constants import ParseMode
from telegram.ext import ContextTypes
import html_parser
from config import *
+from extensions import get_json, format_rating, format_status
async def start_command(update: Update, context: ContextTypes.DEFAULT_TYPE) -> None:
@@ -45,3 +46,65 @@ async def about_command(update: Update, context: ContextTypes.DEFAULT_TYPE) -> N
parse_mode=ParseMode.HTML,
reply_markup=reply_markup
)
+
+
+async def info_command(update: Update, context: ContextTypes.DEFAULT_TYPE) -> None:
+ try:
+ post_id = context.args[0]
+ message = await context.bot.send_message(update.effective_chat.id,
+ f"{html_parser.bold("Information")}\n"
+ f"Fetching...",
+ parse_mode=ParseMode.HTML)
+ post_data = get_json(f"posts/{post_id}")
+ if post_data is None:
+ await update.message.reply_text(
+ f"{html_parser.bold("Error")}: That record was not found.",
+ parse_mode=ParseMode.HTML)
+ return
+ uploader_data = get_json(f"users/{post_data['uploader_id']}")
+ # well, we could check the uploader, but why would we do that?
+
+ keyboard = [
+ [
+ InlineKeyboardButton(f"Open in {app.name}",
+ url=f"https://{app.hostname}/posts/{post_id}")
+ ]
+ ]
+ reply_markup = InlineKeyboardMarkup(keyboard)
+
+ # noinspection PyListCreation
+ m = []
+ m.append(f"ID: {html_parser.code(post_data['id'])}")
+ m.append(f"Uploader: {html_parser.hyperlink(uploader_data['name'],
+ f"http://{app.host}/users/{post_data['uploader_id']}")} "
+ f"{html_parser.hyperlink("»", f"http://{app.host}/posts?tags=user:{uploader_data['name']}")}")
+ m.append(f"Date: {post_data['created_at']}")
+ if post_data['approver_id'] is not None:
+ approver_data = get_json(f"users/{post_data['approver_id']}")
+ m.append(f"Approver: {html_parser.hyperlink(approver_data['name'],
+ f"http://{app.host}/users/{post_data['approver_id']}")} "
+ f"{html_parser.hyperlink("»", f"http://{app.host}/posts?tags=approver:{approver_data['name']}")}")
+ m.append(f"Size: {post_data['media_asset']['file_size']} .{post_data['media_asset']['file_ext']} "
+ f"({post_data['media_asset']['image_width']}x{post_data['media_asset']['image_height']}) "
+ f"{html_parser.hyperlink("»", f"http://{app.host}/media_assets/{post_data['media_asset']['id']}")}")
+ m.append(f"Source: {post_data['source'] if post_data['source'] != "" else "🚫"}")
+ m.append(f"Rating: {format_rating(post_data['rating'])}")
+ m.append(f"Score: {html_parser.hyperlink(post_data['score'],
+ f"http://{app.host}/post_votes?search[post_id]={post_data['id']}&variant=compact")} "
+ f"(+{post_data['up_score']} / -{post_data['down_score']})")
+ m.append(f"Favorites: {html_parser.hyperlink(post_data['fav_count'],
+ f"http://{app.host}/posts/{post_data['id']}/favorites")}")
+ m.append(f"Status: {format_status(post_data)}")
+
+ link_preview_options = LinkPreviewOptions(True)
+ if not post_data['is_banned']:
+ link_preview_options = LinkPreviewOptions(url=post_data['large_file_url'])
+
+ await context.bot.edit_message_text(
+ f"{html_parser.bold("Information")}\n" + "\n".join(m),
+ update.effective_chat.id, message.message_id,
+ parse_mode=ParseMode.HTML, reply_markup=reply_markup, link_preview_options=link_preview_options)
+ except (IndexError, ValueError):
+ await update.message.reply_text(
+ f"{html_parser.bold("Usage")}: {html_parser.code(f"/info <post ID>")}",
+ parse_mode=ParseMode.HTML)
diff --git a/config.py b/config.py
index 0d97476..c6c1a8b 100644
--- a/config.py
+++ b/config.py
@@ -4,7 +4,7 @@ from typing import Optional
import requests
_c = configparser.ConfigParser()
-_c.read("config.ini")
+_c.read("config.ini", "utf-8")
class _General:
diff --git a/extensions.py b/extensions.py
index c6ac510..28562c0 100644
--- a/extensions.py
+++ b/extensions.py
@@ -1,7 +1,11 @@
import re
+import requests
+
+from typing import Any
+from config import app
-def humanize_tags_from_json(value: str, default: str):
+def humanize_tags_from_json(value: str, default: str) -> str:
if value != "":
output = str()
tags = value.split()
@@ -14,7 +18,7 @@ def humanize_tags_from_json(value: str, default: str):
return default
-def format_rating(value: str):
+def format_rating(value: str) -> str | None:
match value:
case "g":
# Negative Squared Latin Capital Letter G
@@ -28,3 +32,32 @@ def format_rating(value: str):
case "e":
# Negative Squared Latin Capital Letter E
return "🅴"
+ return None
+
+
+def format_status(data) -> str:
+ is_active = True
+ is_pending = data['is_pending']
+ is_flagged = data['is_flagged']
+ is_deleted = data['is_deleted']
+ is_banned = data['is_banned']
+ if is_pending | is_flagged | is_deleted:
+ is_active = False
+
+ status = []
+ if is_active:
+ status.append("Active")
+ if is_pending:
+ status.append("Pending")
+ if is_flagged:
+ status.append("Flagged")
+ if is_banned:
+ status.append("Banned")
+ return " ".join(status)
+
+def get_json(pathname: str) -> Any | None:
+ r = requests.get(f"http://{app.host}/{pathname}.json")
+
+ if r.status_code != 200:
+ return None
+ return r.json()
diff --git a/inline_query.py b/inline_query.py
index d308db3..e8c6151 100644
--- a/inline_query.py
+++ b/inline_query.py
@@ -1,13 +1,12 @@
from uuid import uuid4
-import requests
from telegram import Update, InlineKeyboardButton, InlineQueryResultArticle, InputTextMessageContent, \
- InlineKeyboardMarkup
+ InlineKeyboardMarkup, LinkPreviewOptions
from telegram.constants import ParseMode
from telegram.ext import ContextTypes
from config import *
-from extensions import humanize_tags_from_json, format_rating
+from extensions import humanize_tags_from_json, format_rating, get_json
# noinspection PyUnusedLocal
@@ -20,14 +19,11 @@ async def inline_query(update: Update, context: ContextTypes.DEFAULT_TYPE) -> No
if not query.isdigit():
return
- response = requests.get(f"http://{app.host}/posts/{query}.json")
-
- if response.status_code != 200:
+ data = get_json(f"posts/{query}")
+ if data is None:
await invalid_query(update, query)
return
- data = response.json()
-
await answer_query(update, query, data)
@@ -36,6 +32,25 @@ async def answer_query(update: Update, query: str, data) -> None:
copyrights = humanize_tags_from_json(data['tag_string_copyright'], "unknown copyright")
artists = humanize_tags_from_json(data['tag_string_artist'], "unknown artist")
rating = format_rating(data['rating'])
+
+ if data['is_banned']:
+ results = [
+ InlineQueryResultArticle(
+ id=str(uuid4()),
+ title=f"ID: {query}",
+ description=f"{characters} ({copyrights}) drawn by {artists}",
+ input_message_content=InputTextMessageContent(
+ f"ID: {query} {rating}\n"
+ f"{characters} ({copyrights}) drawn by {artists}\n"
+ f"This post has been removed because of a takedown request or rule violation.",
+ parse_mode=ParseMode.HTML
+ )
+ )
+ ]
+
+ await update.inline_query.answer(results)
+ return
+
keyboard = [
[
InlineKeyboardButton(f"Open in {app.name}",
@@ -52,9 +67,9 @@ async def answer_query(update: Update, query: str, data) -> None:
thumbnail_url=data['preview_file_url'],
input_message_content=InputTextMessageContent(
f"ID: {query} {rating}\n"
- f"{characters} ({copyrights}) "
- f"drawn by {artists}",
- parse_mode=ParseMode.HTML
+ f"{characters} ({copyrights}) drawn by {artists}",
+ parse_mode=ParseMode.HTML,
+ link_preview_options=LinkPreviewOptions(url=data['large_file_url'])
),
reply_markup=InlineKeyboardMarkup(keyboard)
)
@@ -68,9 +83,10 @@ async def invalid_query(update: Update, query: str) -> None:
InlineQueryResultArticle(
id=str(uuid4()),
title=f"ID: {query}",
- description="not found.",
+ description="Error",
input_message_content=InputTextMessageContent(
- f"ID: {query}\nrequested post does not exist.",
+ f"ID: {query}\n"
+ f"That record was not found.",
parse_mode=ParseMode.HTML
)
)
diff --git a/main.py b/main.py
index 4f19837..3bc63d2 100644
--- a/main.py
+++ b/main.py
@@ -21,6 +21,7 @@ def main() -> None:
application.add_handler(CommandHandler("start", commands.start_command))
application.add_handler(CommandHandler("help", commands.help_command))
application.add_handler(CommandHandler("about", commands.about_command))
+ application.add_handler(CommandHandler("info", commands.info_command))
from inline_query import inline_query
application.add_handler(InlineQueryHandler(inline_query))
@@ -28,7 +29,7 @@ def main() -> None:
application.run_polling(allowed_updates=commands.Update.ALL_TYPES)
-def get_token():
+def get_token() -> None:
if os.getenv("BOT_TOKEN") is not None:
return os.getenv("BOT_TOKEN")
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..29bdc4d
Binary files /dev/null and b/requirements.txt differ