def _to_node()

in libcloud/compute/drivers/openstack.py [0:0]
62 lines of code
16 McCabe index (conditional complexity)

    def _to_node(self, api_node):
        public_networks_labels = ["public", "internet"]

        public_ips, private_ips = [], []

        for label, values in api_node["addresses"].items():
            for value in values:
                ip = value["addr"]
                is_public_ip = False

                try:
                    is_public_ip = is_public_subnet(ip)
                except Exception:
                    # IPv6

                    # Openstack Icehouse sets 'OS-EXT-IPS:type' to 'floating'
                    # for public and 'fixed' for private
                    explicit_ip_type = value.get("OS-EXT-IPS:type", None)

                    if label in public_networks_labels:
                        is_public_ip = True
                    elif explicit_ip_type == "floating":
                        is_public_ip = True
                    elif explicit_ip_type == "fixed":
                        is_public_ip = False

                if is_public_ip:
                    public_ips.append(ip)
                else:
                    private_ips.append(ip)

        # Sometimes 'image' attribute is not present if the node is in an error
        # state
        image = api_node.get("image", None)
        image_id = image.get("id", None) if image else None
        config_drive = api_node.get("config_drive", False)
        volumes_attached = api_node.get("os-extended-volumes:volumes_attached")
        created = parse_date(api_node["created"])

        return Node(
            id=api_node["id"],
            name=api_node["name"],
            state=self.NODE_STATE_MAP.get(api_node["status"], NodeState.UNKNOWN),
            public_ips=public_ips,
            private_ips=private_ips,
            created_at=created,
            driver=self,
            extra=dict(
                addresses=api_node["addresses"],
                hostId=api_node["hostId"],
                access_ip=api_node.get("accessIPv4"),
                access_ipv6=api_node.get("accessIPv6", None),
                # Docs says "tenantId", but actual is "tenant_id". *sigh*
                # Best handle both.
                tenantId=api_node.get("tenant_id") or api_node["tenantId"],
                userId=api_node.get("user_id", None),
                imageId=image_id,
                flavorId=api_node.get("flavor", {}).get("id", None),
                flavor_details=api_node.get("flavor", None),
                uri=next(link["href"] for link in api_node["links"] if link["rel"] == "self"),
                # pylint: disable=no-member
                service_name=self.connection.get_service_name(),
                metadata=api_node["metadata"],
                password=api_node.get("adminPass", None),
                created=api_node["created"],
                updated=api_node["updated"],
                key_name=api_node.get("key_name", None),
                disk_config=api_node.get("OS-DCF:diskConfig", None),
                config_drive=config_drive,
                availability_zone=api_node.get("OS-EXT-AZ:availability_zone"),
                volumes_attached=volumes_attached,
                task_state=api_node.get("OS-EXT-STS:task_state", None),
                vm_state=api_node.get("OS-EXT-STS:vm_state", None),
                power_state=api_node.get("OS-EXT-STS:power_state", None),
                progress=api_node.get("progress", None),
                fault=api_node.get("fault"),
            ),
        )