Function connectData

libchigraph/src/NodeInstance.cpp:128–184

}

Result connectData(NodeInstance& lhs, size_t lhsConnID, NodeInstance& rhs, size_t rhsConnID) {
	Result res = {};

	assert(&lhs.function() == &rhs.function());

	rhs.module().updateLastEditTime();

	// make sure the connection exists
	// the input to the connection is the output to the node
	if (lhsConnID >= lhs.outputDataConnections.size()) {
		auto dataOutputs = nlohmann::json::array();
		for (auto& output : lhs.type().dataOutputs()) {
			dataOutputs.push_back({{output.name, output.type.qualifiedName()}});
		}

		res.addEntry("E22", "Output Data connection doesn't exist in node",
		             {{"Requested ID", lhsConnID},
		              {"Node Type", lhs.type().qualifiedName()},
		              {"Node JSON", rhs.type().toJSON()},
		              {"Node Output Data Connections", dataOutputs}});
	}
	if (rhsConnID >= rhs.inputDataConnections.size()) {
		auto dataInputs = nlohmann::json::array();
		for (auto& output : rhs.type().dataInputs()) {
			dataInputs.push_back({{output.name, output.type.qualifiedName()}});
		}

		res.addEntry("E23", "Input Data connection doesn't exist in node",
		             {{"Requested ID", rhsConnID},
		              {"Node Type", rhs.type().qualifiedName()},
		              {"Node JSON", rhs.type().toJSON()},
		              {"Node Input Data Connections", dataInputs}});
	}

	// if there are errors, back out
	if (!res) { return res; }
	// make sure the connection is of the right type
	if (lhs.type().dataOutputs()[lhsConnID].type != rhs.type().dataInputs()[rhsConnID].type) {
		res.addEntry("E24", "Connecting data nodes with different types is invalid",
		             {{"Left Hand Type", lhs.type().dataOutputs()[lhsConnID].type.qualifiedName()},
		              {"Right Hand Type", rhs.type().dataInputs()[rhsConnID].type.qualifiedName()},
		              {"Left Node JSON", rhs.type().toJSON()},
		              {"Right Node JSON", rhs.type().toJSON()}});
		return res;
	}

	// if we are replacing a connection, disconnect it
	if (rhs.inputDataConnections[rhsConnID].first != nullptr) {
		res += disconnectData(lhs, lhsConnID, rhs);
		if (!res) { return res; }
	}

	lhs.outputDataConnections[lhsConnID].emplace_back(&rhs, rhsConnID);
	rhs.inputDataConnections[rhsConnID] = {&lhs, lhsConnID};

	return res;
}