feat: add steam importer to users.views.data

journal/importers/__init__.py

@@ -2,5 +2,6 @@
 from .goodreads import GoodreadsImporter
 from .letterboxd import LetterboxdImporter
 from .opml import OPMLImporter
+from .steam import SteamImporter
 
-__all__ = ["LetterboxdImporter", "OPMLImporter", "DoubanImporter", "GoodreadsImporter"]
+__all__ = ["LetterboxdImporter", "OPMLImporter", "DoubanImporter", "GoodreadsImporter", "SteamImporter"]

journal/importers/steam.py

@@ -234,6 +234,14 @@ def estimate_shelf_type(cls, playtime_forever: int, last_played: datetime, app_i
         elif played_long_enough: return ShelfType.COMPLETE
         else: return ShelfType.DROPPED
 
+    @classmethod
+    def validate_apikey(cls, steam_apikey: str) -> bool:
+        ...
+
+    @classmethod
+    def validate_userid(cls, steam_id: str) -> bool:
+        ...
+
     # TODO: Implement get_how_long_to_beat:
     # Such data are available in HowLongToBeat.com and igdb, however
     # 1. time_to_beat can be considered a potential metadata of Game item,

users/views/data.py

@@ -18,6 +18,7 @@
     GoodreadsImporter,
     LetterboxdImporter,
     OPMLImporter,
+    SteamImporter
 )
 from journal.models import ShelfType, reset_journal_visibility_for_user
 from social.models import reset_social_visibility_for_user
@@ -331,3 +332,38 @@ def import_opml(request):
         else:
             messages.add_message(request, messages.ERROR, _("Invalid file."))
     return redirect(reverse("users:data"))
+
+@login_required
+def import_steam(request):
+    if request.method != "POST":
+        return redirect(reverse("users:data"))
+
+    steam_apikey = request.POST.get("steam_apikey")
+    steam_id = request.POST.get("steam_id")
+
+    if not SteamImporter.validate_apikey(steam_apikey):
+        messages.add_message(request, messages.ERROR, _("Invalid API key."))
+        return redirect(reverse("users:data"))
+    if not SteamImporter.validate_userid(steam_id):
+        messages.add_message(request, messages.ERROR, _("Invalid steam id."))
+        return redirect(reverse("users:data"))
+
+    fetch_wishlist = bool(request.POST.get("fetch_wishlist", True))
+    fetch_owned = bool(request.POST.get("fetch_owned", True))
+
+    if not (fetch_wishlist or fetch_owned):
+        messages.add_message(request, messages.ERROR, _("Nothing to fetch."))
+        return redirect(reverse("users:data"))
+
+    SteamImporter.create(
+        user=request.user,
+        shelf_type_reversion = bool(request.POST.get("shelf_type_reversion", False)),
+        fetch_wishlist = fetch_wishlist,
+        fetch_owned = fetch_owned,
+        last_play_to_ctime = bool(request.POST.get("last_play_to_ctime", True)),
+        visibility = int(request.POST.get("visibility", request.user.visibility)),
+        steam_apikey = steam_apikey,
+        steam_id = steam_id
+    ).enqueue()
+    messages.add_message(request, messages.INFO, _("Import in progress."))
+    return redirect(reverse("users:data"))