Vh dZddlmZddlZddlmZddlmZddlm Z ddl m Z m Z d d l mZmZmZGd d eZGd deZy)z'OpenShift plugin for integration tests.) annotationsN)read_text_file)display)IntegrationConfig)run_support_container wait_for_file)CloudEnvironmentCloudEnvironmentConfig CloudProvidercHeZdZdZdfd Zdfd ZddZddZd dZxZ S) OpenShiftCloudProviderzKOpenShift cloud provider plugin. Sets up cloud resources before delegation.cRt||dd|_d|_d|_y)Nz .kubeconfig)config_extensionz'quay.io/ansible/openshift-origin:v3.9.0T)super__init__image uses_docker uses_config)selfargs __class__s k/home/dcms/DCMS/lib/python3.12/site-packages/ansible_test/_internal/commands/integration/cloud/openshift.pyrzOpenShiftCloudProvider.__init__!s.  >? ct||jr|jy|j y)zKSetup the cloud resource before delegation and register a cleanup callback.N)rsetup_use_static_config _setup_static_setup_dynamic)rrs rrzOpenShiftCloudProvider.setup*s0    " " $       !rct|j}tjd|tj}|st j dyy)z.*)$flagsz0Could not find OpenShift endpoint in kubeconfig.N)rconfig_static_pathresearch MULTILINErwarning)rconfigmatchs rrz$OpenShiftCloudProvider._setup_static3s> 7 78 7r||T OON Orc2d}|g}dddd|zg}t|j|j|jd||}|sy|jjrd }n-|j |j d |j d |d }|j|y) z*Create a OpenShift container using docker.i startmasterz--listenzhttps://0.0.0.0:%dzopenshift-origin)cmdNz # Unknownzhttps://:/)rrplatformrexplain _get_configname _write_config)rportportsr. descriptorr)s rr z%OpenShiftCloudProvider._setup_dynamic<s  *.BT.IJ* II MM JJ      99   F%%joo:??\`7abF 6"rct|j|ddd}|}tjdd|tj}tjdd |z|tj}|S) z$Get OpenShift config from container.z>/var/lib/origin/openshift.local.config/master/admin.kubeconfig )sleeptriesz$^( *)certificate-authority-data: .*$z \1insecure-skip-tls-verify: truer"z^( *)server: .*$z \1server: %s)r rr%subr')rcontainer_nameserverstdoutr)s rr3z"OpenShiftCloudProvider._get_configYsztyy.:zCEMOP?AdfltvuAuAB+_v-EvUWUaUab r)rrreturnNone)rBrC)r?strr@rDrBrD) __name__ __module__ __qualname____doc__rrrr r3 __classcell__)rs@rrrs U "P#:rrceZdZdZddZy)OpenShiftCloudEnvironmentzZOpenShift cloud environment plugin. Updates integration test environment after delegation.cFt|j}t|S)zRReturn environment configuration for use in the test environment after delegation.)K8S_AUTH_KUBECONFIG)env_vars)dict config_pathr )rrNs rget_environment_configz0OpenShiftCloudEnvironment.get_environment_configgs' $ 0 0 &  rN)rBr )rErFrGrHrQrrrKrKds d rrK)rH __future__rr%iorutilrr)r containersrr r r r rrKrRrrrXsH-"  C]CL  0  r