EntryPointController.get_all() - Code Metrics - Inspection of "Merge pull request #2727 from StackStorm/feature/r..." - StackStorm/st2 - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( f534b1...a82689 )

by Plexxi

created 2017-03-23 10:00 UTC

EntryPointController.get_all() A

↳ Parent: EntryPointController

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	2
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.

from mongoengine import ValidationError
import six

from st2api.controllers import resource
from st2common.exceptions.db import StackStormDBObjectNotFoundError
from st2common import log as logging
from st2common.content import utils
from st2common.models.api.action import ActionAPI
from st2common.models.utils import action_param_utils
from st2common.persistence.action import Action
from st2common.persistence.runner import RunnerType
from st2common.router import abort

http_client = six.moves.http_client

LOG = logging.getLogger(__name__)


class LookupUtils(object):

    @staticmethod
    def _get_action_by_id(id):

        try:
            return Action.get_by_id(id)
        except Exception as e:
            msg = 'Database lookup for id="%s" resulted in exception. %s' % (id, e)
            LOG.exception(msg)
            abort(http_client.NOT_FOUND, msg)

    @staticmethod
    def _get_runner_by_id(id):

        try:
            return RunnerType.get_by_id(id)
        except (ValueError, ValidationError) as e:
            msg = 'Database lookup for id="%s" resulted in exception. %s' % (id, e)
            LOG.exception(msg)
            abort(http_client.NOT_FOUND, msg)

    @staticmethod
    def _get_runner_by_name(name):
        try:
            return RunnerType.get_by_name(name)
        except (ValueError, ValidationError) as e:
            msg = 'Database lookup for name="%s" resulted in exception. %s' % (id, e)
            LOG.exception(msg)
            abort(http_client.NOT_FOUND, msg)


class ParametersViewController(object):

    def get_one(self, action_id):
        return self._get_one(action_id)

    @staticmethod
    def _get_one(action_id):
        """
            List merged action & runner parameters by action id.

            Handle:
                GET /actions/views/parameters/1
        """
        action_db = LookupUtils._get_action_by_id(action_id)
class MyParent:
    def __init__(self):
        self._x = 1;
        self.y = 2;

class MyChild(MyParent):
    def some_method(self):
        return self._x    # Ok, since accessed from a child class

class AnotherClass:
    def some_method(self, instance_of_my_child):
        return instance_of_my_child._x   # Would be flagged as AnotherClass is not
                                         # a child class of MyParent
        LOG.info('Found action: %s, runner: %s', action_db, action_db.runner_type['name'])
        runner_db = LookupUtils._get_runner_by_name(action_db.runner_type['name'])
class MyParent:
    def __init__(self):
        self._x = 1;
        self.y = 2;

class MyChild(MyParent):
    def some_method(self):
        return self._x    # Ok, since accessed from a child class

class AnotherClass:
    def some_method(self, instance_of_my_child):
        return instance_of_my_child._x   # Would be flagged as AnotherClass is not
                                         # a child class of MyParent

        all_params = action_param_utils.get_params_view(
            action_db=action_db, runner_db=runner_db, merged_only=True)

        return {'parameters': all_params}


class OverviewController(resource.ContentPackResourceController):
    model = ActionAPI
    access = Action
    supported_filters = {}

    query_options = {
        'sort': ['pack', 'name']
    }

    include_reference = True

    def get_one(self, ref_or_id):

        """
            List action by id.

            Handle:
                GET /actions/views/overview/1
        """
        resp = super(OverviewController, self)._get_one(ref_or_id)
        action_api = ActionAPI(**resp.json)
        result = self._transform_action_api(action_api)
        resp.json = result
        return resp

    def get_all(self, **kwargs):
        """
            List all actions.

            Handles requests:
                GET /actions/views/overview
        """
        resp = super(OverviewController, self)._get_all(**kwargs)
        result = []
        for item in resp.json:
            action_api = ActionAPI(**item)
            result.append(self._transform_action_api(action_api))
        resp.json = result
        return resp

    @staticmethod
    def _transform_action_api(action_api):
        action_id = action_api.id
        action_api.parameters = ParametersViewController._get_one(action_id).get('parameters')
class MyParent:
    def __init__(self):
        self._x = 1;
        self.y = 2;

class MyChild(MyParent):
    def some_method(self):
        return self._x    # Ok, since accessed from a child class

class AnotherClass:
    def some_method(self, instance_of_my_child):
        return instance_of_my_child._x   # Would be flagged as AnotherClass is not
                                         # a child class of MyParent
        return action_api


class EntryPointController(resource.ContentPackResourceController):
    model = ActionAPI
    access = Action

    supported_filters = {}

    def get_all(self, **kwargs):
        return abort(404)

    def get_one(self, ref_or_id):

        """
            Outputs the file associated with action entry_point

            Handles requests:
                GET /actions/views/entry_point/1
        """
        LOG.info('GET /actions/views/overview with ref_or_id=%s', ref_or_id)
        action_db = self._get_by_ref_or_id(ref_or_id=ref_or_id)

        pack = getattr(action_db, 'pack', None)
        entry_point = getattr(action_db, 'entry_point', None)

        abs_path = utils.get_entry_point_abs_path(pack, entry_point)

        if not abs_path:
            raise StackStormDBObjectNotFoundError('Action ref_or_id=%s has no entry_point to output'
                                                  % ref_or_id)

        with open(abs_path) as file:
            content = file.read()

        return content


class ActionViewsController(object):
    parameters = ParametersViewController()
    overview = OverviewController()
    entry_point = EntryPointController()


parameters_view_controller = ParametersViewController()
overview_controller = OverviewController()
entry_point_controller = EntryPointController()


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			from mongoengine import ValidationError
17			import six
18
19			from st2api.controllers import resource
20			from st2common.exceptions.db import StackStormDBObjectNotFoundError
21			from st2common import log as logging
22			from st2common.content import utils
23			from st2common.models.api.action import ActionAPI
24			from st2common.models.utils import action_param_utils
25			from st2common.persistence.action import Action
26			from st2common.persistence.runner import RunnerType
27			from st2common.router import abort
28
29			http_client = six.moves.http_client
30
31			LOG = logging.getLogger(__name__)
32
33
34			class LookupUtils(object):
35
36			@staticmethod
37			def _get_action_by_id(id):
			0 ignored issues – show Bug Best Practice introduced 2015-11-20 23:04 UTC by Report Bug Copy Issue Report This seems to re-define the built-in `id`. It is generally discouraged to redefine built-ins as this makes code very hard to read. Loading history...
38			try:
39			return Action.get_by_id(id)
40			except Exception as e:
41			msg = 'Database lookup for id="%s" resulted in exception. %s' % (id, e)
42			LOG.exception(msg)
43			abort(http_client.NOT_FOUND, msg)
44
45			@staticmethod
46			def _get_runner_by_id(id):
			0 ignored issues – show Bug Best Practice introduced 2015-11-20 23:04 UTC by Report Bug Copy Issue Report This seems to re-define the built-in `id`. It is generally discouraged to redefine built-ins as this makes code very hard to read. Loading history...
47			try:
48			return RunnerType.get_by_id(id)
49			except (ValueError, ValidationError) as e:
50			msg = 'Database lookup for id="%s" resulted in exception. %s' % (id, e)
51			LOG.exception(msg)
52			abort(http_client.NOT_FOUND, msg)
53
54			@staticmethod
55			def _get_runner_by_name(name):
56			try:
57			return RunnerType.get_by_name(name)
58			except (ValueError, ValidationError) as e:
59			msg = 'Database lookup for name="%s" resulted in exception. %s' % (id, e)
60			LOG.exception(msg)
61			abort(http_client.NOT_FOUND, msg)
62
63
64			class ParametersViewController(object):
65
66			def get_one(self, action_id):
67			return self._get_one(action_id)
68
69			@staticmethod
70			def _get_one(action_id):
71			"""
72			List merged action & runner parameters by action id.
73
74			Handle:
75			GET /actions/views/parameters/1
76			"""
77			action_db = LookupUtils._get_action_by_id(action_id)
			0 ignored issues – show Coding Style Best Practice introduced 2015-11-20 23:04 UTC by Report Bug Copy Issue Report It seems like `_get_action_by_id` was declared protected and should not be accessed from this context. Prefixing a member variable `_` is usually regarded as the equivalent of declaring it with protected visibility that exists in other languages. Consequentially, such a member should only be accessed from the same class or a child class: class MyParent: def __init__(self): self._x = 1; self.y = 2; class MyChild(MyParent): def some_method(self): return self._x # Ok, since accessed from a child class class AnotherClass: def some_method(self, instance_of_my_child): return instance_of_my_child._x # Would be flagged as AnotherClass is not # a child class of MyParent Loading history...
78			LOG.info('Found action: %s, runner: %s', action_db, action_db.runner_type['name'])
79			runner_db = LookupUtils._get_runner_by_name(action_db.runner_type['name'])
			0 ignored issues – show Coding Style Best Practice introduced 2015-11-20 23:04 UTC by Report Bug Copy Issue Report It seems like `_get_runner_by_name` was declared protected and should not be accessed from this context. Prefixing a member variable `_` is usually regarded as the equivalent of declaring it with protected visibility that exists in other languages. Consequentially, such a member should only be accessed from the same class or a child class: class MyParent: def __init__(self): self._x = 1; self.y = 2; class MyChild(MyParent): def some_method(self): return self._x # Ok, since accessed from a child class class AnotherClass: def some_method(self, instance_of_my_child): return instance_of_my_child._x # Would be flagged as AnotherClass is not # a child class of MyParent Loading history...
80
81			all_params = action_param_utils.get_params_view(
82			action_db=action_db, runner_db=runner_db, merged_only=True)
83
84			return {'parameters': all_params}
85
86
87			class OverviewController(resource.ContentPackResourceController):
88			model = ActionAPI
89			access = Action
90			supported_filters = {}
91
92			query_options = {
93			'sort': ['pack', 'name']
94			}
95
96			include_reference = True
97
98			def get_one(self, ref_or_id):
			0 ignored issues – show Bug introduced 2017-02-13 12:24 UTC by Report Bug Copy Issue Report Arguments number differs from overridden 'get_one' method Loading history...
99			"""
100			List action by id.
101
102			Handle:
103			GET /actions/views/overview/1
104			"""
105			resp = super(OverviewController, self)._get_one(ref_or_id)
106			action_api = ActionAPI(**resp.json)
107			result = self._transform_action_api(action_api)
108			resp.json = result
109			return resp
110
111			def get_all(self, **kwargs):
112			"""
113			List all actions.
114
115			Handles requests:
116			GET /actions/views/overview
117			"""
118			resp = super(OverviewController, self)._get_all(**kwargs)
119			result = []
120			for item in resp.json:
121			action_api = ActionAPI(**item)
122			result.append(self._transform_action_api(action_api))
123			resp.json = result
124			return resp
125
126			@staticmethod
127			def _transform_action_api(action_api):
128			action_id = action_api.id
129			action_api.parameters = ParametersViewController._get_one(action_id).get('parameters')
			0 ignored issues – show Coding Style Best Practice introduced 2015-11-20 23:04 UTC by Report Bug Copy Issue Report It seems like `_get_one` was declared protected and should not be accessed from this context. Prefixing a member variable `_` is usually regarded as the equivalent of declaring it with protected visibility that exists in other languages. Consequentially, such a member should only be accessed from the same class or a child class: class MyParent: def __init__(self): self._x = 1; self.y = 2; class MyChild(MyParent): def some_method(self): return self._x # Ok, since accessed from a child class class AnotherClass: def some_method(self, instance_of_my_child): return instance_of_my_child._x # Would be flagged as AnotherClass is not # a child class of MyParent Loading history...
130			return action_api
131
132
133			class EntryPointController(resource.ContentPackResourceController):
134			model = ActionAPI
135			access = Action
136
137			supported_filters = {}
138
139			def get_all(self, **kwargs):
140			return abort(404)
141
142			def get_one(self, ref_or_id):
			0 ignored issues – show Bug introduced 2017-03-20 07:31 UTC by Report Bug Copy Issue Report Arguments number differs from overridden 'get_one' method Loading history...
143			"""
144			Outputs the file associated with action entry_point
145
146			Handles requests:
147			GET /actions/views/entry_point/1
148			"""
149			LOG.info('GET /actions/views/overview with ref_or_id=%s', ref_or_id)
150			action_db = self._get_by_ref_or_id(ref_or_id=ref_or_id)
151
152			pack = getattr(action_db, 'pack', None)
153			entry_point = getattr(action_db, 'entry_point', None)
154
155			abs_path = utils.get_entry_point_abs_path(pack, entry_point)
156
157			if not abs_path:
158			raise StackStormDBObjectNotFoundError('Action ref_or_id=%s has no entry_point to output'
159			% ref_or_id)
160
161			with open(abs_path) as file:
162			content = file.read()
163
164			return content
165
166
167			class ActionViewsController(object):
168			parameters = ParametersViewController()
169			overview = OverviewController()
170			entry_point = EntryPointController()
171
172
173			parameters_view_controller = ParametersViewController()
174			overview_controller = OverviewController()
175			entry_point_controller = EntryPointController()
176

StackStorm / st2

Push — master ( f534b1...a82689 )

EntryPointController.get_all() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like