BaseAction.establish_connection() - Code Metrics - Inspection of "VSphere Multi Endpoint" - StackStorm/st2contrib - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#513)

unknown

created 2016-07-07 10:49 UTC

BaseAction.establish_connection() A

↳ Parent: Project

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
c	0
b	0
f	0
dl	0
loc	3
rs	10

# Licensed to the StackStorm, Inc ('StackStorm') under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import atexit
import eventlet

from pyVim import connect
from pyVmomi import vim
from st2actions.runners.pythonrunner import Action


class BaseAction(Action):
    def __init__(self, config):
        super(BaseAction, self).__init__(config)
        if config is None:
            raise ValueError("No connection configuration details found")
        if "vsphere" in config:
            if config['vsphere'] is None:
                raise ValueError("'vsphere' config defined but empty.")
            else:
                pass
        elif set(['host', 'port', 'user', 'passwd']).issubset(config):
            pass
        else:
            raise ValueError("Check Connection configuration details")

    def establish_connection(self, vsphere):
        self.si = self._connect(vsphere)
class Foo:
    def __init__(self, x=None):
        self.x = x
        self.si_content = self.si.RetrieveContent()
class Foo:
    def __init__(self, x=None):
        self.x = x

    def _connect(self, vsphere):
        if vsphere:
            connection = self.config['vsphere'].get(vsphere)
        else:
            connection = self.config

        try:
            si = connect.SmartConnect(host=connection['host'],
                                      port=connection['port'],
                                      user=connection['user'],
                                      pwd=connection['passwd'])
        except:
            raise Exception("Unable to connect to vsphere.")

        atexit.register(connect.Disconnect, si)
        return si

    def _wait_for_task(self, task):
        while task.info.state == vim.TaskInfo.State.running:
            eventlet.sleep(1)
        return task.info.state == vim.TaskInfo.State.success


1			# Licensed to the StackStorm, Inc ('StackStorm') under one or more
2			# contributor license agreements. See the NOTICE file distributed with
3			# this work for additional information regarding copyright ownership.
4			# The ASF licenses this file to You under the Apache License, Version 2.0
5			# (the "License"); you may not use this file except in compliance with
6			# the License. You may obtain a copy of the License at
7			#
8			# http://www.apache.org/licenses/LICENSE-2.0
9			#
10			# Unless required by applicable law or agreed to in writing, software
11			# distributed under the License is distributed on an "AS IS" BASIS,
12			# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13			# See the License for the specific language governing permissions and
14			# limitations under the License.
15
16			import atexit
17			import eventlet
18
19			from pyVim import connect
20			from pyVmomi import vim
21			from st2actions.runners.pythonrunner import Action
22
23
24			class BaseAction(Action):
25			def __init__(self, config):
26			super(BaseAction, self).__init__(config)
27			if config is None:
28			raise ValueError("No connection configuration details found")
29			if "vsphere" in config:
30			if config['vsphere'] is None:
31			raise ValueError("'vsphere' config defined but empty.")
32			else:
33			pass
34			elif set(['host', 'port', 'user', 'passwd']).issubset(config):
35			pass
36			else:
37			raise ValueError("Check Connection configuration details")
38
39			def establish_connection(self, vsphere):
40			self.si = self._connect(vsphere)
			0 ignored issues – show Coding Style introduced 2016-06-30 08:45 UTC by Report Bug Copy Issue Report The attribute `si` was defined outside `__init__`. It is generally a good practice to initialize all attributes to default values in the `__init__` method: class Foo: def __init__(self, x=None): self.x = x Loading history...
41			self.si_content = self.si.RetrieveContent()
			0 ignored issues – show Coding Style introduced 2016-06-30 08:45 UTC by Report Bug Copy Issue Report The attribute `si_content` was defined outside `__init__`. It is generally a good practice to initialize all attributes to default values in the `__init__` method: class Foo: def __init__(self, x=None): self.x = x Loading history...
42
43			def _connect(self, vsphere):
44			if vsphere:
45			connection = self.config['vsphere'].get(vsphere)
46			else:
47			connection = self.config
48
49			try:
50			si = connect.SmartConnect(host=connection['host'],
51			port=connection['port'],
52			user=connection['user'],
53			pwd=connection['passwd'])
54			except:
55			raise Exception("Unable to connect to vsphere.")
56
57			atexit.register(connect.Disconnect, si)
58			return si
59
60			def _wait_for_task(self, task):
61			while task.info.state == vim.TaskInfo.State.running:
62			eventlet.sleep(1)
63			return task.info.state == vim.TaskInfo.State.success
64

StackStorm / st2contrib

Pull Request — master (#513)

BaseAction.establish_connection() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like