mirror of
https://github.com/TheFunny/TelegramTwitterMediaBot.git
synced 2026-09-23 23:32:05 +00:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0ca9b55ea8
|
||
|
|
ef17b05c14
|
||
|
|
85d0257c51
|
||
|
|
7f90670f1c
|
||
|
|
755c405196
|
||
|
|
0ffa9903c4
|
||
|
|
248e7d48e0
|
||
|
|
e915cd13de
|
||
|
|
a7d144f2ee
|
||
|
|
081ee595b1
|
@@ -17,7 +17,7 @@ if WEBHOOK:
|
||||
x_url_regex = re.compile(r"^(?:https?://)(?:www\.|mobile\.|)(?:x|twitter)\.com/(.+)/status/(\d+)")
|
||||
x_media_regex = re.compile(r"^(?:https?://)(pbs|video)\.twimg\.com/(.*)")
|
||||
x_tco_regex = re.compile(r"(?:https?://)t\.co/.+$", re.M)
|
||||
message_url_regex = re.compile(r"\{.+\}", re.S)
|
||||
message_url_regex = re.compile(r"\[.+]", re.S)
|
||||
|
||||
logging.basicConfig(
|
||||
level=os.getenv("LOG_LEVEL", "WARNING"),
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import html
|
||||
from functools import wraps
|
||||
|
||||
from aiohttp import ClientSession
|
||||
@@ -56,7 +57,7 @@ async def url_media(update: Update, context: ContextTypes.DEFAULT_TYPE) -> None:
|
||||
if context.user_data.get('edit_before_forward', False):
|
||||
message_reply = await update.effective_message.reply_text(
|
||||
"Reply to edit message.",
|
||||
reply_markup=ForceReply(selective=True, input_field_placeholder="{URL}"),
|
||||
reply_markup=ForceReply(selective=True, input_field_placeholder="[URL]"),
|
||||
reply_to_message_id=update.message.message_id,
|
||||
)
|
||||
context.user_data['message_reply'] = message_reply
|
||||
@@ -70,11 +71,13 @@ async def url_media(update: Update, context: ContextTypes.DEFAULT_TYPE) -> None:
|
||||
async def forward_message(
|
||||
update: Update,
|
||||
context: ContextTypes.DEFAULT_TYPE,
|
||||
message_sent: tuple[Message, ...],
|
||||
message_to_send: tuple[Message, ...],
|
||||
) -> None:
|
||||
try:
|
||||
for i, m in enumerate(message_sent):
|
||||
await m.copy(context.user_data['forward_channel_id'])
|
||||
await update.effective_chat.copy_messages(
|
||||
context.user_data['forward_channel_id'],
|
||||
[m.id for m in message_to_send]
|
||||
)
|
||||
except Exception as e:
|
||||
await update.effective_message.reply_text(str(e))
|
||||
|
||||
@@ -84,7 +87,7 @@ async def edit_message(update: Update, context: ContextTypes.DEFAULT_TYPE) -> No
|
||||
return
|
||||
if update.message.reply_to_message != context.user_data['message_reply']:
|
||||
return
|
||||
update_text = update.message.text
|
||||
update_text = html.escape(update.message.text)
|
||||
match = common.message_url_regex.search(update_text)
|
||||
if match:
|
||||
match = match.span()
|
||||
@@ -92,9 +95,9 @@ async def edit_message(update: Update, context: ContextTypes.DEFAULT_TYPE) -> No
|
||||
context.user_data['message_url'], update_text[match[0] + 1:match[1] - 1]
|
||||
) + update_text[match[1]:]
|
||||
message_to_send = context.user_data['message_to_send']
|
||||
await message_to_send[0].edit_caption(
|
||||
update_text,
|
||||
reply_markup=InlineKeyboardMarkup.from_button(
|
||||
await message_to_send[0].edit_caption(update_text)
|
||||
await context.user_data['message_reply'].edit_reply_markup(
|
||||
InlineKeyboardMarkup.from_button(
|
||||
InlineKeyboardButton("↩️ Confirm", callback_data="forward")
|
||||
)
|
||||
)
|
||||
@@ -104,9 +107,7 @@ async def query_forward_message(update: Update, context: ContextTypes.DEFAULT_TY
|
||||
message_to_send = context.user_data['message_to_send']
|
||||
await forward_message(update, context, message_to_send)
|
||||
await update.callback_query.answer('✅ Forwarded')
|
||||
await update.callback_query.edit_message_reply_markup()
|
||||
message_reply: Message = context.user_data['message_reply']
|
||||
await message_reply.edit_text("Message forwarded.")
|
||||
await update.callback_query.delete_message()
|
||||
del context.user_data['message_reply']
|
||||
del context.user_data['message_to_send']
|
||||
del context.user_data['message_url']
|
||||
|
||||
+1
-1
@@ -1,2 +1,2 @@
|
||||
python-telegram-bot[webhooks]~=21.0.1
|
||||
python-telegram-bot[webhooks]~=21.1.1
|
||||
aiohttp[speedups]~=3.9.3
|
||||
@@ -1,3 +1,4 @@
|
||||
import html
|
||||
from typing import Generator
|
||||
|
||||
from aiohttp import ClientSession
|
||||
@@ -183,12 +184,14 @@ class TGTweet(Tweet):
|
||||
return message_raw_text.format(
|
||||
url=self.url,
|
||||
author_url=self.author_url,
|
||||
author=self.author,
|
||||
text=self.text
|
||||
author=html.escape(self.author),
|
||||
text=html.escape(self.text)
|
||||
)
|
||||
|
||||
@property
|
||||
def inline_query_generator(self) -> Generator[InlineQueryResultPhoto | InlineQueryResultVideo, None, None]:
|
||||
def inline_query_generator(self) -> Generator[
|
||||
InlineQueryResultPhoto | InlineQueryResultVideo | InlineQueryResultMpeg4Gif, None, None
|
||||
]:
|
||||
for i, tweet_media in enumerate(self.media):
|
||||
logger.info(str(tweet_media))
|
||||
if tweet_media.type == "image":
|
||||
@@ -196,7 +199,7 @@ class TGTweet(Tweet):
|
||||
id=str(i),
|
||||
photo_url=tweet_media.url,
|
||||
thumbnail_url=tweet_media.thumb,
|
||||
caption=self.message_text if not i else None
|
||||
caption=self.message_text
|
||||
)
|
||||
elif tweet_media.type == "video":
|
||||
yield InlineQueryResultVideo(
|
||||
@@ -205,18 +208,18 @@ class TGTweet(Tweet):
|
||||
mime_type="video/mp4",
|
||||
thumbnail_url=tweet_media.thumb,
|
||||
title=self.text,
|
||||
caption=self.message_text if not i else None
|
||||
caption=self.message_text
|
||||
)
|
||||
elif tweet_media.type == "gif":
|
||||
yield InlineQueryResultMpeg4Gif(
|
||||
id=str(i),
|
||||
mpeg4_url=tweet_media.url,
|
||||
thumbnail_url=tweet_media.thumb,
|
||||
caption=self.message_text if not i else None
|
||||
caption=self.message_text
|
||||
)
|
||||
|
||||
@property
|
||||
def pm_media_generator(self) -> Generator[InputMediaPhoto | InputMediaVideo, None, None]:
|
||||
def pm_media_generator(self) -> Generator[InputMediaPhoto | InputMediaVideo | InputMediaAnimation, None, None]:
|
||||
for tweet_media in self.media:
|
||||
logger.info(str(tweet_media))
|
||||
if tweet_media.type == "image":
|
||||
|
||||
Reference in New Issue
Block a user