Merge branch 'main' into nm/identity-db-overhaul

dev/generate

@@ -3,6 +3,7 @@ set -e
 
 go generate ./...
 
+# Generate mocks
 mockery
 rm -rf pkg/proto/**/*.pb.go pkg/proto/**/*.pb.gw.go pkg/proto/**/*.swagger.json
 if ! buf generate https://github.com/xmtp/proto.git#branch=main,subdir=proto; then

pkg/mls/store/store.go

@@ -128,7 +128,7 @@ func (s *Store) PublishIdentityUpdate(ctx context.Context, req *identity.Publish
 			return errors.New("inbox log is full")
 		}
 
-		updates := make([]*associations.IdentityUpdate, 0, len(inboxLogEntries)+1)
+		updates := make([]*associations.IdentityUpdate, 0, len(inboxLogEntries))
 		for _, log := range inboxLogEntries {
 			identityUpdate := &associations.IdentityUpdate{}
 			if err := proto.Unmarshal(log.IdentityUpdateProto, identityUpdate); err != nil {

pkg/mls/store/store_test.go

@@ -18,6 +18,7 @@ import (
 	"github.com/xmtp/xmtp-node-go/pkg/proto/identity/associations"
 	mlsv1 "github.com/xmtp/xmtp-node-go/pkg/proto/mls/api/v1"
 	test "github.com/xmtp/xmtp-node-go/pkg/testing"
+	testutils "github.com/xmtp/xmtp-node-go/pkg/testing"
 	"github.com/xmtp/xmtp-node-go/pkg/utils"
 )
 
@@ -44,7 +45,7 @@ func TestPublishIdentityUpdateParallel(t *testing.T) {
 	// Create a mapping of inboxes to addresses
 	inboxes := make(map[string]string)
 	for i := 0; i < 50; i++ {
-		inboxes[utils.HexEncode([]byte(fmt.Sprintf("inbox_%d", i)))] = fmt.Sprintf("address_%d", i)
+		inboxes[testutils.RandomInboxId()] = fmt.Sprintf("address_%d", i)
 	}
 
 	mockMlsValidation := mocks.NewMockMLSValidationService(t)