align with custom mqtt client

 - add AITT_CONNET_FAILED
 - allow non IP string for connecting broker

diff --git a/common/MosquittoMQ.cc b/common/MosquittoMQ.cc
index f10532e..1eb0d17 100644 (file)
--- a/common/MosquittoMQ.cc
+++ b/common/MosquittoMQ.cc
@@ -115,7 +115,7 @@ void MosquittoMQ::ConnectCallback(struct mosquitto *mosq, void *obj, int rc, int
 
     std::lock_guard<std::recursive_mutex> lock_from_here(mq->callback_lock);
     if (mq->connect_cb)
-        mq->connect_cb(AITT_CONNECTED);
+        mq->connect_cb((rc == CONNACK_ACCEPTED) ? AITT_CONNECTED : AITT_CONNECT_FAILED);
 }
 
 void MosquittoMQ::DisconnectCallback(struct mosquitto *mosq, void *obj, int rc,
@@ -189,7 +189,7 @@ void MosquittoMQ::MessageCallback(mosquitto *handle, void *obj, const mosquitto_
 
         bool result = AittUtil::CompareTopic(subscribe_data->topic.c_str(), msg->topic);
         if (result)
-            mq->InvokeCallback(msg, props);
+            mq->InvokeCallback(*mq->subscriber_iterator, msg, props);
 
         if (!mq->subscriber_iterator_updated)
             mq->subscriber_iterator++;
@@ -202,8 +202,11 @@ void MosquittoMQ::MessageCallback(mosquitto *handle, void *obj, const mosquitto_
     mq->new_subscribers.clear();
 }
 
-void MosquittoMQ::InvokeCallback(const mosquitto_message *msg, const mosquitto_property *props)
+void MosquittoMQ::InvokeCallback(SubscribeData *subscriber, const mosquitto_message *msg,
+      const mosquitto_property *props)
 {
+    RET_IF(nullptr == subscriber);
+
     MSG mq_msg;
     mq_msg.SetTopic(msg->topic);
     if (props) {
@@ -248,8 +251,7 @@ void MosquittoMQ::InvokeCallback(const mosquitto_message *msg, const mosquitto_p
         }
     }
 
-    SubscribeData *cb_info = *subscriber_iterator;
-    cb_info->cb(&mq_msg, msg->topic, msg->payload, msg->payloadlen, cb_info->user_data);
+    subscriber->cb(&mq_msg, msg->topic, msg->payload, msg->payloadlen, subscriber->user_data);
 }
 
 void MosquittoMQ::Publish(const std::string &topic, const void *data, const size_t datalen, int qos,

diff --git a/common/MosquittoMQ.h b/common/MosquittoMQ.h
index 6c93809..5a55cfc 100644 (file)
--- a/common/MosquittoMQ.h
+++ b/common/MosquittoMQ.h
@@ -63,7 +63,8 @@ class MosquittoMQ : public MQ {
           const mosquitto_property *props);
     static void MessageCallback(mosquitto *, void *, const mosquitto_message *,
           const mosquitto_property *);
-    void InvokeCallback(const mosquitto_message *msg, const mosquitto_property *props);
+    void InvokeCallback(SubscribeData *subscriber, const mosquitto_message *msg,
+          const mosquitto_property *props);
 
     static const std::string REPLY_SEQUENCE_NUM_KEY;
     static const std::string REPLY_IS_END_SEQUENCE_KEY;

diff --git a/include/AittTypes.h b/include/AittTypes.h
index 1770922..37cbf31 100644 (file)
--- a/include/AittTypes.h
+++ b/include/AittTypes.h
@@ -34,8 +34,9 @@ enum AittQoS {
 };
 
 enum AittConnectionState {
-    AITT_DISCONNECTED = 0,  // The connection is disconnected.
-    AITT_CONNECTED = 1,     // A connection was successfully established to the mqtt broker.
+    AITT_DISCONNECTED = 0,    // The connection is disconnected.
+    AITT_CONNECTED = 1,       // A connection was successfully established to the mqtt broker.
+    AITT_CONNECT_FAILED = 2,  // Failed to connect to the mqtt broker.
 };
 
 #ifdef TIZEN

diff --git a/common/AittUtil.h b/include/AittUtil.h
similarity index 100%
rename from common/AittUtil.h
rename to include/AittUtil.h

diff --git a/include/aitt_c.h b/include/aitt_c.h
index 26d0366..043d370 100644 (file)
--- a/include/aitt_c.h
+++ b/include/aitt_c.h
@@ -188,15 +188,15 @@ int aitt_will_set(aitt_h handle, const char *topic, const void *msg, const size_
  * @brief Connect to mqtt broker.
  * @privlevel public
  * @param[in] handle Handle of AITT service
- * @param[in] broker_ip IP address of the broker to connect to
- * @param[in] port the network port to connect to. Usually 1883.
+ * @param[in] host Identifier of the broker usually it's IP address of the broker to connect to
+ * @param[in] port the network port to connect to. Usually 1883. Ignored if not required.
  * @return @c 0 on success
  *         otherwise a negative error value
  * @retval #AITT_ERROR_NONE  Success
  * @retval #AITT_ERROR_INVALID_PARAMETER Invalid parameter
  * @retval #AITT_ERROR_SYSTEM System errors
  */
-int aitt_connect(aitt_h handle, const char *broker_ip, int port);
+int aitt_connect(aitt_h handle, const char *host, int port);
 
 /**
  * @brief Connect to mqtt broker as aitt_connect(), but takes username and password.

diff --git a/src/aitt_c.cc b/src/aitt_c.cc
index dc33baf..d2f68db 100644 (file)
--- a/src/aitt_c.cc
+++ b/src/aitt_c.cc
@@ -27,6 +27,7 @@ struct aitt_handle {
     aitt_handle() : aitt(nullptr) {}
     AITT *aitt;
     bool connected;
+    bool custom_broker;
 };
 
 struct aitt_option {
@@ -42,6 +43,7 @@ API aitt_h aitt_new(const char *id, aitt_option_h option)
         std::string valid_id;
         std::string valid_ip;
         AittOption aitt_option;
+        bool custom_broker = false;
 
         if (id)
             valid_id = id;
@@ -51,11 +53,13 @@ API aitt_h aitt_new(const char *id, aitt_option_h option)
                 valid_ip = option->my_ip;
             aitt_option.SetClearSession(option->clear_session);
             aitt_option.SetUseCustomMqttBroker(option->custom_broker);
+            custom_broker = option->custom_broker;
         }
 
         handle = new aitt_handle();
         handle->aitt = new AITT(valid_id, valid_ip, aitt_option);
         handle->connected = false;
+        handle->custom_broker = custom_broker;
     } catch (std::exception &e) {
         ERR("new() Fail(%s)", e.what());
         return nullptr;
@@ -191,23 +195,25 @@ static bool is_valid_ip(const char *ip)
     return true;
 }
 
-API int aitt_connect(aitt_h handle, const char *broker_ip, int port)
+API int aitt_connect(aitt_h handle, const char *host, int port)
 {
-    return aitt_connect_full(handle, broker_ip, port, NULL, NULL);
+    return aitt_connect_full(handle, host, port, NULL, NULL);
 }
 
-API int aitt_connect_full(aitt_h handle, const char *broker_ip, int port, const char *username,
+API int aitt_connect_full(aitt_h handle, const char *host, int port, const char *username,
       const char *password)
 {
     RETV_IF(handle == nullptr, AITT_ERROR_INVALID_PARAMETER);
-    RETVM_IF(is_valid_ip(broker_ip) == false, AITT_ERROR_INVALID_PARAMETER, "Invalid IP(%s)",
-          broker_ip);
+    if (handle->custom_broker)
+        RETV_IF(host == nullptr, AITT_ERROR_INVALID_PARAMETER);
+    else
+        RETVM_IF(!is_valid_ip(host), AITT_ERROR_INVALID_PARAMETER, "Invalid IP(%s)", host);
 
     try {
-        handle->aitt->Connect(broker_ip, port, username ? username : std::string(),
+        handle->aitt->Connect(host, port, username ? username : std::string(),
               password ? password : std::string());
     } catch (std::exception &e) {
-        ERR("Connect(%s, %d) Fail(%s)", broker_ip, port, e.what());
+        ERR("Connect(%s, %d) Fail(%s)", host, port, e.what());
         return AITT_ERROR_SYSTEM;
     }