def filter_message_list()

in greengrass-v2/poll-api/artifacts/com.greengrass.FilterApiStream/1.0.0/filter.py [0:0]

• 11 lines of code
• 4 McCabe index (conditional complexity)

def filter_message_list(device_list, message_list, filtered_stream_name):
    for message in message_list:
        payload_dict = GGUtils.get_dict_from_message(message)
        filtered_device_data = {}
        device_data = payload_dict['device_data']['points']

        for device in device_list:
            if device not in device_data:
                continue

            filtered_device_data[device] = device_data[device]

        payload_dict['device_data']['points'] = filtered_device_data
        GGUtils.append_message_to_stream(filtered_stream_name, json.dumps(payload_dict).encode())