mirror of
https://git.anonymousland.org/anonymousland/synapse-product.git
synced 2024-12-24 22:49:29 -05:00
Remove dead code
This commit is contained in:
parent
b245ee34ed
commit
02e4c18171
@ -32,10 +32,8 @@ class BaseHandler(object):
|
|||||||
|
|
||||||
def __init__(self, hs):
|
def __init__(self, hs):
|
||||||
self.store = hs.get_datastore()
|
self.store = hs.get_datastore()
|
||||||
self.event_factory = hs.get_event_factory()
|
|
||||||
self.auth = hs.get_auth()
|
self.auth = hs.get_auth()
|
||||||
self.notifier = hs.get_notifier()
|
self.notifier = hs.get_notifier()
|
||||||
self.room_lock = hs.get_room_lock_manager()
|
|
||||||
self.state_handler = hs.get_state_handler()
|
self.state_handler = hs.get_state_handler()
|
||||||
self.distributor = hs.get_distributor()
|
self.distributor = hs.get_distributor()
|
||||||
self.ratelimiter = hs.get_ratelimiter()
|
self.ratelimiter = hs.get_ratelimiter()
|
||||||
|
@ -436,31 +436,6 @@ class SQLBaseStore(object):
|
|||||||
|
|
||||||
return self.runInteraction("_simple_max_id", func)
|
return self.runInteraction("_simple_max_id", func)
|
||||||
|
|
||||||
def _parse_event_from_row(self, row_dict):
|
|
||||||
d = copy.deepcopy({k: v for k, v in row_dict.items()})
|
|
||||||
|
|
||||||
d.pop("stream_ordering", None)
|
|
||||||
d.pop("topological_ordering", None)
|
|
||||||
d.pop("processed", None)
|
|
||||||
d["origin_server_ts"] = d.pop("ts", 0)
|
|
||||||
replaces_state = d.pop("prev_state", None)
|
|
||||||
|
|
||||||
if replaces_state:
|
|
||||||
d["replaces_state"] = replaces_state
|
|
||||||
|
|
||||||
d.update(json.loads(row_dict["unrecognized_keys"]))
|
|
||||||
d["content"] = json.loads(d["content"])
|
|
||||||
del d["unrecognized_keys"]
|
|
||||||
|
|
||||||
if "age_ts" not in d:
|
|
||||||
# For compatibility
|
|
||||||
d["age_ts"] = d.get("origin_server_ts", 0)
|
|
||||||
|
|
||||||
return self.event_factory.create_event(
|
|
||||||
etype=d["type"],
|
|
||||||
**d
|
|
||||||
)
|
|
||||||
|
|
||||||
def _get_events(self, event_ids):
|
def _get_events(self, event_ids):
|
||||||
return self.runInteraction(
|
return self.runInteraction(
|
||||||
"_get_events", self._get_events_txn, event_ids
|
"_get_events", self._get_events_txn, event_ids
|
||||||
|
Loading…
Reference in New Issue
Block a user