diff --git a/synapse/storage/databases/main/profile.py b/synapse/storage/databases/main/profile.py index a328d0478b..ecd9c53c93 100644 --- a/synapse/storage/databases/main/profile.py +++ b/synapse/storage/databases/main/profile.py @@ -459,6 +459,7 @@ class ProfileWorkerStore(SQLBaseStore): "instance_name": self._instance_name, "user_id": user_id_str, "field_name": field_name, + "inserted_ts": self.clock.time_msec(), }, ) diff --git a/synapse/storage/schema/main/delta/95/01_profile_updates.sql b/synapse/storage/schema/main/delta/95/01_profile_updates.sql index 8f988cecdf..557d01f9ba 100644 --- a/synapse/storage/schema/main/delta/95/01_profile_updates.sql +++ b/synapse/storage/schema/main/delta/95/01_profile_updates.sql @@ -16,8 +16,14 @@ CREATE TABLE profile_updates ( stream_id BIGINT NOT NULL PRIMARY KEY, instance_name TEXT NOT NULL, + -- The full user ID user_id TEXT NOT NULL, - field_name TEXT NOT NULL + -- Profile field name that has been updated, + -- see https://spec.matrix.org/unstable/client-server-api/#profiles + field_name TEXT NOT NULL, + + -- Unix timestamp for debugging purposes + inserted_ts BIGINT NOT NULL ); CREATE INDEX profile_updates_by_user ON profile_updates (user_id, stream_id);