Update syncro_api.py

main
Dan S 2024-07-02 17:23:28 -05:00
parent 336bfbd6dd
commit 1c7011e2cd
1 changed files with 42 additions and 17 deletions

View File

@ -1,17 +1,42 @@
import os import os
import requests import requests
def get_syncro_customers(): def get_syncro_customers():
if syncro_api_key is None: syncro_api_key = os.environ.get('SYNCRO_API_KEY', None) if syncro_api_key is None: syncro_api_key = os.environ.get('SYNCRO_API_KEY', None)
if syncro_api_baseurl is None: syncro_api_baseurl = os.environ.get('SYNCRO_API_BASEURL', None) if syncro_api_baseurl is None: syncro_api_baseurl = os.environ.get('SYNCRO_API_BASEURL', None)
if syncro_api_key is None or syncro_api_baseurl is None: if syncro_api_key is None or syncro_api_baseurl is None:
return "Missing API Key or Base URL" return "Missing API Key or Base URL"
else: else:
return "Syncro API Key: " + syncro_api_key + " Base return "Syncro API Key: " + syncro_api_key + " Base
syncro_api_url = syncro_api_baseurl + '/api/v1/customers' syncro_api_url = syncro_api_baseurl + '/api/v1/customers'
headers = { headers = {
'Authorization': 'Bearer ' + syncro_api_key, 'Authorization': 'Bearer ' + syncro_api_key,
'Content-Type': 'application/json' 'Content-Type': 'application/json'
} }
response = requests.get(syncro_api_url, headers=headers) try:
return response.json() response = requests.get(syncro_api_url, headers=headers)
return response.json()
except requests.exceptions.RequestException as e:
return e
def get_syncro_customers_managed():
#customers.properties["Managed Status"] 35984
if syncro_api_key is None: syncro_api_key = os.environ.get('SYNCRO_API_KEY', None)
if syncro_api_baseurl is None: syncro_api_baseurl = os.environ.get('SYNCRO_API_BASEURL', None)
if syncro_api_key is None or syncro_api_baseurl is None:
return "Missing API Key or Base URL"
syncro_api_url = syncro_api_baseurl + '/api/v1/customers'
headers = {
'Authorization': 'Bearer ' + syncro_api_key,
'Content-Type': 'application/json'
}
try:
response = requests.get(syncro_api_url, headers=headers)
all_customers = response.json()
managed_customers = []
for customer in all_customers:
if customer.properties["Managed Status"] == 35984:
managed_customers.append(customer)
return managed_customers
except requests.exceptions.RequestException as e:
return e