1 # Copyright 2018 Telefonica
5 # Licensed under the Apache License, Version 2.0 (the "License"); you may
6 # not use this file except in compliance with the License. You may obtain
7 # a copy of the License at
9 # http://www.apache.org/licenses/LICENSE-2.0
11 # Unless required by applicable law or agreed to in writing, software
12 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
13 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
14 # License for the specific language governing permissions and limitations
21 from osmclient
.common
import utils
22 from osmclient
.common
.exceptions
import ClientException
23 from osmclient
.common
.exceptions
import NotFound
29 def __init__(self
, http
=None, client
=None):
32 self
._apiName
= '/nslcm'
33 self
._apiVersion
= '/v1'
34 self
._apiResource
= '/ns_instances_content'
35 self
._apiBase
= '{}{}{}'.format(self
._apiName
,
36 self
._apiVersion
, self
._apiResource
)
38 def list(self
, filter=None):
39 """Returns a list of NS
43 filter_string
= '?{}'.format(filter)
44 resp
= self
._http
.get_cmd('{}{}'.format(self
._apiBase
,filter_string
))
50 """Returns an NS based on name or id
52 if utils
.validate_uuid4(name
):
53 for ns
in self
.list():
57 for ns
in self
.list():
58 if name
== ns
['name']:
60 raise NotFound("ns {} not found".format(name
))
62 def get_individual(self
, name
):
64 if not utils
.validate_uuid4(name
):
65 for ns
in self
.list():
66 if name
== ns
['name']:
69 resp
= self
._http
.get_cmd('{}/{}'.format(self
._apiBase
, ns_id
))
70 #resp = self._http.get_cmd('{}/{}/nsd_content'.format(self._apiBase, ns_id))
71 #print yaml.safe_dump(resp)
74 raise NotFound("ns {} not found".format(name
))
76 def delete(self
, name
):
78 resp
= self
._http
.delete_cmd('{}/{}'.format(self
._apiBase
,ns
['_id']))
79 #print 'RESP: '.format(resp)
83 raise ClientException("failed to delete ns {}: {}".format(name
, resp
))
85 def create(self
, nsd_name
, nsr_name
, account
, config
=None,
86 ssh_keys
=None, description
='default description',
87 admin_status
='ENABLED'):
89 nsd
= self
._client
.nsd
.get(nsd_name
)
91 datacenter
= self
._client
.vim
.get(account
)
92 if datacenter
is None:
93 raise NotFound("cannot find datacenter account {}".format(account
))
96 ns
['nsdId'] = nsd
['_id']
97 ns
['nsName'] = nsr_name
98 ns
['nsDescription'] = description
99 ns
['vimAccountId'] = datacenter
['_id']
101 #ns['userdata']['key1']='value1'
102 #ns['userdata']['key2']='value2'
104 if ssh_keys
is not None:
105 # ssh_keys is comma separate list
107 for key
in ssh_keys
.split(','):
108 ssh_keys_format
.append({'key-pair-ref': key
})
110 ns
['ssh-authorized-key'] = ssh_keys_format
112 #print yaml.safe_dump(ns)
114 self
._apiResource
= '/ns_instances_content'
115 self
._apiBase
= '{}{}{}'.format(self
._apiName
,
116 self
._apiVersion
, self
._apiResource
)
118 resp
= self
._http
.post_cmd(endpoint
=self
._apiBase
,
120 if not resp
or 'id' not in resp
:
121 raise ClientException('unexpected response from server: '.format(
125 except ClientException
as exc
:
126 message
="failed to create ns: {} nsd: {}\nerror:\n{}".format(
130 raise ClientException(message
)