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

+use real id

Browse Source
This commit is contained in:
Michael Zanetti 2017-10-04 20:42:45 +02:00
parent 896f5e73a7
commit a2cffbc5fc
3 changed files with 21 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
libguh-core/awsconnector.cpp
View File

@ -57,22 +57,12 @@ void AWSConnector::connect2AWS(const QString &endpoint, const QString &clientId,
std::chrono::milliseconds(30000), std::chrono::milliseconds(30000),
true true
)); ));
m_client = MqttClient::Create(m_networkConnection, std::chrono::milliseconds(30000)); m_client = MqttClient::Create(m_networkConnection, std::chrono::milliseconds(30000), &onDisconnectedCallback, std::shared_ptr<DisconnectCallbackContextData>(this));
m_client->SetDisconnectCallbackPtr(&onDisconnectedCallback, std::shared_ptr<DisconnectCallbackContextData>(this));
m_clientId = clientId; m_clientId = clientId;
m_clientName = clientName; m_clientName = clientName;
qCDebug(dcAWS()) << "Connecting to AWS with ID:" << m_clientId << "endpoint:" << endpoint; qCDebug(dcAWS()) << "Connecting to AWS with ID:" << m_clientId << "endpoint:" << endpoint;
m_connectingFuture = QtConcurrent::run([&]() { doConnect();
ResponseCode rc = m_client->Connect(std::chrono::milliseconds(30000), true, mqtt::Version::MQTT_3_1_1, std::chrono::seconds(60), Utf8String::Create(m_clientId.toStdString()), nullptr, nullptr, nullptr);
if (rc == ResponseCode::MQTT_CONNACK_CONNECTION_ACCEPTED) {
emit connected();
} else {
qCWarning(dcAWS) << "Error connecting to AWS. Response code:" << QString::fromStdString(ResponseHelper::ToString(rc));
m_client.reset();
m_networkConnection.reset();
}
});
} }
DisconnectCallbackContextData::~DisconnectCallbackContextData() {} DisconnectCallbackContextData::~DisconnectCallbackContextData() {}
@ -124,6 +114,19 @@ quint16 AWSConnector::publish(const QString &topic, const QVariantMap &message)
return packetId; return packetId;
} }
void AWSConnector::doConnect()
{
qCDebug(dcAWS()) << "(re)connecting...";
m_connectingFuture = QtConcurrent::run([&]() {
ResponseCode rc = m_client->Connect(std::chrono::milliseconds(30000), true, mqtt::Version::MQTT_3_1_1, std::chrono::seconds(60), Utf8String::Create(m_clientId.toStdString()), nullptr, nullptr, nullptr);
if (rc == ResponseCode::MQTT_CONNACK_CONNECTION_ACCEPTED) {
emit connected();
} else {
qCWarning(dcAWS) << "Error connecting to AWS. Response code:" << QString::fromStdString(ResponseHelper::ToString(rc));
}
});
}
void AWSConnector::onConnected() void AWSConnector::onConnected()
{ {
qCDebug(dcAWS()) << "AWS connected"; qCDebug(dcAWS()) << "AWS connected";
@ -135,17 +138,7 @@ void AWSConnector::onDisconnected()
{ {
qCDebug(dcAWS()) << "AWS disconnected."; qCDebug(dcAWS()) << "AWS disconnected.";
if (m_reconnect) { if (m_reconnect) {
qCDebug(dcAWS()) << "Reconnecting..."; QTimer::singleShot(10000, this, &AWSConnector::doConnect);
m_connectingFuture = QtConcurrent::run([&]() {
ResponseCode rc = m_client->Connect(std::chrono::milliseconds(30000), true, mqtt::Version::MQTT_3_1_1, std::chrono::seconds(60), Utf8String::Create(m_clientId.toStdString()), nullptr, nullptr, nullptr);
if (rc == ResponseCode::MQTT_CONNACK_CONNECTION_ACCEPTED) {
emit connected();
} else {
qCWarning(dcAWS) << "Error connecting to AWS. Response code:" << QString::fromStdString(ResponseHelper::ToString(rc));
m_client.reset();
m_networkConnection.reset();
}
});
} }
} }
@ -309,10 +302,8 @@ ResponseCode AWSConnector::onSubscriptionReceivedCallback(util::String topic_nam
ResponseCode AWSConnector::onDisconnectedCallback(util::String mqtt_client_id, std::shared_ptr<DisconnectCallbackContextData> p_app_handler_data) ResponseCode AWSConnector::onDisconnectedCallback(util::String mqtt_client_id, std::shared_ptr<DisconnectCallbackContextData> p_app_handler_data)
{ {
Q_UNUSED(p_app_handler_data) qCDebug(dcAWS()) << "disconnected" << QString::fromStdString(mqtt_client_id) << p_app_handler_data.get();
qCDebug(dcAWS()) << "disconnected" << QString::fromStdString(mqtt_client_id); // AWSConnector* connector = dynamic_cast<AWSConnector*>(p_app_handler_data.get());
// AWSConnector* connector = static_cast<AWSConnector*>(p_app_handler_data.get());
// emit connector->disconnected(); // emit connector->disconnected();
return ResponseCode::SUCCESS; return ResponseCode::SUCCESS;
} }

1
libguh-core/awsconnector.h
View File

@ -50,6 +50,7 @@ signals:
void webRtcHandshakeMessageReceived(const QString &transactionId, const QVariantMap &data); void webRtcHandshakeMessageReceived(const QString &transactionId, const QVariantMap &data);
private slots: private slots:
void doConnect();
void onConnected(); void onConnected();
void onDisconnected(); void onDisconnected();
void retrievePairedDeviceInfo(); void retrievePairedDeviceInfo();

4
libguh-core/cloudmanager.cpp
View File

@ -111,8 +111,8 @@ void CloudManager::pairDevice(const QString &idToken, const QString &authToken,
void CloudManager::connect2aws() void CloudManager::connect2aws()
{ {
m_awsConnector->connect2AWS(m_serverUrl, m_awsConnector->connect2AWS(m_serverUrl,
"1e10fb7e-d9d9-4145-88dd-2d3caf623c18", // micha's test id (needs micha's test certs) - remove that before merging // "1e10fb7e-d9d9-4145-88dd-2d3caf623c18", // micha's test id (needs micha's test certs) - remove that before merging
// m_deviceId.toString().remove(QRegExp("[{}]*")), m_deviceId.toString().remove(QRegExp("[{}]*")),
m_deviceName, m_deviceName,
m_caCertificate, m_caCertificate,
m_clientCertificate, m_clientCertificate,