@@ -114,6 +114,8 @@ def get_ns_list(logger,body,v1=None):
114114
115115
116116def create_secret (logger ,namespace ,body ,v1 = None ):
117+ """Creates a given secret on a given namespace
118+ """
117119 if v1 is None :
118120 v1 = client .CoreV1Api ()
119121 logger .debug ('new client - fn create secret' )
@@ -151,6 +153,8 @@ def create_secret(logger,namespace,body,v1=None):
151153
152154@kopf .on .create ('' , 'v1' , 'namespaces' )
153155async def namespace_watcher (patch ,logger ,meta ,body ,event ,** kwargs ):
156+ """Watch for namespace events
157+ """
154158 new_ns = meta ['name' ]
155159 logger .debug (f"New namespace created: { new_ns } re-syncing" )
156160 v1 = client .CoreV1Api ()
@@ -159,12 +163,13 @@ async def namespace_watcher(patch,logger,meta,body,event,**kwargs):
159163 obj_body = v ['body' ]
160164 #logger.debug(f'k: {k} \n v:{v}')
161165 matcheddns = v ['syncedns' ]
162- logger .debug (f"Old matcheddns : { matcheddns } - name: { v ['body' ]['metadata' ]['name' ]} " )
166+ logger .debug (f"Old matched namespace : { matcheddns } - name: { v ['body' ]['metadata' ]['name' ]} " )
163167 ns_new_list = get_ns_list (logger ,obj_body ,v1 )
164168 logger .debug (f"new matched list: { ns_new_list } " )
165169 if new_ns in ns_new_list :
166170 logger .debug (f"Clonning secret { v ['body' ]['metadata' ]['name' ]} into the new namespace { new_ns } " )
167171 create_secret (logger ,new_ns ,v ['body' ],v1 )
172+ # if there is a new matching ns, refresh memory
168173 v ['syncedns' ] = ns_new_list
169174
170175 # update ns_new_list on the object so then we also delete from there
0 commit comments