diff --git a/v25/storage/dbstorage.py b/v25/storage/dbstorage.py index 548a013..bc269f0 100644 --- a/v25/storage/dbstorage.py +++ b/v25/storage/dbstorage.py @@ -179,6 +179,8 @@ class DBStorage(PushStorage): session.add(msg.sgn()) self.event(session, m, EVENT_PUSH) session.commit() + if m.sfrom == m.sto: + return state = PushState.of(m.sto) with state.lock: state.pushmsg = True