From 70065dcdcc61058553a0043dbf7803df4e6b1472 Mon Sep 17 00:00:00 2001
From: Dreu Lavelle <dreu.lavelle@dajac.com>
Date: Wed, 20 Dec 2023 10:54:20 -0500
Subject: [PATCH 1/8] Fix range index issues on episode check

---
 backend/program/symlink.py | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/backend/program/symlink.py b/backend/program/symlink.py
index 78fa8c52..8b37033a 100644
--- a/backend/program/symlink.py
+++ b/backend/program/symlink.py
@@ -95,9 +95,10 @@ def _run(self):
                                 episode = obj["episode"]
                                 if type(episode) == list:
                                     for sub_episode in episode:
-                                        season.episodes[sub_episode - 1].set(
-                                            "file", file["filename"]
-                                        )
+                                        if sub_episode - 1 in range(len(season.episodes)):
+                                            season.episodes[sub_episode - 1].set(
+                                                "file", file["filename"]
+                                            )
                                 else:
                                     index = obj["episode"] - 1
                                     if index in range(len(season.episodes)):

From 8656fb68883ff97ab35b0aae57b45462e283e903 Mon Sep 17 00:00:00 2001
From: Dreu Lavelle <dreu.lavelle@dajac.com>
Date: Wed, 20 Dec 2023 11:06:28 -0500
Subject: [PATCH 2/8] Fix docstring

---
 backend/program/symlink.py | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/backend/program/symlink.py b/backend/program/symlink.py
index 8b37033a..333888df 100644
--- a/backend/program/symlink.py
+++ b/backend/program/symlink.py
@@ -10,7 +10,18 @@
 
 
 class Symlinker(threading.Thread):
-    """Content class for mdblist"""
+    """
+    A class that represents a symlinker thread.
+
+    Attributes:
+        media_items (MediaItemContainer): The container of media items.
+        running (bool): Flag indicating if the thread is running.
+        cache (dict): A dictionary to cache file paths.
+        mount_path (str): The absolute path of the container mount.
+        host_path (str): The absolute path of the host mount.
+        symlink_path (str): The path where the symlinks will be created.
+        cache_thread (ThreadRunner): The thread runner for updating the cache.
+    """
 
     def __init__(self, media_items: MediaItemContainer):
         # Symlinking is required

From 345746c9602c6275691a7c3277523b7e79c7092f Mon Sep 17 00:00:00 2001
From: Dreu Lavelle <dreu.lavelle@dajac.com>
Date: Wed, 20 Dec 2023 17:15:55 -0500
Subject: [PATCH 3/8] Added requested_by, and other tweaks.

---
 backend/program/content/mdblist.py        |  2 ++
 backend/program/content/overseerr.py      |  2 ++
 backend/program/content/plex_watchlist.py |  3 +++
 backend/program/debrid/realdebrid.py      |  4 ++--
 backend/program/media.py                  | 11 ++++++---
 backend/program/scrapers/torrentio.py     | 27 +++++++++++++----------
 backend/program/updaters/trakt.py         |  1 +
 backend/utils/default_settings.json       |  4 ++--
 8 files changed, 35 insertions(+), 19 deletions(-)

diff --git a/backend/program/content/mdblist.py b/backend/program/content/mdblist.py
index 8fc14325..bf9d5be0 100644
--- a/backend/program/content/mdblist.py
+++ b/backend/program/content/mdblist.py
@@ -42,6 +42,8 @@ def run(self):
 
                 new_items = [item for item in items if item not in self.media_items]
                 container = self.updater.create_items(new_items)
+                for item in container:
+                    item.set_requested_by("Mdblist")
                 added_items = self.media_items.extend(container)
                 if len(added_items) > 0:
                     logger.info("Added %s items", len(added_items))
diff --git a/backend/program/content/overseerr.py b/backend/program/content/overseerr.py
index ecfd6695..5ac32480 100644
--- a/backend/program/content/overseerr.py
+++ b/backend/program/content/overseerr.py
@@ -38,6 +38,8 @@ def run(self):
         items = self._get_items_from_overseerr(10000)
         new_items = [item for item in items if item not in self.media_items]
         container = self.updater.create_items(new_items)
+        for item in container:
+            item.set_requested_by("Overseerr")
         added_items = self.media_items.extend(container)
         if len(added_items) > 0:
             logger.info("Added %s items", len(added_items))
diff --git a/backend/program/content/plex_watchlist.py b/backend/program/content/plex_watchlist.py
index acea8a05..270c92f0 100644
--- a/backend/program/content/plex_watchlist.py
+++ b/backend/program/content/plex_watchlist.py
@@ -22,6 +22,7 @@ def __init__(self, media_items: MediaItemContainer):
             return
         self.updater = Trakt()
         self.initialized = True
+        self.requested_by = "Plex Watchlist"
 
     def _validate_settings(self):
         try:
@@ -39,6 +40,8 @@ def run(self):
         items = self._get_items_from_plex_watchlist()
         new_items = [item for item in items if item not in self.media_items]
         container = self.updater.create_items(new_items)
+        for item in container:
+            item.set_requested_by("Plex Watchlist")
         added_items = self.media_items.extend(container)
         if len(added_items) > 0:
             logger.info("Added %s items", len(added_items))
diff --git a/backend/program/debrid/realdebrid.py b/backend/program/debrid/realdebrid.py
index 6129c753..67e6cc5a 100644
--- a/backend/program/debrid/realdebrid.py
+++ b/backend/program/debrid/realdebrid.py
@@ -123,9 +123,9 @@ def _download_item(self, item):
         if item.type == "movie":
             log_string = item.title
         if item.type == "season":
-            log_string = f"{item.parent.title} season {item.number}"
+            log_string = f"{item.parent.title} S{item.number}"
         if item.type == "episode":
-            log_string = f"{item.parent.parent.title} season {item.parent.number} episode {item.number}"
+            log_string = f"{item.parent.parent.title} S{item.parent.number}E{item.number}"
 
         logger.debug("Downloaded %s", log_string)
         return 1
diff --git a/backend/program/media.py b/backend/program/media.py
index 6657c36c..78a9cac7 100644
--- a/backend/program/media.py
+++ b/backend/program/media.py
@@ -32,6 +32,7 @@ def __init__(self, item):
         self.streams = {}
         self.symlinked = False
         self.requested_at = item.get("requested_at", None) or datetime.datetime.now()
+        self.requested_by = item.get("requested_by", None)
 
         # Media related
         self.title = item.get("title", None)
@@ -87,7 +88,8 @@ def to_dict(self):
             "aired_at": self.aired_at,
             "genres": self.genres,
             "guid": self.guid,
-            "requested_at": self.requested_at
+            "requested_at": self.requested_at,
+            "requested_by": self.requested_by
         }
     
     def to_extended_dict(self):
@@ -97,7 +99,10 @@ def to_extended_dict(self):
         if self.type == "season":
             dict["episodes"] = [episode.to_extended_dict() for episode in self.episodes]
         return dict
-    
+
+    def set_requested_by(self, requested_by):
+        self.requested_by = requested_by
+
     def is_not_cached(self):
         return not self.is_cached()
 
@@ -276,7 +281,7 @@ def __iadd__(self, other):
         return self
 
     def sort(self, by, reverse):
-        self.items.sort(key=lambda item: item.get(by), reverse=reverse)
+        self.items.sort(key=lambda item: item.get(by) if item is not None else None)
 
     def __len__(self):
         """Get length of container"""
diff --git a/backend/program/scrapers/torrentio.py b/backend/program/scrapers/torrentio.py
index a7cad2fc..b80f88ee 100644
--- a/backend/program/scrapers/torrentio.py
+++ b/backend/program/scrapers/torrentio.py
@@ -63,19 +63,22 @@ def _scrape_show(self, item: MediaItem):
     def _scrape_items(self, items: list):
         amount_scraped = 0
         for item in items:
-            data = self.api_scrape(item)
-            log_string = item.title
-            if item.type == "season":
-                log_string = f"{item.parent.title} season {item.number}"
-            if item.type == "episode":
-                log_string = f"{item.parent.parent.title} season {item.parent.number} episode {item.number}"
-            if len(data) > 0:
-                item.set("streams", data)
-                logger.debug("Found %s streams for %s", len(data), log_string)
-                amount_scraped += 1
+            try:
+                data = self.api_scrape(item)
+                log_string = item.title
+                if item.type == "season":
+                    log_string = f"{item.parent.title} season {item.number}"
+                if item.type == "episode":
+                    log_string = f"{item.parent.parent.title} season {item.parent.number} episode {item.number}"
+                if len(data) > 0:
+                    item.set("streams", data)
+                    logger.debug("Found %s streams for %s", len(data), log_string)
+                    amount_scraped += 1
+                    continue
+                logger.debug("Could not find streams for %s", log_string)
+            except Exception as e:
+                logger.error("Error occurred while scraping %s: %s", log_string, str(e))
                 continue
-            logger.debug("Could not find streams for %s", log_string)
-        return amount_scraped
 
     def _can_we_scrape(self, item: MediaItem) -> bool:
         def is_released():
diff --git a/backend/program/updaters/trakt.py b/backend/program/updaters/trakt.py
index cb708048..83813fd5 100644
--- a/backend/program/updaters/trakt.py
+++ b/backend/program/updaters/trakt.py
@@ -80,6 +80,7 @@ def _map_item_from_data(data, item_type):
         "aired_at": formatted_aired_at,
         "genres": getattr(data, "genres", None),
         "requested_at": datetime.now(),
+        "requested_by": getattr(data, 'requested_by', None),
     }
     match item_type:
         case "movie":
diff --git a/backend/utils/default_settings.json b/backend/utils/default_settings.json
index 2367f5e3..f721d0b5 100644
--- a/backend/utils/default_settings.json
+++ b/backend/utils/default_settings.json
@@ -1,6 +1,6 @@
 {
-  "version": "0.2.1",
-  "debug": true,
+  "version": "0.3.0",
+  "debug": false,
   "log": true,
   "host_mount": "",
   "container_mount": "",

From 8538e6012f9b2e3d5f911c38102795d752c88072 Mon Sep 17 00:00:00 2001
From: Spoked <Spoked@localhost>
Date: Thu, 21 Dec 2023 01:58:40 -0500
Subject: [PATCH 4/8] Lots of tweaks everywhere. Ready for Review

---
 Dockerfile                                |  2 +-
 README.md                                 |  6 +++--
 backend/program/content/plex_watchlist.py | 27 ++++++++++++-----------
 backend/program/media.py                  |  4 ++++
 backend/program/scrapers/torrentio.py     |  7 +++---
 backend/program/updaters/trakt.py         |  2 ++
 backend/utils/logger.py                   |  1 +
 entrypoint.sh                             |  2 +-
 makefile                                  | 20 +++++------------
 9 files changed, 36 insertions(+), 35 deletions(-)

diff --git a/Dockerfile b/Dockerfile
index b8ff047c..ccb3da9f 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -34,4 +34,4 @@ COPY entrypoint.sh ./entrypoint.sh
 RUN chmod +x ./entrypoint.sh
 ENTRYPOINT ["/iceberg/entrypoint.sh"]
 
-EXPOSE 3000 8080
+EXPOSE 3000 8080
\ No newline at end of file
diff --git a/README.md b/README.md
index c55f65d1..8f0e6309 100644
--- a/README.md
+++ b/README.md
@@ -85,10 +85,12 @@ You can view the readme in `make` to get started!
 make
 ```
 
-To get started you can simply
+To get started you can simply do this. This will stop any previous Iceberg containers and remove previous image.
+As well as rebuild the image using cached layers. If your a developer, then any files changed in the code will not get cached, 
+and thus rebuilt in the image.
 
 ```sh
 make start
 ```
 
-You can restart with `make restart` **or** `make restart-nocache` to build the image without caching layers.
+You can also restart the container with `make restart`, or view the logs with `make logs`. 
diff --git a/backend/program/content/plex_watchlist.py b/backend/program/content/plex_watchlist.py
index 270c92f0..69a6a001 100644
--- a/backend/program/content/plex_watchlist.py
+++ b/backend/program/content/plex_watchlist.py
@@ -15,6 +15,7 @@ def __init__(self, media_items: MediaItemContainer):
         self.initialized = False
         self.media_items = media_items
         self.watchlist_url = settings.get("plex")["watchlist"]
+        self.previous_added_items_count = 0
         if not self.watchlist_url or not self._validate_settings():
             logger.info(
                 "Plex watchlist RSS URL is not configured and will not be used."
@@ -22,7 +23,6 @@ def __init__(self, media_items: MediaItemContainer):
             return
         self.updater = Trakt()
         self.initialized = True
-        self.requested_by = "Plex Watchlist"
 
     def _validate_settings(self):
         try:
@@ -42,25 +42,26 @@ def run(self):
         container = self.updater.create_items(new_items)
         for item in container:
             item.set_requested_by("Plex Watchlist")
+        previous_count = len(self.media_items)
         added_items = self.media_items.extend(container)
+        added_items_count = len(self.media_items) - previous_count
+        if added_items_count != self.previous_added_items_count and added_items_count > 0:
+            logger.info("Added %s items", added_items_count)
+            self.previous_added_items_count = added_items_count
         if len(added_items) > 0:
-            logger.info("Added %s items", len(added_items))
+            for added_item in added_items:
+                logger.debug("Added %s", added_item.title)
 
     def _get_items_from_plex_watchlist(self) -> list:
         """Fetch media from Plex watchlist"""
-        response_obj = get(self.watchlist_url, timeout=5)
+        response_obj = get(self.watchlist_url, timeout=30)
         watchlist_data = json.loads(response_obj.response.content)
         items = watchlist_data.get("items", [])
         ids = []
         for item in items:
-            imdb_id = next(
-                (
-                    guid.split("//")[-1]
-                    for guid in item.get("guids")
-                    if "imdb://" in guid
-                ),
-                None,
-            )
-            ids.append(imdb_id)
-        logger.debug("Found %s items", len(ids))
+            imdb_id = next((guid.split("//")[-1] for guid in item.get("guids") if "imdb://" in guid), None)
+            if imdb_id:
+                ids.append(imdb_id)
+            else:
+                logger.debug("No imdb id found for %s", item.get("title"))
         return ids
diff --git a/backend/program/media.py b/backend/program/media.py
index 78a9cac7..4632fff3 100644
--- a/backend/program/media.py
+++ b/backend/program/media.py
@@ -37,6 +37,8 @@ def __init__(self, item):
         # Media related
         self.title = item.get("title", None)
         self.imdb_id = item.get("imdb_id", None)
+        self.tmdb_id = item.get("tmdb_id", None)
+        self.tvdb_id = item.get("tvdb_id", None)
         if self.imdb_id:
             self.imdb_link = f"https://www.imdb.com/title/{self.imdb_id}/"
         self.aired_at = item.get("aired_at", None)
@@ -83,6 +85,8 @@ def to_dict(self):
             "title": self.title,
             "type": self.type,
             "imdb_id": self.imdb_id,
+            "tmdb_id": self.tmdb_id,
+            "tvdb_id": self.tvdb_id,
             "state": self.state.name,
             "imdb_link": self.imdb_link if hasattr(self, "imdb_link") else None,
             "aired_at": self.aired_at,
diff --git a/backend/program/scrapers/torrentio.py b/backend/program/scrapers/torrentio.py
index b80f88ee..8c5698ab 100644
--- a/backend/program/scrapers/torrentio.py
+++ b/backend/program/scrapers/torrentio.py
@@ -63,13 +63,13 @@ def _scrape_show(self, item: MediaItem):
     def _scrape_items(self, items: list):
         amount_scraped = 0
         for item in items:
+            log_string = ""  # Initialize log_string with a default value
             try:
                 data = self.api_scrape(item)
-                log_string = item.title
                 if item.type == "season":
-                    log_string = f"{item.parent.title} season {item.number}"
+                    log_string = f"{item.parent.title} S{item.number}"
                 if item.type == "episode":
-                    log_string = f"{item.parent.parent.title} season {item.parent.number} episode {item.number}"
+                    log_string = f"{item.parent.parent.title} S{item.parent.number}E{item.number}"
                 if len(data) > 0:
                     item.set("streams", data)
                     logger.debug("Found %s streams for %s", len(data), log_string)
@@ -79,6 +79,7 @@ def _scrape_items(self, items: list):
             except Exception as e:
                 logger.error("Error occurred while scraping %s: %s", log_string, str(e))
                 continue
+        return amount_scraped
 
     def _can_we_scrape(self, item: MediaItem) -> bool:
         def is_released():
diff --git a/backend/program/updaters/trakt.py b/backend/program/updaters/trakt.py
index 83813fd5..adfa66fc 100644
--- a/backend/program/updaters/trakt.py
+++ b/backend/program/updaters/trakt.py
@@ -77,6 +77,8 @@ def _map_item_from_data(data, item_type):
         "title": getattr(data, "title", None),
         "year": getattr(data, "year", None),
         "imdb_id": getattr(data.ids, "imdb", None),
+        "tmdb_id": getattr(data.ids, "tmdb", None),
+        "tvdb_id": getattr(data.ids, "tvdb", None),
         "aired_at": formatted_aired_at,
         "genres": getattr(data, "genres", None),
         "requested_at": datetime.now(),
diff --git a/backend/utils/logger.py b/backend/utils/logger.py
index 7ea31bd5..71241f9f 100644
--- a/backend/utils/logger.py
+++ b/backend/utils/logger.py
@@ -20,6 +20,7 @@ def __init__(self):
             "api_key": re.compile(r"(\'api_key\'\s*:\s*\')[^\']*\'", re.IGNORECASE),
             "token": re.compile(r"(\'token\'\s*:\s*\')[^\']*\'", re.IGNORECASE),
             "user": re.compile(r"(\'user\'\s*:\s*\')[^\']*\'", re.IGNORECASE),
+            "watchlist": re.compile(r"(\'watchlist\'\s*:\s*\')[^\']*\'", re.IGNORECASE),
         }
 
     def _redact_string(self, data):
diff --git a/entrypoint.sh b/entrypoint.sh
index 0e619881..2112ec8e 100644
--- a/entrypoint.sh
+++ b/entrypoint.sh
@@ -31,4 +31,4 @@ fi
 chown -R ${USERNAME}:${GROUPNAME} /iceberg
 
 echo "Container Initialization complete."
-exec su -m $USERNAME -c 'cd backend && source /venv/bin/activate && exec python /iceberg/backend/main.py & node /iceberg/frontend/build'
+exec su -m $USERNAME -c 'cd backend && source /venv/bin/activate && exec python /iceberg/backend/main.py & node /iceberg/frontend/build'
\ No newline at end of file
diff --git a/makefile b/makefile
index 6affd144..03a4ecce 100644
--- a/makefile
+++ b/makefile
@@ -1,4 +1,4 @@
-.PHONY: help start reset stop restart rebuild logs exec sc ec update
+.PHONY: help start stop restart logs exec sc ec update
 
 # Detect operating system
 ifeq ($(OS),Windows_NT)
@@ -13,7 +13,6 @@ help:
 	@echo Iceberg Local Development Environment
 	@echo -------------------------------------------------------------------------
 	@echo start     : Build and run the Iceberg container
-	@echo reset     : Build and run the Iceberg container without caching image
 	@echo stop      : Stop and remove the Iceberg container and image
 	@echo restart   : Restart the Iceberg container (without rebuilding image)
 	@echo rebuild   : Rebuild the Iceberg container (with rebuilding image)
@@ -24,24 +23,17 @@ help:
 	@echo update    : Update this repository from GitHub and rebuild image
 	@echo -------------------------------------------------------------------------
 
-start: 
+start: stop
 	@docker build -t iceberg:latest -f Dockerfile .
 	@docker run -d --name iceberg --hostname iceberg -p 3000:3000 -p 8080:8080 -e PUID=1000 -e PGID=1000 -v $(DATA_PATH):/iceberg/data iceberg:latest
 	@echo Iceberg Frontend is running on http://localhost:3000/status/
 	@echo Iceberg Backend is running on http://localhost:8080/items/
 	@docker logs iceberg -f
 
-reset: 
-	@docker build --no-cache -t iceberg:latest -f Dockerfile .
-	@docker run -d --name iceberg --hostname iceberg -p 3000:3000 -p 8080:8080 -e PUID=1000 -e PGID=1000 -v $(DATA_PATH):/iceberg/data iceberg:latest
-	@echo Iceberg Frontend is running on http://localhost:3000/status/
-	@echo Iceberg Backend is running on http://localhost:8080/items/
-	@docker logs iceberg -f
-
 stop:
-	@-docker stop iceberg
-	@-docker rm iceberg
-	@-docker rmi iceberg:latest
+	@-docker stop iceberg --time 0
+	@-docker rm iceberg --force
+	@-docker rmi iceberg:latest --force
 
 restart: 
 	@-docker restart iceberg
@@ -49,8 +41,6 @@ restart:
 	@echo Iceberg Backend is running on http://localhost:8080/items/
 	@docker logs iceberg -f
 
-rebuild: stop reset
-
 logs:
 	@docker logs iceberg -f
 

From e1271228d0af22dc4b458f74de78faf3f95cba86 Mon Sep 17 00:00:00 2001
From: Spoked <Spoked@localhost>
Date: Thu, 21 Dec 2023 02:20:48 -0500
Subject: [PATCH 5/8] make corrections for ids. change to watchlist count.

---
 backend/program/content/plex_watchlist.py | 2 +-
 backend/program/media.py                  | 4 ----
 backend/program/updaters/trakt.py         | 2 --
 3 files changed, 1 insertion(+), 7 deletions(-)

diff --git a/backend/program/content/plex_watchlist.py b/backend/program/content/plex_watchlist.py
index 69a6a001..77873a20 100644
--- a/backend/program/content/plex_watchlist.py
+++ b/backend/program/content/plex_watchlist.py
@@ -48,7 +48,7 @@ def run(self):
         if added_items_count != self.previous_added_items_count and added_items_count > 0:
             logger.info("Added %s items", added_items_count)
             self.previous_added_items_count = added_items_count
-        if len(added_items) > 0:
+        if added_items_count > 0:
             for added_item in added_items:
                 logger.debug("Added %s", added_item.title)
 
diff --git a/backend/program/media.py b/backend/program/media.py
index 4632fff3..78a9cac7 100644
--- a/backend/program/media.py
+++ b/backend/program/media.py
@@ -37,8 +37,6 @@ def __init__(self, item):
         # Media related
         self.title = item.get("title", None)
         self.imdb_id = item.get("imdb_id", None)
-        self.tmdb_id = item.get("tmdb_id", None)
-        self.tvdb_id = item.get("tvdb_id", None)
         if self.imdb_id:
             self.imdb_link = f"https://www.imdb.com/title/{self.imdb_id}/"
         self.aired_at = item.get("aired_at", None)
@@ -85,8 +83,6 @@ def to_dict(self):
             "title": self.title,
             "type": self.type,
             "imdb_id": self.imdb_id,
-            "tmdb_id": self.tmdb_id,
-            "tvdb_id": self.tvdb_id,
             "state": self.state.name,
             "imdb_link": self.imdb_link if hasattr(self, "imdb_link") else None,
             "aired_at": self.aired_at,
diff --git a/backend/program/updaters/trakt.py b/backend/program/updaters/trakt.py
index adfa66fc..83813fd5 100644
--- a/backend/program/updaters/trakt.py
+++ b/backend/program/updaters/trakt.py
@@ -77,8 +77,6 @@ def _map_item_from_data(data, item_type):
         "title": getattr(data, "title", None),
         "year": getattr(data, "year", None),
         "imdb_id": getattr(data.ids, "imdb", None),
-        "tmdb_id": getattr(data.ids, "tmdb", None),
-        "tvdb_id": getattr(data.ids, "tvdb", None),
         "aired_at": formatted_aired_at,
         "genres": getattr(data, "genres", None),
         "requested_at": datetime.now(),

From 42adf0d728b72b7cb9ae091b812af4bebed9a1e8 Mon Sep 17 00:00:00 2001
From: Dreu Lavelle <dreu.lavelle@dajac.com>
Date: Thu, 21 Dec 2023 10:01:35 -0500
Subject: [PATCH 6/8] Add fixes for requested changes

---
 backend/program/content/mdblist.py        |  2 +-
 backend/program/content/overseerr.py      |  2 +-
 backend/program/content/plex_watchlist.py |  3 ++-
 backend/program/media.py                  |  2 +-
 backend/program/scrapers/torrentio.py     | 26 +++++++++--------------
 backend/program/updaters/trakt.py         |  1 -
 6 files changed, 15 insertions(+), 21 deletions(-)

diff --git a/backend/program/content/mdblist.py b/backend/program/content/mdblist.py
index bf9d5be0..3bda41f3 100644
--- a/backend/program/content/mdblist.py
+++ b/backend/program/content/mdblist.py
@@ -43,7 +43,7 @@ def run(self):
                 new_items = [item for item in items if item not in self.media_items]
                 container = self.updater.create_items(new_items)
                 for item in container:
-                    item.set_requested_by("Mdblist")
+                    item.set("requested_by", "Mdblist")
                 added_items = self.media_items.extend(container)
                 if len(added_items) > 0:
                     logger.info("Added %s items", len(added_items))
diff --git a/backend/program/content/overseerr.py b/backend/program/content/overseerr.py
index 5ac32480..5d647fab 100644
--- a/backend/program/content/overseerr.py
+++ b/backend/program/content/overseerr.py
@@ -39,7 +39,7 @@ def run(self):
         new_items = [item for item in items if item not in self.media_items]
         container = self.updater.create_items(new_items)
         for item in container:
-            item.set_requested_by("Overseerr")
+            item.set("requested_by", "Overseerr")
         added_items = self.media_items.extend(container)
         if len(added_items) > 0:
             logger.info("Added %s items", len(added_items))
diff --git a/backend/program/content/plex_watchlist.py b/backend/program/content/plex_watchlist.py
index 77873a20..a7c1c25a 100644
--- a/backend/program/content/plex_watchlist.py
+++ b/backend/program/content/plex_watchlist.py
@@ -41,7 +41,7 @@ def run(self):
         new_items = [item for item in items if item not in self.media_items]
         container = self.updater.create_items(new_items)
         for item in container:
-            item.set_requested_by("Plex Watchlist")
+            item.set("requested_by", "Plex Watchlist")
         previous_count = len(self.media_items)
         added_items = self.media_items.extend(container)
         added_items_count = len(self.media_items) - previous_count
@@ -63,5 +63,6 @@ def _get_items_from_plex_watchlist(self) -> list:
             if imdb_id:
                 ids.append(imdb_id)
             else:
+                # TODO: Add tvdb conversion here
                 logger.debug("No imdb id found for %s", item.get("title"))
         return ids
diff --git a/backend/program/media.py b/backend/program/media.py
index 78a9cac7..8571401a 100644
--- a/backend/program/media.py
+++ b/backend/program/media.py
@@ -281,7 +281,7 @@ def __iadd__(self, other):
         return self
 
     def sort(self, by, reverse):
-        self.items.sort(key=lambda item: item.get(by) if item is not None else None)
+        self.items.sort(key=lambda item: item.get(by), reverse=reverse)
 
     def __len__(self):
         """Get length of container"""
diff --git a/backend/program/scrapers/torrentio.py b/backend/program/scrapers/torrentio.py
index 8c5698ab..c7f89b98 100644
--- a/backend/program/scrapers/torrentio.py
+++ b/backend/program/scrapers/torrentio.py
@@ -63,22 +63,16 @@ def _scrape_show(self, item: MediaItem):
     def _scrape_items(self, items: list):
         amount_scraped = 0
         for item in items:
-            log_string = ""  # Initialize log_string with a default value
-            try:
-                data = self.api_scrape(item)
-                if item.type == "season":
-                    log_string = f"{item.parent.title} S{item.number}"
-                if item.type == "episode":
-                    log_string = f"{item.parent.parent.title} S{item.parent.number}E{item.number}"
-                if len(data) > 0:
-                    item.set("streams", data)
-                    logger.debug("Found %s streams for %s", len(data), log_string)
-                    amount_scraped += 1
-                    continue
-                logger.debug("Could not find streams for %s", log_string)
-            except Exception as e:
-                logger.error("Error occurred while scraping %s: %s", log_string, str(e))
-                continue
+            data = self.api_scrape(item)
+            if item.type == "season":
+                log_string = f"{item.parent.title} S{item.number}"
+            if item.type == "episode":
+                log_string = f"{item.parent.parent.title} S{item.parent.number}E{item.number}"
+            if len(data) > 0:
+                item.set("streams", data)
+                logger.debug("Found %s streams for %s", len(data), log_string)
+                amount_scraped += 1
+            logger.debug("Could not find streams for %s", log_string)
         return amount_scraped
 
     def _can_we_scrape(self, item: MediaItem) -> bool:
diff --git a/backend/program/updaters/trakt.py b/backend/program/updaters/trakt.py
index 83813fd5..cb708048 100644
--- a/backend/program/updaters/trakt.py
+++ b/backend/program/updaters/trakt.py
@@ -80,7 +80,6 @@ def _map_item_from_data(data, item_type):
         "aired_at": formatted_aired_at,
         "genres": getattr(data, "genres", None),
         "requested_at": datetime.now(),
-        "requested_by": getattr(data, 'requested_by', None),
     }
     match item_type:
         case "movie":

From f218e6e9838ed6671fcba637e70191fe445025db Mon Sep 17 00:00:00 2001
From: Dreu Lavelle <dreu.lavelle@dajac.com>
Date: Thu, 21 Dec 2023 10:34:02 -0500
Subject: [PATCH 7/8] remove unnecessary function

---
 backend/program/media.py | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/backend/program/media.py b/backend/program/media.py
index 8571401a..fd8e3be8 100644
--- a/backend/program/media.py
+++ b/backend/program/media.py
@@ -100,9 +100,6 @@ def to_extended_dict(self):
             dict["episodes"] = [episode.to_extended_dict() for episode in self.episodes]
         return dict
 
-    def set_requested_by(self, requested_by):
-        self.requested_by = requested_by
-
     def is_not_cached(self):
         return not self.is_cached()
 

From bbaf2575dc359528e66f95c01619fba89bbed837 Mon Sep 17 00:00:00 2001
From: Dreu Lavelle <dreu.lavelle@dajac.com>
Date: Thu, 21 Dec 2023 12:25:37 -0500
Subject: [PATCH 8/8] Add latest changes

---
 backend/program/content/plex_watchlist.py | 11 +++++++----
 backend/program/updaters/trakt.py         | 15 +++++++++++++--
 2 files changed, 20 insertions(+), 6 deletions(-)

diff --git a/backend/program/content/plex_watchlist.py b/backend/program/content/plex_watchlist.py
index a7c1c25a..25b8b993 100644
--- a/backend/program/content/plex_watchlist.py
+++ b/backend/program/content/plex_watchlist.py
@@ -61,8 +61,11 @@ def _get_items_from_plex_watchlist(self) -> list:
         for item in items:
             imdb_id = next((guid.split("//")[-1] for guid in item.get("guids") if "imdb://" in guid), None)
             if imdb_id:
-                ids.append(imdb_id)
-            else:
-                # TODO: Add tvdb conversion here
-                logger.debug("No imdb id found for %s", item.get("title"))
+                tvdb_id = next((guid.split("//")[-1] for guid in item.get("guids") if "tvdb://" in guid), None)
+                if tvdb_id:
+                    # TODO: Convert tvdb to imdb. Will work on this later.
+                    logger.debug("Found imdb id %s and tvdb id %s for %s", imdb_id, tvdb_id, item.get("title"))
+                else:
+                    # TODO: Needs testing to determine if streams only return tvdb/imdb or if there are other options.
+                    logger.debug("No imdb id or tvdb id found for %s", item.get("title"))
         return ids
diff --git a/backend/program/updaters/trakt.py b/backend/program/updaters/trakt.py
index cb708048..9a6d48b2 100644
--- a/backend/program/updaters/trakt.py
+++ b/backend/program/updaters/trakt.py
@@ -1,8 +1,8 @@
 """Trakt updater module"""
 from datetime import datetime
 from os import path
-from utils.logger import get_data_path, logger
-from utils.request import get
+from backend.utils.logger import get_data_path, logger
+from backend.utils.request import get
 from program.media import (
     Episode,
     MediaItemContainer,
@@ -130,3 +130,14 @@ def create_item_from_imdb_id(imdb_id: str):
             if data:
                 return _map_item_from_data(data, media_type)
     return None
+
+def get_imdb_id_from_tvdb(tvdb_id: str) -> str:
+    """Get IMDb ID from TVDB ID in Trakt"""
+    url = f"https://api.trakt.tv/search/tvdb/{tvdb_id}?extended=full"
+    response = get(
+        url,
+        additional_headers={"trakt-api-version": "2", "trakt-api-key": CLIENT_ID},
+    )
+    if response.is_ok and len(response.data) > 0:
+            return response.data[0].show.ids.imdb
+    return None