diff --git a/aleksis/apps/matrix/model_extensions.py b/aleksis/apps/matrix/model_extensions.py index 4e0472b2a75acaea8486a95e10982815ef61619f..205ee407c6b17ec82c88cc000e88c5517485c1e8 100644 --- a/aleksis/apps/matrix/model_extensions.py +++ b/aleksis/apps/matrix/model_extensions.py @@ -22,7 +22,6 @@ def provision_in_matrix(self, sync: bool = False) -> Union[MatrixRoom, AsyncResu def _provision_in_matrix(self) -> MatrixRoom: """Create and sync a room for this group in Matrix.""" room = MatrixRoom.from_group(self) - room.sync() return room diff --git a/aleksis/apps/matrix/signals.py b/aleksis/apps/matrix/signals.py index 10db2f5675c4cbb473e7b4f691677f08fdd201e7..0b67a1fa331fdfc963ab0813a208275dcfad6b2c 100644 --- a/aleksis/apps/matrix/signals.py +++ b/aleksis/apps/matrix/signals.py @@ -8,9 +8,6 @@ from .tasks import sync_room def post_save_matrix_signal(sender, instance, created, **kwargs): """Sync Matrix room after changing a group/Matrix room/Matrix profile.""" - if created: - return - rooms = [] if isinstance(instance, Group): rooms = MatrixRoom.objects.filter(group=instance) diff --git a/aleksis/apps/matrix/tasks.py b/aleksis/apps/matrix/tasks.py index f61f53b92c69a36505e257a21a61b5077696371c..8574b3aab89df610212447ddebe2e81d12db22bd 100644 --- a/aleksis/apps/matrix/tasks.py +++ b/aleksis/apps/matrix/tasks.py @@ -1,6 +1,8 @@ from datetime import timedelta from typing import Sequence +from celery.task.sets import TaskSet + from aleksis.apps.matrix.models import MatrixRoom from aleksis.core.celery import app from aleksis.core.models import Group @@ -33,4 +35,4 @@ def sync_rooms(): """Synchronise all Matrix rooms.""" rooms = MatrixRoom.objects.all() for room in rooms: - room.sync() + sync_room.delay(room.pk)