feat: update version to 0.5.1 and enhance connection validation logic for data type compatibility

Author: trkbt10

package.json

@@ -1,6 +1,6 @@
 {
   "name": "react-wireflow",
-  "version": "0.5.0",
+  "version": "0.5.1",
   "type": "module",
   "main": "dist/index.cjs",
   "module": "dist/index.js",

src/core/connection/validation.spec.ts

@@ -252,6 +252,58 @@ describe("canConnectPorts - data type compatibility", () => {
     const inPort: Port = { id: "in", nodeId: "b", type: "input", label: "in", position: "left", dataType: "json" };
     expect(canConnectPorts(outPort, inPort, defA, defB)).toBe(true);
   });
+
+  it("uses port dataType when multiple definitions share same id (instances pattern)", () => {
+    // Simulates a node with multiple PortDefinitions that share the same id
+    // but have different dataTypes, selected via `instances` function.
+    // Example: artifact-io with scope-out having typed-object, object, string, binary variants
+    const defWithMultipleSameIdPorts = baseNodeDef("ArtifactIO", [
+      { id: "scope-out", type: "output", label: "Scope (Typed Object)", position: "right", dataType: "typed-object", instances: () => 0 },
+      { id: "scope-out", type: "output", label: "Scope (Object)", position: "right", dataType: "object", instances: () => 0 },
+      { id: "scope-out", type: "output", label: "Scope (String)", position: "right", dataType: "string", instances: () => 1 }, // Active one
+      { id: "scope-out", type: "output", label: "Scope (Binary)", position: "right", dataType: "binary", instances: () => 0 },
+    ]);
+    const defConsumer = baseNodeDef("Consumer", [
+      { id: "in", type: "input", label: "in", position: "left", dataType: "string" },
+    ]);
+
+    // The derived Port has dataType: "string" from the active definition
+    const derivedPort: Port = {
+      id: "scope-out",
+      definitionId: "scope-out",
+      nodeId: "artifact",
+      type: "output",
+      label: "Scope (String)",
+      position: "right",
+      dataType: "string", // Set during port derivation from active PortDefinition
+    };
+    const consumerPort: Port = {
+      id: "in",
+      nodeId: "consumer",
+      type: "input",
+      label: "in",
+      position: "left",
+      dataType: "string",
+    };
+
+    // Should connect because Port.dataType is "string" (not "typed-object" from first matching definition)
+    expect(canConnectPorts(derivedPort, consumerPort, defWithMultipleSameIdPorts, defConsumer)).toBe(true);
+
+    // Verify incompatible type is rejected
+    const binaryConsumer = baseNodeDef("BinaryConsumer", [
+      { id: "in", type: "input", label: "in", position: "left", dataType: "binary" },
+    ]);
+    const binaryPort: Port = {
+      id: "in",
+      nodeId: "binary-consumer",
+      type: "input",
+      label: "in",
+      position: "left",
+      dataType: "binary",
+    };
+    // Should NOT connect because string !== binary
+    expect(canConnectPorts(derivedPort, binaryPort, defWithMultipleSameIdPorts, binaryConsumer)).toBe(false);
+  });
 });
 
 describe("canConnectPorts - maxConnections default/unlimited", () => {

src/core/connection/validation.ts

@@ -68,16 +68,14 @@ export const canConnectNormalizedPorts = (
   }
 
   // Check data type compatibility
+  // Port.dataType is set during derivation from the active PortDefinition,
+  // so it takes priority. Only fall back to PortDefinition lookup when Port.dataType is not set.
+  // This is important when multiple PortDefinitions share the same id but have different
+  // dataTypes (selected via instances function).
   const sourcePortDef = getPortDefinition(sourcePort, sourceDefinition);
   const targetPortDef = getPortDefinition(targetPort, targetDefinition);
-  const sourceTypes = mergePortDataTypes(
-    sourcePort.dataType,
-    mergePortDataTypes(sourcePortDef?.dataType, sourcePortDef?.dataTypes),
-  );
-  const targetTypes = mergePortDataTypes(
-    targetPort.dataType,
-    mergePortDataTypes(targetPortDef?.dataType, targetPortDef?.dataTypes),
-  );
+  const sourceTypes = sourcePort.dataType ?? mergePortDataTypes(sourcePortDef?.dataType, sourcePortDef?.dataTypes);
+  const targetTypes = targetPort.dataType ?? mergePortDataTypes(targetPortDef?.dataType, targetPortDef?.dataTypes);
   if (!arePortDataTypesCompatible(sourceTypes, targetTypes)) {
     return false;
   }