diff --git a/synapse/storage/__init__.py b/synapse/storage/__init__.py
index c2560f6045..31a0022d54 100644
--- a/synapse/storage/__init__.py
+++ b/synapse/storage/__init__.py
@@ -46,7 +46,7 @@ from .signatures import SignatureStore
from syutil.base64util import decode_base64
-from synapse.crypto.event_signing import compute_pdu_event_reference_hash
+from synapse.crypto.event_signing import compute_event_reference_hash
import json
@@ -271,11 +271,10 @@ class DataStore(RoomMemberStore, RoomStore,
txn, event.event_id, prev_event_id, alg, hash_bytes
)
- # TODO
- # (ref_alg, ref_hash_bytes) = compute_pdu_event_reference_hash(pdu)
- # self._store_event_reference_hash_txn(
- # txn, event.event_id, ref_alg, ref_hash_bytes
- # )
+ (ref_alg, ref_hash_bytes) = compute_event_reference_hash(event)
+ self._store_event_reference_hash_txn(
+ txn, event.event_id, ref_alg, ref_hash_bytes
+ )
self._update_min_depth_for_room_txn(txn, event.room_id, event.depth)
diff --git a/synapse/storage/event_federation.py b/synapse/storage/event_federation.py
index 8357071db6..dcc116bad2 100644
--- a/synapse/storage/event_federation.py
+++ b/synapse/storage/event_federation.py
@@ -69,7 +69,7 @@ class EventFederationStore(SQLBaseStore):
results = []
for event_id, depth in txn.fetchall():
- hashes = self._get_prev_event_hashes_txn(txn, event_id)
+ hashes = self._get_event_reference_hashes_txn(txn, event_id)
prev_hashes = {
k: encode_base64(v) for k, v in hashes.items()
if k == "sha256"
|
