--- libaitmqtt/inc/mqttapi.h	2012/04/25 16:26:38	1.1.2.4
+++ libaitmqtt/inc/mqttapi.h	2012/05/01 01:12:16	1.1.2.5
@@ -3,7 +3,7 @@
 *  by Michael Pounov <misho@openbsd-bg.org>
 *
 * $Author: misho $
-* $Id: mqttapi.h,v 1.1.2.4 2012/04/25 16:26:38 misho Exp $
+* $Id: mqttapi.h,v 1.1.2.5 2012/05/01 01:12:16 misho Exp $
 *
 **************************************************************************
 The ELWIX and AITNET software is distributed under the following
@@ -50,6 +50,7 @@ SUCH DAMAGE.
 #include "aitmqtt.h"
 
 
+#ifdef API_SERVER_SIDE
 /* MQTT server structure & hooks */
 
 /* MQTT command callback. 1st argument is (mqtt_srv_t*) server handle */
@@ -64,7 +65,6 @@ typedef struct {
 #define mqtt_srv_getCmd(x, _cmd)	(assert((x)), (x)->cmds[(_cmd)])
 
 
-#ifdef API_SERVER_SIDE
 /*
  * mqtt_srv_Init() Init server side actor
  *
@@ -100,7 +100,30 @@ int mqtt_srv_Dispatch(mqtt_srv_t * __restrict srv, voi
  */
 int mqtt_KeepAlive(int sock, unsigned short ka, unsigned char tries);
 
+
 #ifdef API_CLIENT_SIDE
+/* MQTT client structure */
+
+typedef struct {
+	int		sock;
+	mqtt_msg_t	*buf;
+} mqtt_cli_t;
+
+
+/*
+ * mqtt_cli_Open() - Open client connection to MQTT broker
+ *
+ * @addr = brokers address
+ * return: NULL error or !=NULL connected to broker
+ */
+mqtt_cli_t *mqtt_cli_Open(struct sockaddr *addr);
+/*
+ * mqtt_cli_Close() - Close client connection
+ *
+ * @cli = connected client
+ * return: -1 error or 0 disconnected client and freed all resources
+ */
+int mqtt_cli_Close(mqtt_cli_t ** __restrict cli);
 #endif