ResultSets.parseBucket() - Code Metrics - Inspection of "Re-generate README.md" - StackStorm/st2contrib - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( fa16f8...51c46e )

unknown

created 2016-03-03 19:42 UTC

ResultSets.parseBucket() A

↳ Parent: ResultSets

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Metric	Value
cc	2
dl	0
loc	3
rs	10

import boto
import six


class FieldLists():
    ADDRESS = [
        'allocation_id',
        'association_id',
        'domain',
        'instance_id',
        'network_interface_id',
        'network_interface_owner_id',
        'private_ip_address',
        'public_ip'
    ]

    BLOCK_DEVICE_TYPE = [
        'attach_time',
        'delete_on_termination',
        'encrypted',
        'ephemeral_name',
        'iops',
        'size',
        'snapshot_id',
        'status',
        'volume_id',
        'volume_type'
    ]

    BUCKET = [
        'connection',
        'creation_date',
        'LoggingGroup',
        'name'
    ]

    EC2ZONE = [
        'messages',
        'name',
        'region_name',
        'state'
    ]

    INSTANCE = [
        'ami_launch_index',
        'architecture',
        'hypervisor',
        'id',
        'image_id',
        'instance_type',
        'ip_address',
        'kernel',
        'key_name',
        'launch_time',
        'monitored',
        'monitoring_state',
        'placement',
        'placement_group',
        'placement_tenancy',
        'platform',
        'previous_state',
        'previous_state_code',
        'private_dns_name',
        'private_ip_address',
        'public_dns_name',
        'ramdisk',
        'root_device_name',
        'root_device_type',
        'spot_instance_request_id',
        'state',
        'state_code',
        'state_reason',
        'subnet_id',
        'virtualization_type',
        'vpc_id',
    ]

    RECORD = [
        'alias_dns_name',
        'alias_evaluate_target_health',
        'alias_hosted_zone_id',
        'failover',
        'health_check',
        'identifier',
        'name',
        'region',
        'resource_records',
        'ttl',
        'type',
        'weight'
    ]

    R53ZONE = [
        'callerreference',
        'config',
        'id',
        'name',
        'resourcerecordsetcount'
    ]

    R53STATUS = [
        'comment',
        'id',
        'status',
        'submittedat'
    ]

    VOLUME = [
        'create_time',
        'encrypted',
        'id',
        'iops',
        'size',
        'snapshot_id',
        'status',
        'type',
        'zone'
    ]


class ResultSets(object):

    def __init__(self):
        self.foo = ''

    def selector(self, output):
        if isinstance(output, boto.ec2.instance.Reservation):
            return self.parseReservation(output)
        elif isinstance(output, boto.ec2.instance.Instance):
            return self.parseInstance(output)
        elif isinstance(output, boto.ec2.volume.Volume):
            return self.parseVolume(output)
        elif isinstance(output, boto.ec2.blockdevicemapping.BlockDeviceType):
            return self.parseBlockDeviceType(output)
        elif isinstance(output, boto.ec2.zone.Zone):
            return self.parseEC2Zone(output)
        elif isinstance(output, boto.ec2.address.Address):
            return self.parseAddress(output)
        elif isinstance(output, boto.route53.record.Record):
            return self.parseRecord(output)
        elif isinstance(output, boto.route53.zone.Zone):
            return self.parseR53Zone(output)
        elif isinstance(output, boto.route53.status.Status):
            return self.parseR53Status(output)
        elif isinstance(output, boto.ec2.ec2object.EC2Object):
            return self.parseEC2Object(output)
        else:
            return output

    def formatter(self, output):
        if isinstance(output, list):
            return [self.formatter(item) for item in output]
        elif isinstance(output, dict):
            return {key: self.formatter(value) for key, value in six.iteritems(output)}
        else:
            return self.selector(output)

    def parseReservation(self, output):
        instance_list = []
        for instance in output.instances:
            instance_data = self.parseInstance(instance)
            instance_data['owner_id'] = output.owner_id
            instance_list.append(instance_data)
        return instance_list

    def parseAddress(self, output):
        instance_data = {field: getattr(output, field) for field in FieldLists.ADDRESS}
        return instance_data

    def parseInstance(self, output):
        instance_data = {field: getattr(output, field) for field in FieldLists.INSTANCE}
        return instance_data

    def parseVolume(self, output):
        volume_data = {field: getattr(output, field) for field in FieldLists.VOLUME}
        return volume_data

    def parseBlockDeviceType(self, output):
        data = {field: getattr(output, field) for field in FieldLists.BLOCK_DEVICE_TYPE}
        return data

    def parseEC2Zone(self, output):
        zone_data = {field: getattr(output, field) for field in FieldLists.EC2ZONE}
        return zone_data

    def parseRecord(self, output):
        record_data = {field: getattr(output, field) for field in FieldLists.RECORD}
        return record_data

    def parseR53Zone(self, output):
        zone_data = {field: getattr(output, field) for field in FieldLists.R53ZONE}
        return zone_data

    def parseR53Status(self, output):
        status_data = {field: getattr(output, field) for field in FieldLists.R53STATUS}
        return status_data

    def parseBucket(self, output):
        bucket_data = {field: getattr(output, field) for field in FieldLists.BUCKET}
        return bucket_data

    def parseEC2Object(self, output):
        # Looks like everything that is an EC2Object pretty much only has these extra
        # 'unparseable' properties so handle region and connection specially.
        output = vars(output)
        del output['connection']
        # special handling for region since name here is better than id.
        region = output.get('region', None)
        output['region'] = region.name if region else ''
        # now anything that is an EC2Object get some special marshalling care.
        for k, v in six.iteritems(output):
            if isinstance(v, boto.ec2.ec2object.EC2Object):
                # Better not to assume each EC2Object has an id. If not found
                # resort to the str of the object which should have something meaningful.
                output[k] = getattr(v, 'id', str(v))
            # Generally unmarshallable object might be hiding in list so better to
            if isinstance(v, list):
                v_list = []
                for item in v:
                    # avoid touching the basic types.
                    if isinstance(item, (basestring, bool, int, long, float)):

                        v_list.append(v)
                    else:
                        v_list.append(str(item))
                output[k] = v_list
        return output


1			import boto
2			import six
3
4
5			class FieldLists():
6			ADDRESS = [
7			'allocation_id',
8			'association_id',
9			'domain',
10			'instance_id',
11			'network_interface_id',
12			'network_interface_owner_id',
13			'private_ip_address',
14			'public_ip'
15			]
16
17			BLOCK_DEVICE_TYPE = [
18			'attach_time',
19			'delete_on_termination',
20			'encrypted',
21			'ephemeral_name',
22			'iops',
23			'size',
24			'snapshot_id',
25			'status',
26			'volume_id',
27			'volume_type'
28			]
29
30			BUCKET = [
31			'connection',
32			'creation_date',
33			'LoggingGroup',
34			'name'
35			]
36
37			EC2ZONE = [
38			'messages',
39			'name',
40			'region_name',
41			'state'
42			]
43
44			INSTANCE = [
45			'ami_launch_index',
46			'architecture',
47			'hypervisor',
48			'id',
49			'image_id',
50			'instance_type',
51			'ip_address',
52			'kernel',
53			'key_name',
54			'launch_time',
55			'monitored',
56			'monitoring_state',
57			'placement',
58			'placement_group',
59			'placement_tenancy',
60			'platform',
61			'previous_state',
62			'previous_state_code',
63			'private_dns_name',
64			'private_ip_address',
65			'public_dns_name',
66			'ramdisk',
67			'root_device_name',
68			'root_device_type',
69			'spot_instance_request_id',
70			'state',
71			'state_code',
72			'state_reason',
73			'subnet_id',
74			'virtualization_type',
75			'vpc_id',
76			]
77
78			RECORD = [
79			'alias_dns_name',
80			'alias_evaluate_target_health',
81			'alias_hosted_zone_id',
82			'failover',
83			'health_check',
84			'identifier',
85			'name',
86			'region',
87			'resource_records',
88			'ttl',
89			'type',
90			'weight'
91			]
92
93			R53ZONE = [
94			'callerreference',
95			'config',
96			'id',
97			'name',
98			'resourcerecordsetcount'
99			]
100
101			R53STATUS = [
102			'comment',
103			'id',
104			'status',
105			'submittedat'
106			]
107
108			VOLUME = [
109			'create_time',
110			'encrypted',
111			'id',
112			'iops',
113			'size',
114			'snapshot_id',
115			'status',
116			'type',
117			'zone'
118			]
119
120
121			class ResultSets(object):
122
123			def __init__(self):
124			self.foo = ''
125
126			def selector(self, output):
127			if isinstance(output, boto.ec2.instance.Reservation):
128			return self.parseReservation(output)
129			elif isinstance(output, boto.ec2.instance.Instance):
130			return self.parseInstance(output)
131			elif isinstance(output, boto.ec2.volume.Volume):
132			return self.parseVolume(output)
133			elif isinstance(output, boto.ec2.blockdevicemapping.BlockDeviceType):
134			return self.parseBlockDeviceType(output)
135			elif isinstance(output, boto.ec2.zone.Zone):
136			return self.parseEC2Zone(output)
137			elif isinstance(output, boto.ec2.address.Address):
138			return self.parseAddress(output)
139			elif isinstance(output, boto.route53.record.Record):
140			return self.parseRecord(output)
141			elif isinstance(output, boto.route53.zone.Zone):
142			return self.parseR53Zone(output)
143			elif isinstance(output, boto.route53.status.Status):
144			return self.parseR53Status(output)
145			elif isinstance(output, boto.ec2.ec2object.EC2Object):
146			return self.parseEC2Object(output)
147			else:
148			return output
149
150			def formatter(self, output):
151			if isinstance(output, list):
152			return [self.formatter(item) for item in output]
153			elif isinstance(output, dict):
154			return {key: self.formatter(value) for key, value in six.iteritems(output)}
155			else:
156			return self.selector(output)
157
158			def parseReservation(self, output):
159			instance_list = []
160			for instance in output.instances:
161			instance_data = self.parseInstance(instance)
162			instance_data['owner_id'] = output.owner_id
163			instance_list.append(instance_data)
164			return instance_list
165
166			def parseAddress(self, output):
167			instance_data = {field: getattr(output, field) for field in FieldLists.ADDRESS}
168			return instance_data
169
170			def parseInstance(self, output):
171			instance_data = {field: getattr(output, field) for field in FieldLists.INSTANCE}
172			return instance_data
173
174			def parseVolume(self, output):
175			volume_data = {field: getattr(output, field) for field in FieldLists.VOLUME}
176			return volume_data
177
178			def parseBlockDeviceType(self, output):
179			data = {field: getattr(output, field) for field in FieldLists.BLOCK_DEVICE_TYPE}
180			return data
181
182			def parseEC2Zone(self, output):
183			zone_data = {field: getattr(output, field) for field in FieldLists.EC2ZONE}
184			return zone_data
185
186			def parseRecord(self, output):
187			record_data = {field: getattr(output, field) for field in FieldLists.RECORD}
188			return record_data
189
190			def parseR53Zone(self, output):
191			zone_data = {field: getattr(output, field) for field in FieldLists.R53ZONE}
192			return zone_data
193
194			def parseR53Status(self, output):
195			status_data = {field: getattr(output, field) for field in FieldLists.R53STATUS}
196			return status_data
197
198			def parseBucket(self, output):
199			bucket_data = {field: getattr(output, field) for field in FieldLists.BUCKET}
200			return bucket_data
201
202			def parseEC2Object(self, output):
203			# Looks like everything that is an EC2Object pretty much only has these extra
204			# 'unparseable' properties so handle region and connection specially.
205			output = vars(output)
206			del output['connection']
207			# special handling for region since name here is better than id.
208			region = output.get('region', None)
209			output['region'] = region.name if region else ''
210			# now anything that is an EC2Object get some special marshalling care.
211			for k, v in six.iteritems(output):
212			if isinstance(v, boto.ec2.ec2object.EC2Object):
213			# Better not to assume each EC2Object has an id. If not found
214			# resort to the str of the object which should have something meaningful.
215			output[k] = getattr(v, 'id', str(v))
216			# Generally unmarshallable object might be hiding in list so better to
217			if isinstance(v, list):
218			v_list = []
219			for item in v:
220			# avoid touching the basic types.
221			if isinstance(item, (basestring, bool, int, long, float)):
			0 ignored issues – show Comprehensibility Best Practice introduced 2016-02-01 22:20 UTC by Report Bug Copy Issue Report Undefined variable 'basestring' Loading history... Comprehensibility Best Practice introduced 2016-02-01 22:20 UTC by Report Bug Copy Issue Report Undefined variable 'long' Loading history...
222			v_list.append(v)
223			else:
224			v_list.append(str(item))
225			output[k] = v_list
226			return output
227

StackStorm / st2contrib

Push — master ( fa16f8...51c46e )

ResultSets.parseBucket() A

Complexity

Size

Duplication

Duplication Side-by-Side

Filter issues like