BaseAction._connect() - Code Metrics - Inspection of "Merge pull request #524 from Pulsant/psm/data-get-..." - StackStorm/st2contrib - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 0b35a8...1091ee )

by Tomaz

created 2016-07-27 16:54 UTC

BaseAction._connect() B

↳ Parent: Project

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes	5
Bugs	0	Features	1

Metric	Value
cc	5
c	5
b	0
f	1
dl	0
loc	22
rs	8.3411

# 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

CONNECTION_ITEMS = ['host', 'port', 'user', 'passwd']


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
        else:
            for item in CONNECTION_ITEMS:
                if item in config:
                    pass
                else:
                    raise KeyError("Config.yaml Mising: %s" % (item))

    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)
            for item in CONNECTION_ITEMS:
                if item in connection:
                    pass
                else:
                    raise KeyError("Config.yaml Mising: vsphere:%s:%s"
                                   % (vsphere, item))
        else:
            connection = self.config

        try:
            si = connect.SmartConnect(host=connection['host'],
                                      port=connection['port'],
                                      user=connection['user'],
                                      pwd=connection['passwd'])
        except Exception as e:
            raise Exception(e)

        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			CONNECTION_ITEMS = ['host', 'port', 'user', 'passwd']
24
25
26			class BaseAction(Action):
27			def __init__(self, config):
28			super(BaseAction, self).__init__(config)
29			if config is None:
30			raise ValueError("No connection configuration details found")
31			if "vsphere" in config:
32			if config['vsphere'] is None:
33			raise ValueError("'vsphere' config defined but empty.")
34			else:
35			pass
36			else:
37			for item in CONNECTION_ITEMS:
38			if item in config:
39			pass
40			else:
41			raise KeyError("Config.yaml Mising: %s" % (item))
42
43			def establish_connection(self, vsphere):
44			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...
45			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...
46
47			def _connect(self, vsphere):
48			if vsphere:
49			connection = self.config['vsphere'].get(vsphere)
50			for item in CONNECTION_ITEMS:
51			if item in connection:
52			pass
53			else:
54			raise KeyError("Config.yaml Mising: vsphere:%s:%s"
55			% (vsphere, item))
56			else:
57			connection = self.config
58
59			try:
60			si = connect.SmartConnect(host=connection['host'],
61			port=connection['port'],
62			user=connection['user'],
63			pwd=connection['passwd'])
64			except Exception as e:
65			raise Exception(e)
66
67			atexit.register(connect.Disconnect, si)
68			return si
69
70			def _wait_for_task(self, task):
71			while task.info.state == vim.TaskInfo.State.running:
72			eventlet.sleep(1)
73			return task.info.state == vim.TaskInfo.State.success
74

StackStorm / st2contrib

Push — master ( 0b35a8...1091ee )

BaseAction._connect() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like