fix: Rework the P2P integration tests

node/node.go

@@ -312,6 +312,10 @@ func (n *Node) WaitForPubSubEvent(id peer.ID) error {
 }
 
 // WaitForPushLogEvent listens to the event channel for a push log event from a given peer.
+//
+// It will block the calling thread until an event is yielded to an internal channel. This
+// event is not nessecarily the next event and is dependent on the number of concurrent callers
+// (each event will only notify a single caller, not all of them).
 func (n *Node) WaitForPushLogEvent(id peer.ID) error {
 	for {
 		select {

tests/integration/net/tcp_test.go → tests/integration/net/order/tcp_test.go

@@ -8,7 +8,7 @@
 // by the Apache License, Version 2.0, included in the file
 // licenses/APL.txt.
 
-package net
+package order
 
 import (
 	"testing"

tests/integration/net/utils.go → tests/integration/net/order/utils.go

@@ -8,7 +8,7 @@
 // by the Apache License, Version 2.0, included in the file
 // licenses/APL.txt.
 
-package net
+package order
 
 import (
 	"context"
@@ -220,7 +220,7 @@ func executeTestCase(t *testing.T, test P2PTestCase) {
 		require.NoError(t, err)
 
 		if i == 0 {
-			dockeys = append(dockeys, d...)
+			dockeys = d
 		}
 		nodes = append(nodes, n)
 	}

tests/integration/net/state/peer/with_create_test.go

@@ -0,0 +1,64 @@
+// Copyright 2022 Democratized Data Foundation
+//
+// Use of this software is governed by the Business Source License
+// included in the file licenses/BSL.txt.
+//
+// As of the Change Date specified in that file, in accordance with
+// the Business Source License, use of this software will be governed
+// by the Apache License, Version 2.0, included in the file
+// licenses/APL.txt.
+
+package peer_test
+
+import (
+	"testing"
+
+	"github.com/sourcenetwork/defradb/config"
+	testUtils "github.com/sourcenetwork/defradb/tests/integration/net/state"
+)
+
+func TestP2PCreateDoesNotSync(t *testing.T) {
+	test := testUtils.P2PTestCase{
+		NodeConfig: []*config.Config{
+			testUtils.RandomNetworkingConfig(),
+			testUtils.RandomNetworkingConfig(),
+		},
+		NodePeers: map[int][]int{
+			1: {
+				0,
+			},
+		},
+		SeedDocuments: map[int]string{
+			0: `{
+				"Name": "Shahzad",
+				"Age": 300
+			}`,
+		},
+		Creates: map[int]map[int]string{
+			0: {
+				1: `{
+					"Name": "John",
+					"Age": 21
+				}`,
+			},
+		},
+		Results: map[int]map[int]map[string]any{
+			0: {
+				0: {
+					"Age": uint64(300),
+				},
+				1: {
+					"Age": uint64(21),
+				},
+			},
+			1: {
+				0: {
+					"Age": uint64(300),
+				},
+				// Peer sync should not sync new documents to nodes
+			},
+		},
+	}
+
+	testUtils.ExecuteTestCase(t, test)
+}