from shared.integration.pipedrive_api import PipedriveApi

PIPEDRIVE_API = PipedriveApi()


def get_all_organizations(organizations=[], start=0):
    response = PIPEDRIVE_API.get('/organizations', {'limit': 500})
    resonse_data = response.json()

    if response_data['additional_data']['more_items_in_collection'] is True:
        organizations.extend(response_data['data'])

        return get_organizations(organizations=organizations,
                                 start=response_data['additional_data']['next_start'])
    else:
        return None