Write new column

synapse/handlers/federation.py

@@ -631,6 +631,7 @@ async def do_invite_join(
  room_id=room_id,
  servers=ret.servers_in_room,
  device_lists_stream_id=self.store.get_device_stream_token(),
+ joined_via=origin,
  )
 
  try:

synapse/storage/databases/main/room.py

@@ -1827,6 +1827,7 @@ async def store_partial_state_room(
  room_id: str,
  servers: Collection[str],
  device_lists_stream_id: int,
+ joined_via: str,
  ) -> None:
  """Mark the given room as containing events with partial state.
 
@@ -1842,13 +1843,15 @@ async def store_partial_state_room(
  servers: other servers known to be in the room
  device_lists_stream_id: the device_lists stream ID at the time when we first
  joined the room.
+ joined_via: the server name we requested a partial join from.
  """
  await self.db_pool.runInteraction(
  "store_partial_state_room",
  self._store_partial_state_room_txn,
  room_id,
  servers,
  device_lists_stream_id,
+ joined_via,
  )
 
  def _store_partial_state_room_txn(
@@ -1857,6 +1860,7 @@ def _store_partial_state_room_txn(
  room_id: str,
  servers: Collection[str],
  device_lists_stream_id: int,
+ joined_via: str,
  ) -> None:
  DatabasePool.simple_insert_txn(
  txn,
@@ -1866,6 +1870,7 @@ def _store_partial_state_room_txn(
  "device_lists_stream_id": device_lists_stream_id,
  # To be updated later once the join event is persisted.
  "join_event_id": None,
+ "joined_via": joined_via,
  },
  )
  DatabasePool.simple_insert_many_txn(