Support "Timed Entry" tickets about camply HOT 5 CLOSED

import logging
from pprint import pprint
from typing import Dict, Any

from camply.providers import RecreationDotGov

logging.basicConfig(level=logging.DEBUG)
recdotgov = RecreationDotGov()
response: Dict[str, Any] = recdotgov._ridb_get_data(path="facilities/10088426")
pprint(response)

from camply.providers import RecreationDotGov
from camply.notifications.telegram import TelegramNotifications
from camply.config import (RecreationBookingConfig,
                           STANDARD_HEADERS,
                           USER_AGENTS)
from camply.utils import api_utils
from typing import Union
from datetime import datetime, date
from random import choice
from json import loads
from urllib import parse
import logging
import os
import requests
from tenacity import retry, wait_random

logger = logging.getLogger(__name__)

logging.basicConfig(
    format='%(asctime)s %(levelname)-8s %(message)s',
    level=logging.INFO,
    datefmt='%Y-%m-%d %H:%M:%S')

notify = TelegramNotifications()

def get_timed_entry(facility_id: int, date: datetime) -> Union[dict, list]:
    try:
        base_url = api_utils.generate_url(scheme=RecreationBookingConfig.API_SCHEME,
                                          netloc=RecreationBookingConfig.API_NET_LOC,
                                          path="api/timedentry/availability/facility/")
        api_endpoint = parse.urljoin(
            base_url, f"{facility_id}")
        # BUILD THE HEADERS EXPECTED FROM THE API
        headers = STANDARD_HEADERS.copy()
        headers.update(choice(USER_AGENTS))
        headers.update(RecreationBookingConfig.API_REFERRERS)
        response = requests.get(url=api_endpoint, headers=headers,
                                params=dict(
                                    date=date.strftime("%Y-%m-%d")
                                ),
                                timeout=30)
        assert response.status_code == 200
    except AssertionError:
        response_error = response.text
        error_message = "Bad Data Returned from the RecreationDotGov API"
        logger.debug(f"{error_message}, will continue to retry")
        logger.debug(f"Error Details: {response_error}")
        raise ConnectionError(f"{error_message}: {response_error}")
    return loads(response.content)


@retry(wait=wait_random(min=60*5, max=60*6))
def checkLatestInformation():
    facility_id = 10086745

    days = [
        date.fromisoformat('2022-06-27'),
        date.fromisoformat('2022-06-28'),
        date.fromisoformat('2022-06-29')
    ]

    for day in days:
        tours = get_timed_entry(facility_id, day)

        for tour in tours:
            tour_id = tour["tour_id"]
            display_date = day.strftime("%Y-%m-%d")
            inventory = sum(tour["inventory_count"].values())
            reserved = sum(tour["reservation_count"].values())
            available = inventory - reserved

            logger.info(f"{display_date}: {available}")
            if available > 0:
                logger.info("FOUND SOMETHING");
                notify.send_message(
                    f"{available} spot(s) in Yosemite for {display_date}: https://www.recreation.gov/timed-entry/{facility_id}/ticket/{tour_id}")

    raise Exception

checkLatestInformation()