adobe_tools - Add/Remove products (Internal)

WP_adobeapi_addremoveproducts.py

def _add_product_to_user(config_data, products, user, access_token):
  """Add product config to user."""
  add_dict = {
    'user': user,
    'do': [
      {
        'add': {
          'product': products
        }
      }
    ]
  }
  body = json.dumps([add_dict])
  url = "https://" + config_data['host'] + config_data['endpoint'] + \
        "/action/" + config_data['org_id']
  res = requests.post(
    url,
    headers=headers(config_data, access_token),
    data=body
  )
  if res.status_code != 200:
    print(res.status_code)
    print(res.headers)
    print(res.text)
  else:
    results = json.loads(res.text)
    if results.get('notCompleted') == 1:
      print("Not completed!")
      print(results.get('errors'))
      return False
    if results.get('completed') == 1:
      print("Completed!")
      return True


def _remove_product_from_user(config_data, products, user, access_token):
  """Remove products from user."""
  add_dict = {
    'user': user,
    'do': [
      {
        'remove': {
          'product': products
        }
      }
    ]
  }
  body = json.dumps([add_dict])
  url = "https://" + config_data['host'] + config_data['endpoint'] + \
        "/action/" + config_data['org_id']
  res = requests.post(
    url,
    headers=headers(config_data, access_token),
    data=body
  )
  if res.status_code != 200:
    print(res.status_code)
    print(res.headers)
    print(res.text)
  else:
    results = json.loads(res.text)
    if results.get('notCompleted') == 1:
      print("Not completed!")
      print(results.get('errors'))
      return False
    if results.get('completed') == 1:
      print("Completed!")
      return True