diff --git a/auth/reset.go b/auth/reset.go index a688926b93c6cb441a88ff016ba817276b6b5321..9f6114f466534efc6e27d2382d6caa71abb726f3 100644 --- a/auth/reset.go +++ b/auth/reset.go @@ -30,6 +30,8 @@ func (s *state) Reset(partner contact.Contact) (id.Round, error) { _ = s.store.DeleteSentRequest(partner.ID) _ = s.store.DeleteReceivedRequest(partner.ID) + _ = s.store.DeleteSentRequest(partner.ID) + // Try to initiate a clean session request return s.request(partner, fact.FactList{}, true) } diff --git a/auth/store/deletion.go b/auth/store/deletion.go index 677e1d02cacbe65d4c0e1b0dca22f70aefb449f2..c02e39571a3447f543b823de496781e273c1f2af 100644 --- a/auth/store/deletion.go +++ b/auth/store/deletion.go @@ -2,6 +2,7 @@ package store import ( "fmt" + "github.com/pkg/errors" jww "github.com/spf13/jwalterweatherman" "gitlab.com/xx_network/primitives/id" @@ -114,6 +115,7 @@ func (s *Store) DeleteSentRequest(partner *id.ID) error { sr.mux.Lock() s.mux.Lock() _, exist = s.sentByID[*partner] + s.srh.Delete(sr) delete(s.receivedByID, *partner) s.mux.Unlock() sr.mux.Unlock()