Client.make_call() - Code Metrics - StackStorm/st2contrib - Measure and Improve Code Quality continuously with Scrutinizer

Client.make_call() F
last analyzed 2017-07-26 18:29 UTC

↳ Parent: Project

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	11
c	0
b	0
f	0
dl	0
loc	51
rs	3.6

How to fix Long Method Complexity

# pylint: disable=no-member
import json
import urllib
import signal
import sys
import time
import pycurl

POST_PARAMS = {}
MAX_ATTEMPTS = 3


class Client:
    def __init__(self, action, api_url, api_user, api_password, method):
        self.conn = None
        self.action = action
        self.keep_trying = 1
        self.api_url = api_url
        self.api_user = api_user
        self.api_password = api_password
        self.method = method
        self.buffer = ''
        signal.signal(signal.SIGINT, self.handle_ctrl_c)

    def handle_ctrl_c(self, signal, frame):
        sys.stderr.write('SIGINT receivied')
        sys.stderr.write('You pressed Ctrl+C?!')
        self.abort_session()

    def abort_session(self):
        self.keep_trying = 0
        self.conn.close()

    def setup_connection(self):

        if self.conn:
            self.conn.close()
        self.headers = ['Accept: application/json', 'Expect:', 'Connection: close']
        self.conn = pycurl.Curl()
        self.conn.setopt(pycurl.SSL_VERIFYHOST, False)
        self.conn.setopt(pycurl.SSL_VERIFYPEER, False)
        self.conn.setopt(pycurl.USERPWD, "%s:%s" % (self.api_user, self.api_password))
        self.conn.setopt(pycurl.URL, self.api_url)
        self.conn.setopt(pycurl.VERBOSE, 0)
        self.conn.setopt(pycurl.WRITEFUNCTION, self.on_receive)
        self.conn.setopt(pycurl.NOSIGNAL, 1)
        self.conn.setopt(pycurl.NOPROGRESS, 1)
        self.conn.setopt(pycurl.HTTPHEADER, self.headers)
        if self.method == 'post':
            self.conn.setopt(pycurl.POST, 1)
            self.conn.setopt(pycurl.POSTFIELDS, urllib.urlencode(POST_PARAMS))
        elif self.method == 'get':
            self.conn.setopt(pycurl.POST, 0)

    def on_receive(self, data):
        # self.action.logger.debug('Icinga2GetStatus: client on_receive, data: %s', data)
        # complete message received
        self.buffer += data
        # sys.stderr.write(data)
        try:
            event = json.loads(self.buffer)
            update_body = True
        except:
            # no json found
            update_body = False

        if update_body:
            if self.action is not None:
                # sys.stderr.write('Updating body\n')
                self.action.set_body(event)
            else:
                print event

    def __del__(self):
        self.conn.close()

    def make_call(self):
        backoff_network_error = 0.25
        backoff_http_error = 1
        backoff_rate_limit = 60
        attempt = 0
        while True and self.keep_trying == 1 and attempt < MAX_ATTEMPTS:
            attempt += 1
            self.setup_connection()
            try:
                self.conn.perform()
            except:
                # Network error, use linear back off up to 16 seconds
                if self.keep_trying == 0:
                    continue
                sys.stderr.write('Network error: %s' % self.conn.errstr())
                sys.stderr.write('Waiting %s seconds before trying again' % backoff_network_error)
                time.sleep(backoff_network_error)
                backoff_network_error = min(backoff_network_error + 1, 16)
                continue
            # HTTP Error
            sc = self.conn.getinfo(pycurl.HTTP_CODE)
            if sc == 200:
                # sys.stderr.write('HTTP request successful.')
                self.conn.close()
                break
            elif sc == 420:
                # Rate limit, use exponential back off starting with 1 minute then doubling
                sys.stderr.write('Rate limit, waiting %s seconds' % backoff_rate_limit)
                time.sleep(backoff_rate_limit)
                backoff_rate_limit *= 2
            elif sc == 401:
                # Authentication error
                sys.stderr.write('Authentication error, check user/password.')
                self.action.error = 1
                break
            elif sc == 404:
                # Authorization error
                sys.stderr.write('Object not found. Verify request and/or check permissions.')
                self.action.error = 2
                break
            elif sc == 400:
                # Authorization error
                sys.stderr.write('Bad request.')
                self.action.error = 3
                break
            else:
                # HTTP error, use exponential back off up to 320 seconds
                sys.stderr.write('HTTP error %s, %s' % (sc, self.conn.errstr()))
                sys.stderr.write('Waiting %s seconds' % backoff_http_error)
                time.sleep(backoff_http_error)
                backoff_http_error = min(backoff_http_error * 2, 10)


1			# pylint: disable=no-member
2			import json
3			import urllib
4			import signal
5			import sys
6			import time
7			import pycurl
8
9			POST_PARAMS = {}
10			MAX_ATTEMPTS = 3
11
12
13			class Client:
14			def __init__(self, action, api_url, api_user, api_password, method):
15			self.conn = None
16			self.action = action
17			self.keep_trying = 1
18			self.api_url = api_url
19			self.api_user = api_user
20			self.api_password = api_password
21			self.method = method
22			self.buffer = ''
23			signal.signal(signal.SIGINT, self.handle_ctrl_c)
24
25			def handle_ctrl_c(self, signal, frame):
26			sys.stderr.write('SIGINT receivied')
27			sys.stderr.write('You pressed Ctrl+C?!')
28			self.abort_session()
29
30			def abort_session(self):
31			self.keep_trying = 0
32			self.conn.close()
33
34			def setup_connection(self):
35
36			if self.conn:
37			self.conn.close()
38			self.headers = ['Accept: application/json', 'Expect:', 'Connection: close']
39			self.conn = pycurl.Curl()
40			self.conn.setopt(pycurl.SSL_VERIFYHOST, False)
41			self.conn.setopt(pycurl.SSL_VERIFYPEER, False)
42			self.conn.setopt(pycurl.USERPWD, "%s:%s" % (self.api_user, self.api_password))
43			self.conn.setopt(pycurl.URL, self.api_url)
44			self.conn.setopt(pycurl.VERBOSE, 0)
45			self.conn.setopt(pycurl.WRITEFUNCTION, self.on_receive)
46			self.conn.setopt(pycurl.NOSIGNAL, 1)
47			self.conn.setopt(pycurl.NOPROGRESS, 1)
48			self.conn.setopt(pycurl.HTTPHEADER, self.headers)
49			if self.method == 'post':
50			self.conn.setopt(pycurl.POST, 1)
51			self.conn.setopt(pycurl.POSTFIELDS, urllib.urlencode(POST_PARAMS))
52			elif self.method == 'get':
53			self.conn.setopt(pycurl.POST, 0)
54
55			def on_receive(self, data):
56			# self.action.logger.debug('Icinga2GetStatus: client on_receive, data: %s', data)
57			# complete message received
58			self.buffer += data
59			# sys.stderr.write(data)
60			try:
61			event = json.loads(self.buffer)
62			update_body = True
63			except:
64			# no json found
65			update_body = False
66
67			if update_body:
68			if self.action is not None:
69			# sys.stderr.write('Updating body\n')
70			self.action.set_body(event)
71			else:
72			print event
73
74			def __del__(self):
75			self.conn.close()
76
77			def make_call(self):
78			backoff_network_error = 0.25
79			backoff_http_error = 1
80			backoff_rate_limit = 60
81			attempt = 0
82			while True and self.keep_trying == 1 and attempt < MAX_ATTEMPTS:
83			attempt += 1
84			self.setup_connection()
85			try:
86			self.conn.perform()
87			except:
88			# Network error, use linear back off up to 16 seconds
89			if self.keep_trying == 0:
90			continue
91			sys.stderr.write('Network error: %s' % self.conn.errstr())
92			sys.stderr.write('Waiting %s seconds before trying again' % backoff_network_error)
93			time.sleep(backoff_network_error)
94			backoff_network_error = min(backoff_network_error + 1, 16)
95			continue
96			# HTTP Error
97			sc = self.conn.getinfo(pycurl.HTTP_CODE)
98			if sc == 200:
99			# sys.stderr.write('HTTP request successful.')
100			self.conn.close()
101			break
102			elif sc == 420:
103			# Rate limit, use exponential back off starting with 1 minute then doubling
104			sys.stderr.write('Rate limit, waiting %s seconds' % backoff_rate_limit)
105			time.sleep(backoff_rate_limit)
106			backoff_rate_limit *= 2
107			elif sc == 401:
108			# Authentication error
109			sys.stderr.write('Authentication error, check user/password.')
110			self.action.error = 1
111			break
112			elif sc == 404:
113			# Authorization error
114			sys.stderr.write('Object not found. Verify request and/or check permissions.')
115			self.action.error = 2
116			break
117			elif sc == 400:
118			# Authorization error
119			sys.stderr.write('Bad request.')
120			self.action.error = 3
121			break
122			else:
123			# HTTP error, use exponential back off up to 320 seconds
124			sys.stderr.write('HTTP error %s, %s' % (sc, self.conn.errstr()))
125			sys.stderr.write('Waiting %s seconds' % backoff_http_error)
126			time.sleep(backoff_http_error)
127			backoff_http_error = min(backoff_http_error * 2, 10)
128

StackStorm / st2contrib

Client.make_call() F last analyzed 2017-07-26 18:29 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Complexity

Duplication Side-by-Side

Filter issues like

Client.make_call() F
last analyzed 2017-07-26 18:29 UTC