diff options
author | David Baker <dave@matrix.org> | 2015-12-10 17:51:15 +0000 |
---|---|---|
committer | David Baker <dave@matrix.org> | 2015-12-10 17:51:15 +0000 |
commit | aa667ee396c473f497b084655d47b2a9520a538a (patch) | |
tree | 70ebebbe67f710c164fe4dd92f5e9833777d49b0 /synapse/storage/event_actions.py | |
parent | Having consulted The Erikle, this should go at the end of on_receive_pdu, oth... (diff) | |
download | synapse-aa667ee396c473f497b084655d47b2a9520a538a.tar.xz |
Save event actions to the db
Diffstat (limited to 'synapse/storage/event_actions.py')
-rw-r--r-- | synapse/storage/event_actions.py | 41 |
1 files changed, 41 insertions, 0 deletions
diff --git a/synapse/storage/event_actions.py b/synapse/storage/event_actions.py new file mode 100644 index 0000000000..593b1714c7 --- /dev/null +++ b/synapse/storage/event_actions.py @@ -0,0 +1,41 @@ +# -*- coding: utf-8 -*- +# Copyright 2014 OpenMarket Ltd +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +from ._base import SQLBaseStore +from twisted.internet import defer + +import logging +import simplejson as json + +logger = logging.getLogger(__name__) + + +class EventActionsStore(SQLBaseStore): + @defer.inlineCallbacks + def set_actions_for_event(self, event_id, user_id, profile_tag, actions): + actionsJson = json.dumps(actions) + + ret = yield self.runInteraction( + "_set_actions_for_event", + self._simple_upsert_txn, + EventActionsTable.table_name, + {'event_id': event_id, 'user_id': user_id, 'profile_tag': profile_tag}, + {'actions': actionsJson} + ) + defer.returnValue(ret) + + +class EventActionsTable(object): + table_name = "event_actions" |