Fixing vertex dependencies issue

packages/node/src/handlers.ts

@@ -32,7 +32,7 @@ export async function topologyMessagesHandler(
 
 	switch (message.type) {
 		case NetworkPb.Message_MessageType.UPDATE:
-			updateHandler(node, message.data);
+			updateHandler(node, message.data, message.sender);
 			break;
 		case NetworkPb.Message_MessageType.SYNC:
 			if (!stream) {
@@ -71,14 +71,20 @@ export async function topologyMessagesHandler(
   data: { id: string, operations: {nonce: string, fn: string, args: string[] }[] }
   operations array doesn't contain the full remote operations array
 */
-function updateHandler(node: TopologyNode, data: Uint8Array) {
+async function updateHandler(
+	node: TopologyNode,
+	data: Uint8Array,
+	senderPeerId: string,
+) {
 	const updateMessage = NetworkPb.Update.decode(data);
 	const object = node.objectStore.get(updateMessage.objectId);
 	if (!object) {
 		console.error("topology::node::updateHandler", "Object not found");
 		return false;
 	}
 
+	await node.syncObject(updateMessage.objectId, senderPeerId);
+
 	object.merge(
 		updateMessage.vertices.map((v) => {
 			return {
@@ -92,6 +98,7 @@ function updateHandler(node: TopologyNode, data: Uint8Array) {
 			};
 		}),
 	);
+
 	node.objectStore.put(object.id, object);
 
 	return true;
@@ -147,7 +154,7 @@ function syncHandler(
   data: { id: string, operations: {nonce: string, fn: string, args: string[] }[] }
   operations array contain the full remote operations array
 */
-function syncAcceptHandler(
+async function syncAcceptHandler(
 	node: TopologyNode,
 	protocol: string,
 	sender: string,
@@ -173,6 +180,7 @@ function syncAcceptHandler(
 	});
 
 	if (vertices.length !== 0) {
+		await node.syncObject(object.id, sender);
 		object.merge(vertices);
 		node.objectStore.put(object.id, object);
 	}

packages/node/src/version.ts

@@ -1 +1 @@
-export const VERSION = "0.3.0";
+export const VERSION = "0.3.1";