Function process_files

dshell/decode.py:504–533

(inputs, **kwargs)

# TODO: The use of kwargs makes it difficult to understand what arguments the function accept
#   and difficult to follow the code flow.
def process_files(inputs, **kwargs):
    # Iterate over each of the input files
    # For live capture, the "input" would just be the name of the interface
    global plugin_chain
    interface = kwargs.get("interface", False)
    count = kwargs.get("count", None)
    # Try and use the first plugin's BPF as the initial filter
    # The BPFs for other plugins will be applied along the chain as needed
    bpf = plugin_chain[0].bpf

    while len(inputs) > 0:
        input0 = inputs.pop(0)

        # Check if file needs to be decompressed by its file extension
        extension = os.path.splitext(input0)[-1]
        if extension in (".gz", ".bz2", ".zip") and "interface" not in kwargs:
            tempfiles = decompress_file(input0, extension, kwargs.get("unzipdir", tempfile.gettempdir()))
            inputs = tempfiles + inputs
            continue

        for plugin in plugin_chain:
            plugin._prefile(input0)

        for packet in read_packets(input0, interface=interface, bpf=bpf, count=count):
            feed_plugin_chain(0, packet)

        clean_plugin_chain(0)
        for plugin in plugin_chain:
            plugin.purge()
            plugin._postfile()


# TODO: Separate some of this logic outside of this function so we can call