Navigation Menu

Skip to content

Commit

Permalink
Fixup missing fields and validate them for droogna-send command
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Jan 15, 2015
1 parent eae9a15 commit 0434f43
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions bin/droonga-send
Expand Up @@ -21,6 +21,8 @@ require "yajl"
require "json"

require "droonga/client"
require "droonga/client/message_perfector"
require "droonga/client/message_validator"

options = OpenStruct.new
options.report_request = false
Expand All @@ -33,6 +35,9 @@ servers = []
default_server = "droonga:localhost:10031/droonga"
messages_per_second = Droonga::Client::RateLimiter::DEFAULT_LIMIT

perfector = Droonga::Client::MessagePerfector.new
validator = Droonga::Client::MessageValidator.new

def parse_server(server, options)
server_matcher = /\A(?:(droonga|http):)?([^:]+)(?::([0-9]+))?(?:\/(.+))?\z/
server =~ server_matcher
Expand Down Expand Up @@ -167,6 +172,8 @@ json_parser.on_parse_complete = lambda do |request_message|
message << "\n"
print(message)
end
request_message = perfector.perfect(request_message)
validator.validate(request_message)
client = clients[client_index]
client.send(request_message)
client_index = (client_index + 1) % clients.size
Expand Down

0 comments on commit 0434f43

Please sign in to comment.