From e3e00a99b12b2557de5331dfc822c303cf9a5241 Mon Sep 17 00:00:00 2001
From: huangdan <wang_yi20081014@163.com>
Date: Sun, 25 Sep 2016 07:40:36 +0800
Subject: [PATCH] alarm test

---
 test/emqttd_SUITE.erl | 28 +++++++++++++++++++++++++++-
 1 file changed, 27 insertions(+), 1 deletion(-)

diff --git a/test/emqttd_SUITE.erl b/test/emqttd_SUITE.erl
index 41ad9f60e..c56068885 100644
--- a/test/emqttd_SUITE.erl
+++ b/test/emqttd_SUITE.erl
@@ -39,6 +39,7 @@ all() ->
      {group, http},
      {group, cluster},
      %%{group, backend},
+     {group, alarms},
      {group, cli}].
 
 groups() ->
@@ -70,6 +71,7 @@ groups() ->
     {http, [sequence], 
      [request_status,
       request_publish
+     % websocket_test
      ]},
     {cluster, [sequence],
      [cluster_test,
@@ -79,6 +81,9 @@ groups() ->
       cluster_remove2,
       cluster_node_down
      ]},
+     {alarms, [sequence], 
+     [set_alarms]
+     },
      {cli, [sequence],
       [ctl_register_cmd,
        cli_status,
@@ -387,6 +392,18 @@ auth_header_(User, Pass) ->
     Encoded = base64:encode_to_string(lists:append([User,":",Pass])),
     {"Authorization","Basic " ++ Encoded}.
 
+websocket_test(_) ->
+%    Conn = esockd_connection:new(esockd_transport, nil, []),
+%    Req = mochiweb_request:new(Conn, 'GET', "/mqtt", {1, 1}, 
+%                                mochiweb_headers:make([{"Sec-WebSocket-Protocol","mqtt"},
+%                                                       {"Upgrade","websocket"}
+%                                                      ])),
+    Req = "GET " ++ "/mqtt" ++" HTTP/1.1\r\nUpgrade: WebSocket\r\nConnection: Upgrade\r\n" ++ 
+	"Host: " ++ "127.0.0.1"++ "\r\n" ++
+	"Origin: http://" ++ "127.0.0.1" ++ "/\r\n\r\n",
+
+    ct:log("Req:~p", [Req]),
+    emqttd_http:handle_request(Req).
 %%--------------------------------------------------------------------
 %% cluster group
 %%--------------------------------------------------------------------
@@ -461,7 +478,16 @@ cluster_node_down(_) ->
     timer:sleep(1000),
     Routes = lists:sort(emqttd_router:match(<<"a/b/c">>)).
 
- 
+set_alarms(_) ->
+    AlarmTest = #mqtt_alarm{id = <<"1">>, severity = error, title="alarm title", summary="alarm summary"},
+    emqttd_alarm:set_alarm(AlarmTest),
+    Alarms = emqttd_alarm:get_alarms(),
+    ?assertEqual(1, length(Alarms)),
+    emqttd_alarm:clear_alarm(<<"1">>),
+    [] = emqttd_alarm:get_alarms().
+
+
+
 %%--------------------------------------------------------------------
 %% Cli group
 %%--------------------------------------------------------------------