@@ -70,7 +70,8 @@ def __init__(self, hs: "HomeServer"):
70
70
# Guard to ensure we only process deltas one at a time
71
71
self ._is_processing = False
72
72
73
- if self .update_user_directory :
73
+ # T2B: Disable user directory
74
+ if self .update_user_directory and False :
74
75
self .notifier .add_replication_callback (self .notify_new_event )
75
76
76
77
# We kick this off so that we don't have to wait for a change before
@@ -109,6 +110,11 @@ async def search_users(
109
110
110
111
def notify_new_event (self ) -> None :
111
112
"""Called when there may be more deltas to process"""
113
+
114
+ # T2B: Disable user directory
115
+ if True :
116
+ return
117
+
112
118
if not self .update_user_directory :
113
119
return
114
120
@@ -133,6 +139,10 @@ async def handle_local_profile_change(
133
139
# FIXME(#3714): We should probably do this in the same worker as all
134
140
# the other changes.
135
141
142
+ # T2B: Disable user directory
143
+ if True :
144
+ return
145
+
136
146
if await self .store .should_include_local_user_in_dir (user_id ):
137
147
await self .store .update_profile_in_user_dir (
138
148
user_id , profile .display_name , profile .avatar_url
@@ -142,6 +152,11 @@ async def handle_local_user_deactivated(self, user_id: str) -> None:
142
152
"""Called when a user ID is deactivated"""
143
153
# FIXME(#3714): We should probably do this in the same worker as all
144
154
# the other changes.
155
+
156
+ # T2B: Disable user directory
157
+ if True :
158
+ return
159
+
145
160
await self .store .remove_from_user_dir (user_id )
146
161
147
162
async def _unsafe_process (self ) -> None :
0 commit comments