@@ -37,7 +37,6 @@ def add_arguments(self, parser):
3737 type = str ,
3838 help = 'CSV of accessor netid, accessor name, access right' )
3939
40-
4140 def handle (self , * args , ** options ):
4241 self .commit_changes = options ['commit' ]
4342 netid = options ['netid' ]
@@ -50,7 +49,6 @@ def handle(self, *args, **options):
5049 except Exception as ex :
5150 logger .error ("restore_access_rights: Exception: {}" .format (ex ))
5251
53-
5452 def restore_netid_access (self , netid ):
5553 accessee = get_accessee_model (netid )
5654 for delegate , right in self .get_delegates_for_netid (netid ).items ():
@@ -74,21 +72,22 @@ def get_delegates_for_netid(self, netid):
7472 user = delegations ['User' ]
7573 if not user :
7674 continue
77-
75+
7876 rights = delegations ['AccessRights' ]
7977 delegates [user ] = rights
8078 elif isinstance (delegations , list ):
8179 for d in delegations :
8280 user = d ['User' ]
8381 if not user :
8482 continue
85-
83+
8684 rights = d ['AccessRights' ]
8785 if isinstance (rights , list ):
8886 if len (rights ) == 1 :
8987 delegates [user ] = rights [0 ]
9088 else :
91- raise Exception (f"multiple rights for { user } : { rights } " )
89+ raise Exception (f"multiple rights for "
90+ f"{ user } : { rights } " )
9291 elif isinstance (rights , str ):
9392 delegates [user ] = rights
9493 else :
@@ -121,8 +120,8 @@ def fix_access_record(self, accessee, delegate, right):
121120 f"{ '' if self .commit_changes else 'WOULD ' } ASSIGN: "
122121 f"mailbox { ar .accessee .netid } "
123122 f"delegate { ar .accessor .name } "
124- f"right '{ ar .access_right .display_name if (self . commit_changes ) else rr . display_name } '" )
125-
123+ f"right '{ ar .access_right .display_name if (
124+ self . commit_changes ) else rr . display_name } '" )
126125
127126 def reconcile_csv_access (self , csv_file ):
128127 delegations = {}
@@ -132,11 +131,11 @@ def reconcile_csv_access(self, csv_file):
132131 delegates = json .loads (line [1 ])
133132 if not delegates or delegates == 'null' :
134133 continue
135-
134+
136135 netid = line [0 ]
137136 if netid not in delegations :
138137 delegations [netid ] = {}
139-
138+
140139 if isinstance (delegates , dict ):
141140 user = delegates ['User' ]
142141 right = delegates ['AccessRights' ]
@@ -146,15 +145,15 @@ def reconcile_csv_access(self, csv_file):
146145 user = d ['User' ]
147146 right = d ['AccessRights' ]
148147 delegations [netid ][user ] = right
149-
148+
150149 with open ('/tmp/blanks_remaining.csv' , 'r' ) as f :
151150 blank_reader = csv .reader (f )
152151 for i , line in enumerate (blank_reader ):
153152 netid = line [0 ]
154153 if netid not in delegations :
155154 logger .info (f"mailbox { netid } has no delegates" )
156155 continue
157-
156+
158157 try :
159158 accessee = get_accessee_model (netid )
160159 except UnrecognizedUWNetid :
@@ -163,7 +162,7 @@ def reconcile_csv_access(self, csv_file):
163162 except Exception as ex :
164163 logger .info (f"ERROR: get accessee { netid } : { ex } " )
165164 continue
166-
165+
167166 for delegate , right in delegations [netid ].items ():
168167 try :
169168 fix_access_record (accessee , delegate , right )
0 commit comments