forked from MirrorHub/synapse
Remove unused functions
This commit is contained in:
parent
b75adaedca
commit
670dcdfc14
1 changed files with 0 additions and 42 deletions
|
@ -13,48 +13,6 @@
|
||||||
# See the License for the specific language governing permissions and
|
# See the License for the specific language governing permissions and
|
||||||
# limitations under the License.
|
# limitations under the License.
|
||||||
|
|
||||||
from twisted.internet import defer
|
|
||||||
|
|
||||||
|
|
||||||
class EventSnapshot(object):
|
|
||||||
def __init__(self, prev_events, depth, current_state,
|
|
||||||
current_state_group):
|
|
||||||
self._prev_events = prev_events
|
|
||||||
self._depth = depth
|
|
||||||
self._current_state = current_state
|
|
||||||
self._current_state_group = current_state_group
|
|
||||||
|
|
||||||
|
|
||||||
class EventCache(object):
|
|
||||||
def __init__(self, store):
|
|
||||||
self._store = store
|
|
||||||
|
|
||||||
self._cache = {}
|
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
|
||||||
def load_event(self, event_id):
|
|
||||||
event = self._cache.get(event_id, None)
|
|
||||||
|
|
||||||
if not event:
|
|
||||||
event = yield self._store.get_event(
|
|
||||||
event_id,
|
|
||||||
allow_none=True
|
|
||||||
)
|
|
||||||
|
|
||||||
if event:
|
|
||||||
self._cache[event_id] = event
|
|
||||||
|
|
||||||
defer.returnValue(event)
|
|
||||||
|
|
||||||
def load_event_from_cache(self, event_id):
|
|
||||||
return self._cache.get(event_id, None)
|
|
||||||
|
|
||||||
def add_to_cache(self, *events):
|
|
||||||
self._cache.update({
|
|
||||||
event.event_id: event
|
|
||||||
for event in events
|
|
||||||
})
|
|
||||||
|
|
||||||
|
|
||||||
class EventContext(object):
|
class EventContext(object):
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue