Add mosquitto_client_port() for plugins.

ChangeLog.txt

@@ -55,6 +55,7 @@ Broker:
   command. This is disabled by default, but can be enabled with the
   `enable_control_api` option.
 - Add support for `getPluginInfo` to mosquitto_ctrl.
+- Add `mosquitto_client_port()` function for plugins.
 
 Client library:
 - Add MOSQ_OPT_DISABLE_SOCKETPAIR to allow the disabling of the socketpair

include/mosquitto_broker.h

@@ -374,6 +374,14 @@ mosq_EXPORT void mosquitto_log_printf(int level, const char *fmt, ...);
 mosq_EXPORT const char *mosquitto_client_address(const struct mosquitto *client);
 
 
+/*
+ * Function: mosquitto_client_address
+ *
+ * Retrieve the network port number the client connected to, or 0 on error.
+ */
+mosq_EXPORT int mosquitto_client_port(const struct mosquitto *client);
+
+
 /*
  * Function: mosquitto_client_clean_session
  *

src/linker-macosx.syms

@@ -1,4 +1,4 @@
-_mosquitto_broker_publish
+t_mosquitto_broker_publish
 _mosquitto_broker_publish_copy
 _mosquitto_callback_register
 _mosquitto_callback_unregister
@@ -8,6 +8,7 @@ _mosquitto_client_certificate
 _mosquitto_client_clean_session
 _mosquitto_client_id
 _mosquitto_client_keepalive
+_mosquitto_client_port
 _mosquitto_client_protocol
 _mosquitto_client_protocol_version
 _mosquitto_client_sub_count

src/linker.syms

@@ -9,6 +9,7 @@
 	mosquitto_client_clean_session;
 	mosquitto_client_id;
 	mosquitto_client_keepalive;
+	mosquitto_client_port;
 	mosquitto_client_protocol;
 	mosquitto_client_protocol_version;
 	mosquitto_client_sub_count;

src/plugin_public.c

@@ -60,6 +60,16 @@ const char *mosquitto_client_address(const struct mosquitto *client)
 }
 
 
+int mosquitto_client_port(const struct mosquitto *client)
+{
+	if(client && client->listener){
+		return client->listener->port;
+	}else{
+		return 0;
+	}
+}
+
+
 bool mosquitto_client_clean_session(const struct mosquitto *client)
 {
 	if(client){