diff --git a/kfet/views.py b/kfet/views.py index 5cec6eff..aa3faa2c 100644 --- a/kfet/views.py +++ b/kfet/views.py @@ -1603,6 +1603,29 @@ def perform_transfers(request): transfer.save() data['transfers'].append(transfer.pk) + # Websocket data + websocket_data = {} + websocket_data['opegroups'] = [{ + 'add': True, + 'type': 'transfergroup', + 'id': transfergroup.pk, + 'at': transfergroup.at, + 'comment': transfergroup.comment, + 'valid_by__trigramme': ( transfergroup.valid_by and + transfergroup.valid_by.trigramme or None), + 'opes': [], + }] + for transfer in transfers: + ope_data = { + 'id': transfer.pk, + 'amount': transfer.amount, + 'from_acc': transfer.from_acc.trigramme, + 'to_acc': transfer.to_acc.trigramme, + 'canceled_by__trigramme': None, 'canceled_at': None, + } + websocket_data['opegroups'][0]['opes'].append(ope_data) + + consumers.KPsul.group_send('kfet.kpsul', websocket_data) return JsonResponse(data)