7 from vcpecommon import *
11 def __init__(self, vcpecommon):
15 self.logger = logging.getLogger(__name__)
16 self.logger.setLevel(logging.DEBUG)
17 self.vcpecommon = vcpecommon
19 def get_service_list(self):
24 url = self.vcpecommon.sdc_service_list_url
26 r = requests.get(url, headers=self.vcpecommon.sdc_get_request_headers, auth=self.vcpecommon.sdc_get_request_userpass)
30 self.logger.debug('---------------------------------------------------------------')
31 self.logger.debug('------- Creation request submitted to SDC, got response --------')
32 self.logger.debug('response code = %s' % r.status_code )
33 self.logger.debug(json.dumps(data, indent=4, sort_keys=True))
34 self.logger.debug('---------------------------------------------------------------')
37 if service['name'].startswith('demoVCPE'):
38 self.logger.debug('service name = %s, url = %s' % (service['name'], service['toscaModelURL']))
39 self.download_file(self.vcpecommon.sdc_url_prefix + service['toscaModelURL'])
41 def get_filename_from_cd(self, cd):
43 cd: in the format of Content-Disposition: attachment; filename="service-Demovcpeinfra-csar.csar"
45 fname = re.findall('filename="(.+)"', cd)
46 self.logger.debug('fname = %s' % fname[0])
49 def download_file(self, url):
51 response = requests.get(url, headers=self.vcpecommon.sdc_get_request_headers, auth=self.vcpecommon.sdc_get_request_userpass)
52 filename = 'csar/' + self.get_filename_from_cd(response.headers.get('Content-Disposition'))
53 open(filename, 'wb').write(response.content)