def customer_get()

in services/customer-async/main.py [0:0]

• 24 lines of code
• 6 McCabe index (conditional complexity)

def customer_get():
    json_data = request.get_json()
    customer_id = None
    invalid_fields = []
    for key in json_data.keys():
        if key == 'customer_id':
            customer_id = json_data[key]
        else:
            invalid_fields.append(key)
    if customer_id is None:
        return error500()

    query = ds_client.query(kind='Customer')
    query.add_filter('customer_id', '=', customer_id)
    resp = None
    for result in query.fetch(): # This should return a single entity.
        resp = {
            'customer_id': result['customer_id'],
            'credit': result['credit'],
            'limit': result['limit']
        }
        break
    if resp is None:
        return error500()

    return resp, 200