Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #28 from device42/D42-14544
D42-14544 - Dell warranty sync API v5 error Fixes issues syncing warranty information from Dell. Adds support for Cisco.
- Loading branch information
Showing
7 changed files
with
302 additions
and
34 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,220 @@ | ||
| import json | ||
| import sys | ||
| import time | ||
| import random | ||
| import requests | ||
| from datetime import datetime, timedelta | ||
|
|
||
| from shared import DEBUG, RETRY, ORDER_NO_TYPE, left | ||
| from warranty_abstract import WarrantyBase | ||
|
|
||
| try: | ||
| requests.packages.urllib3.disable_warnings() | ||
| except: | ||
| pass | ||
|
|
||
|
|
||
| class Cisco(WarrantyBase, object): | ||
|
|
||
| def __init__(self, params): | ||
| super(Cisco, self).__init__() | ||
| self.url = params['url'] | ||
| self.client_id = params['client_id'] | ||
| self.client_secret = params['client_secret'] | ||
| self.debug = DEBUG | ||
| self.retry = RETRY | ||
| self.order_no = ORDER_NO_TYPE | ||
| self.d42_rest = params['d42_rest'] | ||
| self.common = None | ||
|
|
||
| if self.order_no == 'common': | ||
| self.common = self.generate_random_order_no() | ||
|
|
||
| # OAuth 2.0 | ||
| self.expires_at = None | ||
| self.access_token = None | ||
|
|
||
| # OAth 2.0 | ||
| def get_access_token(self, client_id, client_secret): | ||
| access_token_request_url = "https://cloudsso.cisco.com/as/token.oauth2" | ||
|
|
||
| timeout = 10 | ||
|
|
||
| payload = { | ||
| 'client_id': client_id, | ||
| 'client_secret': client_secret, | ||
| 'grant_type': 'client_credentials' | ||
| } | ||
|
|
||
| try: | ||
| resp = requests.post(access_token_request_url, data=payload, timeout=timeout) | ||
|
|
||
| msg = 'Status code: %s' % str(resp.status_code) | ||
|
|
||
| if str(resp.status_code) == '400' or str(resp.status_code) == '401' or str(resp.status_code) == '404': | ||
| print 'HTTP error. Message was: %s' % msg | ||
| elif str(resp.status_code) == '500': | ||
| print 'HTTP error. Message was: %s' % msg | ||
| print 'token access services may be down, try again later...' | ||
| print resp.text | ||
| else: | ||
| # assign access token and expiration to instance variables | ||
| result = resp.json() | ||
| self.access_token = "Bearer " + str(result['access_token']) | ||
| self.expires_at = datetime.utcnow() + timedelta(seconds=int(result['expires_in'])) | ||
| if self.debug > 1: | ||
| print "Request Token Acquired" | ||
| except requests.RequestException as e: | ||
| self.error_msg(e) | ||
|
|
||
| def run_warranty_check(self, inline_serials, retry=True): | ||
| global full_serials | ||
| full_serials = {} | ||
|
|
||
| if self.debug: | ||
| print '\t[+] Checking warranty info for "%s"' % inline_serials | ||
| timeout = 10 | ||
|
|
||
| # making sure the warranty also gets updated if the serial has been changed by decom lifecycle process | ||
| incoming_serials = inline_serials.split(',') | ||
| inline_serials = [] | ||
|
|
||
| for d42_serial in incoming_serials: | ||
| d42_serial = d42_serial.upper() | ||
| if '_' in d42_serial: | ||
| full_serials.update({d42_serial.split('_')[0]: d42_serial}) | ||
| d42_serial = d42_serial.split('_')[0] | ||
| elif '(' in d42_serial: | ||
| full_serials.update({d42_serial.split('(')[0]: d42_serial}) | ||
| d42_serial = d42_serial.split('(')[0] | ||
| else: | ||
| full_serials.update({d42_serial: d42_serial}) | ||
| inline_serials.append(d42_serial) | ||
| inline_serials = ','.join(inline_serials) | ||
|
|
||
| # check to see if the access token is expired, if it is get a new one, else, continue | ||
| if self.expires_at is None or self.expires_at is not None and self.expires_at <= datetime.utcnow(): | ||
| if self.debug > 1: | ||
| print 'attempting to acquire access_token' | ||
|
|
||
| self.get_access_token(self.client_id, self.client_secret) | ||
|
|
||
| if self.access_token is None: | ||
| if self.debug > 1: | ||
| print 'unable to acquire access_token' | ||
| return None | ||
|
|
||
| # get the device information using the requested access token | ||
| # maximum serials per request is 70 devices with a maximum length of 40 separated by commas | ||
| payload = { | ||
| 'sr_no': inline_serials | ||
| } | ||
|
|
||
| headers = { | ||
| 'Accept': 'Application/json', | ||
| 'Authorization': self.access_token | ||
| } | ||
|
|
||
| # request serial number information | ||
| try: | ||
| resp = requests.get(self.url, params=payload, headers=headers, verify=True, timeout=timeout) | ||
| msg = 'Status code: %s' % str(resp.status_code) | ||
| if str(resp.status_code) == '401' or str(resp.status_code) == '404': | ||
| print '\t[!] HTTP error. Message was: %s' % msg | ||
| print '\t[!] waiting for 30 seconds to let the api server calm down' | ||
| # suspecting blockage due to to many api calls. Put in a pause of 30 seconds and go on | ||
| time.sleep(30) | ||
| if retry: | ||
| print '\n[!] Retry' | ||
| self.run_warranty_check(inline_serials, False) | ||
| else: | ||
| return None | ||
| else: | ||
| result = resp.json() | ||
| return result | ||
| except requests.RequestException as e: | ||
| self.error_msg(e) | ||
| return None | ||
|
|
||
| def process_result(self, result, purchases): | ||
| global full_serials | ||
| data = {} | ||
|
|
||
| if 'serial_numbers' in result: | ||
| for device in result['serial_numbers']: | ||
| try: | ||
| if self.order_no == 'common': | ||
| order_no = self.common | ||
| else: | ||
| order_no = self.generate_random_order_no() | ||
|
|
||
| serial = device['sr_no'] | ||
|
|
||
| data.clear() | ||
|
|
||
| data.update({'order_no': order_no}) | ||
| data.update({'completed': 'yes'}) | ||
|
|
||
| data.update({'vendor': 'Cisco'}) | ||
| data.update({'line_device_serial_nos': full_serials[serial]}) | ||
| data.update({'line_type': 'contract'}) | ||
| data.update({'line_item_type': 'device'}) | ||
| data.update({'line_completed': 'yes'}) | ||
|
|
||
| try: | ||
| line_contract_id = device['service_contract_number'] | ||
| except KeyError: | ||
| line_contract_id = "Not Available" | ||
|
|
||
| data.update({'line_notes': line_contract_id}) | ||
| data.update({'line_contract_id': line_contract_id}) | ||
|
|
||
| try: | ||
| warranty_type = device['warranty_type'] | ||
| except KeyError: | ||
| warranty_type = "Service" | ||
|
|
||
| data.update({'line_contract_type': warranty_type}) | ||
|
|
||
| if warranty_type == 'Service': | ||
| # Skipping the services, only want the warranties | ||
| continue | ||
|
|
||
| try: | ||
| # max 64 character limit on the line service type field in Device42 (version 13.1.0) | ||
| service_line_description = left(device['service_line_descr'], 64) | ||
| data.update({'line_service_type': service_line_description}) | ||
| except KeyError: | ||
| pass | ||
|
|
||
| start_date = "0001-01-01" | ||
| end_date = device['warranty_end_date'] | ||
| data.update({'line_end_date': end_date}) | ||
|
|
||
| # Compare warranty dates by serial, contract_id, start date and end date | ||
| # Start date is not provided in request response so the date is simply used for hasher | ||
| hasher = serial + line_contract_id + start_date + end_date | ||
|
|
||
| try: | ||
| d_purchase_id, d_order_no, d_line_no, d_contractid, d_start, d_end, forcedupdate = \ | ||
| purchases[hasher] | ||
|
|
||
| if forcedupdate: | ||
| data['purchase_id'] = d_purchase_id | ||
| data.pop('order_no') | ||
| raise KeyError | ||
|
|
||
| # check for duplicate state | ||
| if d_contractid == line_contract_id and d_start == start_date and d_end == end_date: | ||
| print '\t[!] Duplicate found. Purchase ' \ | ||
| 'for SKU "%s" and "%s" with end date "%s" ' \ | ||
| 'order_id: %s and line_no: %s' % ( | ||
| serial, line_contract_id, end_date, d_purchase_id, d_line_no) | ||
| except KeyError: | ||
| raise KeyError | ||
|
|
||
| except KeyError: | ||
| self.d42_rest.upload_data(data) | ||
| data.clear() | ||
| else: | ||
| print 'API result did not report devices.' |
Oops, something went wrong.