Add initial support for sendevent to mod_erlang_event

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@10280 d0543943-73ff-0310-b7d9-9358b9ac24b2

diff --git a/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c b/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c
index 69d65fa11cd5d4acb7ffc7d845732df73107751c..861eda978fbe18f3e2eba0048f8ef1f8831dfa48 100644 (file)
--- a/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c
+++ b/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c
@@ -687,6 +687,60 @@ static int handle_msg(listener_t *listener, erlang_msg *msg, ei_x_buff *buf, ei_
                        ei_x_encode_string(rbuf, acs->uuid_str);
 
                        break;
+               } else if (!strncmp(tupletag, "sendevent", MAXATOMLEN)) {
+                       char ename[MAXATOMLEN];
+
+                       if (ei_decode_atom(buf->buff, &buf->index, ename)) {
+                               ei_x_encode_tuple_header(rbuf, 2);
+                               ei_x_encode_atom(rbuf, "error");
+                               ei_x_encode_atom(rbuf, "badarg");
+                               break;
+                       }
+
+                       int headerlength;
+
+                       if (ei_decode_list_header(buf->buff, &buf->index, &headerlength)) {
+                               ei_x_encode_tuple_header(rbuf, 2);
+                               ei_x_encode_atom(rbuf, "error");
+                               ei_x_encode_atom(rbuf, "badarg");
+                               break;
+                       }
+
+                       switch_event_types_t etype;
+                       if (switch_name_event(ename, &etype) == SWITCH_STATUS_SUCCESS) {
+                               switch_event_t *event;
+
+                               if (switch_event_create(&event, etype) == SWITCH_STATUS_SUCCESS) {
+
+                                       char key[1024];
+                                       char value[1024];
+                                       int i = 0;
+                                       while(!ei_decode_tuple_header(buf->buff, &buf->index, &arity) && arity == 2) {
+                                               i++;
+                                               if (ei_decode_string(buf->buff, &buf->index, key))
+                                                       goto sendmsg_fail;
+                                               if (ei_decode_string(buf->buff, &buf->index, value))
+                                                       goto sendmsg_fail;
+
+                                               switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, key, value);
+                                       }
+
+                                       if (headerlength != i)
+                                               goto sendmsg_fail;
+                                       
+
+                                       switch_event_fire(&event);
+                                       ei_x_encode_atom(rbuf, "ok");
+                                       break;
+
+sendmsg_fail:
+                                       ei_x_encode_tuple_header(rbuf, 2);
+                                       ei_x_encode_atom(rbuf, "error");
+                                       ei_x_encode_atom(rbuf, "badarg");
+                                       break;
+                               }
+                       }
+
                } else {
                        ei_x_encode_tuple_header(rbuf, 2);
                        ei_x_encode_atom(rbuf, "error");
@@ -740,7 +794,7 @@ static int handle_msg(listener_t *listener, erlang_msg *msg, ei_x_buff *buf, ei_
                } else if (!strncmp(atom, "exit", MAXATOMLEN)) {
                        switch_clear_flag_locked(listener, LFLAG_RUNNING);
                        ei_x_encode_atom(rbuf, "ok");
-                       goto done;
+                       goto event_done;
                } else {
                        ei_x_encode_tuple_header(rbuf, 2);
                        ei_x_encode_atom(rbuf, "error");
@@ -762,7 +816,7 @@ static int handle_msg(listener_t *listener, erlang_msg *msg, ei_x_buff *buf, ei_
 noreply:
        return 0;
 
-done:
+event_done:
        ei_send(listener->sockfd, &msg->from, rbuf->buff, rbuf->index);
        return 1;
 }