Method insert_record

python3_cron_scripts/libs3/IPManager.py:569–770

Insert an IP into the tracking table This function completely rebuilds the record because it is simpler and cleaner than tracking which data came from which location and whether to expire specific sections.

(
        self,
        ip,
        source=None,
        account_id=None,
        cloud_env=None,
        account_info=None,
        fqdn=None,
    )

        return rnds_value, rdns_zone

    def insert_record(
        self,
        ip,
        source=None,
        account_id=None,
        cloud_env=None,
        account_info=None,
        fqdn=None,
    ):
        """
        Insert an IP into the tracking table
        This function completely rebuilds the record because it is simpler and cleaner than tracking which
        data came from which location and whether to expire specific sections.
        """

        if ip is None or ip == "":
            self._logger.error("ERROR: Sent an invalid IP address: " + str(ip))
            return

        if isinstance(ip, str):
            ip_addr = IPAddress(ip)
        else:
            ip_addr = ip
            ip = str(ip_addr)

        if ip_addr is None:
            self._logger.error("ERROR: Could not insert: " + str(ip))
            return

        if self.is_local_ip(ip):
            if fqdn is not None:
                self._logger.warning(
                    "WARNING: all_ips does not track local IP addresses: " + str(fqdn)
                )
            else:
                self._logger.warning(
                    "WARNING: all_ips does not track local IP addresses"
                )
            return

        record = {}
        record["ip"] = ip
        record["version"] = ip_addr.version
        record["updated"] = datetime.now()

        if account_info is not None:
            record["accountInfo"] = account_info

        if account_id is None and account_info is not None:
            for entry in account_info:
                if entry["key"] == "accountId":
                    account_id = entry["value"]

        # Check existance
        result = self._mongo_connector.perform_find_one(
            self.all_ips_collection, {"ip": ip}
        )
        if result is not None: