Skip to content

N
nginx-push-stream-module
Commit b47737b8 authored by Marek Janda's avatar Marek Janda Committed by Wandenberg
Browse files
Options

remove quotes from integers values on JSON statistics (being possible to use... 

remove quotes from integers values on JSON statistics (being possible to use tools like InfluxData Telegraf)
parent 5d50f46f
Show whitespace changes
Inline Side-by-side
Showing with 74 additions and 74 deletions
include/ngx_http_push_stream_module_utils.h
View file @ b47737b8
...@@ -62,14 +62,14 @@ static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNELS_INFO_SUMMARIZED_WORKER_LAST_ITEM ...@@ -62,14 +62,14 @@ static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNELS_INFO_SUMMARIZED_WORKER_LAST_ITEM
static ngx_str_t NGX_HTTP_PUSH_STREAM_CONTENT_TYPE_PLAIN = ngx_string("text/plain"); static ngx_str_t NGX_HTTP_PUSH_STREAM_CONTENT_TYPE_PLAIN = ngx_string("text/plain");
#define NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON_PATTERN "{\"channel\": \"%s\", \"published_messages\": \"%ui\", \"stored_messages\": \"%ui\", \"subscribers\": \"%ui\"}" #define NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON_PATTERN "{\"channel\": \"%s\", \"published_messages\": %ui, \"stored_messages\": %ui, \"subscribers\": %ui}"
#define NGX_HTTP_PUSH_STREAM_WORKER_INFO_JSON_PATTERN "{\"pid\": \"%d\", \"subscribers\": \"%ui\", \"uptime\": \"%ui\"}" #define NGX_HTTP_PUSH_STREAM_WORKER_INFO_JSON_PATTERN "{\"pid\": \"%d\", \"subscribers\": %ui, \"uptime\": %ui}"
static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON_PATTERN CRLF); static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON_PATTERN CRLF);
static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_GROUP_HEAD_JSON = ngx_string("{\"hostname\": \"%s\", \"time\": \"%s\", \"channels\": \"%ui\", \"wildcard_channels\": \"%ui\", \"uptime\": \"%ui\", \"infos\": [" CRLF); static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_GROUP_HEAD_JSON = ngx_string("{\"hostname\": \"%s\", \"time\": \"%s\", \"channels\": %ui, \"wildcard_channels\": %ui, \"uptime\": %ui, \"infos\": [" CRLF);
static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_GROUP_TAIL_JSON = ngx_string("]}" CRLF); static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_GROUP_TAIL_JSON = ngx_string("]}" CRLF);
static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_GROUP_ITEM_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON_PATTERN "," CRLF); static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_GROUP_ITEM_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON_PATTERN "," CRLF);
static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_GROUP_LAST_ITEM_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON_PATTERN CRLF); static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_GROUP_LAST_ITEM_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_CHANNEL_INFO_JSON_PATTERN CRLF);
static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNELS_INFO_SUMMARIZED_JSON = ngx_string("{\"hostname\": \"%s\", \"time\": \"%s\", \"channels\": \"%ui\", \"wildcard_channels\": \"%ui\", \"published_messages\": \"%ui\", \"stored_messages\": \"%ui\", \"messages_in_trash\": \"%ui\", \"channels_in_trash\": \"%ui\", \"subscribers\": \"%ui\", \"uptime\": \"%ui\", \"by_worker\": [" CRLF "%s" CRLF"]}" CRLF); static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNELS_INFO_SUMMARIZED_JSON = ngx_string("{\"hostname\": \"%s\", \"time\": \"%s\", \"channels\": %ui, \"wildcard_channels\": %ui, \"published_messages\": %ui, \"stored_messages\": %ui, \"messages_in_trash\": %ui, \"channels_in_trash\": %ui, \"subscribers\": %ui, \"uptime\": %ui, \"by_worker\": [" CRLF "%s" CRLF"]}" CRLF);
static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNELS_INFO_SUMMARIZED_WORKER_ITEM_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_WORKER_INFO_JSON_PATTERN "," CRLF); static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNELS_INFO_SUMMARIZED_WORKER_ITEM_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_WORKER_INFO_JSON_PATTERN "," CRLF);
static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNELS_INFO_SUMMARIZED_WORKER_LAST_ITEM_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_WORKER_INFO_JSON_PATTERN); static ngx_str_t NGX_HTTP_PUSH_STREAM_CHANNELS_INFO_SUMMARIZED_WORKER_LAST_ITEM_JSON = ngx_string(NGX_HTTP_PUSH_STREAM_WORKER_INFO_JSON_PATTERN);
static ngx_str_t NGX_HTTP_PUSH_STREAM_CONTENT_TYPE_JSON = ngx_string("application/json"); static ngx_str_t NGX_HTTP_PUSH_STREAM_CONTENT_TYPE_JSON = ngx_string("application/json");
......
misc/spec/mix/channel_statistics_spec.rb
View file @ b47737b8
...@@ -44,9 +44,9 @@ shared_examples_for "statistics location" do ...@@ -44,9 +44,9 @@ shared_examples_for "statistics location" do
response = JSON.parse(actual_response) response = JSON.parse(actual_response)
expect(response["channel"].to_s).to eql(channel) expect(response["channel"].to_s).to eql(channel)
expect(response["published_messages"].to_i).to eql(1) expect(response["published_messages"]).to eql(1)
expect(response["stored_messages"].to_i).to eql(1) expect(response["stored_messages"]).to eql(1)
expect(response["subscribers"].to_i).to eql(0) expect(response["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -64,9 +64,9 @@ shared_examples_for "statistics location" do ...@@ -64,9 +64,9 @@ shared_examples_for "statistics location" do
expect(pub_1).to be_http_status(200) expect(pub_1).to be_http_status(200)
response = JSON.parse(pub_1.response) response = JSON.parse(pub_1.response)
expect(response["channel"].to_s).to eql(channel) expect(response["channel"].to_s).to eql(channel)
expect(response["published_messages"].to_i).to eql(0) expect(response["published_messages"]).to eql(0)
expect(response["stored_messages"].to_i).to eql(0) expect(response["stored_messages"]).to eql(0)
expect(response["subscribers"].to_i).to eql(1) expect(response["subscribers"]).to eql(1)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -112,9 +112,9 @@ shared_examples_for "statistics location" do ...@@ -112,9 +112,9 @@ shared_examples_for "statistics location" do
response = JSON.parse(actual_response) response = JSON.parse(actual_response)
expect(response["infos"].length).to eql(1) expect(response["infos"].length).to eql(1)
expect(response["infos"][0]["channel"].to_s).to eql(channel) expect(response["infos"][0]["channel"].to_s).to eql(channel)
expect(response["infos"][0]["published_messages"].to_i).to eql(1) expect(response["infos"][0]["published_messages"]).to eql(1)
expect(response["infos"][0]["stored_messages"].to_i).to eql(1) expect(response["infos"][0]["stored_messages"]).to eql(1)
expect(response["infos"][0]["subscribers"].to_i).to eql(0) expect(response["infos"][0]["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -135,12 +135,12 @@ shared_examples_for "statistics location" do ...@@ -135,12 +135,12 @@ shared_examples_for "statistics location" do
expect(pub_2).to be_http_status(200) expect(pub_2).to be_http_status(200)
response = JSON.parse(pub_2.response) response = JSON.parse(pub_2.response)
expect(response["infos"].length).to eql(1) expect(response["infos"].length).to eql(1)
expect(response["channels"].to_i).to eql(0) expect(response["channels"]).to eql(0)
expect(response["wildcard_channels"].to_i).to eql(1) expect(response["wildcard_channels"]).to eql(1)
expect(response["infos"][0]["channel"].to_s).to eql(channel) expect(response["infos"][0]["channel"].to_s).to eql(channel)
expect(response["infos"][0]["published_messages"].to_i).to eql(1) expect(response["infos"][0]["published_messages"]).to eql(1)
expect(response["infos"][0]["stored_messages"].to_i).to eql(1) expect(response["infos"][0]["stored_messages"]).to eql(1)
expect(response["infos"][0]["subscribers"].to_i).to eql(0) expect(response["infos"][0]["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -159,9 +159,9 @@ shared_examples_for "statistics location" do ...@@ -159,9 +159,9 @@ shared_examples_for "statistics location" do
response = JSON.parse(pub_1.response) response = JSON.parse(pub_1.response)
expect(response["infos"].length).to eql(1) expect(response["infos"].length).to eql(1)
expect(response["infos"][0]["channel"].to_s).to eql(channel) expect(response["infos"][0]["channel"].to_s).to eql(channel)
expect(response["infos"][0]["published_messages"].to_i).to eql(0) expect(response["infos"][0]["published_messages"]).to eql(0)
expect(response["infos"][0]["stored_messages"].to_i).to eql(0) expect(response["infos"][0]["stored_messages"]).to eql(0)
expect(response["infos"][0]["subscribers"].to_i).to eql(1) expect(response["infos"][0]["subscribers"]).to eql(1)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -176,7 +176,7 @@ shared_examples_for "statistics location" do ...@@ -176,7 +176,7 @@ shared_examples_for "statistics location" do
expect(pub_1).to be_http_status(200) expect(pub_1).to be_http_status(200)
response = JSON.parse(pub_1.response) response = JSON.parse(pub_1.response)
expect(response.has_key?("channels")).to be_truthy expect(response.has_key?("channels")).to be_truthy
expect(response["channels"].to_i).to eql(0) expect(response["channels"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -207,9 +207,9 @@ shared_examples_for "statistics location" do ...@@ -207,9 +207,9 @@ shared_examples_for "statistics location" do
response = JSON.parse(actual_response) response = JSON.parse(actual_response)
expect(response.has_key?("channels")).to be_truthy expect(response.has_key?("channels")).to be_truthy
expect(response["channels"].to_i).to eql(1) expect(response["channels"]).to eql(1)
expect(response["published_messages"].to_i).to eql(1) expect(response["published_messages"]).to eql(1)
expect(response["subscribers"].to_i).to eql(0) expect(response["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -230,10 +230,10 @@ shared_examples_for "statistics location" do ...@@ -230,10 +230,10 @@ shared_examples_for "statistics location" do
expect(pub_2).to be_http_status(200) expect(pub_2).to be_http_status(200)
response = JSON.parse(pub_2.response) response = JSON.parse(pub_2.response)
expect(response.has_key?("channels")).to be_truthy expect(response.has_key?("channels")).to be_truthy
expect(response["channels"].to_i).to eql(0) expect(response["channels"]).to eql(0)
expect(response["wildcard_channels"].to_i).to eql(1) expect(response["wildcard_channels"]).to eql(1)
expect(response["published_messages"].to_i).to eql(1) expect(response["published_messages"]).to eql(1)
expect(response["subscribers"].to_i).to eql(0) expect(response["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -251,9 +251,9 @@ shared_examples_for "statistics location" do ...@@ -251,9 +251,9 @@ shared_examples_for "statistics location" do
expect(pub_1).to be_http_status(200) expect(pub_1).to be_http_status(200)
response = JSON.parse(pub_1.response) response = JSON.parse(pub_1.response)
expect(response.has_key?("channels")).to be_truthy expect(response.has_key?("channels")).to be_truthy
expect(response["channels"].to_i).to eql(1) expect(response["channels"]).to eql(1)
expect(response["published_messages"].to_i).to eql(0) expect(response["published_messages"]).to eql(0)
expect(response["subscribers"].to_i).to eql(1) expect(response["subscribers"]).to eql(1)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -410,9 +410,9 @@ shared_examples_for "statistics location" do ...@@ -410,9 +410,9 @@ shared_examples_for "statistics location" do
response = JSON.parse(pub_2.response) response = JSON.parse(pub_2.response)
expect(response["infos"].length).to eql(1) expect(response["infos"].length).to eql(1)
expect(response["infos"][0]["channel"].to_s).to eql(channel) expect(response["infos"][0]["channel"].to_s).to eql(channel)
expect(response["infos"][0]["published_messages"].to_i).to eql(1) expect(response["infos"][0]["published_messages"]).to eql(1)
expect(response["infos"][0]["stored_messages"].to_i).to eql(1) expect(response["infos"][0]["stored_messages"]).to eql(1)
expect(response["infos"][0]["subscribers"].to_i).to eql(0) expect(response["infos"][0]["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -436,13 +436,13 @@ shared_examples_for "statistics location" do ...@@ -436,13 +436,13 @@ shared_examples_for "statistics location" do
response = JSON.parse(pub_2.response) response = JSON.parse(pub_2.response)
expect(response["infos"].length).to eql(2) expect(response["infos"].length).to eql(2)
expect(response["infos"][0]["channel"].to_s).to eql(channel) expect(response["infos"][0]["channel"].to_s).to eql(channel)
expect(response["infos"][0]["published_messages"].to_i).to eql(1) expect(response["infos"][0]["published_messages"]).to eql(1)
expect(response["infos"][0]["stored_messages"].to_i).to eql(1) expect(response["infos"][0]["stored_messages"]).to eql(1)
expect(response["infos"][0]["subscribers"].to_i).to eql(0) expect(response["infos"][0]["subscribers"]).to eql(0)
expect(response["infos"][1]["channel"].to_s).to eql(channel_1) expect(response["infos"][1]["channel"].to_s).to eql(channel_1)
expect(response["infos"][1]["published_messages"].to_i).to eql(1) expect(response["infos"][1]["published_messages"]).to eql(1)
expect(response["infos"][1]["stored_messages"].to_i).to eql(1) expect(response["infos"][1]["stored_messages"]).to eql(1)
expect(response["infos"][1]["subscribers"].to_i).to eql(0) expect(response["infos"][1]["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -463,12 +463,12 @@ shared_examples_for "statistics location" do ...@@ -463,12 +463,12 @@ shared_examples_for "statistics location" do
expect(pub_2).to be_http_status(200) expect(pub_2).to be_http_status(200)
response = JSON.parse(pub_2.response) response = JSON.parse(pub_2.response)
expect(response["infos"].length).to eql(1) expect(response["infos"].length).to eql(1)
expect(response["channels"].to_i).to eql(0) expect(response["channels"]).to eql(0)
expect(response["wildcard_channels"].to_i).to eql(1) expect(response["wildcard_channels"]).to eql(1)
expect(response["infos"][0]["channel"].to_s).to eql(channel) expect(response["infos"][0]["channel"].to_s).to eql(channel)
expect(response["infos"][0]["published_messages"].to_i).to eql(1) expect(response["infos"][0]["published_messages"]).to eql(1)
expect(response["infos"][0]["stored_messages"].to_i).to eql(1) expect(response["infos"][0]["stored_messages"]).to eql(1)
expect(response["infos"][0]["subscribers"].to_i).to eql(0) expect(response["infos"][0]["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -487,9 +487,9 @@ shared_examples_for "statistics location" do ...@@ -487,9 +487,9 @@ shared_examples_for "statistics location" do
response = JSON.parse(pub_1.response) response = JSON.parse(pub_1.response)
expect(response["infos"].length).to eql(1) expect(response["infos"].length).to eql(1)
expect(response["infos"][0]["channel"].to_s).to eql(channel) expect(response["infos"][0]["channel"].to_s).to eql(channel)
expect(response["infos"][0]["published_messages"].to_i).to eql(0) expect(response["infos"][0]["published_messages"]).to eql(0)
expect(response["infos"][0]["stored_messages"].to_i).to eql(0) expect(response["infos"][0]["stored_messages"]).to eql(0)
expect(response["infos"][0]["subscribers"].to_i).to eql(1) expect(response["infos"][0]["subscribers"]).to eql(1)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -549,7 +549,7 @@ shared_examples_for "statistics location" do ...@@ -549,7 +549,7 @@ shared_examples_for "statistics location" do
pub_3.callback do pub_3.callback do
expect(pub_3).to be_http_status(200) expect(pub_3).to be_http_status(200)
response = JSON.parse(pub_3.response) response = JSON.parse(pub_3.response)
expect(response["uptime"].to_i).to be_in_the_interval(2, 3) expect(response["uptime"]).to be_in_the_interval(2, 3)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -586,8 +586,8 @@ shared_examples_for "statistics location" do ...@@ -586,8 +586,8 @@ shared_examples_for "statistics location" do
pub_3.callback do pub_3.callback do
expect(pub_3).to be_http_status(200) expect(pub_3).to be_http_status(200)
response = JSON.parse(pub_3.response) response = JSON.parse(pub_3.response)
expect(response["uptime"].to_i).to be_in_the_interval(2, 3) expect(response["uptime"]).to be_in_the_interval(2, 3)
expect(response["by_worker"][0]["uptime"].to_i).to be_in_the_interval(2, 3) expect(response["by_worker"][0]["uptime"]).to be_in_the_interval(2, 3)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -608,16 +608,16 @@ shared_examples_for "statistics location" do ...@@ -608,16 +608,16 @@ shared_examples_for "statistics location" do
pub_2.callback do pub_2.callback do
expect(pub_2).to be_http_status(200) expect(pub_2).to be_http_status(200)
response = JSON.parse(pub_2.response) response = JSON.parse(pub_2.response)
expect(response["stored_messages"].to_i).to eql(1) expect(response["stored_messages"]).to eql(1)
expect(response["messages_in_trash"].to_i).to eql(0) expect(response["messages_in_trash"]).to eql(0)
sleep(5) sleep(5)
pub_3 = EventMachine::HttpRequest.new(nginx_address + '/channels-stats').get :head => headers pub_3 = EventMachine::HttpRequest.new(nginx_address + '/channels-stats').get :head => headers
pub_3.callback do pub_3.callback do
expect(pub_3).to be_http_status(200) expect(pub_3).to be_http_status(200)
response = JSON.parse(pub_3.response) response = JSON.parse(pub_3.response)
expect(response["stored_messages"].to_i).to eql(0) expect(response["stored_messages"]).to eql(0)
expect(response["messages_in_trash"].to_i).to eql(1) expect(response["messages_in_trash"]).to eql(1)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -640,9 +640,9 @@ shared_examples_for "statistics location" do ...@@ -640,9 +640,9 @@ shared_examples_for "statistics location" do
pub_2.callback do pub_2.callback do
expect(pub_2).to be_http_status(200) expect(pub_2).to be_http_status(200)
response = JSON.parse(pub_2.response) response = JSON.parse(pub_2.response)
expect(response["channels"].to_i).to eql(2) expect(response["channels"]).to eql(2)
expect(response["wildcard_channels"].to_i).to eql(1) expect(response["wildcard_channels"]).to eql(1)
expect(response["channels_in_trash"].to_i).to eql(0) expect(response["channels_in_trash"]).to eql(0)
pub = EventMachine::HttpRequest.new(nginx_address + '/pub?id=' + channel.to_s).delete :head => headers pub = EventMachine::HttpRequest.new(nginx_address + '/pub?id=' + channel.to_s).delete :head => headers
pub.callback do pub.callback do
...@@ -654,9 +654,9 @@ shared_examples_for "statistics location" do ...@@ -654,9 +654,9 @@ shared_examples_for "statistics location" do
pub_3.callback do pub_3.callback do
expect(pub_3).to be_http_status(200) expect(pub_3).to be_http_status(200)
response = JSON.parse(pub_3.response) response = JSON.parse(pub_3.response)
expect(response["channels"].to_i).to eql(1) expect(response["channels"]).to eql(1)
expect(response["wildcard_channels"].to_i).to eql(1) expect(response["wildcard_channels"]).to eql(1)
expect(response["channels_in_trash"].to_i).to eql(1) expect(response["channels_in_trash"]).to eql(1)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -707,14 +707,14 @@ shared_examples_for "statistics location" do ...@@ -707,14 +707,14 @@ shared_examples_for "statistics location" do
response = JSON.parse(actual_response) response = JSON.parse(actual_response)
expect(response["infos"].length).to eql(2) expect(response["infos"].length).to eql(2)
expect(response["infos"][0]["channel"].to_s).to eql("ch3") expect(response["infos"][0]["channel"].to_s).to eql("ch3")
expect(response["infos"][0]["published_messages"].to_i).to eql(1) expect(response["infos"][0]["published_messages"]).to eql(1)
expect(response["infos"][0]["stored_messages"].to_i).to eql(1) expect(response["infos"][0]["stored_messages"]).to eql(1)
expect(response["infos"][0]["subscribers"].to_i).to eql(0) expect(response["infos"][0]["subscribers"]).to eql(0)
expect(response["infos"][1]["channel"].to_s).to eql("ch1") expect(response["infos"][1]["channel"].to_s).to eql("ch1")
expect(response["infos"][1]["published_messages"].to_i).to eql(1) expect(response["infos"][1]["published_messages"]).to eql(1)
expect(response["infos"][1]["stored_messages"].to_i).to eql(1) expect(response["infos"][1]["stored_messages"]).to eql(1)
expect(response["infos"][1]["subscribers"].to_i).to eql(0) expect(response["infos"][1]["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
...@@ -747,14 +747,14 @@ shared_examples_for "statistics location" do ...@@ -747,14 +747,14 @@ shared_examples_for "statistics location" do
response = JSON.parse(actual_response) response = JSON.parse(actual_response)
expect(response["infos"].length).to eql(2) expect(response["infos"].length).to eql(2)
expect(response["infos"][0]["channel"].to_s).to eql("ch3") expect(response["infos"][0]["channel"].to_s).to eql("ch3")
expect(response["infos"][0]["published_messages"].to_i).to eql(1) expect(response["infos"][0]["published_messages"]).to eql(1)
expect(response["infos"][0]["stored_messages"].to_i).to eql(1) expect(response["infos"][0]["stored_messages"]).to eql(1)
expect(response["infos"][0]["subscribers"].to_i).to eql(0) expect(response["infos"][0]["subscribers"]).to eql(0)
expect(response["infos"][1]["channel"].to_s).to eql("ch2") expect(response["infos"][1]["channel"].to_s).to eql("ch2")
expect(response["infos"][1]["published_messages"].to_i).to eql(1) expect(response["infos"][1]["published_messages"]).to eql(1)
expect(response["infos"][1]["stored_messages"].to_i).to eql(1) expect(response["infos"][1]["stored_messages"]).to eql(1)
expect(response["infos"][1]["subscribers"].to_i).to eql(0) expect(response["infos"][1]["subscribers"]).to eql(0)
EventMachine.stop EventMachine.stop
end end
end end
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

Technounit-GROUP 2023