FS-9310 Native support for Flowroute SMS API over HTTP(S)

build/modules.conf.in

@@ -40,6 +40,7 @@ applications/mod_httapi
 #applications/mod_redis
 #applications/mod_rss
 applications/mod_sms
+#applications/mod_sms_flowroute
 #applications/mod_snapshot
 #applications/mod_snom
 #applications/mod_sonar

conf/vanilla/autoload_configs/modules.conf.xml

@@ -71,6 +71,7 @@
     <!--<load module="mod_fsk"/>-->
     <!--<load module="mod_spy"/>-->
     <!--<load module="mod_sms"/>-->
+    <!--<load module="mod_sms_flowroute"/>-->
     <!--<load module="mod_smpp"/>-->
     <!--<load module="mod_random"/>-->
     <load module="mod_httapi"/>

conf/vanilla/autoload_configs/sms_flowroute.conf.xml

+<configuration name="sms_flowroute.conf" description="SMS_FLOWROUTE send configs">
+  <profiles>
+    <profile name="default">
+      <params>
+	<param name="host" value="https://api.flowroute.com/v2/messages"/>
+	<param name="debug" value="1"/>
+	<param name="port" value="8090"/>
+	<param name="access-key" value="ACCESS-KEY"/>
+	<param name="secret-key" value="SECRET-KEY"/>
+      </params>
+    </profile>
+  </profiles>
+</configuration>

conf/vanilla/chatplan/default.xml

@@ -6,7 +6,7 @@
       <condition field="to" expression="^(.*)$">
 	<!--	<action application="lua" data="test.lua"/> -->
 
-	<action application="reply" data="Hello, you said: ${_body}"/>
+	<action application="reply" data="Hello, you said: ${body}"/>
       </condition>
     </extension>
 

configure.ac

@@ -1413,6 +1413,18 @@ PKG_CHECK_MODULES([AMQP], [librabbitmq >= 0.5.2],[
   AM_CONDITIONAL([HAVE_AMQP],[true])],[
   AC_MSG_RESULT([no]); AM_CONDITIONAL([HAVE_AMQP],[false])])
 
+PKG_CHECK_MODULES([H2O], [libh2o-evloop >= 0.11.0],[
+  AM_CONDITIONAL([HAVE_H2O],[true])],[
+  AC_MSG_RESULT([no]); AM_CONDITIONAL([HAVE_H2O],[false])])
+
+PKG_CHECK_MODULES([BROTLIENC], [libbrotlienc >= 0.1.0],[
+  AM_CONDITIONAL([HAVE_BROTLIENC],[true])],[
+  AC_MSG_RESULT([no]); AM_CONDITIONAL([HAVE_BROTLIENC],[false])])
+
+PKG_CHECK_MODULES([BROTLIDEC], [libbrotlidec >= 0.1.0],[
+  AM_CONDITIONAL([HAVE_BROTLIDEC],[true])],[
+  AC_MSG_RESULT([no]); AM_CONDITIONAL([HAVE_BROTLIDEC],[false])])
+
 PKG_CHECK_MODULES([TAP], [tap >= 0.1.0],[
   AM_CONDITIONAL([HAVE_TAP],[true])],[
   AC_MSG_RESULT([no]); AM_CONDITIONAL([HAVE_TAP],[false])])
@@ -1746,6 +1758,7 @@ AC_CONFIG_FILES([Makefile
 		src/mod/applications/mod_rss/Makefile
 		src/mod/applications/mod_skel/Makefile
 		src/mod/applications/mod_sms/Makefile
+		src/mod/applications/mod_sms_flowroute/Makefile
 		src/mod/applications/mod_snapshot/Makefile
 		src/mod/applications/mod_snom/Makefile
 		src/mod/applications/mod_sonar/Makefile

src/mod/applications/mod_sms_flowroute/Makefile.am

+include $(top_srcdir)/build/modmake.rulesam
+MODNAME=mod_sms_flowroute
+
+if HAVE_H2O
+
+mod_LTLIBRARIES = mod_sms_flowroute.la
+mod_sms_flowroute_la_SOURCES  = mod_sms_flowroute.c
+mod_sms_flowroute_la_CFLAGS   = $(AM_CFLAGS) $(H2O_CFLAGS) $(BROTLIENC_CFLAGS) $(BROTLIDEC_CFLAGS)
+mod_sms_flowroute_la_LIBADD   = $(switch_builddir)/libfreeswitch.la
+mod_sms_flowroute_la_LDFLAGS  = -avoid-version -module -no-undefined -shared $(H2O_LIBS) $(BROTLIENC_LIBS) $(BROTLIDEC_LIBS) $(SWITCH_AM_LDFLAGS)
+
+else
+install: error
+all: error
+error:
+	$(error You must install libh2o and libh2o-dev to build this module)
+endif

src/mod/applications/mod_sms_flowroute/TODO.txt

+
+
+
+
+
+For inbound, these are known leaks on per module load(not per message). These will likely require additions to libh2o to add a destroy function.
+
+=================================================================
+==4164==ERROR: LeakSanitizer: detected memory leaks
+
+Direct leak of 1104 byte(s) in 26 object(s) allocated from:
+    #0 0x4c1e28 in __interceptor_malloc (/usr/local/freeswitch_sms_flowroute/bin/freeswitch+0x4c1e28)
+        #1 0x7f868d71acbd in wcsdup /build/glibc-h_iKOs/glibc-2.19/wcsmbs/wcsdup.c:30
+
+Direct leak of 184 byte(s) in 1 object(s) allocated from:
+    #0 0x4c1e28 in __interceptor_malloc (/usr/local/freeswitch_sms_flowroute/bin/freeswitch+0x4c1e28)
+        #1 0x7f867cdcbaee in h2o_mem_alloc /usr/src/h2o/include/h2o/memory.h:298
+	    #2 0x7f867cdcbaee in create_socket /usr/src/h2o/lib/common/socket/evloop.c.h:361
+
+Indirect leak of 184 byte(s) in 1 object(s) allocated from:
+    #0 0x4c1e28 in __interceptor_malloc (/usr/local/freeswitch_sms_flowroute/bin/freeswitch+0x4c1e28)
+        #1 0x7f867cdcbaee in h2o_mem_alloc /usr/src/h2o/include/h2o/memory.h:298
+	    #2 0x7f867cdcbaee in create_socket /usr/src/h2o/lib/common/socket/evloop.c.h:361
+
+Indirect leak of 88 byte(s) in 1 object(s) allocated from:
+    #0 0x4c1e28 in __interceptor_malloc (/usr/local/freeswitch_sms_flowroute/bin/freeswitch+0x4c1e28)
+        #1 0x7f867cdc9e12 in h2o_mem_alloc /usr/src/h2o/include/h2o/memory.h:298
+	    #2 0x7f867cdc9e12 in h2o_multithread_create_queue /usr/src/h2o/lib/common/multithread.c:106
+
+SUMMARY: AddressSanitizer: 1560 byte(s) leaked in 29 allocation(s).

src/mod/applications/mod_sms_flowroute/mod_sms_flowroute.h

+/*
+* FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
+* Copyright (C) 2005-2012, Anthony Minessale II <anthm@freeswitch.org>
+*
+* Version: MPL 1.1
+*
+* The contents of this file are subject to the Mozilla Public License Version
+* 1.1 (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+* http://www.mozilla.org/MPL/
+*
+* Software distributed under the License is distributed on an "AS IS" basis,
+* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
+* for the specific language governing rights and limitations under the
+* License.
+*
+* The Original Code is FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
+*
+* The Initial Developer of the Original Code is
+* Anthony Minessale II <anthm@freeswitch.org>
+* Portions created by the Initial Developer are Copyright (C)
+* the Initial Developer. All Rights Reserved.
+*
+* Based on mod_skel by
+* Anthony Minessale II <anthm@freeswitch.org>
+*
+* Contributor(s):
+*
+* William King <william.king@quentustech.com>
+*
+* mod_sms_flowroute.c SMS support for Flowroute SMS
+*
+*/
+
+#ifndef MOD_SMS_FLOWROUTE_H
+#define MOD_SMS_FLOWROUTE_H
+
+#define H2O_USE_LIBUV 0
+#define H2O_USE_BROTLI 1
+
+#include <switch.h>
+#include "h2o.h"
+#include "h2o/http1client.h"
+
+typedef struct {
+  char *name;
+  int port;
+  int debug;
+  int running;
+  char *host;
+
+  char *access_key;
+  char *secret_key;
+
+  unsigned char auth_b64[512];
+  int auth_b64_size;
+  
+  h2o_url_t url_parsed;
+  h2o_socketpool_t *sockpool;
+
+  h2o_globalconf_t h2o_globalconf;
+  h2o_hostconf_t *h2o_hostconf;
+  h2o_pathconf_t *h2o_pathconf;
+  h2o_handler_t *h2o_handler;
+  h2o_context_t h2o_context;
+  h2o_accept_ctx_t *h2o_accept_context;
+  h2o_multithread_queue_t *queue;
+
+  switch_thread_t *profile_thread;
+  switch_memory_pool_t *pool;
+} mod_sms_flowroute_profile_t;
+
+typedef struct {
+  h2o_http1client_ctx_t ctx;
+  mod_sms_flowroute_profile_t *profile;
+  switch_mutex_t *mutex;
+  h2o_iovec_t req;
+  int status;
+  h2o_multithread_receiver_t getaddr_receiver;
+  h2o_timeout_t io_timeout;
+} mod_sms_flowroute_message_t;
+
+typedef struct mod_sms_flowroute_globals_s {
+  switch_memory_pool_t *pool;
+  switch_hash_t *profile_hash;
+  int debug;
+} mod_sms_flowroute_globals_t;
+
+extern mod_sms_flowroute_globals_t mod_sms_flowroute_globals;
+
+
+#endif /* MOD_SMS_FLOWROUTE_H */
+