Skip to content
Snippets Groups Projects
Select Git revision
  • 81bc116c4db70ddda1d2297c87fde9f7eed2d2c2
  • master default protected
  • rednatco-v2
  • rednatco
  • test
  • ntc-tube-uniform-color
  • ntc-tube-missing-atoms
  • restore-vertex-array-per-program
  • watlas2
  • dnatco_new
  • cleanup-old-nodejs
  • webmmb
  • fix_auth_seq_id
  • update_deps
  • ext_dev
  • ntc_balls
  • nci-2
  • plugin
  • bugfix-0.4.5
  • nci
  • servers
  • v0.5.0-dev.1
  • v0.4.5
  • v0.4.4
  • v0.4.3
  • v0.4.2
  • v0.4.1
  • v0.4.0
  • v0.3.12
  • v0.3.11
  • v0.3.10
  • v0.3.9
  • v0.3.8
  • v0.3.7
  • v0.3.6
  • v0.3.5
  • v0.3.4
  • v0.3.3
  • v0.3.2
  • v0.3.1
  • v0.3.0
41 results

webpack.config.viewer.debug.js

Blame
  • ipresolve.py 1.34 KiB
    #!/usr/bin/python
    # -*- coding: utf-8 -*-
    
    from __future__ import absolute_import, division, print_function, unicode_literals
    import sys
    from deadbeat import movement, log, conf, dns, text, fs
    from deadbeat.movement import itemsetter
    from operator import itemgetter
    
    name = "IP_Resolve"
    description = "Proof-of-concept bulk IP resolver"
    
    conf_def = conf.cfg_root((
        conf.cfg_item(
            "input_files", conf.cast_path_list, "Input log files", default="test-input.txt"),
        conf.cfg_item(
            "output_file", str, "Output file", default="test-output.txt"),
        conf.cfg_section("log", log.log_base_config, "Logging"),
        conf.cfg_section("config", conf.cfg_base_config, "Configuration")
    ))
    
    def main():
        cfg = conf.gather(typedef=conf_def, name=name, description=description)
        log.configure(**cfg.log)
        train = movement.Train()
        file_watcher = fs.FileWatcherSupply(train.esc, filenames=cfg.input_files, tail=True)
        csv_parse = text.CSVParse(fieldsetters=(itemsetter("ip"),))
        resolve = dns.IPtoPTR(train.esc)
        serialise = text.CSVMarshall(fieldgetters=(itemgetter("ip"), itemgetter("hostnames")))
        output = fs.LineFileDrain(train=train, path=cfg.output_file, timestamp=False, flush=False)
        train.update(movement.train_line(file_watcher, csv_parse, resolve, serialise, output))
        train()
    
    
    if __name__ == '__main__':
        sys.exit(main())