@@ -174,7 +174,7 @@ async def get_push_rules_for_user(self, user_id: str) -> List[JsonDict]:
174
174
"conditions" ,
175
175
"actions" ,
176
176
),
177
- desc = "get_push_rules_enabled_for_user " ,
177
+ desc = "get_push_rules_for_user " ,
178
178
)
179
179
180
180
rows .sort (key = lambda row : (- int (row ["priority_class" ]), - int (row ["priority" ])))
@@ -188,10 +188,10 @@ async def get_push_rules_enabled_for_user(self, user_id: str) -> Dict[str, bool]
188
188
results = await self .db_pool .simple_select_list (
189
189
table = "push_rules_enable" ,
190
190
keyvalues = {"user_name" : user_id },
191
- retcols = ("user_name" , " rule_id" , "enabled" ),
191
+ retcols = ("rule_id" , "enabled" ),
192
192
desc = "get_push_rules_enabled_for_user" ,
193
193
)
194
- return {r ["rule_id" ]: False if r ["enabled" ] == 0 else True for r in results }
194
+ return {r ["rule_id" ]: bool ( r ["enabled" ]) for r in results }
195
195
196
196
async def have_push_rules_changed_for_user (
197
197
self , user_id : str , last_id : int
@@ -213,11 +213,7 @@ def have_push_rules_changed_txn(txn: LoggingTransaction) -> bool:
213
213
"have_push_rules_changed" , have_push_rules_changed_txn
214
214
)
215
215
216
- @cachedList (
217
- cached_method_name = "get_push_rules_for_user" ,
218
- list_name = "user_ids" ,
219
- num_args = 1 ,
220
- )
216
+ @cachedList (cached_method_name = "get_push_rules_for_user" , list_name = "user_ids" )
221
217
async def bulk_get_push_rules (
222
218
self , user_ids : Collection [str ]
223
219
) -> Dict [str , List [JsonDict ]]:
@@ -249,9 +245,7 @@ async def bulk_get_push_rules(
249
245
return results
250
246
251
247
@cachedList (
252
- cached_method_name = "get_push_rules_enabled_for_user" ,
253
- list_name = "user_ids" ,
254
- num_args = 1 ,
248
+ cached_method_name = "get_push_rules_enabled_for_user" , list_name = "user_ids"
255
249
)
256
250
async def bulk_get_push_rules_enabled (
257
251
self , user_ids : Collection [str ]
0 commit comments