import requests

import secrets

s = requests.Session()
s.auth = (secrets.username, secrets.app_password)


def get_changeactivities(query: list[str], fields: list[str]) -> dict:

    incomplete_result = True
    results = []
    page_number = 0

    parameters = dict(
        query = ';'.join(query),
        fields = ','.join(fields),
        pageSize = 5000
    )

    while incomplete_result:
        r = s.get(f"{secrets.url}/operatorChangeActivities", params={**parameters, **dict(pageStart=page_number)})

        page_number += 1

        results.extend(r.json().get('results'))

        incomplete_result = r.status_code == 206
    
    return results


def get_incidenten(query: list[str], fields: list[str]) -> dict:

    incomplete_result = True
    results = []
    page_number = 0

    parameters = dict(
        query = ';'.join(query),
        fields = ','.join(fields),
        pageSize = 5000
    )

    while incomplete_result:
        r = s.get(f"{secrets.url}/incidents", params={**parameters, **dict(pageStart=page_number)})

        page_number += 1

        results.extend(r.json())

        incomplete_result = r.status_code == 206

    return results