Merged testing

Homegear · Mar 10, 2019 · 3cba504 · 3cba504
2 parents 4cfc781 + 169ea47
commit 3cba504
Show file tree

Hide file tree

Showing 23 changed files with 384 additions and 88 deletions.
diff --git a/CMakeLists.txt b/CMakeLists.txt
@@ -4,6 +4,8 @@ project(homegear_somfy_tahoma)
 set(CMAKE_CXX_STANDARD 11)
 
 set(SOURCE_FILES
+        src/Api.cpp
+        src/Api.h
         src/DescriptionCreator.cpp
         src/DescriptionCreator.h
         src/Factory.cpp

diff --git a/misc/Config Directory/somfytahoma.conf b/misc/Config Directory/somfytahoma.conf
@@ -6,3 +6,9 @@ ___________________________________________________________________________
 [General]
 
 moduleEnabled = false
+
+# Your TaHoma user name
+user = 
+
+# Your TaHoma password
+password = 
diff --git a/src/Api.cpp b/src/Api.cpp
@@ -0,0 +1,221 @@
+/* Copyright 2013-2019 Homegear GmbH
+ *
+ * Homegear is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Homegear is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Homegear.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * In addition, as a special exception, the copyright holders give
+ * permission to link the code of portions of this program with the
+ * OpenSSL library under certain conditions as described in each
+ * individual source file, and distribute linked combinations
+ * including the two.
+ * You must obey the GNU General Public License in all respects
+ * for all of the code used other than OpenSSL.  If you modify
+ * file(s) with this exception, you may extend this exception to your
+ * version of the file(s), but you are not obligated to do so.  If you
+ * do not wish to do so, delete this exception statement from your
+ * version.  If you delete this exception statement from all source
+ * files in the program, then also delete it here.
+ */
+
+#include "Api.h"
+#include "GD.h"
+
+namespace MyFamily
+{
+
+Api::Api()
+{
+    _out.init(GD::bl);
+    _out.setPrefix(GD::out.getPrefix() + " TaHoma client: ");
+
+    signal(SIGPIPE, SIG_IGN);
+
+    _httpClient = std::unique_ptr<BaseLib::HttpClient>(new BaseLib::HttpClient(GD::bl, "www.tahomalink.com", 443, false, true));
+    _jsonEncoder = std::unique_ptr<BaseLib::Rpc::JsonEncoder>(new BaseLib::Rpc::JsonEncoder(GD::bl));
+    _jsonDecoder = std::unique_ptr<BaseLib::Rpc::JsonDecoder>(new BaseLib::Rpc::JsonDecoder(GD::bl));
+
+    _loggedIn = false;
+    _stopWorkerThread = false;
+}
+
+Api::~Api()
+{
+    stop();
+}
+
+void Api::start()
+{
+    try
+    {
+        _stopWorkerThread = false;
+        GD::bl->threadManager.start(_workerThread, true, &Api::worker, this);
+    }
+    catch(const std::exception& ex)
+    {
+        _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__, ex.what());
+    }
+    catch(BaseLib::Exception& ex)
+    {
+        _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__, ex.what());
+    }
+    catch(...)
+    {
+        _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__);
+    }
+}
+
+void Api::stop()
+{
+    try
+    {
+        _stopWorkerThread = true;
+        GD::bl->threadManager.join(_workerThread);
+    }
+    catch(const std::exception& ex)
+    {
+        _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__, ex.what());
+    }
+    catch(BaseLib::Exception& ex)
+    {
+        _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__, ex.what());
+    }
+    catch(...)
+    {
+        _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__);
+    }
+}
+
+void Api::worker()
+{
+    while(!_stopWorkerThread)
+    {
+        try
+        {
+            for(int32_t i = 0; i < 60; i++)
+            {
+                std::this_thread::sleep_for(std::chrono::milliseconds(1000));
+                if(_stopWorkerThread) break;
+            }
+
+            login();
+
+            std::string getRequest = "GET " + _path + "getSetup HTTP/1.1\r\nUser-Agent: Homegear\r\nHost: www.tahomalink.com:" + std::to_string(443) + "\r\nConnection: Close\r\nCookie: " + _cookie + "\r\n\r\n";
+            BaseLib::Http result;
+            _httpClient->sendRequest(getRequest, result);
+
+            auto resultJson = _jsonDecoder->decode(result.getContent());
+
+            if(result.getHeader().responseCode >= 400 && result.getHeader().responseCode <= 499)
+            {
+                auto jsonIterator = resultJson->structValue->find("error");
+                if(jsonIterator != resultJson->structValue->end()) GD::out.printError("Error getting setup: " + jsonIterator->second->stringValue);
+                else GD::out.printError("Error getting setup: Unknown error");
+
+                _loggedIn = false;
+            }
+            else
+            {
+                resultJson->print(true, true);
+            }
+        }
+        catch(const std::exception& ex)
+        {
+            _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__, ex.what());
+        }
+        catch(BaseLib::Exception& ex)
+        {
+            _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__, ex.what());
+        }
+        catch(...)
+        {
+            _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__);
+        }
+    }
+}
+
+bool Api::login()
+{
+    try
+    {
+        std::lock_guard<std::mutex> loginGuard(_loginMutex);
+        if(_loggedIn) return true;
+
+        std::string settingName = "user";
+        auto setting = GD::family->getFamilySetting(settingName);
+        if(!setting || setting->stringValue.empty())
+        {
+            _out.printError("Error: Setting \"user\" not specified in \"somfytahoma.conf\".");
+            return false;
+        }
+        std::string user = BaseLib::HelperFunctions::stringReplace(setting->stringValue, "\"", "\\\"");
+        settingName = "password";
+        setting = GD::family->getFamilySetting(settingName);
+        if(!setting || setting->stringValue.empty())
+        {
+            _out.printError("Error: Setting \"password\" not specified in \"somfytahoma.conf\".");
+            return false;
+        }
+        std::string password = BaseLib::HelperFunctions::stringReplace(setting->stringValue, "\"", "\\\"");;
+
+        std::string postData = "userId=" + BaseLib::Http::encodeURL(user) + "&userPassword=" + BaseLib::Http::encodeURL(password);
+        std::string postRequest = "POST " + _path + "login HTTP/1.1\r\nUser-Agent: Homegear\r\nHost: www.tahomalink.com:" + std::to_string(443) + "\r\nConnection: Close\r\nContent-Type: application/x-www-form-urlencoded\r\nContent-Length: " + std::to_string(postData.size()) + "\r\n\r\n" + postData;
+        BaseLib::Http result;
+        _httpClient->sendRequest(postRequest, result);
+
+        if(GD::bl->debugLevel >= 5) _out.printDebug("Debug: Response: " + std::string(result.getContent().data(), result.getContentSize()));
+
+        if(result.getHeader().responseCode == 200)
+        {
+            auto resultJson = _jsonDecoder->decode(result.getContent());
+            auto jsonIterator = resultJson->structValue->find("success");
+            if(jsonIterator != resultJson->structValue->end() && jsonIterator->second->booleanValue)
+            {
+                if(GD::bl->debugLevel >= 5) _out.printDebug("Debug: Successfully logged in.");
+
+                auto fieldIterator = result.getHeader().fields.find("set-cookie");
+                if(fieldIterator == result.getHeader().fields.end()) return false;
+
+                _cookie = fieldIterator->second;
+                _loggedIn = true;
+
+                return true;
+            }
+
+            return false;
+        }
+        else if(result.getHeader().responseCode >= 400 && result.getHeader().responseCode <= 499)
+        {
+            auto resultJson = _jsonDecoder->decode(result.getContent());
+            auto jsonIterator = resultJson->structValue->find("error");
+            if(jsonIterator != resultJson->structValue->end()) GD::out.printError("Error logging in: " + jsonIterator->second->stringValue);
+            else GD::out.printError("Error logging in: Unknown error");
+        }
+
+        return false;
+    }
+    catch(const std::exception& ex)
+    {
+        _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__, ex.what());
+    }
+    catch(BaseLib::Exception& ex)
+    {
+        _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__, ex.what());
+    }
+    catch(...)
+    {
+        _out.printEx(__FILE__, __LINE__, __PRETTY_FUNCTION__);
+    }
+    return false;
+}
+
+}
diff --git a/src/Api.h b/src/Api.h
@@ -0,0 +1,69 @@
+/* Copyright 2013-2019 Homegear GmbH
+ *
+ * Homegear is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Homegear is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Homegear.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * In addition, as a special exception, the copyright holders give
+ * permission to link the code of portions of this program with the
+ * OpenSSL library under certain conditions as described in each
+ * individual source file, and distribute linked combinations
+ * including the two.
+ * You must obey the GNU General Public License in all respects
+ * for all of the code used other than OpenSSL.  If you modify
+ * file(s) with this exception, you may extend this exception to your
+ * version of the file(s), but you are not obligated to do so.  If you
+ * do not wish to do so, delete this exception statement from your
+ * version.  If you delete this exception statement from all source
+ * files in the program, then also delete it here.
+ */
+
+#ifndef TAHOMA_API_H
+#define TAHOMA_API_H
+
+#include <homegear-base/Sockets/HttpClient.h>
+#include <homegear-base/Output/Output.h>
+#include <homegear-base/Encoding/JsonEncoder.h>
+#include <homegear-base/Encoding/JsonDecoder.h>
+
+namespace MyFamily
+{
+
+class Api
+{
+public:
+    Api();
+    virtual ~Api();
+
+    void start();
+    void stop();
+private:
+    BaseLib::Output _out;
+    std::unique_ptr<BaseLib::HttpClient> _httpClient;
+    std::unique_ptr<BaseLib::Rpc::JsonEncoder> _jsonEncoder;
+    std::unique_ptr<BaseLib::Rpc::JsonDecoder> _jsonDecoder;
+
+    std::atomic_bool _stopWorkerThread;
+    std::thread _workerThread;
+
+    const std::string _path = "/enduser-mobile-web/externalAPI/json/";
+    std::mutex _loginMutex;
+    std::atomic_bool _loggedIn;
+    std::string _cookie;
+
+    bool login();
+    void worker();
+};
+
+}
+
+#endif
diff --git a/src/DescriptionCreator.cpp b/src/DescriptionCreator.cpp
@@ -1,4 +1,4 @@
-/* Copyright 2013-2017 Homegear UG (haftungsbeschränkt) */
+/* Copyright 2013-2019 Homegear GmbH */
 
 #include "DescriptionCreator.h"
 #include "GD.h"

diff --git a/src/DescriptionCreator.h b/src/DescriptionCreator.h
@@ -1,4 +1,4 @@
-/* Copyright 2013-2017 Homegear UG (haftungsbeschränkt) */
+/* Copyright 2013-2019 Homegear GmbH */
 
 #ifndef HOMEGEAR_TAHOMA_DESCRIPTIONCREATOR_H
 #define HOMEGEAR_TAHOMA_DESCRIPTIONCREATOR_H

diff --git a/src/Factory.cpp b/src/Factory.cpp
@@ -1,4 +1,4 @@
-/* Copyright 2013-2017 Sathya Laufer
+/* Copyright 2013-2019 Homegear GmbH
  *
  * Homegear is free software: you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
@@ -31,7 +31,7 @@
 #include "../config.h"
 #include "GD.h"
 
-BaseLib::Systems::DeviceFamily* MyFactory::createDeviceFamily(BaseLib::SharedObjects* bl, BaseLib::Systems::DeviceFamily::IFamilyEventSink* eventHandler)
+BaseLib::Systems::DeviceFamily* MyFactory::createDeviceFamily(BaseLib::SharedObjects* bl, BaseLib::Systems::IFamilyEventSink* eventHandler)
 {
 	return new MyFamily::MyFamily(bl, eventHandler);
 }

diff --git a/src/Factory.h b/src/Factory.h
@@ -1,4 +1,4 @@
-/* Copyright 2013-2017 Sathya Laufer
+/* Copyright 2013-2019 Homegear GmbH
  *
  * Homegear is free software: you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
@@ -36,7 +36,7 @@
 class MyFactory : BaseLib::Systems::SystemFactory
 {
 public:
-	virtual BaseLib::Systems::DeviceFamily* createDeviceFamily(BaseLib::SharedObjects* bl, BaseLib::Systems::DeviceFamily::IFamilyEventSink* eventHandler);
+	virtual BaseLib::Systems::DeviceFamily* createDeviceFamily(BaseLib::SharedObjects* bl, BaseLib::Systems::IFamilyEventSink* eventHandler);
 };
 
 extern "C" std::string getVersion();

diff --git a/src/GD.cpp b/src/GD.cpp
@@ -1,4 +1,4 @@
-/* Copyright 2013-2017 Sathya Laufer
+/* Copyright 2013-2019 Homegear GmbH
  *
  * Homegear is free software: you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by

diff --git a/src/GD.h b/src/GD.h
@@ -1,4 +1,4 @@
-/* Copyright 2013-2017 Sathya Laufer
+/* Copyright 2013-2019 Homegear GmbH
  *
  * Homegear is free software: you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by