ETM-Schurig/powersync-core
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Support providing a custom remote proxy url

Browse Source
This commit is contained in:
Michael Zanetti 2019-02-15 16:19:20 +01:00
parent 153774ae24
commit 309240ed47
4 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
libnymea-core/cloud/awsconnector.cpp
View File

@ -489,6 +489,7 @@ void AWSConnector::onPublishReceived(const QString &topic, const QByteArray &pay
} else if (topic.startsWith(QString("%1/eu-west-1:").arg(m_clientId)) && topic.contains("proxy")) { } else if (topic.startsWith(QString("%1/eu-west-1:").arg(m_clientId)) && topic.contains("proxy")) {
QString token = jsonDoc.toVariant().toMap().value("token").toString(); QString token = jsonDoc.toVariant().toMap().value("token").toString();
QString timestamp = jsonDoc.toVariant().toMap().value("timestamp").toString(); QString timestamp = jsonDoc.toVariant().toMap().value("timestamp").toString();
QString serverUrl = jsonDoc.toVariant().toMap().value("serverUrl").toString();
static QHash<QString, QDateTime> dupes; static QHash<QString, QDateTime> dupes;
QString packetId = topic + token + timestamp; QString packetId = topic + token + timestamp;
if (dupes.contains(packetId)) { if (dupes.contains(packetId)) {
@ -502,7 +503,7 @@ void AWSConnector::onPublishReceived(const QString &topic, const QByteArray &pay
} }
} }
qCDebug(dcAWS) << "Proxy remote connection request received"; qCDebug(dcAWS) << "Proxy remote connection request received";
proxyConnectionRequestReceived(token, timestamp); proxyConnectionRequestReceived(token, timestamp, serverUrl);
} else if (topic == QString("%1/notify/response").arg(m_clientId)) { } else if (topic == QString("%1/notify/response").arg(m_clientId)) {
int transactionId = jsonDoc.toVariant().toMap().value("id").toInt(); int transactionId = jsonDoc.toVariant().toMap().value("id").toInt();
int status = jsonDoc.toVariant().toMap().value("status").toInt(); int status = jsonDoc.toVariant().toMap().value("status").toInt();

2
libnymea-core/cloud/awsconnector.h
View File

@ -65,7 +65,7 @@ signals:
void pushNotificationSent(int id, int status); void pushNotificationSent(int id, int status);
void turnCredentialsReceived(const QVariantMap &turnCredentials); void turnCredentialsReceived(const QVariantMap &turnCredentials);
void proxyConnectionRequestReceived(const QString &token, const QString &nonce); void proxyConnectionRequestReceived(const QString &token, const QString &nonce, const QString &serverUrl);
private slots: private slots:
void doConnect(); void doConnect();

9
libnymea-core/cloud/cloudtransport.cpp
View File

@ -31,7 +31,7 @@ namespace nymeaserver {
CloudTransport::CloudTransport(const ServerConfiguration &config, QObject *parent): CloudTransport::CloudTransport(const ServerConfiguration &config, QObject *parent):
TransportInterface(config, parent) TransportInterface(config, parent)
{ {
m_proxyUrl = QUrl("wss://remoteproxy.nymea.io"); m_defaultProxyUrl = "wss://remoteproxy.nymea.io";
} }
void CloudTransport::sendData(const QUuid &clientId, const QByteArray &data) void CloudTransport::sendData(const QUuid &clientId, const QByteArray &data)
@ -75,9 +75,10 @@ bool CloudTransport::stopServer()
return true; return true;
} }
void CloudTransport::connectToCloud(const QString &token, const QString &nonce) void CloudTransport::connectToCloud(const QString &token, const QString &nonce, const QString &serverUrl)
{ {
qCDebug(dcCloud()) << "Connecting to remote proxy server" << m_proxyUrl.toString(); QString proxyUrl = serverUrl.isEmpty() ? m_defaultProxyUrl : serverUrl;
qCDebug(dcCloud()) << "Connecting to remote proxy server" << proxyUrl;
ConnectionContext context; ConnectionContext context;
context.clientId = QUuid::createUuid(); context.clientId = QUuid::createUuid();
@ -93,7 +94,7 @@ void CloudTransport::connectToCloud(const QString &token, const QString &nonce)
connect(context.proxyConnection, &RemoteProxyConnection::remoteConnectionEstablished, this, &CloudTransport::transportConnected); connect(context.proxyConnection, &RemoteProxyConnection::remoteConnectionEstablished, this, &CloudTransport::transportConnected);
connect(context.proxyConnection, &RemoteProxyConnection::disconnected, this, &CloudTransport::transportDisconnected); connect(context.proxyConnection, &RemoteProxyConnection::disconnected, this, &CloudTransport::transportDisconnected);
context.proxyConnection->connectServer(m_proxyUrl); context.proxyConnection->connectServer(QUrl(proxyUrl));
} }
void CloudTransport::remoteConnectionStateChanged(RemoteProxyConnection::State state) void CloudTransport::remoteConnectionStateChanged(RemoteProxyConnection::State state)

4
libnymea-core/cloud/cloudtransport.h
View File

@ -44,7 +44,7 @@ public:
signals: signals:
public slots: public slots:
void connectToCloud(const QString &token, const QString &nonce); void connectToCloud(const QString &token, const QString &nonce, const QString &serverUrl);
private slots: private slots:
void remoteConnectionStateChanged(remoteproxyclient::RemoteProxyConnection::State state); void remoteConnectionStateChanged(remoteproxyclient::RemoteProxyConnection::State state);
@ -54,7 +54,7 @@ private slots:
void transportDisconnected(); void transportDisconnected();
private: private:
QUrl m_proxyUrl; QString m_defaultProxyUrl;
class ConnectionContext { class ConnectionContext {
public: public: