import os import requests def get_token(vendor='smf'): payload = { "audience": "https://qa-fan-response-jwt-authorizer", "grant_type": "client_credentials" } if vendor == 'smf': payload['client_id'] = os.environ.get('SMF_CLIENT_ID') payload['client_secret'] = os.environ.get('SMF_SECRET_KEY') elif vendor == 'tunespeak': payload["client_id"] = os.environ.get('TUNESPEAK_CLIENT_ID') payload["client_secret"] = os.environ.get('TUNESPEAK_SECRET_KEY') elif vendor == 'wyng': payload["client_id"] = os.environ.get('WYNG_CLIENT_ID') payload["client_secret"] = os.environ.get('WYNG_SECRET_KEY') else: raise ValueError(f'Unknown vendor: {vendor}') headers = {'content-type': "application/json"} res = requests.post("https://qa-orchard.auth0.com/oauth/token", payload, headers) data = res.json() return data['access_token'] def make_request(token, payload, vendor='smf'): if vendor == 'smf': url = 'https://qa-fan-response-api.theorchard.io/smf/response' elif vendor == 'tunespeak': url = 'https://qa-fan-response-api.theorchard.io/tunespeak/response' elif vendor == 'wyng': url = 'https://qa-fan-response-api.theorchard.io/wyng/response' else: raise ValueError(f'Unknown vendor: {vendor}') headers = { 'Authorization': f'Bearer {token}', 'Content-Type': 'application/json' } response = requests.post(url, headers=headers, json=payload) return response.status_code, response.json() if response.text else response.text def doi_message(): token = get_token() email_address = "ssavva+qa-doi-0815_v3@sonymusic-pde.com" print(f'Sending single triggered send to {email_address}') payload = { "email_address": email_address, "first_name": "Sergei", "last_name": "Savva", "form_id": "502364", "triggered_sends": [ "6399646;QA_DOI_KDH_EMAIL;" ], "mailing_list": [ "a0STy000001wpeHMAQ" ], } result = make_request(token, payload) print(result) if __name__ == '__main__': doi_message()