api_contact_request_test.go

package weshnet

import (
	"context"
	"testing"
	"time"

	mocknet "github.com/libp2p/go-libp2p/p2p/net/mock"
	"github.com/stretchr/testify/require"

	"berty.tech/weshnet/v2/pkg/protocoltypes"
	"berty.tech/weshnet/v2/pkg/testutil"
)

func TestShareContact(t *testing.T) {
	ctx, cancel := context.WithTimeout(context.Background(), time.Second*20)
	defer cancel()
	logger, cleanup := testutil.Logger(t)
	defer cleanup()

	opts := TestingOpts{
		Mocknet: mocknet.New(),
		Logger:  logger,
	}

	pts, cleanup := NewTestingProtocolWithMockedPeers(ctx, t, &opts, nil, 2)
	defer cleanup()

	binaryContact, err := pts[0].Client.ShareContact(ctx, &protocoltypes.ShareContact_Request{})
	require.NoError(t, err)

	// Check that ShareContact reset the contact request reference and enabled contact requests.
	contactRequestRef, err := pts[0].Client.ContactRequestReference(ctx,
		&protocoltypes.ContactRequestReference_Request{})
	require.NoError(t, err)

	require.NotEqual(t, 0, len(contactRequestRef.PublicRendezvousSeed))
	require.Equal(t, true, contactRequestRef.Enabled)

	// Decode.
	contact, err := pts[0].Client.DecodeContact(ctx, &protocoltypes.DecodeContact_Request{
		EncodedContact: binaryContact.EncodedContact,
	})
	require.NoError(t, err)

	// Check for the expected info.
	config, err := pts[0].Client.ServiceGetConfiguration(ctx,
		&protocoltypes.ServiceGetConfiguration_Request{})
	require.NoError(t, err)
	require.Equal(t, contact.Contact.Pk, config.AccountPk)
	require.Equal(t, contact.Contact.PublicRendezvousSeed, contactRequestRef.PublicRendezvousSeed)
}