Skip to content
Snippets Groups Projects
Select Git revision
  • e4fb4e450ecab05d276e358d2b518152c2429062
  • release default protected
  • 11-22-implement-kv-interface-defined-in-collectiveversionedkvgo
  • hotfix/TestHostPool_UpdateNdf_AddFilter
  • XX-4719/announcementChannels
  • xx-4717/logLevel
  • jonah/noob-channel
  • master protected
  • XX-4707/tagDiskJson
  • xx-4698/notification-retry
  • hotfix/notifylockup
  • syncNodes
  • hotfix/localCB
  • XX-4677/NewChanManagerMobile
  • XX-4689/DmSync
  • duplicatePrefix
  • XX-4601/HavenInvites
  • finalizedUICallbacks
  • XX-4673/AdminKeySync
  • debugNotifID
  • anne/test
  • v4.7.5
  • v4.7.4
  • v4.7.3
  • v4.7.2
  • v4.7.1
  • v4.6.3
  • v4.6.1
  • v4.5.0
  • v4.4.4
  • v4.3.11
  • v4.3.8
  • v4.3.7
  • v4.3.6
  • v4.3.5
  • v4.2.0
  • v4.3.0
  • v4.3.4
  • v4.3.3
  • v4.3.2
  • v4.3.1
41 results

receiver_test.go

Blame
    • store_test.go 28.00 KiB 
    ////////////////////////////////////////////////////////////////////////////////
// Copyright © 2022 xx foundation                                             //
//                                                                            //
// Use of this source code is governed by a license that can be found in the  //
// LICENSE file.                                                              //
////////////////////////////////////////////////////////////////////////////////

package store

import (
	"bytes"
	"io"
	"math/rand"
	"reflect"
	"sort"
	"testing"

	"github.com/cloudflare/circl/dh/sidh"
	"gitlab.com/elixxir/client/cmix/rounds"
	sidhinterface "gitlab.com/elixxir/client/interfaces/sidh"
	util "gitlab.com/elixxir/client/storage/utility"
	"gitlab.com/elixxir/client/storage/versioned"
	"gitlab.com/elixxir/comms/mixmessages"
	"gitlab.com/elixxir/crypto/contact"
	"gitlab.com/elixxir/crypto/cyclic"
	"gitlab.com/elixxir/crypto/e2e/auth"
	"gitlab.com/elixxir/ekv"
	"gitlab.com/elixxir/primitives/format"
	"gitlab.com/elixxir/primitives/states"
	"gitlab.com/xx_network/comms/connect"
	"gitlab.com/xx_network/crypto/csprng"
	"gitlab.com/xx_network/crypto/large"
	"gitlab.com/xx_network/primitives/id"
	"gitlab.com/xx_network/primitives/netTime"
)

type mockSentRequestHandler struct{}

func (msrh *mockSentRequestHandler) Add(sr *SentRequest)    {}
func (msrh *mockSentRequestHandler) Delete(sr *SentRequest) {}

// Happy path.
func TestNewOrLoadStore(t *testing.T) {
	kv := versioned.NewKV(ekv.MakeMemstore())
	grp := cyclic.NewGroup(large.NewInt(173), large.NewInt(2))

	_, err := NewOrLoadStore(kv, grp, &mockSentRequestHandler{})
	if err != nil {
		t.Errorf("NewStore() returned an error: %+v", err)
	}
}

// Happy path.
func TestLoadStore(t *testing.T) {
	rng := csprng.NewSystemRNG()

	// Create a random storage object + keys
	s, kv := makeTestStore(t)

	// Generate random contact information and add it to the store
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	_, sidhPubKey := genSidhAKeys(rng)
	r := makeTestRound(t)
	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}

	// Create a sent request object and add it to the store
	privSidh, pubSidh := genSidhAKeys(rng)
	var sr *SentRequest
    	var err error
	if sr, err = s.AddSent(id.NewIdFromUInt(rand.Uint64(), id.User, t), s.grp.NewInt(5), s.grp.NewInt(6),
		s.grp.NewInt(7), privSidh, pubSidh,
		format.Fingerprint{42}, false); err != nil {
		t.Fatalf("AddSent() produced an error: %+v", err)
	}

	s.CheckIfNegotiationIsNew(
		sr.partner, auth.CreateNegotiationFingerprint(sr.myPrivKey, sidhPubKey))

	err = s.save()
	if err != nil {
		t.Errorf("Failed to save: %+v", err)
	}

	// Attempt to load the store
	store, err := NewOrLoadStore(kv, s.grp, &mockSentRequestHandler{})
	if err != nil {
		t.Errorf("LoadStore() returned an error: %+v", err)
	}

	srLoaded, ok := store.sentByID[*sr.partner]
	if !ok {
		t.Error("Sent request could not be found")
	}

	if sr.myPrivKey == srLoaded.myPrivKey && sr.mySidHPrivKeyA == srLoaded.mySidHPrivKeyA && sr.mySidHPubKeyA == srLoaded.mySidHPubKeyA && sr.fingerprint == srLoaded.fingerprint && sr.partnerHistoricalPubKey == sr.partnerHistoricalPubKey {
		t.Errorf("GetReceivedRequest() returned incorrect send req."+
			"\n\texpected: %+v\n\treceived: %+v", sr, srLoaded)
	}

	if s.receivedByID[*c.ID] == nil {
		t.Errorf("AddSent() failed to add request to map for "+
			"partner ID %s.", c.ID)
	}
}

// Happy path: tests that the correct SentRequest is added to the map.
func TestStore_AddSent(t *testing.T) {
	rng := csprng.NewSystemRNG()
	s, _ := makeTestStore(t)

	sidhPrivKey, sidhPubKey := genSidhAKeys(rng)

	partner := id.NewIdFromUInt(rand.Uint64(), id.User, t)

	var sr *SentRequest
	sr, err := s.AddSent(partner, s.grp.NewInt(5), s.grp.NewInt(6),
		s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
		format.Fingerprint{42}, false)
	if err != nil {
		t.Errorf("AddSent() produced an error: %+v", err)
	}

	if s.sentByID[*partner] == nil {
		t.Errorf("AddSent() failed to add request to map for "+
			"partner ID %s.", partner)
	} else if !reflect.DeepEqual(sr, s.sentByID[*partner]) {
		t.Errorf("AddSent() failed store the correct SentRequest."+
			"\n\texpected: %+v\n\treceived: %+v",
			sr, s.sentByID[*partner])
	}

	if _, exists := s.sentByID[*sr.partner]; !exists {
		t.Errorf("AddSent() failed to add fingerprint to map for "+
			"fingerprint %s.", sr.fingerprint)
	} else if !reflect.DeepEqual(sr,
		s.sentByID[*sr.partner]) {
		t.Errorf("AddSent() failed store the correct fingerprint."+
			"\n\texpected: %+v\n\treceived: %+v",
    			sr, s.sentByID[*sr.partner])
	}
}

// // Error path: request with request already exists in map.
// func TestStore_AddSent_PartnerAlreadyExistsError(t *testing.T) {
// 	s, _ := makeTestStore(t)

// 	rng := csprng.NewSystemRNG()
// 	sidhPrivKey, sidhPubKey := genSidhAKeys(rng)

// 	partner := id.NewIdFromUInt(rand.Uint64(), id.User, t)

// 	_, err := s.AddSent(partner, s.grp.NewInt(5), s.grp.NewInt(6),
// 		s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
// 		format.Fingerprint{42}, true)
// 	if err != nil {
// 		t.Errorf("AddSent() produced an error: %+v", err)
// 	}

// 	_, err = s.AddSent(partner, s.grp.NewInt(5), s.grp.NewInt(6),
// 		s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
// 		format.Fingerprint{42}, true)
// 	if err == nil {
// 		t.Errorf("AddSent() did not produce the expected error for " +
// 			"a request that already exists.")
// 	}
// }

// Happy path.
func TestStore_AddReceived(t *testing.T) {
	s, _ := makeTestStore(t)

	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	r := makeTestRound(t)

	err := s.AddReceived(c, sidhPubKey, r)
	if err != nil {
		t.Errorf("AddReceived() returned an error: %+v", err)
	}

	if s.receivedByID[*c.ID] == nil {
		t.Errorf("AddReceived() failed to add request to map for "+
			"partner ID %s.", c.ID)
	} else if !reflect.DeepEqual(r, s.receivedByID[*c.ID].round) {
		t.Errorf("AddReceived() failed store the correct round."+
			"\n\texpected: %+v\n\treceived: %+v", r, s.receivedByID[*c.ID].round)
	}
}

// Error path: request with request already exists in map.
func TestStore_AddReceived_PartnerAlreadyExistsError(t *testing.T) {
	s, _ := makeTestStore(t)
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}

	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	r := makeTestRound(t)

	err := s.AddReceived(c, sidhPubKey, r)
	if err != nil {
		t.Errorf("AddReceived() returned an error: %+v", err)
	}

	err = s.AddReceived(c, sidhPubKey, r)
	if err == nil {
    		t.Errorf("AddReceived() did not produce the expected error " +
			"for a request that already exists.")
	}
}

// Happy path.
func TestStore_GetReceivedRequest(t *testing.T) {
	s, _ := makeTestStore(t)
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	r := makeTestRound(t)

	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}

	testC, err := s.GetReceivedRequest(c.ID)
	if err != nil {
		t.Errorf("GetReceivedRequest() returned an error: %+v", err)
	}

	if !reflect.DeepEqual(c, testC) {
		t.Errorf("GetReceivedRequest() returned incorrect Contact."+
			"\n\texpected: %+v\n\treceived: %+v", c, testC)
	}

	keyBytes := make([]byte, sidhinterface.PubKeyByteSize)
	sidhPubKey.Export(keyBytes)
	expKeyBytes := make([]byte, sidhinterface.PubKeyByteSize)
	s.receivedByID[*c.ID].theirSidHPubKeyA.Export(expKeyBytes)
	if !reflect.DeepEqual(keyBytes, expKeyBytes) {
		t.Errorf("GetReceivedRequest did not send proper sidh bytes")
	}
}

// Error path: request is deleted between first and second check.
func TestStore_GetReceivedRequest_RequestDeleted(t *testing.T) {
	s, _ := makeTestStore(t)
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	r := makeTestRound(t)

	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}

	rr := s.receivedByID[*c.ID]
	rr.mux.Lock()

	delete(s.receivedByID, *c.ID)
	rr.mux.Unlock()

	testC, err := s.GetReceivedRequest(c.ID)
	if err == nil {
		t.Errorf("GetReceivedRequest() did not return an error " +
			"when the request should not exist.")
	}

	if !reflect.DeepEqual(contact.Contact{}, testC) {
		t.Errorf("GetReceivedRequest() returned incorrect Contact."+
			"\n\texpected: %+v\n\treceived: %+v", contact.Contact{},
			testC)
	}

	// Check if the request's mutex is locked
	if reflect.ValueOf(&rr.mux).Elem().FieldByName("state").Int() != 0 {
    		t.Errorf("GetReceivedRequest() did not unlock mutex.")
	}
}

// Error path: request does not exist.
func TestStore_GetReceivedRequest_RequestNotInMap(t *testing.T) {
	s, _ := makeTestStore(t)

	testC, err := s.GetReceivedRequest(
		id.NewIdFromUInt(rand.Uint64(),
			id.User, t))
	if err == nil {
		t.Errorf("GetReceivedRequest() did not return an error " +
			"when the request should not exist.")
	}

	if !reflect.DeepEqual(contact.Contact{}, testC) {
		t.Errorf("GetReceivedRequest() returned incorrect Contact."+
			"\n\texpected: %+v\n\treceived: %+v", contact.Contact{},
			testC)
	}
}

// Happy path.
func TestStore_GetReceivedRequestData(t *testing.T) {
	s, _ := makeTestStore(t)
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	r := makeTestRound(t)

	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}

	testC, err := s.GetReceivedRequest(c.ID)
	if err != nil {
		t.Errorf("GetReceivedRequestData() returned an error: %+v", err)
	}

	if !reflect.DeepEqual(c, testC) {
		t.Errorf("GetReceivedRequestData() returned incorrect Contact."+
			"\n\texpected: %+v\n\treceived: %+v", c, testC)
	}
}

// Error path: request does not exist.
func TestStore_GetReceivedRequestData_RequestNotInMap(t *testing.T) {
	s, _ := makeTestStore(t)

	testC, err := s.GetReceivedRequest(id.NewIdFromUInt(
		rand.Uint64(),
		id.User, t))
	if err == nil {
		t.Errorf("GetReceivedRequestData() did not return an error " +
			"when the request should not exist.")
	}

	if !reflect.DeepEqual(contact.Contact{}, testC) {
		t.Errorf("GetReceivedRequestData() returned incorrect Contact."+
			"\n\texpected: %+v\n\treceived: %+v", contact.Contact{},
			testC)
	}
}

// Happy path: request is of type Receive.
func TestStore_GetRequest_ReceiveRequest(t *testing.T) {
	s, _ := makeTestStore(t)
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
    	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	r := makeTestRound(t)

	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}

	con, err := s.GetReceivedRequest(c.ID)
	if err != nil {
		t.Errorf("GetRequest() returned an error: %+v", err)
	}
	if !reflect.DeepEqual(c, con) {
		t.Errorf("GetRequest() returned incorrect Contact."+
			"\n\texpected: %+v\n\treceived: %+v", c, con)
	}
}

//
//// Happy path: request is of type Sent.
//func TestStore_GetRequest_SentRequest(t *testing.T) {
//	s, _ := makeTestStore(t)
//	partnerID := id.NewIdFromUInt(rand.Uint64(), id.User, t)
//	rng := csprng.NewSystemRNG()
//	sidhPrivKey, sidhPubKey := genSidhAKeys(rng)
//
//	var sr *SentRequest
//	var err error
//	if sr, err = s.AddSent(partnerID, s.grp.NewInt(5), s.grp.NewInt(6),
//		s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
//		format.Fingerprint{42}, false); err != nil {
//		t.Fatalf("AddSent() returned an error: %+v", err)
//	}
//
//	rType, request, con, err := s.GetRequest(sr.partner)
//	if err != nil {
//		t.Errorf("GetRequest() returned an error: %+v", err)
//	}
//	if rType != Sent {
//		t.Errorf("GetRequest() returned incorrect RequestType."+
//			"\n\texpected: %d\n\treceived: %d", Sent, rType)
//	}
//	if !reflect.DeepEqual(sr, request) {
//		t.Errorf("GetRequest() returned incorrect SentRequest."+
//			"\n\texpected: %+v\n\treceived: %+v", sr, request)
//	}
//	if !reflect.DeepEqual(contact.Contact{}, con) {
//		t.Errorf("GetRequest() returned incorrect Contact."+
//			"\n\texpected: %+v\n\treceived: %+v", contact.Contact{},
//			con)
//	}
//}
//
//// Error path: request type is invalid.
//func TestStore_GetRequest_InvalidType(t *testing.T) {
//	s, _, _ := makeTestStore(t)
//	uid := id.NewIdFromUInt(rand.Uint64(), id.User, t)
//	s.receivedByID[*uid] = &ReceivedRequest{rt: 42}
//
//	rType, request, con, err := s.GetRequest(uid)
//	if err == nil {
//		t.Errorf("GetRequest() did not return an error " +
//			"when the request type should be invalid.")
//	}
//	if rType != 0 {
//		t.Errorf("GetRequest() returned incorrect RequestType."+
//			"\n\texpected: %d\n\treceived: %d", 0, rType)
//	}
//	if request != nil {
    //		t.Errorf("GetRequest() returned incorrect SentRequest."+
//			"\n\texpected: %+v\n\treceived: %+v", nil, request)
//	}
//	if !reflect.DeepEqual(contact.Contact{}, con) {
//		t.Errorf("GetRequest() returned incorrect Contact."+
//			"\n\texpected: %+v\n\treceived: %+v", contact.Contact{},
//			con)
//	}
//}

// Error path: request does not exist in map.
func TestStore_GetRequest_RequestNotInMap(t *testing.T) {
	s, _ := makeTestStore(t)
	uid := id.NewIdFromUInt(rand.Uint64(), id.User, t)

	con, err := s.GetReceivedRequest(uid)
	if err == nil {
		t.Errorf("GetRequest() did not return an error " +
			"when the request was not in the map.")
	}
	if !reflect.DeepEqual(contact.Contact{}, con) {
		t.Errorf("GetRequest() returned incorrect Contact."+
			"\n\texpected: %+v\n\treceived: %+v", contact.Contact{},
			con)
	}
}

// Happy path.
//func TestStore_Fail(t *testing.T) {
//	s, _ := makeTestStore(t)
//	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
//	rng := csprng.NewSystemRNG()
//	_, sidhPubKey := genSidhAKeys(rng)
//
//  r := makeTestRound()
//
//	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
//		t.Fatalf("AddReceived() returned an error: %+v", err)
//	}
//	if _, err := s.GetReceivedRequest(c.ID); err != nil {
//		t.Fatalf("GetReceivedRequest() returned an error: %+v", err)
//	}
//
//	defer func() {
//		if r := recover(); r != nil {
//			t.Errorf("The code did not panic")
//		}
//	}()
//
//	s.Done(c.ID)
//
//	// Check if the request's mutex is locked
//	if reflect.ValueOf(&s.receivedByID[*c.ID].mux).Elem().FieldByName(
//		"state").Int() != 0 {
//		t.Errorf("Done() did not unlock mutex.")
//	}
//}

// Error path: request does not exist.
//func TestStore_Fail_RequestNotInMap(t *testing.T) {
//	s,, _ := makeTestStore(t)
//
//	defer func() {
//		if r := recover(); r == nil {
//			t.Errorf("Done() did not panic when the " +
//				"request is not in map.")
//		}
//	}()
//
//	s.Done(id.NewIdFromUInt(rand.Uint64(), id.User, t))
    //}

// Happy path: partner request.
func TestStore_Delete_ReceiveRequest(t *testing.T) {
	s, _ := makeTestStore(t)
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	r := makeTestRound(t)

	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}
	if _, err := s.GetReceivedRequest(c.ID); err != nil {
		t.Fatalf("GetReceivedRequest() returned an error: %+v", err)
	}

	err := s.DeleteRequest(c.ID)
	if err != nil {
		t.Errorf("delete() returned an error: %+v", err)
	}

	if s.receivedByID[*c.ID] != nil {
		t.Errorf("delete() failed to delete request for user %s.", c.ID)
	}
}

// Happy path: sent request.
func TestStore_Delete_SentRequest(t *testing.T) {
	s, _ := makeTestStore(t)
	partnerID := id.NewIdFromUInt(rand.Uint64(), id.User, t)
	rng := csprng.NewSystemRNG()
	sidhPrivKey, sidhPubKey := genSidhAKeys(rng)
	sr := &SentRequest{
		kv:                      s.kv,
		partner:                 partnerID,
		partnerHistoricalPubKey: s.grp.NewInt(1),
		myPrivKey:               s.grp.NewInt(2),
		myPubKey:                s.grp.NewInt(3),
		mySidHPrivKeyA:          sidhPrivKey,
		mySidHPubKeyA:           sidhPubKey,
		fingerprint:             format.Fingerprint{5},
	}
	if _, err := s.AddSent(sr.partner, s.grp.NewInt(5), s.grp.NewInt(6),
		s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
		format.Fingerprint{42}, false); err != nil {
		t.Fatalf("AddSent() returned an error: %+v", err)
	}

	//if _, _, _, err := s.GetFingerprint(sr.fingerprint); err != nil {  // TODO legacy
	//	t.Fatalf("GetFingerprint() returned an error: %+v", err)
	//}

	err := s.DeleteRequest(sr.partner)
	if err != nil {
		t.Errorf("delete() returned an error: %+v", err)
	}

	if s.receivedByID[*sr.partner] != nil {
		t.Errorf("delete() failed to delete request for user %s.",
			sr.partner)
	}

	if _, exists := s.sentByID[*sr.partner]; exists {
		t.Errorf("delete() failed to delete fingerprint for fp %v.",
			sr.fingerprint)
	}
}

    // Error path: request does not exist.
func TestStore_Delete_RequestNotInMap(t *testing.T) {
	s, _ := makeTestStore(t)

	err := s.DeleteRequest(id.NewIdFromUInt(rand.Uint64(), id.User, t))
	if err == nil {
		t.Errorf("delete() did not return an error when the request " +
			"was not in the map.")
	}
}

// Unit test of Store.GetAllReceived.
func TestStore_GetAllReceived(t *testing.T) {
	s, _ := makeTestStore(t)
	numReceived := 10

	expectContactList := make([]contact.Contact, 0, numReceived)
	// Add multiple received contact receivedByID
	for i := 0; i < numReceived; i++ {
		c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
		rng := csprng.NewSystemRNG()
		_, sidhPubKey := genSidhAKeys(rng)

		r := makeTestRound(t)

		if err := s.AddReceived(c, sidhPubKey, r); err != nil {
			t.Fatalf("AddReceived() returned an error: %+v", err)
		}

		expectContactList = append(expectContactList, c)
	}

	// Check that GetAllReceived returns all contacts
	receivedRequestList := s.GetAllReceivedRequests()
	var receivedContactList = make([]contact.Contact, len(receivedRequestList))
	for i, req := range receivedRequestList {
		receivedContactList[i] = req.GetContact()
	}

	if len(receivedContactList) != numReceived {
		t.Errorf("GetAllReceived did not return expected amount of contacts."+
			"\nExpected: %d"+
			"\nReceived: %d", numReceived, len(receivedContactList))
	}

	// Sort expected and received lists so that they are in the same order
	// since extraction from a map does not maintain order
	sort.Slice(expectContactList, func(i, j int) bool {
		return bytes.Compare(expectContactList[i].ID.Bytes(), expectContactList[j].ID.Bytes()) == -1
	})
	sort.Slice(receivedContactList, func(i, j int) bool {
		return bytes.Compare(receivedContactList[i].ID.Bytes(), receivedContactList[j].ID.Bytes()) == -1
	})

	// Check validity of contacts
	if !reflect.DeepEqual(expectContactList, receivedContactList) {
		t.Errorf("GetAllReceived did not return expected contact list."+
			"\nExpected: %+v"+
			"\nReceived: %+v", expectContactList, receivedContactList)
	}

}

// Tests that Store.GetAllReceived returns an empty list when there are no
// received receivedByID.
func TestStore_GetAllReceived_EmptyList(t *testing.T) {
	s, _ := makeTestStore(t)

	// Check that GetAllReceived returns all contacts
	receivedContactList := s.GetAllReceivedRequests()
    	if len(receivedContactList) != 0 {
		t.Errorf("GetAllReceived did not return expected amount of contacts."+
			"\nExpected: %d"+
			"\nReceived: %d", 0, len(receivedContactList))
	}

	// Add Sent and Receive receivedByID
	for i := 0; i < 10; i++ {
		partnerID := id.NewIdFromUInt(rand.Uint64(), id.User, t)
		rng := csprng.NewSystemRNG()
		sidhPrivKey, sidhPubKey := genSidhAKeys(rng)
		if _, err := s.AddSent(partnerID, s.grp.NewInt(5), s.grp.NewInt(6),
			s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
			format.Fingerprint{42}, false); err != nil {
			t.Fatalf("AddSent() returned an error: %+v", err)
		}
	}

	// Check that GetAllReceived returns all contacts
	receivedContactList = s.GetAllReceivedRequests()
	if len(receivedContactList) != 0 {
		t.Errorf("GetAllReceived did not return expected amount of contacts. "+
			"It may be pulling from Sent Requests."+
			"\nExpected: %d"+
			"\nReceived: %d", 0, len(receivedContactList))
	}

}

// Tests that Store.GetAllReceived returns only Sent receivedByID when there
// are both Sent and Receive receivedByID in Store.
func TestStore_GetAllReceived_MixSentReceived(t *testing.T) {
	s, _ := makeTestStore(t)
	numReceived := 10

	// Add multiple received contact receivedByID
	for i := 0; i < numReceived; i++ {
		// Add received request
		c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
		rng := csprng.NewSystemRNG()
		_, sidhPubKey := genSidhAKeys(rng)

		r := makeTestRound(t)

		if err := s.AddReceived(c, sidhPubKey, r); err != nil {
			t.Fatalf("AddReceived() returned an error: %+v", err)
		}

		// Add sent request
		partnerID := id.NewIdFromUInt(rand.Uint64(), id.User, t)
		sidhPrivKey, sidhPubKey := genSidhAKeys(rng)
		if _, err := s.AddSent(partnerID, s.grp.NewInt(5), s.grp.NewInt(6),
			s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
			format.Fingerprint{42}, false); err != nil {
			t.Fatalf("AddSent() returned an error: %+v", err)
		}
	}

	// Check that GetAllReceived returns all contacts
	receivedContactList := s.GetAllReceivedRequests()
	if len(receivedContactList) != numReceived {
		t.Errorf("GetAllReceived did not return expected amount of contacts. "+
			"It may be pulling from Sent Requests."+
			"\nExpected: %d"+
			"\nReceived: %d", numReceived, len(receivedContactList))
	}

}

// Error case: Call DeleteRequest on a request that does
    // not exist.
func TestStore_DeleteRequest_NonexistantRequest(t *testing.T) {
	s, _ := makeTestStore(t)
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	r := makeTestRound(t)

	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}
	if _, err := s.GetReceivedRequest(c.ID); err != nil {
		t.Fatalf("GetReceivedRequest() returned an error: %+v", err)
	}

	err := s.DeleteRequest(c.ID)
	if err != nil {
		t.Errorf("DeleteRequest should return an error " +
			"when trying to delete a partner request")
	}

}

// Unit test.
func TestStore_DeleteReceiveRequests(t *testing.T) {
	s, _ := makeTestStore(t)
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	r := makeTestRound(t)

	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}
	if _, err := s.GetReceivedRequest(c.ID); err != nil {
		t.Fatalf("GetReceivedRequest() returned an error: %+v", err)
	}

	err := s.DeleteReceiveRequests()
	if err != nil {
		t.Fatalf("DeleteReceiveRequests returned an error: %+v", err)
	}

	if s.receivedByID[*c.ID] != nil {
		t.Errorf("delete() failed to delete request for user %s.", c.ID)
	}
}

// Unit test.
func TestStore_DeleteSentRequests(t *testing.T) {
	s, _ := makeTestStore(t)
	partnerID := id.NewIdFromUInt(rand.Uint64(), id.User, t)
	rng := csprng.NewSystemRNG()
	sidhPrivKey, sidhPubKey := genSidhAKeys(rng)
	var sr *SentRequest
	var err error
	if sr, err = s.AddSent(partnerID, s.grp.NewInt(5), s.grp.NewInt(6),
		s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
		format.Fingerprint{42}, false); err != nil {
		t.Fatalf("AddSent() returned an error: %+v", err)
	}

	err = s.DeleteSentRequests()
	if err != nil {
		t.Fatalf("DeleteSentRequests returned an error: %+v", err)
	}

	if s.receivedByID[*sr.partner] != nil {
    		t.Errorf("delete() failed to delete request for user %s.",
			sr.partner)
	}

	if _, exists := s.sentByID[*sr.partner]; exists {
		t.Errorf("delete() failed to delete fingerprint for fp %v.",
			sr.fingerprint)
	}
}

// Tests that DeleteSentRequests does not affect partner receivedByID in map
func TestStore_DeleteSentRequests_ReceiveInMap(t *testing.T) {
	s, _ := makeTestStore(t)
	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	rng := csprng.NewSystemRNG()
	_, sidhPubKey := genSidhAKeys(rng)

	r := makeTestRound(t)

	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}

	err := s.DeleteSentRequests()
	if err != nil {
		t.Fatalf("DeleteSentRequests returned an error: %+v", err)
	}

	if s.receivedByID[*c.ID] == nil {
		t.Fatalf("DeleteSentRequests removes partner receivedByID!")
	}

}

// Tests that DeleteReceiveRequests does not affect sentByID in map
func TestStore_DeleteReceiveRequests_SentInMap(t *testing.T) {
	s, _ := makeTestStore(t)
	partnerID := id.NewIdFromUInt(rand.Uint64(), id.User, t)
	rng := csprng.NewSystemRNG()
	sidhPrivKey, sidhPubKey := genSidhAKeys(rng)
	var err error
	if _, err = s.AddSent(partnerID, s.grp.NewInt(5), s.grp.NewInt(6),
		s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
		format.Fingerprint{42}, false); err != nil {
		t.Fatalf("AddSent() returned an error: %+v", err)
	}

	err = s.DeleteReceiveRequests()
	if err != nil {
		t.Fatalf("DeleteSentRequests returned an error: %+v", err)
	}

	if s.sentByID[*partnerID] == nil {
		t.Fatalf("DeleteReceiveRequests removes sent receivedByID!")
	}

}

// Unit test.
func TestStore_DeleteAllRequests(t *testing.T) {
	s, _ := makeTestStore(t)
	partnerID := id.NewIdFromUInt(rand.Uint64(), id.User, t)
	rng := csprng.NewSystemRNG()
	sidhPrivKey, sidhPubKey := genSidhAKeys(rng)
	var sr *SentRequest
	var err error
	if sr, err = s.AddSent(partnerID, s.grp.NewInt(5), s.grp.NewInt(6),
		s.grp.NewInt(7), sidhPrivKey, sidhPubKey,
		format.Fingerprint{42}, false); err != nil {
		t.Fatalf("AddSent() returned an error: %+v", err)
    	}

	c := contact.Contact{ID: id.NewIdFromUInt(rand.Uint64(), id.User, t)}
	_, sidhPubKey = genSidhAKeys(rng)
	r := makeTestRound(t)
	if err := s.AddReceived(c, sidhPubKey, r); err != nil {
		t.Fatalf("AddReceived() returned an error: %+v", err)
	}

	err = s.DeleteAllRequests()
	if err != nil {
		t.Fatalf("DeleteAllRequests returned an error: %+v", err)
	}

	if s.receivedByID[*sr.partner] != nil {
		t.Errorf("delete() failed to delete request for user %s.",
			sr.partner)
	}

	if _, exists := s.sentByID[*sr.partner]; exists {
		t.Errorf("delete() failed to delete fingerprint for fp %v.",
			sr.fingerprint)
	}

	if s.receivedByID[*c.ID] != nil {
		t.Errorf("delete() failed to delete request for user %s.", c.ID)
	}

}

func makeTestStore(t *testing.T) (*Store, *versioned.KV) {
	kv := versioned.NewKV(ekv.MakeMemstore())
	grp := cyclic.NewGroup(large.NewInt(173), large.NewInt(0))

	store, err := NewOrLoadStore(kv, grp, &mockSentRequestHandler{})
	if err != nil {
		t.Fatalf("Failed to create new Store: %+v", err)
	}

	return store, kv
}

func genSidhAKeys(rng io.Reader) (*sidh.PrivateKey, *sidh.PublicKey) {
	sidHPrivKeyA := util.NewSIDHPrivateKey(sidh.KeyVariantSidhA)
	sidHPubKeyA := util.NewSIDHPublicKey(sidh.KeyVariantSidhA)

	if err := sidHPrivKeyA.Generate(rng); err != nil {
		panic("failure to generate SidH A private key")
	}
	sidHPrivKeyA.GeneratePublicKey(sidHPubKeyA)

	return sidHPrivKeyA, sidHPubKeyA
}

func genSidhBKeys(rng io.Reader) (*sidh.PrivateKey, *sidh.PublicKey) {
	sidHPrivKeyB := util.NewSIDHPrivateKey(sidh.KeyVariantSidhB)
	sidHPubKeyB := util.NewSIDHPublicKey(sidh.KeyVariantSidhB)

	if err := sidHPrivKeyB.Generate(rng); err != nil {
		panic("failure to generate SidH A private key")
	}
	sidHPrivKeyB.GeneratePublicKey(sidHPubKeyB)

	return sidHPrivKeyB, sidHPubKeyB
}

func makeTestRound(t *testing.T) rounds.Round {
	nids := []*id.ID{
		id.NewIdFromString("one", id.User, t),
		id.NewIdFromString("two", id.User, t),
    		id.NewIdFromString("three", id.User, t)}
	r := rounds.Round{
		ID:               2,
		State:            states.REALTIME,
		Topology:         connect.NewCircuit(nids),
		Timestamps:       nil,
		Errors:           nil,
		BatchSize:        0,
		AddressSpaceSize: 0,
		UpdateID:         0,
		Raw: &mixmessages.RoundInfo{
			ID:                         5,
			UpdateID:                   0,
			State:                      2,
			BatchSize:                  5,
			Topology:                   [][]byte{[]byte("one"), []byte("two")},
			Timestamps:                 []uint64{uint64(netTime.Now().UnixNano()), uint64(netTime.Now().UnixNano())},
			Errors:                     nil,
			ClientErrors:               nil,
			ResourceQueueTimeoutMillis: 0,
			Signature:                  nil,
			AddressSpaceSize:           0,
			EccSignature:               nil,
		},
	}
	return r
}