guardian / CDS-K8s - Conditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

There are 104 units with 1,108 lines of code in units (47.2% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
2 medium complex units (78 lines of code)
12 simple units (284 lines of code)
90 very simple units (746 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex units

Unit	# lines	McCabe index	# params
def valid_message_receive() in cdsresponder/rabbitmq/UploadRequestedProcessor.py	48	18	6
def checkAdmin[A]() in cdslogviewer/app/auth/Security.scala	30	11	2
def validateToken() in cdslogviewer/app/auth/BearerTokenAuth.scala	36	10	1
def _watcher() in cdsreaper/jobwatcher.py	32	8	1
def getVerifier() in cdslogviewer/app/auth/BearerTokenAuth.scala	19	8	1
def notify() in cdsreaper/messagesender.py	29	7	4
private def onUnauthorized() in cdslogviewer/app/auth/Security.scala	15	7	2
def raw_message_receive() in cdsresponder/rabbitmq/messageprocessor.py	35	7	5
def get_job_status_string() in cdsreaper/jobwatcher.py	12	6	1
async function loadMoreLogLines() in cdslogviewer/frontend/app/data-loading.ts	42	6	3
private def hmacUsername() in cdslogviewer/app/auth/Security.scala	22	6	2
def __init__() in cdsresponder/cds/cds_launcher.py	16	6	2
def get_should_keep_jobs() in cdsresponder/rabbitmq/K8MessageProcessor.py	8	6	0
def __init__() in cdsresponder/rabbitmq/K8MessageProcessor.py	18	6	2
def job_is_failed() in cdsreaper/jobwatcher.py	2	5	1
function formatError() in cdslogviewer/frontend/app/common/format_error.ts	18	5	2
def calculateHmac() in cdslogviewer/app/auth/HMAC.scala	22	5	3
def streamLog() in cdslogviewer/app/controllers/LogsController.scala	26	5	3
def load_job_template() in cdsresponder/cds/cds_launcher.py	10	5	1
def build_filename() in cdsresponder/rabbitmq/UploadRequestedProcessor.py	13	5	3
def valid_message_receive() in cdsresponder/rabbitmq/K8MessageProcessor.py	16	5	6
def read() in cdsreaper/models.py	17	4	2
def job_is_starting() in cdsreaper/jobwatcher.py	2	4	1
def job_is_running() in cdsreaper/jobwatcher.py	2	4	1
def job_is_success() in cdsreaper/jobwatcher.py	2	4	1
async function authenticatedFetch() in cdslogviewer/frontend/app/common/authenticated_fetch.ts	20	4	2
private def username() in cdslogviewer/app/auth/Security.scala	16	4	1
def listLogs() in cdslogviewer/app/controllers/LogsController.scala	19	4	1
def find_job_template() in cdsresponder/cds/cds_launcher.py	11	4	1
def job_is_retry() in cdsreaper/jobwatcher.py	2	3	1
def check_job() in cdsreaper/jobwatcher.py	13	3	2
def _establish_connection() in cdsreaper/journal.py	12	3	2
def get_most_recent_event() in cdsreaper/journal.py	11	3	1
def _setup_channel() in cdsreaper/messagesender.py	13	3	2
async function loadLogsForRoute() in cdslogviewer/frontend/app/data-loading.ts	15	3	2
const reduceValue:() in cdslogviewer/frontend/app/common/bytesformatter.ts	9	3	0
function bestErrorString() in cdslogviewer/frontend/app/common/format_error.ts	5	3	2
def extract_checksum() in cdslogviewer/app/auth/HMAC.scala	13	3	1
def extractAuthorization() in cdslogviewer/app/auth/BearerTokenAuth.scala	9	3	1
def apply() in cdslogviewer/app/auth/BearerTokenAuth.scala	15	3	1
def MyAuthenticated[A]() in cdslogviewer/app/auth/Security.scala	13	3	4
def index() in cdslogviewer/app/controllers/IndexController.scala	13	3	1
def build_job_doc() in cdsresponder/cds/cds_launcher.py	12	3	4
def write_out_inmeta() in cdsresponder/rabbitmq/UploadRequestedProcessor.py	14	3	3
def retry_count() in cdsresponder/rabbitmq/K8MessageProcessor.py	10	3	1
def read_logs() in cdsresponder/rabbitmq/K8MessageProcessor.py	11	3	3
def __init__() in cdsreaper/models.py	5	2	5
def init_k8s_client() in cdsreaper/cdsreaper.py	7	2	0
def get_current_namespace() in cdsreaper/cdsreaper.py	7	2	0
def get_most_recent_condition() in cdsreaper/jobwatcher.py	5	2	1