fix: add timeout when awaiting notification response

All socket connections were changed and now are started in ssl mode. This changes the way messages are sent and received from sockets. As a result, `timeout` option is not anymore respected when receiving messages from socket. However, the messages now are received only via methods from mobile device lib. As there isn't a built-in method in mobile device that can work with timeout, we implemented timeout mechanism using threads. The `await_notification_response` operation is started in separate thread and after the provided timeout, the started thread is terminated.

Author: Fatme

IOSDeviceLib/Declarations.h

@@ -31,7 +31,6 @@ struct AwaitNotificationResponseInfo
 	std::string response_command_type;
 	std::string response_property_name;
 	SOCKET socket;
-	int timeout;
 };
 
 struct DeviceApplication {

IOSDeviceLib/IOSDeviceLib.cpp

@@ -631,6 +631,30 @@ void install_application(std::string install_path, std::string device_identifier
 	cleanup_file_resources(device_identifier);
 }
 
+void setTimeout(std::function<void()> operation, int timeout) {
+    std::thread([=]() {
+        std::this_thread::sleep_for(std::chrono::milliseconds(timeout * 1000));
+        operation();
+    }).detach();
+}
+
+void* handleThreadOperationEntry(void *data) {
+    auto operation = *(std::function<void ()> *)(data);
+    operation();
+    return nullptr;
+}
+
+void perform_detached_operation_with_timeout(std::string device_identifier, std::string method_id, int timeout, std::function<void ()> operation) {
+    pthread_t thread;
+    pthread_create(&thread, nullptr, handleThreadOperationEntry, &operation);
+    
+    setTimeout([=]() {
+        pthread_cancel(thread);
+        pthread_detach(thread);
+        print_error("Operation timeouted.", device_identifier, method_id);
+    }, timeout);
+}
+
 void perform_detached_operation(void(*operation)(std::string, std::string), std::string arg, std::string method_id)
 {
 	std::thread([operation, arg, method_id]() { operation(arg, method_id);  }).detach();
@@ -1179,8 +1203,7 @@ void await_notification_response(std::string device_identifier, AwaitNotificatio
 	ServiceConnRef connection = serviceConnections[(int)await_notification_response_info.socket];
 	std::string invalid_connection_error_message = "Invalid socket: " + std::to_string(await_notification_response_info.socket);
 	PRINT_ERROR_AND_RETURN_IF_FAILED_RESULT(connection == nullptr, invalid_connection_error_message.c_str(), device_identifier, method_id);
-	
-	ServiceInfo currentNotificationProxy = devices[device_identifier].services[kNotificationProxy];
+
 	std::map<std::string, boost::any> response = receive_con_message(connection);
 	if (response.size())
 	{
@@ -1195,7 +1218,7 @@ void await_notification_response(std::string device_identifier, AwaitNotificatio
 	}
 	else
 	{
-		print_error("ObserveNotification timeout.", device_identifier, method_id);
+		print_error("ObserveNotification failed.", device_identifier, method_id);
 	}
 }
 
@@ -1527,8 +1550,11 @@ int main()
 					SOCKET socket = arg.value(kSocket, 0);
 					int timeout = arg.value(kTimeout, -1);
 
-					AwaitNotificationResponseInfo await_notification_response_info({ response_command_type, response_key_name, socket, timeout });
-					std::thread([=]() { await_notification_response(device_identifier, await_notification_response_info, method_id); }).detach();
+					AwaitNotificationResponseInfo await_notification_response_info({ response_command_type, response_key_name, socket });
+                   
+                    perform_detached_operation_with_timeout(device_identifier, method_id, timeout, [=]() {
+                        await_notification_response(device_identifier, await_notification_response_info, method_id);
+                    });
 				}
 			}
 			else if (method_name == "start")