tjkLddlZddlZddlZddlZddlmZGddZdS)N)ConfigExceptionc8eZdZdZddZedZddZdS) ExecProvidera, Implementation of the proposal for out-of-tree client authentication providers as described here -- https://github.com/kubernetes/community/blob/master/contributors/design-proposals/auth/kubectl-exec-plugins.md Missing from implementation: * TLS cert support * caching NcdD]}||vrtd|z|d|_|dg|_|dr |j|dt j|_|drs|222rc jttjdotj}|jdd|id}|r ||dd<|jrn|jj|dd<|jjdr:|jjdD]'}|d d kr|d |ddd <n(tj ||j d <tj |j tj|r tjn tj|r tjnd|j|j d|j}|\}}|}|dkr2d|z} |}|r| d|zz } t-|  tj|} n$#t0$r} t-d| zd} ~ wwxYwdD]} | | vrt-d| z| d|jkr t-d| dd|j| dS)NisattyExecCredential interactive)r kindspecr+responser extensionsr z!client.authentication.k8s.io/exec extensionconfigKUBERNETES_EXEC_INFOT)stdoutstderrstdinrr universal_newlinesr%rzexec: process returned %dz. %sz)exec: failed to decode process output: %s)r r*statusz*exec: malformed response. missing key '%s'r zexec: plugin api version z does not match r5)hasattrr#r1r'rrr getjsondumpsr subprocessPopenr PIPEr2r3rr% communicatewaitstriprloads ValueError) rprevious_responseis_interactivekubernetes_exec_infor.processr1r2 exit_codemsgdataders rrunzExecProvider.runGs X66N3:;L;L;N;N*$~    I7H  ( 4 < 6:l6H  ( 3|!%%l33 !%!3L!AI (,OOOLUVaLb,V4Y?IP,0:6J+K+K'(" I?!/D3::Z_-7#))4#*#..00LLNN >>- 9C\\^^F 'v&!#&& & B:f%%DD B B B!;b@BB B B4 J JC$%BSHJJJ  !1 1 1!/l###T%5%5788 8H~s(F== GGG)N)__name__ __module__ __qualname____doc__rpropertyr%rJrrrrsa  833X3222222rr)r8rr:r#config_exceptionrrrPrrrRs|  ------ccccccccccr