|
|
|
@ -603,7 +603,7 @@ class RegistrationStore( |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
self.register_background_update_handler( |
|
|
|
|
"users_set_deactivated_flag", self._backgroud_update_set_deactivated_flag |
|
|
|
|
"users_set_deactivated_flag", self._background_update_set_deactivated_flag |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
# Create a background job for culling expired 3PID validity tokens |
|
|
|
@ -618,14 +618,14 @@ class RegistrationStore( |
|
|
|
|
hs.get_clock().looping_call(start_cull, THIRTY_MINUTES_IN_MS) |
|
|
|
|
|
|
|
|
|
@defer.inlineCallbacks |
|
|
|
|
def _backgroud_update_set_deactivated_flag(self, progress, batch_size): |
|
|
|
|
def _background_update_set_deactivated_flag(self, progress, batch_size): |
|
|
|
|
"""Retrieves a list of all deactivated users and sets the 'deactivated' flag to 1 |
|
|
|
|
for each of them. |
|
|
|
|
""" |
|
|
|
|
|
|
|
|
|
last_user = progress.get("user_id", "") |
|
|
|
|
|
|
|
|
|
def _backgroud_update_set_deactivated_flag_txn(txn): |
|
|
|
|
def _background_update_set_deactivated_flag_txn(txn): |
|
|
|
|
txn.execute( |
|
|
|
|
""" |
|
|
|
|
SELECT |
|
|
|
@ -670,7 +670,7 @@ class RegistrationStore( |
|
|
|
|
return False |
|
|
|
|
|
|
|
|
|
end = yield self.runInteraction( |
|
|
|
|
"users_set_deactivated_flag", _backgroud_update_set_deactivated_flag_txn |
|
|
|
|
"users_set_deactivated_flag", _background_update_set_deactivated_flag_txn |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
if end: |
|
|
|
|