Function update_dns

python3_cron_scripts/get_data_by_cidr_unified.py:107–153

Search DNS file and insert relevant records into the database.

(logger, dns_file, dns_manager, ip_manager, zones)

def update_dns(logger, dns_file, dns_manager, ip_manager, zones):
    """
    Search DNS file and insert relevant records into the database.
    """
    with open(dns_file, "r") as dns_f:
        for line in dns_f:
            try:
                data = json.loads(line)
            except ValueError:
                continue
            except Exception as e:
                logger.error("Error parsing file...")
                logger.error("Exception: " + str(e))
                raise

            try:
                domain = data["name"]
            except:
                logger.warning("Error with line: " + line)
                domain = ""

            dtype = data["type"]

            try:
                value = data["value"]
            except KeyError:
                logger.warning("Error with line: " + line)
                value = ""
            timestamp = data["timestamp"]

            if (
                dtype == "a"
                and value != ""
                and domain != ""
                and ip_manager.is_tracked_ip(value)
            ):
                logger.debug("Matched DNS " + value)
                zone = find_zone(domain, zones)
                insert_json = {}
                insert_json["fqdn"] = domain
                insert_json["zone"] = zone
                insert_json["type"] = dtype
                insert_json["status"] = "unknown"
                insert_json["value"] = value
                insert_json["sonar_timestamp"] = int(timestamp)
                insert_json["created"] = datetime.now()
                dns_manager.insert_record(insert_json, "sonar_dns")


def check_for_ptr_record(ipaddr, dns_manager, g_dns, zones):