From 58f05fe7736ce387bb8086128bc9de32b8cd6a59 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Alejandro=20Avil=C3=A9s?= Date: Tue, 4 Nov 2014 17:42:51 +0100 Subject: [PATCH] Add simplify.py --- livesync/indico_livesync/simplify.py | 45 ++++++++++++++++++++++++++++ 1 file changed, 45 insertions(+) create mode 100644 livesync/indico_livesync/simplify.py diff --git a/livesync/indico_livesync/simplify.py b/livesync/indico_livesync/simplify.py new file mode 100644 index 0000000..347ff94 --- /dev/null +++ b/livesync/indico_livesync/simplify.py @@ -0,0 +1,45 @@ +# This file is part of Indico. +# Copyright (C) 2002 - 2014 European Organization for Nuclear Research (CERN). +# +# Indico is free software; you can redistribute it and/or +# modify it under the terms of the GNU General Public License as +# published by the Free Software Foundation; either version 3 of the +# License, or (at your option) any later version. +# +# Indico is distributed in the hope that it will be useful, but +# WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU +# General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with Indico; if not, see . + +from indico_livesync.models.queue import ChangeType + + +def process_records(records): + changes = {} + + for record in records: + if record.type != ChangeType.deleted and record.object is None: + continue + if record.type == ChangeType.created: + changes[record.obj] = ChangeType.type + elif record.type == ChangeType.deleted: + changes[record.obj] = ChangeType.type + elif record.type in {ChangeType.moved, ChangeType.protection_changed}: + changes.update(_cascade_change(record)) + elif record.type == ChangeType.title_changed: + pass + elif record.type == ChangeType.data_changed and not record.category_id: + changes[record.obj] = ChangeType.type + + for obj, state in records.iteritems(): + pass + + +def _cascade_change(record): + changes = {record.obj: record.type} + for subrecord in record.subrecords(): + changes.update(_cascade_change(subrecord)) + return changes