From 9399919b0836759b5776555d34da18e3c892ce89 Mon Sep 17 00:00:00 2001
From: corbz <corbz.jones@gmail.com>
Date: Sun, 18 Feb 2024 21:43:28 +0000
Subject: [PATCH] Removed unused and commented code

---
 src/extensions/rss.py | 686 +-----------------------------------------
 1 file changed, 3 insertions(+), 683 deletions(-)

diff --git a/src/extensions/rss.py b/src/extensions/rss.py
index 0e69f3d..6dfcfa6 100644
--- a/src/extensions/rss.py
+++ b/src/extensions/rss.py
@@ -5,35 +5,20 @@ Loading this file via `commands.Bot.load_extension` will add `FeedCog` to the bo
 
 import logging
 from typing import Tuple
-from dataclasses import asdict
 
 import aiohttp
 import validators
 from feedparser import FeedParserDict, parse
 from discord.ext import commands
-from discord import Interaction, Embed, Colour, TextChannel, Permissions
-from discord.app_commands import Choice, Group, autocomplete, choices, rename, command
-from sqlalchemy import insert, select, and_, delete
-from sqlalchemy.exc import NoResultFound, IntegrityError
+from discord import Interaction, TextChannel
+from discord.app_commands import Choice, Group, autocomplete, rename
 
 from api import API
-from feed import  Source, RSSFeed, Subscription, SubscriptionChannel, TrackedContent
-from errors import IllegalFeed
-from db import (
-    DatabaseManager,
-    SentArticleModel,
-    RssSourceModel,
-    FeedChannelModel,
-    AuditModel
-)
+from feed import  Subscription, SubscriptionChannel, TrackedContent
 from utils import (
     Followup,
     PaginationView,
     get_rss_data,
-    followup,
-    audit,
-    extract_error_info,
-    get_unparsed_feed
 )
 
 log = logging.getLogger(__name__)
@@ -91,24 +76,6 @@ async def validate_rss_source(nickname: str, url: str) -> Tuple[str | None, Feed
 
     return None, feed
 
-async def set_all_articles_as_sent(inter, channel: TextChannel, feed_id: int, rss_url: str):
-    unparsed_feed = await get_unparsed_feed(rss_url)
-    source = Source.from_parsed(parse(unparsed_feed))
-    articles = source.get_latest_articles()
-
-    async with DatabaseManager() as database:
-        query = insert(SentArticleModel).values([
-            {
-                "discord_server_id": inter.guild_id,
-                "discord_channel_id": channel.id,
-                "discord_message_id": -1,
-                "article_url": article.url,
-                "feed_channel_id": feed_id 
-            }
-            for article in articles
-        ])
-        await database.session.execute(query)
-
 
 class FeedCog(commands.Cog):
     """
@@ -125,27 +92,6 @@ class FeedCog(commands.Cog):
 
         log.info("%s cog is ready", self.__class__.__name__)
 
-    # async def autocomplete_channels(self, inter: Interaction, name: str) -> list[Choice]:
-    #     """"""
-
-    #     log.debug("autocompleting channels '%s'", name)
-
-    #     try:
-    #         async with aiohttp.ClientSession() as session:
-    #             api = API(self.bot.api_token, session)
-    #             results, _ = await api.get_channel(server=inter.guild_id)
-
-    #     except Exception as exc:
-    #         log.error(exc)
-    #         return []
-
-    #     channels = Channel.from_list(results)
-
-    #     return [
-    #         Choice(name=channel.get_textchannel(self.bot).name, value=channel.id)
-    #         for channel in channels
-    #     ]
-
     async def autocomplete_subscriptions(self, inter: Interaction, name: str) -> list[Choice]:
         """"""
 
@@ -192,101 +138,6 @@ class FeedCog(commands.Cog):
             for link in subscription_channels
         ]
 
-
-    # channel_group = Group(
-    #     name="channels",
-    #     description="channel commands",
-    #     guild_only=True
-    # )
-
-    # @channel_group.command(name="add")
-    # @autocomplete(sub_uuid=autocomplete_subscriptions)
-    # @rename(sub_uuid="subscription", textchannel="channel")
-    # async def new_channel(self, inter: Interaction, sub_uuid: str, textchannel: TextChannel):
-    #     """Create a new channel."""
-
-    #     await inter.response.defer()
-
-    #     try:
-    #         async with aiohttp.ClientSession() as session:
-    #             api = API(self.bot.api_token, session)
-    #             await api.create_channel(textchannel.id)
-    #             # sub = await api.get_subscription(sub_uuid)
-    #             # sub["channels"].append(textchannel.id)
-    #             # await api.put_subscription(sub_uuid, sub)
-
-    #     except Exception as exc:
-    #         return await (
-    #             Followup(exc.__class__.__name__, str(exc))
-    #             .error()
-    #             .send(inter)
-    #         )
-
-    #     await (
-    #         Followup("Channel Assigned!")
-    #         .fields(
-    #             subscription=sub_uuid,
-    #             channel=textchannel.mention
-    #         )
-    #         .added()
-    #         .send(inter)
-    #     )
-
-    # @channel_group.command(name="remove")
-    # @autocomplete(id=autocomplete_channels)
-    # @rename(id="choice")
-    # async def remove_channel(self, inter: Interaction, id: int):
-    #     """Remove a channel."""
-
-    #     await inter.response.defer()
-
-    #     try:
-    #         async with aiohttp.ClientSession() as session:
-    #             api = API(self.bot.api_token, session)
-    #             await api.delete_channel(id)
-
-    #     except Exception as exc:
-    #         return await (
-    #             Followup(exc.__class__.__name__, str(exc))
-    #             .error()
-    #             .send(inter)
-    #         )
-
-    #     await (
-    #         Followup("Channel Removed!", str(id))
-    #         .trash()
-    #         .send(inter)
-    #     )
-
-    # @channel_group.command(name="list")
-    # async def list_channels(self, inter: Interaction):
-
-    #     log.debug("Listing all subscription channels with this server.")
-
-    #     await inter.response.defer()
-
-    #     page = 1
-    #     pagesize = 10
-
-    #     def formatdata(index, item):
-    #         item = Channel.from_dict(item)
-    #         text_channel = item.get_textchannel(self.bot)
-
-    #         key = f"{index}. {text_channel.mention}"
-    #         value = f"[RSS]({item.rss_url}) · [API]({API.CHANNEL_ENDPOINT}{item.uuid}/)"
-    #         return key, value
-
-    #     async def getdata(page):
-    #         async with aiohttp.ClientSession() as session:
-    #             api = API(self.bot.api_token, session)
-    #             return await api.get_subscriptions(
-    #                 server=inter.guild.id, page=page, page_size=pagesize
-    #             )
-
-    #     embed = Followup(f"Subscriptions in {inter.guild.name}").info()._embed
-    #     pagination = PaginationView(self.bot, inter, embed, getdata, formatdata, pagesize, page)
-    #     await pagination.send()
-
     subscription_group = Group(
         name="subscriptions",
         description="subscription commands",
@@ -494,537 +345,6 @@ class FeedCog(commands.Cog):
         await pagination.send()
 
 
-    # # All RSS commands belong to this group.
-    # feed_group = Group(
-    #     name="feed",
-    #     description="Commands for RSS sources.",
-    #     default_permissions=Permissions.elevated(),
-    #     guild_only=True  # We store guild IDs in the database, so guild only = True
-    # )
-
-    # @feed_group.command(name="new")
-    # async def add_rssfeed(self, inter: Interaction, name: str, url: str):
-    #     """Add a new RSS Feed for this server.
-
-    #     Args:
-    #         inter (Interaction): Represents the discord command interaction.
-    #         name (str): A nickname used to refer to this RSS Feed.
-    #         url (str): The URL of the RSS Feed.
-    #     """
-
-    #     await inter.response.defer()
-
-    #     try:
-    #         rssfeed = await self.bot.functions.create_new_rssfeed(name, url, inter.guild_id)
-    #     except Exception as exc:
-    #         await (
-    #             Followup(exc.__class__.__name__, str(exc))
-    #             .error()
-    #             .send(inter)
-    #         )
-    #     else:
-    #         await (
-    #             Followup("New RSS Feed")
-    #             .image(rssfeed.image)
-    #             .fields(uuid=rssfeed.uuid, name=name, url=url)
-    #             .added()
-    #             .send(inter)
-    #         )
-
-    # @feed_group.command(name="delete")
-    # @autocomplete(uuid=autocomplete_rssfeed)
-    # @rename(uuid="rssfeed")
-    # async def delete_rssfeed(self, inter: Interaction, uuid: str):
-    #     """Delete an existing RSS Feed for this server.
-
-    #     Args:
-    #         inter (Interaction): Represents the discord command interaction.
-    #         uuid (str): The UUID of the 
-    #     """
-
-    #     await inter.response.defer()
-
-    #     try:
-    #         rssfeed = await self.bot.functions.delete_rssfeed(uuid)
-    #     except NoResultFound: 
-    #         await (
-    #             Followup(
-    #                 "Feed Not Found Error",
-    #                 "A Feed with these parameters could not be found."
-    #             )
-    #             .error()
-    #             .send(inter)
-    #         )
-    #     else:
-    #         await (
-    #             Followup("Feed Deleted")
-    #             .image(rssfeed.image)
-    #             .fields(uuid=rssfeed.uuid, name=rssfeed.name, url=rssfeed.url)
-    #             .trash()
-    #             .send(inter)
-    #         )
-
-    # @feed_group.command(name="list")
-    # async def list_rssfeeds(self, inter: Interaction):
-    #     """Provides a list of all RSS Feeds
-
-    #     Args:
-    #         inter (Interaction): Represents the discord command interaction.
-    #     """
-
-    #     await inter.response.defer()
-
-    #     page = 1
-    #     pagesize = 10
-
-    #     try:
-    #         def formatdata(index, item):
-    #             key = f"{index}. {item.name}"
-    #             value = f"[RSS]({item.url}) · [API]({API.RSS_FEED_ENDPOINT}{item.uuid}/)"
-    #             return key, value
-
-    #         async def getdata(page):
-    #             data, count =  await self.bot.functions.get_rssfeeds(inter.guild_id, page, pagesize)
-    #             return data, count
-
-    #         embed = Followup(f"Available RSS Feeds in {inter.guild.name}").info()._embed
-    #         pagination = PaginationView(self.bot, inter, embed, getdata, formatdata, pagesize, 1)
-    #         await pagination.send()
-
-    #     except Exception as exc:
-    #         await (
-    #             Followup(exc.__class__.__name__, str(exc))
-    #             .error()
-    #             .send(inter)
-    #         )
-
-    # # @feed_group.command(name="fetch")
-    # # @rename(max_="max")
-    # # @autocomplete(rss=source_autocomplete)
-    # async def fetch_rss(self, inter: Interaction, rss: str, max_: int=1):
-    #     """Fetch an item from the specified RSS feed.
-
-    #     Parameters
-    #     ----------
-    #     inter : Interaction
-    #         Represents an app command interaction.
-    #     rss : str
-    #         The RSS feed to fetch from.
-    #     max_ : int, optional
-    #         Maximum number of items to fetch, by default 1, limits at 5.
-    #     """
-
-    #     await inter.response.defer()
-
-    #     if max_ > 5:
-    #         followup(inter, "It looks like you have requested too many articles.\nThe limit is 5")
-    #         return
-
-    #     invalid_message, feed = await validate_rss_source("", rss)
-    #     if invalid_message:
-    #         await followup(inter, invalid_message)
-    #         return
-
-    #     source = Source.from_parsed(feed)
-    #     articles = source.get_latest_articles(max_)
-
-    #     if not articles:
-    #         await followup(inter, "Sorry, I couldn't find any articles from this feed.")
-    #         return
-
-    #     async with aiohttp.ClientSession() as session:
-    #         embeds = [await article.to_embed(session) for article in articles]
-
-    #     async with DatabaseManager() as database:
-    #         query = insert(SentArticleModel).values([
-    #             {
-    #                 "discord_server_id": inter.guild_id,
-    #                 "discord_channel_id": inter.channel_id,
-    #                 "discord_message_id": inter.id,
-    #                 "article_url": article.url,
-    #             }
-    #             for article in articles
-    #         ])
-    #         await database.session.execute(query)
-    #         await audit(self,
-    #             f"User is requesting {max_} articles from {source.name}",
-    #             inter.user.id, database=database
-    #         )
-
-    #     await followup(inter, embeds=embeds)
-
-    # # Help     ---- ---- ----
-
-    # @feed_group.command(name="help")
-    # async def get_help(self, inter: Interaction):
-    #     """Get help on how to use my commands.
-
-    #     Parameters
-    #     ----------
-    #     inter : Interaction
-    #         Represents an app command interaction.
-    #     """
-
-    #     await inter.response.defer()
-
-    #     description = (
-    #         "`/feed add <nickname> <url>` \n\n"
-    #         "Save a new RSS feed to the bot. This can be referred to later, when assigning "
-    #         "channels to receive content from these RSS feeds."
-
-    #         "\n\n\n`/feed remove <option>` \n\n"
-    #         "Remove a previously saved RSS feed. Select the nickname from the shown options "
-    #         "if any. You can re-add the RSS feed to the bot using the `/feeds add` command."
-
-    #         "\n\n\n`/feed list <sort> <sort_reverse>` \n\n"
-    #         "List all saved RSS feeds numerically. Use the `<sort>` option to order "
-    #         "the results by either nickname or date & time added. Use the `<sort_reverse>` "
-    #         "option to order by ascending or descending in conjunction with the `<sort>` option."
-
-    #         "\n\n\n`/feed assign <rss> <textchannel>` \n\n"
-    #         "Assign a channel to an RSS feed. Previously saved RSS feeds will be selectable "
-    #         "under the `<rss>` option. The channel will be assumed as the current channel, "
-    #         "unless specified otherwise using the `<textchannel` option."
-
-    #         "\n\n\n`/feed unassign <option>` \n\n"
-    #         "Unassigned channel from an RSS feed. Previously assigned channels will be shown "
-    #         "as an `<option>`, select one to remove it."
-
-    #         "\n\n\n`/feed channels` \n\n"
-    #         "List all channels assigned to an RSS feed numerically."
-    #     )
-
-    #     embed = Embed(
-    #         title="Help",
-    #         description=description,
-    #         colour=Colour.blue(),
-    #     )
-
-    #     await followup(inter, embed=embed)
-
-    # # Channels ---- ---- ----
-
-    # async def autocomplete_rss_sources(self, inter: Interaction, nickname: str):
-    #     """_summary_
-
-    #     Parameters
-    #     ----------
-    #     inter : Interaction
-    #         _description_
-    #     nickname : str
-    #         _description_
-
-    #     Returns
-    #     -------
-    #     _type_
-    #         _description_
-    #     """
-
-    #     async with DatabaseManager() as database:
-    #         whereclause = and_(
-    #             RssSourceModel.discord_server_id == inter.guild_id,
-    #             RssSourceModel.nick.ilike(f"%{nickname}%")
-    #         )
-    #         query = select(RssSourceModel).where(whereclause)
-    #         result = await database.session.execute(query)
-    #         sources = [
-    #             Choice(name=rss.nick, value=rss.rss_url)
-    #             for rss in result.scalars().all()
-    #         ]
-
-    #     log.debug("Autocomplete rss_sources returned %s results", len(sources))
-
-    #     return sources
-
-    # async def autocomplete_existing_feeds(self, inter: Interaction, current: str):
-    #     """Returns a list of existing RSS + Channel feeds.
-
-    #     Parameters
-    #     ----------
-    #     inter : Interaction
-    #         Represents an app command interaction.
-    #     current : str
-    #         The current text entered for the autocomplete.
-    #     """
-
-    #     async with DatabaseManager() as database:
-    #         whereclause = and_(
-    #             FeedChannelModel.discord_server_id == inter.guild_id,
-    #             FeedChannelModel.search_name.ilike(f"%{current}%"),
-    #             RssSourceModel.id == FeedChannelModel.rss_source_id
-    #         )
-    #         query = (
-    #             select(FeedChannelModel, RssSourceModel)
-    #             .where(whereclause)
-    #             .join(RssSourceModel)
-    #             .order_by(FeedChannelModel.discord_channel_id)
-    #         )
-    #         result = await database.session.execute(query)
-    #         feeds = []
-    #         for feed in result.scalars().all():
-    #             channel = inter.guild.get_channel(feed.discord_channel_id)
-    #             feeds.append(Choice(
-    #                 name=f"# {channel.name}  |  {feed.rss_source.nick}",
-    #                 value=feed.id
-    #             ))
-
-    #     log.debug("Autocomplete existing_feeds returned %s results", len(feeds))
-
-    #     return feeds
-
-    # # # All RSS commands belong to this group.
-    # # channel_group = Group(
-    # #     name="channels",
-    # #     description="Commands for channel assignment.",
-    # #     guild_only=True  # These commands belong to channels of
-    # # )
-
-    # @feed_group.command(name="assign")
-    # @rename(url="feed")
-    # @autocomplete(url=autocomplete_rss_sources)
-    # async def include_feed(
-    #     self, inter: Interaction, url: str, channel: TextChannel = None, prevent_spam: bool = True
-    # ):
-    #     """Include a feed within the specified channel.
-
-    #     Parameters
-    #     ----------
-    #     inter : Interaction
-    #         Represents an app command interaction.
-    #     url : int
-    #         The RSS feed to include.
-    #     channel : TextChannel
-    #         The channel to include the feed in.
-    #     """
-
-    #     await inter.response.defer()
-
-    #     channel = channel or inter.channel
-
-    #     try:
-    #         feed_id, source = await self.bot.functions.assign_feed(
-    #             url, channel.name, channel.id, inter.guild_id
-    #         )
-    #     except IntegrityError:
-    #         await (
-    #             Followup(
-    #                 "Duplicate Assigned Feed Error",
-    #                 f"This Feed has already been assigned to {channel.mention}"
-    #             )
-    #             .error()
-    #             .send(inter)
-    #         )
-    #     except NoResultFound:
-    #         await (
-    #             Followup(
-    #                 "Feed Not Found Error",
-    #                 "A Feed with these parameters could not be found."
-    #             )
-    #             .error()
-    #             .send(inter)
-    #         )
-    #     else:
-    #         await (
-    #             Followup(
-    #                 "Feed Assigned",
-    #                 f"I've assigned {channel.mention} to receive content from "
-    #                 f"[{source.name}]({source.url})."
-    #             )
-    #             .assign()
-    #             .send(inter)
-    #         )
-
-    #     if prevent_spam:
-    #         await set_all_articles_as_sent(inter, channel, feed_id, url)
-
-    # @feed_group.command(name="unassign")
-    # @autocomplete(option=autocomplete_existing_feeds)
-    # async def exclude_feed(self, inter: Interaction, option: int):
-    #     """Undo command for the `/channel include-feed` command.
-
-    #     Parameters
-    #     ----------
-    #     inter : Interaction
-    #         Represents an app command interaction.
-    #     option : str
-    #         The RSS feed and channel to exclude.
-    #     """
-
-    #     await inter.response.defer()
-
-    #     try:
-    #         await self.bot.functions.unassign_feed(option, inter.guild_id)
-    #     except NoResultFound:
-    #         await (
-    #             Followup(
-    #                 "Assigned Feed Not Found",
-    #                 "The assigned Feed doesn't exist."
-    #             )
-    #             .error()
-    #             .send(inter)
-    #         )
-    #     else:
-    #         await (
-    #             Followup(
-    #                 "Unassigned Feed",
-    #                 "Feed has been unassigned."                                                                                                                       
-    #             )
-    #             .trash()
-    #             .send(inter)
-    #         )
-
-    #     # async with DatabaseManager() as database:
-    #     #     query = delete(FeedChannelModel).where(and_(
-    #     #         FeedChannelModel.id == option,
-    #     #         FeedChannelModel.discord_server_id == inter.guild_id
-    #     #     ))
-
-    #     #     result = await database.session.execute(query)
-
-    #     # if not result.rowcount:
-    #     #     await followup_error(inter,
-    #     #         title="Assigned Feed Not Found",
-    #     #         message=f"I couldn't find any assigned feeds for the option: {option}"
-    #     #     )
-    #     #     return
-
-    #     await followup(inter, "I've removed this item (placeholder response)")
-
-    # @feed_group.command(name="channels")
-    # @choices(sort=channels_list_sort_choices)
-    # async def list_feeds(self, inter: Interaction, sort: Choice[int] = 0, sort_reverse: bool = False):
-    #     """List all of the channels and their respective included feeds.
-
-    #     Parameters
-    #     ----------
-    #     inter : Interaction
-    #         Represents an app command interaction.
-    #     """
-
-    #     await inter.response.defer()
-
-    #     description = "Sort By "
-
-    #     if isinstance(sort, Choice):
-    #         match sort.value, sort_reverse:
-    #             case 0, False:
-    #                 order_by = RssSourceModel.nick.asc()
-    #                 description += "Nickname "
-    #             case 0, True:
-    #                 order_by = RssSourceModel.nick.desc()
-    #                 description += "Nickname "
-    #             case 1, False:
-    #                 order_by = FeedChannelModel.discord_channel_id.asc()
-    #                 description += "Channel ID "
-    #             case 1, True:
-    #                 order_by = FeedChannelModel.discord_channel_id.desc()
-    #                 description += "Channel ID "
-    #             case 2, False:
-    #                 order_by = RssSourceModel.created.desc()
-    #                 description += "Date Added "
-    #             case 2, True:
-    #                 order_by = RssSourceModel.created.asc()
-    #                 description += "Date Added "
-    #             case _, _:
-    #                 raise ValueError(f"Unknown sort: {sort}")
-    #     else:
-    #         order_by = FeedChannelModel.discord_channel_id.asc()
-    #         description = ""
-
-    #     async with DatabaseManager() as database:
-    #         whereclause = and_(
-    #             FeedChannelModel.discord_server_id == inter.guild_id,
-    #             RssSourceModel.id == FeedChannelModel.rss_source_id
-    #         )
-    #         query = (
-    #             select(FeedChannelModel, RssSourceModel)
-    #             .where(whereclause)
-    #             .join(RssSourceModel)
-    #             .order_by(order_by)
-    #         )
-    #         result = await database.session.execute(query)
-
-    #         feed_channels = result.scalars().all()
-    #         rowcount = len(feed_channels)
-
-    #         if not feed_channels:
-    #             await followup_error(inter,
-    #                 title="No Assigned Feeds Found",
-    #                 message="Assign a channel to receive feed content with `/feed assign`."
-    #             )
-    #             return
-
-    #         output = "\n".join([
-    #             f"{i}. <#{feed.discord_channel_id}> · "  # TODO: add icon indicating inaccessible channel, if is the case.
-    #             f"[{feed.rss_source.nick}]({feed.rss_source.rss_url})"
-    #             for i, feed in enumerate(feed_channels)
-    #         ])
-
-    #     embed = Embed(
-    #         title="Saved Feed Channels",
-    #         description=f"{description}\n{output}",
-    #         colour=Colour.blue()
-    #     )
-    #     embed.set_footer(text=f"Showing {rowcount} results")
-
-    #     await followup(inter, embed=embed)
-
-    # admin_group = Group(
-    #     name="admin",
-    #     description="Administration tasks",
-    #     guild_only=True,
-    #     default_permissions=Permissions.elevated()
-    # )
-
-    # @admin_group.command(name="clear-sent-articles")
-    # async def clear_sent_articles(self, inter: Interaction):
-    #     """Clear the database of all sent articles.
-
-    #     Parameters
-    #     ----------
-    #     inter : Interaction
-    #         Represents an app command interaction.
-    #     """
-
-    #     await inter.response.defer()
-
-    #     async with DatabaseManager() as database:
-    #         query = delete(SentArticleModel).where(and_(
-    #             SentArticleModel.discord_server_id == inter.guild_id
-    #         ))
-    #         result = await database.session.execute(query)
-
-    #     await followup(inter,
-    #         f"{result.rowcount} sent articles have been cleared from the database. "
-    #         "I will no longer recognise these articles as sent, and will send them "
-    #         "again if they appear during the next RSS feed scan."
-    #     )
-
-    # audit_group = Group(
-    #     name="audit",
-    #     description="Check audited actions.",
-    #     guild_only=True,
-    #     default_permissions=Permissions.elevated()
-    # )
-
-    # @audit_group.command(name="check")
-    # async def check_audit_log(self, inter: Interaction):
-    #     """Check the audit log.
-
-    #     Parameters
-    #     ----------
-    #     inter : Interaction
-    #         Represents an app command interaction.
-    #     """
-
-    #     await inter.response.defer()
-
-    #     async with DatabaseManager() as database:
-    #         query = select(AuditModel).where(and_(
-    #         ))
-    #         result = await database.session.execute(query)
-
-
 async def setup(bot):
     """
     Setup function for this extension.