mirror of
https://github.com/element-hq/synapse.git
synced 2024-12-19 01:21:09 +03:00
uncommitted changes on matrix.org
These might be important? who knows?
This commit is contained in:
parent
bae1115e55
commit
f5abaafabd
4 changed files with 10 additions and 10 deletions
|
@ -42,7 +42,7 @@ EMTPY_THIRD_PARTY_ID = ThirdPartyInstanceID(None, None)
|
||||||
class RoomListHandler(BaseHandler):
|
class RoomListHandler(BaseHandler):
|
||||||
def __init__(self, hs):
|
def __init__(self, hs):
|
||||||
super(RoomListHandler, self).__init__(hs)
|
super(RoomListHandler, self).__init__(hs)
|
||||||
self.response_cache = ResponseCache(hs)
|
self.response_cache = ResponseCache(hs, timeout_ms=10 * 60 * 1000)
|
||||||
self.remote_response_cache = ResponseCache(hs, timeout_ms=30 * 1000)
|
self.remote_response_cache = ResponseCache(hs, timeout_ms=30 * 1000)
|
||||||
|
|
||||||
def get_local_public_room_list(self, limit=None, since_token=None,
|
def get_local_public_room_list(self, limit=None, since_token=None,
|
||||||
|
@ -62,18 +62,18 @@ class RoomListHandler(BaseHandler):
|
||||||
appservice and network id to use an appservice specific one.
|
appservice and network id to use an appservice specific one.
|
||||||
Setting to None returns all public rooms across all lists.
|
Setting to None returns all public rooms across all lists.
|
||||||
"""
|
"""
|
||||||
if search_filter or network_tuple is not (None, None):
|
if search_filter:
|
||||||
# We explicitly don't bother caching searches or requests for
|
# We explicitly don't bother caching searches or requests for
|
||||||
# appservice specific lists.
|
# appservice specific lists.
|
||||||
return self._get_public_room_list(
|
return self._get_public_room_list(
|
||||||
limit, since_token, search_filter, network_tuple=network_tuple,
|
limit, since_token, search_filter, network_tuple=network_tuple,
|
||||||
)
|
)
|
||||||
|
|
||||||
result = self.response_cache.get((limit, since_token))
|
result = self.response_cache.get((limit, since_token, network_tuple))
|
||||||
if not result:
|
if not result:
|
||||||
result = self.response_cache.set(
|
result = self.response_cache.set(
|
||||||
(limit, since_token),
|
(limit, since_token, network_tuple),
|
||||||
self._get_public_room_list(limit, since_token)
|
self._get_public_room_list(limit, since_token, network_tuple=network_tuple)
|
||||||
)
|
)
|
||||||
return result
|
return result
|
||||||
|
|
||||||
|
|
|
@ -101,11 +101,11 @@ class EventPushActionsStore(SQLBaseStore):
|
||||||
# notif=1
|
# notif=1
|
||||||
sql = (
|
sql = (
|
||||||
"SELECT count(*)"
|
"SELECT count(*)"
|
||||||
" FROM event_push_actions ea"
|
" FROM (SELECT * FROM event_push_actions"
|
||||||
" WHERE"
|
" WHERE"
|
||||||
" user_id = ?"
|
" user_id = ?"
|
||||||
" AND room_id = ?"
|
" AND room_id = ?"
|
||||||
" AND %s"
|
" AND %s LIMIT 100) as ea"
|
||||||
) % (lower_bound(token, self.database_engine, inclusive=False),)
|
) % (lower_bound(token, self.database_engine, inclusive=False),)
|
||||||
|
|
||||||
txn.execute(sql, (user_id, room_id))
|
txn.execute(sql, (user_id, room_id))
|
||||||
|
|
|
@ -483,9 +483,9 @@ class RoomMemberStore(SQLBaseStore):
|
||||||
|
|
||||||
def add_membership_profile_txn(txn):
|
def add_membership_profile_txn(txn):
|
||||||
sql = ("""
|
sql = ("""
|
||||||
SELECT stream_ordering, event_id, room_id, content
|
SELECT stream_ordering, event_id, events.room_id, content
|
||||||
FROM events
|
FROM events
|
||||||
INNER JOIN room_memberships USING (room_id, event_id)
|
INNER JOIN room_memberships USING (event_id)
|
||||||
WHERE ? <= stream_ordering AND stream_ordering < ?
|
WHERE ? <= stream_ordering AND stream_ordering < ?
|
||||||
AND type = 'm.room.member'
|
AND type = 'm.room.member'
|
||||||
ORDER BY stream_ordering DESC
|
ORDER BY stream_ordering DESC
|
||||||
|
|
|
@ -600,7 +600,7 @@ def _parse_query(database_engine, search_term):
|
||||||
results = re.findall(r"([\w\-]+)", search_term, re.UNICODE)
|
results = re.findall(r"([\w\-]+)", search_term, re.UNICODE)
|
||||||
|
|
||||||
if isinstance(database_engine, PostgresEngine):
|
if isinstance(database_engine, PostgresEngine):
|
||||||
return " & ".join(result + ":*" for result in results)
|
return " & ".join(result for result in results)
|
||||||
elif isinstance(database_engine, Sqlite3Engine):
|
elif isinstance(database_engine, Sqlite3Engine):
|
||||||
return " & ".join(result + "*" for result in results)
|
return " & ".join(result + "*" for result in results)
|
||||||
else:
|
else:
|
||||||
|
|
Loading…
Reference in a new issue