|
@@ -21,14 +21,7 @@ from synapse.api.errors import StoreError
|
|
|
from ._base import SQLBaseStore
|
|
|
|
|
|
|
|
|
-class ProfileStore(SQLBaseStore):
|
|
|
- def create_profile(self, user_localpart):
|
|
|
- return self._simple_insert(
|
|
|
- table="profiles",
|
|
|
- values={"user_id": user_localpart},
|
|
|
- desc="create_profile",
|
|
|
- )
|
|
|
-
|
|
|
+class ProfileWorkerStore(SQLBaseStore):
|
|
|
@defer.inlineCallbacks
|
|
|
def get_profileinfo(self, user_localpart):
|
|
|
try:
|
|
@@ -61,14 +54,6 @@ class ProfileStore(SQLBaseStore):
|
|
|
desc="get_profile_displayname",
|
|
|
)
|
|
|
|
|
|
- def set_profile_displayname(self, user_localpart, new_displayname):
|
|
|
- return self._simple_update_one(
|
|
|
- table="profiles",
|
|
|
- keyvalues={"user_id": user_localpart},
|
|
|
- updatevalues={"displayname": new_displayname},
|
|
|
- desc="set_profile_displayname",
|
|
|
- )
|
|
|
-
|
|
|
def get_profile_avatar_url(self, user_localpart):
|
|
|
return self._simple_select_one_onecol(
|
|
|
table="profiles",
|
|
@@ -77,14 +62,6 @@ class ProfileStore(SQLBaseStore):
|
|
|
desc="get_profile_avatar_url",
|
|
|
)
|
|
|
|
|
|
- def set_profile_avatar_url(self, user_localpart, new_avatar_url):
|
|
|
- return self._simple_update_one(
|
|
|
- table="profiles",
|
|
|
- keyvalues={"user_id": user_localpart},
|
|
|
- updatevalues={"avatar_url": new_avatar_url},
|
|
|
- desc="set_profile_avatar_url",
|
|
|
- )
|
|
|
-
|
|
|
def get_from_remote_profile_cache(self, user_id):
|
|
|
return self._simple_select_one(
|
|
|
table="remote_profile_cache",
|
|
@@ -94,6 +71,31 @@ class ProfileStore(SQLBaseStore):
|
|
|
desc="get_from_remote_profile_cache",
|
|
|
)
|
|
|
|
|
|
+
|
|
|
+class ProfileStore(ProfileWorkerStore):
|
|
|
+ def create_profile(self, user_localpart):
|
|
|
+ return self._simple_insert(
|
|
|
+ table="profiles",
|
|
|
+ values={"user_id": user_localpart},
|
|
|
+ desc="create_profile",
|
|
|
+ )
|
|
|
+
|
|
|
+ def set_profile_displayname(self, user_localpart, new_displayname):
|
|
|
+ return self._simple_update_one(
|
|
|
+ table="profiles",
|
|
|
+ keyvalues={"user_id": user_localpart},
|
|
|
+ updatevalues={"displayname": new_displayname},
|
|
|
+ desc="set_profile_displayname",
|
|
|
+ )
|
|
|
+
|
|
|
+ def set_profile_avatar_url(self, user_localpart, new_avatar_url):
|
|
|
+ return self._simple_update_one(
|
|
|
+ table="profiles",
|
|
|
+ keyvalues={"user_id": user_localpart},
|
|
|
+ updatevalues={"avatar_url": new_avatar_url},
|
|
|
+ desc="set_profile_avatar_url",
|
|
|
+ )
|
|
|
+
|
|
|
def add_remote_profile_cache(self, user_id, displayname, avatar_url):
|
|
|
"""Ensure we are caching the remote user's profiles.
|
|
|
|