+template<class T>
+void SignalProxy::dispatch(Peer* peer, const T& protoMessage)
+{
+ _targetPeer = peer;
+
+ if (peer && peer->isOpen())
+ peer->dispatch(protoMessage);
+ else
+ QCoreApplication::postEvent(this, new ::RemovePeerEvent(peer));
+
+ _targetPeer = nullptr;
+}
+
+void SignalProxy::handle(Peer* peer, const SyncMessage& syncMessage)
+{
+ if (!_syncSlave.contains(syncMessage.className) || !_syncSlave[syncMessage.className].contains(syncMessage.objectName)) {
+ qWarning() << QString("no registered receiver for sync call: %1::%2 (objectName=\"%3\"). Params are:")
+ .arg(syncMessage.className, syncMessage.slotName, syncMessage.objectName)
+ << syncMessage.params;
+ return;
+ }
+
+ SyncableObject* receiver = _syncSlave[syncMessage.className][syncMessage.objectName];
+ ExtendedMetaObject* eMeta = extendedMetaObject(receiver);
+ if (!eMeta->slotMap().contains(syncMessage.slotName)) {
+ qWarning() << QString("no matching slot for sync call: %1::%2 (objectName=\"%3\"). Params are:")
+ .arg(syncMessage.className, syncMessage.slotName, syncMessage.objectName)
+ << syncMessage.params;
+ return;
+ }
+
+ int slotId = eMeta->slotMap()[syncMessage.slotName];
+ if (proxyMode() != eMeta->receiverMode(slotId)) {
+ qWarning("SignalProxy::handleSync(): invokeMethod for \"%s\" failed. Wrong ProxyMode!", eMeta->methodName(slotId).constData());
+ return;
+ }
+
+ // We can no longer construct a QVariant from QMetaType::Void
+ QVariant returnValue;
+ int returnType = eMeta->returnType(slotId);
+ if (returnType != QMetaType::Void)
+ returnValue = QVariant(static_cast<QVariant::Type>(returnType));
+
+ if (!invokeSlot(receiver, slotId, syncMessage.params, returnValue, peer)) {
+ qWarning("SignalProxy::handleSync(): invokeMethod for \"%s\" failed ", eMeta->methodName(slotId).constData());
+ return;
+ }
+
+ if (returnValue.type() != QVariant::Invalid && eMeta->receiveMap().contains(slotId)) {
+ int receiverId = eMeta->receiveMap()[slotId];
+ QVariantList returnParams;
+ if (eMeta->argTypes(receiverId).count() > 1)
+ returnParams << syncMessage.params;
+ returnParams << returnValue;
+ _targetPeer = peer;
+ peer->dispatch(SyncMessage(syncMessage.className, syncMessage.objectName, eMeta->methodName(receiverId), returnParams));
+ _targetPeer = nullptr;
+ }
+
+ // send emit update signal
+ invokeSlot(receiver, eMeta->updatedRemotelyId());
+}
+
+void SignalProxy::handle(Peer* peer, const RpcCall& rpcCall)
+{
+ Q_UNUSED(peer)
+
+ auto range = _attachedSlots.equal_range(rpcCall.signalName);
+ std::for_each(range.first, range.second, [&rpcCall](const auto& p) {
+ if (!p.second->invoke(rpcCall.params)) {
+ qWarning() << "Could not invoke slot for remote signal" << rpcCall.signalName;
+ }
+ });
+}
+
+void SignalProxy::handle(Peer* peer, const InitRequest& initRequest)
+{
+ if (!_syncSlave.contains(initRequest.className)) {
+ qWarning() << "SignalProxy::handleInitRequest() received initRequest for unregistered Class:" << initRequest.className;
+ return;
+ }
+
+ if (!_syncSlave[initRequest.className].contains(initRequest.objectName)) {
+ qWarning() << "SignalProxy::handleInitRequest() received initRequest for unregistered Object:" << initRequest.className
+ << initRequest.objectName;
+ return;
+ }
+
+ SyncableObject* obj = _syncSlave[initRequest.className][initRequest.objectName];
+ _targetPeer = peer;
+ peer->dispatch(InitData(initRequest.className, initRequest.objectName, initData(obj)));
+ _targetPeer = nullptr;
+}
+
+void SignalProxy::handle(Peer* peer, const InitData& initData)
+{
+ Q_UNUSED(peer)
+
+ if (!_syncSlave.contains(initData.className)) {
+ qWarning() << "SignalProxy::handleInitData() received initData for unregistered Class:" << initData.className;
+ return;
+ }
+
+ if (!_syncSlave[initData.className].contains(initData.objectName)) {
+ qWarning() << "SignalProxy::handleInitData() received initData for unregistered Object:" << initData.className << initData.objectName;
+ return;
+ }
+
+ SyncableObject* obj = _syncSlave[initData.className][initData.objectName];
+ setInitData(obj, initData.initData);
+}
+
+bool SignalProxy::invokeSlot(QObject* receiver, int methodId, const QVariantList& params, QVariant& returnValue, Peer* peer)
+{
+ ExtendedMetaObject* eMeta = extendedMetaObject(receiver);
+ const QList<int> args = eMeta->argTypes(methodId);
+ const int numArgs = params.count() < args.count() ? params.count() : args.count();
+
+ if (eMeta->minArgCount(methodId) > params.count()) {
+ qWarning() << "SignalProxy::invokeSlot(): not enough params to invoke" << eMeta->methodName(methodId);
+ return false;
+ }
+
+ void* _a[] = {nullptr, // return type...
+ nullptr,
+ nullptr,
+ nullptr,
+ nullptr,
+ nullptr, // and 10 args - that's the max size qt can handle with signals and slots
+ nullptr,
+ nullptr,
+ nullptr,
+ nullptr,
+ nullptr};
+
+ // check for argument compatibility and build params array
+ for (int i = 0; i < numArgs; i++) {
+ if (!params[i].isValid()) {
+ qWarning() << "SignalProxy::invokeSlot(): received invalid data for argument number" << i << "of method"
+ << QString("%1::%2()")
+ .arg(receiver->metaObject()->className())
+ .arg(receiver->metaObject()->method(methodId).methodSignature().constData());
+ qWarning() << " - make sure all your data types are known by the Qt MetaSystem";
+ return false;
+ }
+ if (args[i] != QMetaType::type(params[i].typeName())) {
+ qWarning() << "SignalProxy::invokeSlot(): incompatible param types to invoke" << eMeta->methodName(methodId);
+ return false;
+ }
+
+ _a[i + 1] = const_cast<void*>(params[i].constData());
+ }
+
+ if (returnValue.type() != QVariant::Invalid)
+ _a[0] = const_cast<void*>(returnValue.constData());
+
+ Qt::ConnectionType type = QThread::currentThread() == receiver->thread() ? Qt::DirectConnection : Qt::QueuedConnection;
+
+ if (type == Qt::DirectConnection) {
+ _sourcePeer = peer;
+ auto result = receiver->qt_metacall(QMetaObject::InvokeMetaMethod, methodId, _a) < 0;
+ _sourcePeer = nullptr;
+ return result;
+ }
+ else {
+ qWarning() << "Queued Connections are not implemented yet";
+ // note to self: qmetaobject.cpp:990 ff
+ return false;
+ }
+}
+
+bool SignalProxy::invokeSlot(QObject* receiver, int methodId, const QVariantList& params, Peer* peer)
+{
+ QVariant ret;
+ return invokeSlot(receiver, methodId, params, ret, peer);
+}
+
+void SignalProxy::requestInit(SyncableObject* obj)
+{
+ if (proxyMode() == Server || obj->isInitialized())
+ return;
+
+ dispatch(InitRequest(obj->syncMetaObject()->className(), obj->objectName()));
+}
+
+QVariantMap SignalProxy::initData(SyncableObject* obj) const
+{
+ return obj->toVariantMap();
+}
+
+void SignalProxy::setInitData(SyncableObject* obj, const QVariantMap& properties)
+{
+ if (obj->isInitialized())
+ return;
+ obj->fromVariantMap(properties);
+ obj->setInitialized();
+ emit objectInitialized(obj);
+ invokeSlot(obj, extendedMetaObject(obj)->updatedRemotelyId());
+}
+
+void SignalProxy::customEvent(QEvent* event)
+{
+ switch ((int)event->type()) {
+ case RemovePeerEvent: {
+ auto* e = static_cast<::RemovePeerEvent*>(event);
+ removePeer(e->peer);
+ event->accept();
+ break;
+ }
+
+ default:
+ qWarning() << Q_FUNC_INFO << "Received unknown custom event:" << event->type();
+ return;
+ }
+}
+
+void SignalProxy::sync_call__(const SyncableObject* obj, SignalProxy::ProxyMode modeType, const char* funcname, va_list ap)
+{
+ // qDebug() << obj << modeType << "(" << _proxyMode << ")" << funcname;
+ if (modeType != _proxyMode)
+ return;
+
+ ExtendedMetaObject* eMeta = extendedMetaObject(obj);
+
+ QVariantList params;
+
+ const QList<int>& argTypes = eMeta->argTypes(eMeta->methodId(QByteArray(funcname)));
+
+ for (int i = 0; i < argTypes.size(); i++) {
+ if (argTypes[i] == 0) {
+ qWarning() << Q_FUNC_INFO << "received invalid data for argument number" << i << "of signal"
+ << QString("%1::%2").arg(eMeta->metaObject()->className()).arg(funcname);
+ qWarning() << " - make sure all your data types are known by the Qt MetaSystem";
+ return;
+ }
+ params << QVariant(argTypes[i], va_arg(ap, void*));
+ }
+
+ if (_restrictMessageTarget) {
+ for (auto peer : _restrictedTargets) {
+ if (peer != nullptr)
+ dispatch(peer, SyncMessage(eMeta->metaObject()->className(), obj->objectName(), QByteArray(funcname), params));
+ }
+ }
+ else
+ dispatch(SyncMessage(eMeta->metaObject()->className(), obj->objectName(), QByteArray(funcname), params));
+}
+
+void SignalProxy::disconnectDevice(QIODevice* dev, const QString& reason)
+{
+ if (!reason.isEmpty())
+ qWarning() << qPrintable(reason);
+ auto* sock = qobject_cast<QAbstractSocket*>(dev);
+ if (sock)
+ qWarning() << qPrintable(tr("Disconnecting")) << qPrintable(sock->peerAddress().toString());
+ dev->close();
+}
+
+void SignalProxy::dumpProxyStats()
+{
+ QString mode;
+ if (proxyMode() == Server)
+ mode = "Server";
+ else
+ mode = "Client";
+
+ int slaveCount = 0;
+ foreach (ObjectId oid, _syncSlave.values())
+ slaveCount += oid.count();
+
+ qDebug() << this;
+ qDebug() << " Proxy Mode:" << mode;
+ qDebug() << " attached Slots:" << _attachedSlots.size();
+ qDebug() << " number of synced Slaves:" << slaveCount;
+ qDebug() << "number of Classes cached:" << _extendedMetaObjects.count();
+}
+
+void SignalProxy::updateSecureState()
+{
+ bool wasSecure = _secure;
+
+ _secure = !_peerMap.isEmpty();
+ for (auto peer : _peerMap.values()) {
+ _secure &= peer->isSecure();
+ }
+
+ if (wasSecure != _secure)
+ emit secureStateChanged(_secure);
+}
+
+QVariantList SignalProxy::peerData()
+{
+ QVariantList result;
+ for (auto&& peer : _peerMap.values()) {
+ QVariantMap data;
+ data["id"] = peer->id();
+ data["clientVersion"] = peer->clientVersion();
+ // We explicitly rename this, as, due to the Debian reproducability changes, buildDate isn’t actually the build
+ // date anymore, but on newer clients the date of the last git commit
+ data["clientVersionDate"] = peer->buildDate();
+ data["remoteAddress"] = peer->address();
+ data["connectedSince"] = peer->connectedSince();
+ data["secure"] = peer->isSecure();
+ data["features"] = static_cast<quint32>(peer->features().toLegacyFeatures());
+ data["featureList"] = peer->features().toStringList();
+ result << data;
+ }
+ return result;
+}
+
+Peer* SignalProxy::peerById(int peerId)
+{
+ // We use ::value() here instead of the [] operator because the latter has the side-effect
+ // of automatically inserting a null value with the passed key into the map. See
+ // https://doc.qt.io/qt-5/qhash.html#operator-5b-5d and https://doc.qt.io/qt-5/qhash.html#value.
+ return _peerMap.value(peerId);
+}
+
+void SignalProxy::restrictTargetPeers(QSet<Peer*> peers, std::function<void()> closure)
+{
+ auto previousRestrictMessageTarget = _restrictMessageTarget;
+ auto previousRestrictedTargets = _restrictedTargets;
+ _restrictMessageTarget = true;
+ _restrictedTargets = peers;
+
+ closure();
+
+ _restrictMessageTarget = previousRestrictMessageTarget;
+ _restrictedTargets = previousRestrictedTargets;
+}
+
+Peer* SignalProxy::sourcePeer()
+{
+ return _sourcePeer;
+}
+
+void SignalProxy::setSourcePeer(Peer* sourcePeer)
+{
+ _sourcePeer = sourcePeer;
+}
+
+Peer* SignalProxy::targetPeer()
+{
+ return _targetPeer;
+}
+
+void SignalProxy::setTargetPeer(Peer* targetPeer)
+{
+ _targetPeer = targetPeer;
+}
+
+// ---- SlotObjectBase ---------------------------------------------------------------------------------------------------------------------
+
+SignalProxy::SlotObjectBase::SlotObjectBase(const QObject* context)
+ : _context{context}
+{}
+
+const QObject* SignalProxy::SlotObjectBase::context() const
+{
+ return _context;
+}
+
+// ---- ExtendedMetaObject ----------------------------------------------------------------------------------------------------------------
+
+SignalProxy::ExtendedMetaObject::ExtendedMetaObject(const QMetaObject* meta, bool checkConflicts)
+ : _meta(meta)
+ , _updatedRemotelyId(_meta->indexOfSignal("updatedRemotely()"))
+{
+ for (int i = 0; i < _meta->methodCount(); i++) {
+ if (_meta->method(i).methodType() != QMetaMethod::Slot)
+ continue;
+
+ if (_meta->method(i).methodSignature().contains('*'))
+ continue; // skip methods with ptr params
+
+ QByteArray method = methodName(_meta->method(i));
+ if (method.startsWith("init"))
+ continue; // skip initializers
+
+ if (_methodIds.contains(method)) {
+ /* funny... moc creates for methods containing default parameters multiple metaMethod with separate methodIds.
+ we don't care... we just need the full fledged version
+ */
+ const QMetaMethod& current = _meta->method(_methodIds[method]);
+ const QMetaMethod& candidate = _meta->method(i);
+ if (current.parameterTypes().count() > candidate.parameterTypes().count()) {
+ int minCount = candidate.parameterTypes().count();
+ QList<QByteArray> commonParams = current.parameterTypes().mid(0, minCount);
+ if (commonParams == candidate.parameterTypes())
+ continue; // we already got the full featured version
+ }
+ else {
+ int minCount = current.parameterTypes().count();
+ QList<QByteArray> commonParams = candidate.parameterTypes().mid(0, minCount);
+ if (commonParams == current.parameterTypes()) {
+ _methodIds[method] = i; // use the new one
+ continue;
+ }
+ }
+ if (checkConflicts) {
+ qWarning() << "class" << meta->className() << "contains overloaded methods which is currently not supported!";
+ qWarning() << " - " << _meta->method(i).methodSignature() << "conflicts with"
+ << _meta->method(_methodIds[method]).methodSignature();
+ }
+ continue;
+ }
+ _methodIds[method] = i;
+ }
+}
+
+const SignalProxy::ExtendedMetaObject::MethodDescriptor& SignalProxy::ExtendedMetaObject::methodDescriptor(int methodId)
+{
+ if (!_methods.contains(methodId)) {
+ _methods[methodId] = MethodDescriptor(_meta->method(methodId));
+ }
+ return _methods[methodId];
+}
+
+const QHash<int, int>& SignalProxy::ExtendedMetaObject::receiveMap()
+{
+ if (_receiveMap.isEmpty()) {
+ QHash<int, int> receiveMap;
+
+ QMetaMethod requestSlot;
+ QByteArray returnTypeName;
+ QByteArray signature;
+ QByteArray methodName;
+ QByteArray params;
+ int paramsPos;
+ int receiverId;
+ const int methodCount = _meta->methodCount();
+ for (int i = 0; i < methodCount; i++) {
+ requestSlot = _meta->method(i);
+ if (requestSlot.methodType() != QMetaMethod::Slot)
+ continue;
+
+ returnTypeName = requestSlot.typeName();
+ if (QMetaType::Void == (QMetaType::Type)returnType(i))
+ continue;
+
+ signature = requestSlot.methodSignature();
+ if (!signature.startsWith("request"))
+ continue;
+
+ paramsPos = signature.indexOf('(');
+ if (paramsPos == -1)
+ continue;
+
+ methodName = signature.left(paramsPos);
+ params = signature.mid(paramsPos);
+
+ methodName = methodName.replace("request", "receive");
+ params = params.left(params.count() - 1) + ", " + returnTypeName + ")";
+
+ signature = QMetaObject::normalizedSignature(methodName + params);
+ receiverId = _meta->indexOfSlot(signature);
+
+ if (receiverId == -1) {
+ signature = QMetaObject::normalizedSignature(methodName + "(" + returnTypeName + ")");
+ receiverId = _meta->indexOfSlot(signature);
+ }
+
+ if (receiverId != -1) {
+ receiveMap[i] = receiverId;
+ }
+ }
+ _receiveMap = receiveMap;
+ }
+ return _receiveMap;
+}
+
+QByteArray SignalProxy::ExtendedMetaObject::methodName(const QMetaMethod& method)
+{
+ QByteArray sig(method.methodSignature());
+ return sig.left(sig.indexOf("("));
+}
+
+QString SignalProxy::ExtendedMetaObject::methodBaseName(const QMetaMethod& method)
+{
+ QString methodname = QString(method.methodSignature()).section("(", 0, 0);
+
+ // determine where we have to chop:
+ int upperCharPos;
+ if (method.methodType() == QMetaMethod::Slot) {
+ // we take evertyhing from the first uppercase char if it's slot
+ upperCharPos = methodname.indexOf(QRegExp("[A-Z]"));
+ if (upperCharPos == -1)
+ return QString();
+ methodname = methodname.mid(upperCharPos);
+ }
+ else {
+ // and if it's a signal we discard everything from the last uppercase char
+ upperCharPos = methodname.lastIndexOf(QRegExp("[A-Z]"));
+ if (upperCharPos == -1)
+ return QString();
+ methodname = methodname.left(upperCharPos);
+ }
+
+ methodname[0] = methodname[0].toUpper();
+
+ return methodname;
+}
+
+SignalProxy::ExtendedMetaObject::MethodDescriptor::MethodDescriptor(const QMetaMethod& method)
+ : _methodName(SignalProxy::ExtendedMetaObject::methodName(method))
+ , _returnType(QMetaType::type(method.typeName()))
+{
+ // determine argTypes
+ QList<QByteArray> paramTypes = method.parameterTypes();
+ QList<int> argTypes;
+ for (int i = 0; i < paramTypes.count(); i++) {
+ argTypes.append(QMetaType::type(paramTypes[i]));
+ }
+ _argTypes = argTypes;
+
+ // determine minArgCount
+ QString signature(method.methodSignature());
+ _minArgCount = method.parameterTypes().count() - signature.count("=");
+
+ _receiverMode = (_methodName.startsWith("request")) ? SignalProxy::Server : SignalProxy::Client;
+}