path: root/callback.py

import io
from typing import cast, List

from telegram import ReplyKeyboardRemove
from telegram.constants import ChatAction
from telegram.error import BadRequest
from telegram.ext import CallbackContext

from command import *
from dbstore.dbm_store import get_loc
from foursquare.poi import OSM_ENDPOINT
from foursquare.poi import query_poi
from toot import mastodon_client


def generate_toot_text(poi_name, poi_locality, poi_region, poi_lat, poi_lon):
    osm_url = OSM_ENDPOINT.format(poi_lat, poi_lon)

    location = ""
    if poi_locality:
        location = poi_locality
    if poi_region:
        location += ", " + poi_region
    if location:
        return f"I'm at {poi_name} in {location}, {osm_url}"
    else:
        return f"I'm at {poi_name}, {osm_url}"


async def callback_location_sharing(update: Update, context: ContextTypes.DEFAULT_TYPE) -> int:
    if update.message.venue is not None:
        context.user_data["fsq_id"] = update.message.venue.foursquare_id
        context.user_data["title"] = update.message.venue.title
        context.user_data["latitude"] = update.message.venue.location.latitude
        context.user_data["longitude"] = update.message.venue.location.longitude

        poi = get_loc(context.user_data.get("fsq_id"))
        content = generate_toot_text(poi["name"], poi["locality"], poi["region"], poi["latitude"], poi["longitude"])
        status = mastodon_client.status_post(content, visibility=DEFAULT_TOOT_VISIBILITY, media_ids=[])

        context.user_data[KEY_TOOT_STATUS_ID] = status["id"]
        context.user_data[KEY_TOOT_STATUS_CONTENT] = content

        await update.message.reply_text(text=f"Selected place: {poi['name']}, \nPosted to Mastodon: {status['url']}",
                                        parse_mode=ParseMode.MARKDOWN)

        msg = await update.message.reply_text(PROMPT_ADD_COMMENT, reply_markup=INLINE_SKIP_MENU)
        context.user_data[PROMPT_ADD_COMMENT] = msg.message_id

        return ADD_COMMENT
    else:
        context.user_data["latitude"] = update.message.location.latitude
        context.user_data["longitude"] = update.message.location.longitude

        await update.message.reply_text("Searching...", reply_markup=ReplyKeyboardRemove())
        msg = await update.message.reply_text(PROMPT_LOCATION_KEYWORD, reply_markup=INLINE_SKIP_MENU)

        context.user_data[PROMPT_LOCATION_KEYWORD] = msg.message_id
        return LOCATION_SEARCH_KEYWORD


async def callback_location_keyword_search(update: Update, context: ContextTypes.DEFAULT_TYPE) -> int:
    await context.bot.delete_message(update.effective_chat.id, context.user_data.get(PROMPT_LOCATION_KEYWORD))

    location_search_keyword = update.effective_message.text
    latitude = context.user_data.get("latitude")
    longitude = context.user_data.get("longitude")

    keyboard = []
    poi_result = query_poi(location_search_keyword, latitude, longitude)
    if len(poi_result) == 0:
        poi_result = query_poi("", latitude, longitude)

    for poi in poi_result:
        keyboard.append([
            InlineKeyboardButton(poi["name"], callback_data=poi["fsq_id"]),
        ])

    if len(keyboard) == 0:
        msg = await update.message.reply_text(PROMPT_WAIT_LOCATION_CONFIRMATION_NO_NEARBY_POI)
    else:
        context.user_data["location_search"] = location_search_keyword
        msg = await update.message.reply_text(PROMPT_WAIT_LOCATION_CONFIRMATION,
                                              reply_markup=InlineKeyboardMarkup(keyboard))

    context.user_data[PROMPT_WAIT_LOCATION_CONFIRMATION] = msg.message_id
    return LOCATION_CONFIRMATION


async def callback_skip_location_keyword(update: Update, context: ContextTypes.DEFAULT_TYPE) -> int:
    query = update.callback_query
    await query.answer()

    await query.message.delete()
    latitude = context.user_data.get("latitude")
    longitude = context.user_data.get("longitude")

    keyboard = []

    for poi in query_poi("", latitude, longitude):
        keyboard.append([
            InlineKeyboardButton(poi["name"], callback_data=poi["fsq_id"]),
        ])

    await query.message.reply_text(PROMPT_WAIT_LOCATION_CONFIRMATION, reply_markup=InlineKeyboardMarkup(keyboard))

    return LOCATION_CONFIRMATION


async def callback_location_confirmation(update: Update, context: ContextTypes.DEFAULT_TYPE) -> int:
    query = update.callback_query
    await query.answer()

    context.user_data["fsq_id"] = query.data
    await query.delete_message()

    poi = get_loc(context.user_data.get("fsq_id"))
    content = generate_toot_text(poi["name"], poi["locality"], poi["region"], poi["latitude"], poi["longitude"])
    status = mastodon_client.status_post(content, visibility=DEFAULT_TOOT_VISIBILITY, media_ids=[])

    context.user_data[KEY_TOOT_STATUS_ID] = status["id"]
    context.user_data[KEY_TOOT_STATUS_CONTENT] = content

    await query.message.reply_text(
        text=f"Selected place: {poi['name']}, `{query.data}`\nPosted to Mastodon: {status['url']}",
        parse_mode=ParseMode.MARKDOWN,
    )

    msg = await query.message.reply_text(PROMPT_ADD_COMMENT, reply_markup=INLINE_SKIP_MENU)
    context.user_data[PROMPT_ADD_COMMENT] = msg.message_id

    return ADD_COMMENT


async def callback_manual_location(update: Update, context: ContextTypes.DEFAULT_TYPE) -> int:
    manual_poi_name = update.effective_message.text
    content = generate_toot_text(manual_poi_name, "", "", context.user_data.get("latitude"),
                                 context.user_data.get("longitude"))
    status = mastodon_client.status_post(content, visibility=DEFAULT_TOOT_VISIBILITY, media_ids=[])

    context.user_data[KEY_TOOT_STATUS_ID] = status["id"]
    context.user_data[KEY_TOOT_STATUS_CONTENT] = content

    await update.message.reply_text(
        text=f"Manually selected place: {manual_poi_name}, \nPosted to Mastodon: {status['url']}",
        parse_mode=ParseMode.MARKDOWN,
    )

    msg = await update.message.reply_text(PROMPT_ADD_COMMENT, reply_markup=INLINE_SKIP_MENU)
    context.user_data[PROMPT_ADD_COMMENT] = msg.message_id

    return ADD_COMMENT


async def callback_add_comment(update: Update, context: ContextTypes.DEFAULT_TYPE) -> int:
    await context.bot.delete_message(update.effective_chat.id, context.user_data.get(PROMPT_ADD_COMMENT))
    comment = update.effective_message.text

    mastodon_client.status_update(id=context.user_data.get(KEY_TOOT_STATUS_ID),
                                  status=f"{comment} " + context.user_data.get(KEY_TOOT_STATUS_CONTENT))

    context.user_data[KEY_TOOT_STATUS_CONTENT] = f"{comment} " + context.user_data.get(KEY_TOOT_STATUS_CONTENT)
    prompt_attach_photo_msg = await update.message.reply_text(PROMPT_ADD_MEDIA, reply_markup=INLINE_SKIP_MENU)
    context.user_data[PROMPT_ADD_MEDIA] = prompt_attach_photo_msg.message_id

    return ADD_MEDIA


async def callback_skip_comment(update: Update, context: ContextTypes.DEFAULT_TYPE) -> int:
    await context.bot.delete_message(update.effective_chat.id, context.user_data.get(PROMPT_ADD_COMMENT))
    prompt_attach_photo_msg = await context.bot.send_message(chat_id=update.effective_chat.id,
                                                             text=PROMPT_ADD_MEDIA,
                                                             reply_markup=INLINE_SKIP_MENU)
    context.user_data[PROMPT_ADD_MEDIA] = prompt_attach_photo_msg.message_id
    return ADD_MEDIA


async def callback_add_media(update: Update, context: CallbackContext):
    async def process_media_group(context: CallbackContext):
        context.job.data = cast(List[MsgDict], context.job.data)

        _media_id = []
        chat_id = context.job.data[0].get("chat_id")
        for _msg_dict in context.job.data:
            if len(_media_id) >= 4:
                await context.bot.send_message(chat_id=chat_id, text=PROMPT_MAX_PHOTO_REACHED, reply_markup=MAIN_MENU)
                return

            _file = await context.bot.get_file(_msg_dict.get("media_id"))
            _img = io.BytesIO()
            await _file.download_to_memory(_img)

            _img.seek(0)

            _media = mastodon_client.media_post(_img.read(), mime_type="image/jpeg")
            _media_id.append(_media["id"])

            mastodon_client.status_update(
                status=_msg_dict.get("content"),
                id=_msg_dict.get("status_id"),
                media_ids=_media_id)

        await context.bot.send_message(chat_id=chat_id, text=PROMPT_DONE, reply_markup=MAIN_MENU)

    await update.message.reply_chat_action(ChatAction.TYPING)

    try:
        await context.bot.delete_message(chat_id=update.message.chat_id,
                                         message_id=context.user_data.get(PROMPT_ADD_MEDIA))
    except BadRequest as e:
        if "not found" in str(e.message):
            pass

    status_id = context.user_data.get(KEY_TOOT_STATUS_ID)
    status_content = context.user_data.get(KEY_TOOT_STATUS_CONTENT)

    message = update.effective_message
    context.user_data["media"] = []
    if message.media_group_id:
        media_id = message.photo[-1].file_id if message.photo else message.effective_attachment.file_id
        msg_dict = {
            "media_id": media_id,
            "caption": message.caption_html,
            "status_id": status_id,
            "content": status_content,
            "chat_id": message.chat_id,
        }
        jobs = context.job_queue.get_jobs_by_name(str(message.media_group_id))
        if jobs:
            jobs[0].data.append(msg_dict)
        else:
            context.job_queue.run_once(callback=process_media_group, when=MEDIA_GROUP_TIMEOUT,
                                       data=[msg_dict], name=str(message.media_group_id))
    else:
        file = await update.message.effective_attachment[-1].get_file()
        img = io.BytesIO()
        await file.download_to_memory(img)
        img.seek(0)

        media = mastodon_client.media_post(img.read(), mime_type="image/jpeg")
        mastodon_client.status_update(status=status_content, id=status_id, media_ids=media["id"])

        await update.message.reply_text(text=PROMPT_DONE, reply_markup=MAIN_MENU)


async def callback_skip_media(update: Update, context: ContextTypes.DEFAULT_TYPE) -> int:
    query = update.callback_query
    await query.answer()

    await query.delete_message()
    await query.message.reply_text(text=PROMPT_DONE, reply_markup=MAIN_MENU)

    return ConversationHandler.END