Update fitness to new API

Author: jonathanmelitski

Pipfile

@@ -0,0 +1,11 @@
+[[source]]
+url = "https://pypi.org/simple"
+verify_ssl = true
+name = "pypi"
+
+[packages]
+
+[dev-packages]
+
+[requires]
+python_version = "3.11"

backend/penndata/management/commands/get_fitness_snapshot.py

@@ -1,8 +1,10 @@
+import zoneinfo
+
 import requests
-from bs4 import BeautifulSoup
-from dateutil import parser
+from django.conf import settings
 from django.core.management.base import BaseCommand
-from django.utils import timezone
+from django.utils.dateparse import parse_datetime
+from django.utils.timezone import make_aware
 
 from penndata.models import FitnessRoom, FitnessSnapshot
 
@@ -12,77 +14,59 @@ def cap_string(s):
 
 
 def get_usages():
-
-    # count/capacities default to 0 since spreadsheet number appears blank if no one there
-    locations = [
-        "4th Floor Fitness",
-        "3rd Floor Fitness",
-        "2nd Floor Strength",
-        "Basketball Courts",
-        "MPR",
-        "Climbing Wall",
-        "1st Floor Fitness",
-        "Pool-Shallow",
-        "Pool-Deep",
-    ]
-    usages = {location: {"count": 0, "capacity": 0} for location in locations}
-
-    date = timezone.localtime()  # default if can't get date from spreadsheet
-
     try:
         resp = requests.get(
-            (
-                "https://docs.google.com/spreadsheets/u/0/d/e/"
-                "2PACX-1vSX91_MlAjJo5uVLznuy7BFnUgiBOI28oBCReLRKKo76L"
-                "-k8EFgizAYXpIKPBX_c76wC3aztn3BogD4"
-                "/pubhtml/sheet?headers=false&gid=0"
-            )
+            "https://goboardapi.azurewebsites.net/api/FacilityCount/GetCountsByAccount",
+            params={"AccountAPIKey": settings.FITNESS_TOKEN},
         )
+        data = resp.json()
     except ConnectionError:
         return None
-
-    html = resp.content.decode("utf8")
-    soup = BeautifulSoup(html, "html5lib")
-    if not (embedded_spreadsheet := soup.find("tbody")):
+    except requests.exceptions.JSONDecodeError:
         return None
 
-    table_rows = embedded_spreadsheet.findChildren("tr")
-    for i, row in enumerate(table_rows):
-        cells = row.findChildren("td")
-        if i == 0:
-            date = timezone.make_aware(parser.parse(cells[1].getText()))
-        elif (location := cap_string(cells[0].getText())) in usages:
-            try:
-                count = int(cells[1].getText())
-                capacity = float(cells[2].getText().strip("%"))
-                usages[location] = {"count": count, "capacity": capacity}
-            except ValueError:
-                pass
-        else:
-            print(f"Unknown location: {location}")
-    return usages, date
+    def location_aware_datetime(time_str):
+        date = parse_datetime(time_str)
+        timezone = zoneinfo.ZoneInfo("America/New_York")
+        return make_aware(date, timezone=timezone)
+
+    usages = {
+        location["LocationName"]: {
+            "count": location["LastCount"],
+            "capacity": location["TotalCapacity"],
+            "last_updated": location_aware_datetime(location["LastUpdatedDateAndTime"]),
+        }
+        for location in data
+    }
+    return usages
 
 
 class Command(BaseCommand):
-    help = "Captures a new Fitness Snapshot for every Laundry room."
+    help = "Captures a new Fitness Snapshot for every Fitness room."
 
     def handle(self, *args, **kwargs):
-        usage_by_location, date = get_usages()
-
-        # prevent double creating FitnessSnapshots
-        if FitnessSnapshot.objects.filter(date=date).exists():
-            self.stdout.write("FitnessSnapshots already exist for this date!")
-            return
-
+        def exists(record):
+            (name, usage) = record
+            try:
+                room = FitnessRoom.objects.get(name=name)
+            except FitnessRoom.DoesNotExist:
+                return False
+            return not FitnessSnapshot.objects.filter(
+                date=usage["last_updated"], room=room
+            ).exists()
+
+        # Don't update locations for which we already have a room with a matching last_updated date.
+        # This is also O(n^2), idk how we feel about that chat
+        usage_by_location = filter(exists, get_usages().items())
         FitnessSnapshot.objects.bulk_create(
             [
                 FitnessSnapshot(
                     room=FitnessRoom.objects.get_or_create(name=room_name)[0],
-                    date=date,
+                    date=room_usage["last_updated"],
                     count=room_usage["count"],
                     capacity=room_usage["capacity"],
                 )
-                for room_name, room_usage in usage_by_location.items()
+                for (room_name, room_usage) in usage_by_location
             ]
         )
 

backend/penndata/management/commands/load_fitness_rooms.py

@@ -6,15 +6,18 @@
 class Command(BaseCommand):
     def handle(self, *args, **kwargs):
         fitness_rooms = [
-            "4th Floor Fitness",
-            "3rd Floor Fitness",
-            "2nd Floor Strength",
-            "Basketball Courts",
-            "MPR",
             "Climbing Wall",
+            "Rec Lounge",
             "1st Floor Fitness",
-            "Pool-Shallow",
-            "Pool-Deep",
+            "Court 1",
+            "Court 2",
+            "Court 3",
+            "Multipurpose Room",
+            "2nd Floor Weight Room",
+            "3rd Floor Fitness Room",
+            "4th Floor Fitness Room",
+            "Studio 409",
+            "Sheerr Pool",
         ]
         for room in fitness_rooms:
             obj, _ = FitnessRoom.objects.get_or_create(name=room)

backend/pennmobile/settings/base.py

@@ -180,6 +180,9 @@
 LIBCAL_SECRET = os.environ.get("LIBCAL_SECRET", None)
 WHARTON_TOKEN = os.environ.get("WHARTON_TOKEN", None)
 
+# Fitness Token
+FITNESS_TOKEN = os.environ.get("FITNESS_TOKEN", None)
+
 # Upload file storage
 DEFAULT_FILE_STORAGE = "storages.backends.s3boto3.S3Boto3Storage"
 AWS_ACCESS_KEY_ID = os.getenv("AWS_ACCESS_KEY_ID", None)