emailmessage.EmailMessageCollection.on_get() - Code Metrics - Inspection of "Add a Codacy badge to README.md" - myems/myems-api - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#1)

unknown

created 2020-11-25 03:36 UTC

emailmessage.EmailMessageCollection.on_get() F

↳ Parent: emailmessage

Complexity

Conditions

Size

Total Lines	70
Code Lines	56

Duplication

Lines	70
Ratio	100 %

Importance

Changes

Metric	Value
eloc	56
dl	70
loc	70
rs	3.6
c	0
b	0
f	0
cc	14
nop	4

How to fix Long Method Complexity

import falcon
import json
import mysql.connector
import config
from datetime import datetime, timedelta, timezone


class EmailMessageCollection:

    @staticmethod
    def __init__():
        pass

    @staticmethod
    def on_options(req, resp, startdate, enddate):
        resp.status = falcon.HTTP_200

    @staticmethod
    def on_get(req, resp, startdate, enddate):
        try:
            start_datetime_local = datetime.strptime(startdate, '%Y-%m-%d')
        except Exception:
            raise falcon.HTTPError(falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.INVALID_START_DATE_FORMAT')
        try:
            end_datetime_local = datetime.strptime(enddate, '%Y-%m-%d')
        except Exception:
            raise falcon.HTTPError(falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.INVALID_END_DATE_FORMAT')

        timezone_offset = int(config.utc_offset[1:3]) * 60 + int(config.utc_offset[4:6])
        if config.utc_offset[0] == '-':
            timezone_offset = -timezone_offset

        start_datetime_utc = start_datetime_local.replace(tzinfo=timezone.utc)
        start_datetime_utc -= timedelta(minutes=timezone_offset)

        end_datetime_utc = end_datetime_local.replace(tzinfo=timezone.utc)
        end_datetime_utc -= timedelta(minutes=timezone_offset)
        end_datetime_utc += timedelta(days=1)

        if start_datetime_utc >= end_datetime_utc:
            raise falcon.HTTPError(falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.START_DATETIME_SHOULD_BE_EARLY_THAN_END_DATETIME')

        try:
            cnx = mysql.connector.connect(**config.myems_fdd_db)
            cursor = cnx.cursor()
        except Exception as e:
            raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))

        try:
            query = (" SELECT id, recipient_name, recipient_email, "
                     "        subject, message, attachment_file_name, "
                     "        created_datetime_utc, scheduled_datetime_utc, status "
                     " FROM tbl_email_messages "
                     " WHERE created_datetime_utc >= %s AND created_datetime_utc < %s "
                     " ORDER BY created_datetime_utc ")
            cursor.execute(query, (start_datetime_utc, end_datetime_utc))
            rows = cursor.fetchall()

            if cursor:
                cursor.close()
            if cnx:
                cnx.disconnect()
        except Exception as e:
            raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))

        result = list()
        if rows is not None and len(rows) > 0:
            for row in rows:
                meta_result = {"id": row[0],
                               "recipient_name": row[1],
                               "recipient_email": row[2],
                               "subject": row[3],
                               "message": row[4].replace("<br>", ""),
                               "attachment_file_name": row[5],
                               "created_datetime": row[6].timestamp() * 1000 if isinstance(row[6], datetime) else None,
                               "scheduled_datetime":
                                   row[7].timestamp() * 1000 if isinstance(row[7], datetime) else None,
                               "status": row[8]}
                result.append(meta_result)

        resp.body = json.dumps(result)


class EmailMessageItem:

    @staticmethod
    def __init__():
        pass

    @staticmethod
    def on_options(req, resp, id_):
        resp.status = falcon.HTTP_200

    @staticmethod
    def on_get(req, resp, id_):
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_EMAIL_MESSAGE_ID')

        try:
            cnx = mysql.connector.connect(**config.myems_fdd_db)
            cursor = cnx.cursor()
        except Exception as e:
            raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))

        try:
            query = (" SELECT id, recipient_name, recipient_email, "
                     "        subject, message, attachment_file_name, "
                     "        created_datetime_utc, scheduled_datetime_utc, status "
                     " FROM tbl_email_messages "
                     " WHERE id = %s ")
            cursor.execute(query, (id_,))
            row = cursor.fetchone()

            if cursor:
                cursor.close()
            if cnx:
                cnx.disconnect()
        except Exception as e:
            if cursor:
                cursor.close()
            if cnx:
                cnx.disconnect()
            raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))

        if row is None:
            raise falcon.HTTPError(falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.EMAIL_MESSAGE_NOT_FOUND')

        result = {"id": row[0],
                  "recipient_name": row[1],
                  "recipient_email": row[2],
                  "subject": row[3],
                  "message": row[4].replace("<br>", ""),
                  "attachment_file_name": row[5],
                  "created_datetime": row[6].timestamp() * 1000 if isinstance(row[6], datetime) else None,
                  "scheduled_datetime": row[7].timestamp() * 1000 if isinstance(row[7], datetime) else None,
                  "status": row[8]}

        resp.body = json.dumps(result)

    @staticmethod
    def on_delete(req, resp, id_):
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_EMAIL_MESSAGE_ID')

        cnx = None
        cursor = None
        try:
            cnx = mysql.connector.connect(**config.myems_fdd_db)
            cursor = cnx.cursor()
        except Exception as e:
            if cursor:
                cursor.close()
            if cnx:
                cnx.disconnect()
            raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))

        try:
            cursor.execute(" SELECT id FROM tbl_email_messages WHERE id = %s ", (id_,))
            row = cursor.fetchone()
        except Exception as e:
            if cursor:
                cursor.close()
            if cnx:
                cnx.disconnect()
            raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))

        if row is None:
            if cursor:
                cursor.close()
            if cnx:
                cnx.disconnect()
            raise falcon.HTTPError(falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.EMAIL_MESSAGE_NOT_FOUND')

        try:
            cursor.execute(" DELETE FROM tbl_email_messages WHERE id = %s ", (id_,))
            cnx.commit()
            if cursor:
                cursor.close()
            if cnx:
                cnx.disconnect()
        except Exception as e:
            if cursor:
                cursor.close()
            if cnx:
                cnx.disconnect()
            raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))

        resp.status = falcon.HTTP_204



1		import falcon
2		import json
3		import mysql.connector
4		import config
5		from datetime import datetime, timedelta, timezone
6
7
8	View Code Duplication	class EmailMessageCollection:
		0 ignored issues – show Duplication introduced 2020-11-24 10:14 UTC by Report Bug Copy Issue Report This code seems to be duplicated in your project. Loading history...
9		@staticmethod
10		def __init__():
11		pass
12
13		@staticmethod
14		def on_options(req, resp, startdate, enddate):
15		resp.status = falcon.HTTP_200
16
17		@staticmethod
18		def on_get(req, resp, startdate, enddate):
19		try:
20		start_datetime_local = datetime.strptime(startdate, '%Y-%m-%d')
21		except Exception:
22		raise falcon.HTTPError(falcon.HTTP_400,
23		title='API.BAD_REQUEST',
24		description='API.INVALID_START_DATE_FORMAT')
25		try:
26		end_datetime_local = datetime.strptime(enddate, '%Y-%m-%d')
27		except Exception:
28		raise falcon.HTTPError(falcon.HTTP_400,
29		title='API.BAD_REQUEST',
30		description='API.INVALID_END_DATE_FORMAT')
31
32		timezone_offset = int(config.utc_offset[1:3]) * 60 + int(config.utc_offset[4:6])
33		if config.utc_offset[0] == '-':
34		timezone_offset = -timezone_offset
35
36		start_datetime_utc = start_datetime_local.replace(tzinfo=timezone.utc)
37		start_datetime_utc -= timedelta(minutes=timezone_offset)
38
39		end_datetime_utc = end_datetime_local.replace(tzinfo=timezone.utc)
40		end_datetime_utc -= timedelta(minutes=timezone_offset)
41		end_datetime_utc += timedelta(days=1)
42
43		if start_datetime_utc >= end_datetime_utc:
44		raise falcon.HTTPError(falcon.HTTP_400,
45		title='API.BAD_REQUEST',
46		description='API.START_DATETIME_SHOULD_BE_EARLY_THAN_END_DATETIME')
47
48		try:
49		cnx = mysql.connector.connect(**config.myems_fdd_db)
50		cursor = cnx.cursor()
51		except Exception as e:
52		raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))
53
54		try:
55		query = (" SELECT id, recipient_name, recipient_email, "
56		" subject, message, attachment_file_name, "
57		" created_datetime_utc, scheduled_datetime_utc, status "
58		" FROM tbl_email_messages "
59		" WHERE created_datetime_utc >= %s AND created_datetime_utc < %s "
60		" ORDER BY created_datetime_utc ")
61		cursor.execute(query, (start_datetime_utc, end_datetime_utc))
62		rows = cursor.fetchall()
63
64		if cursor:
65		cursor.close()
66		if cnx:
67		cnx.disconnect()
68		except Exception as e:
69		raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))
70
71		result = list()
72		if rows is not None and len(rows) > 0:
73		for row in rows:
74		meta_result = {"id": row[0],
75		"recipient_name": row[1],
76		"recipient_email": row[2],
77		"subject": row[3],
78		"message": row[4].replace("<br>", ""),
79		"attachment_file_name": row[5],
80		"created_datetime": row[6].timestamp() * 1000 if isinstance(row[6], datetime) else None,
81		"scheduled_datetime":
82		row[7].timestamp() * 1000 if isinstance(row[7], datetime) else None,
83		"status": row[8]}
84		result.append(meta_result)
85
86		resp.body = json.dumps(result)
87
88
89	View Code Duplication	class EmailMessageItem:
		0 ignored issues – show Duplication introduced 2020-11-24 10:14 UTC by Report Bug Copy Issue Report This code seems to be duplicated in your project. Loading history...
90		@staticmethod
91		def __init__():
92		pass
93
94		@staticmethod
95		def on_options(req, resp, id_):
96		resp.status = falcon.HTTP_200
97
98		@staticmethod
99		def on_get(req, resp, id_):
100		if not id_.isdigit() or int(id_) <= 0:
101		raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
102		description='API.INVALID_EMAIL_MESSAGE_ID')
103
104		try:
105		cnx = mysql.connector.connect(**config.myems_fdd_db)
106		cursor = cnx.cursor()
107		except Exception as e:
108		raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))
109
110		try:
111		query = (" SELECT id, recipient_name, recipient_email, "
112		" subject, message, attachment_file_name, "
113		" created_datetime_utc, scheduled_datetime_utc, status "
114		" FROM tbl_email_messages "
115		" WHERE id = %s ")
116		cursor.execute(query, (id_,))
117		row = cursor.fetchone()
118
119		if cursor:
120		cursor.close()
121		if cnx:
122		cnx.disconnect()
123		except Exception as e:
124		if cursor:
125		cursor.close()
126		if cnx:
127		cnx.disconnect()
128		raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))
129
130		if row is None:
131		raise falcon.HTTPError(falcon.HTTP_404, title='API.NOT_FOUND',
132		description='API.EMAIL_MESSAGE_NOT_FOUND')
133
134		result = {"id": row[0],
135		"recipient_name": row[1],
136		"recipient_email": row[2],
137		"subject": row[3],
138		"message": row[4].replace("<br>", ""),
139		"attachment_file_name": row[5],
140		"created_datetime": row[6].timestamp() * 1000 if isinstance(row[6], datetime) else None,
141		"scheduled_datetime": row[7].timestamp() * 1000 if isinstance(row[7], datetime) else None,
142		"status": row[8]}
143
144		resp.body = json.dumps(result)
145
146		@staticmethod
147		def on_delete(req, resp, id_):
148		if not id_.isdigit() or int(id_) <= 0:
149		raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
150		description='API.INVALID_EMAIL_MESSAGE_ID')
151
152		cnx = None
153		cursor = None
154		try:
155		cnx = mysql.connector.connect(**config.myems_fdd_db)
156		cursor = cnx.cursor()
157		except Exception as e:
158		if cursor:
159		cursor.close()
160		if cnx:
161		cnx.disconnect()
162		raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))
163
164		try:
165		cursor.execute(" SELECT id FROM tbl_email_messages WHERE id = %s ", (id_,))
166		row = cursor.fetchone()
167		except Exception as e:
168		if cursor:
169		cursor.close()
170		if cnx:
171		cnx.disconnect()
172		raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))
173
174		if row is None:
175		if cursor:
176		cursor.close()
177		if cnx:
178		cnx.disconnect()
179		raise falcon.HTTPError(falcon.HTTP_404, title='API.NOT_FOUND',
180		description='API.EMAIL_MESSAGE_NOT_FOUND')
181
182		try:
183		cursor.execute(" DELETE FROM tbl_email_messages WHERE id = %s ", (id_,))
184		cnx.commit()
185		if cursor:
186		cursor.close()
187		if cnx:
188		cnx.disconnect()
189		except Exception as e:
190		if cursor:
191		cursor.close()
192		if cnx:
193		cnx.disconnect()
194		raise falcon.HTTPError(falcon.HTTP_500, title='API.DATABASE_ERROR', description=str(e))
195
196		resp.status = falcon.HTTP_204
197
198

myems / myems-api

Pull Request — master (#1)

emailmessage.EmailMessageCollection.on_get() F

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Complexity

Duplication Side-by-Side

Filter issues like