diff options
author | Dmitriy Zaporozhets <dmitriy.zaporozhets@gmail.com> | 2013-11-08 16:21:02 +0000 |
---|---|---|
committer | Dmitriy Zaporozhets <dmitriy.zaporozhets@gmail.com> | 2013-11-08 16:21:02 +0000 |
commit | d5486093ea1b7249069aa1fb310cfc74434039d4 (patch) | |
tree | b18491f61f8252ee3612e542e10128649d68ac1c | |
parent | e68025401538eed3a11b6d874c6455acf49ef664 (diff) | |
parent | 6c8c9ff5aa117b198d487510b514cc1122cfb2cf (diff) | |
download | gitlab-shell-d5486093ea1b7249069aa1fb310cfc74434039d4.tar.gz |
Merge branch 'refactor_redis' of /home/git/repositories/gitlab/gitlab-shellv1.7.7
-rw-r--r-- | lib/gitlab_config.rb | 6 | ||||
-rw-r--r-- | lib/gitlab_update.rb | 6 |
2 files changed, 7 insertions, 5 deletions
diff --git a/lib/gitlab_config.rb b/lib/gitlab_config.rb index 9dc5c66..ad15247 100644 --- a/lib/gitlab_config.rb +++ b/lib/gitlab_config.rb @@ -48,12 +48,12 @@ class GitlabConfig if redis.empty? # Default to old method of connecting to redis # for users that haven't updated their configuration - "env -i redis-cli" + %W(env -i redis-cli) else if redis.has_key?("socket") - "#{redis['bin']} -s #{redis['socket']}" + %W(#{redis['bin']} -s #{redis['socket']}) else - "#{redis['bin']} -h #{redis['host']} -p #{redis['port']}" + %W(#{redis['bin']} -h #{redis['host']} -p #{redis['port']}) end end end diff --git a/lib/gitlab_update.rb b/lib/gitlab_update.rb index 40ddc6e..038253a 100644 --- a/lib/gitlab_update.rb +++ b/lib/gitlab_update.rb @@ -1,5 +1,6 @@ require_relative 'gitlab_init' require_relative 'gitlab_net' +require 'json' class GitlabUpdate attr_reader :config @@ -53,7 +54,8 @@ class GitlabUpdate end def update_redis - command = "#{config.redis_command} rpush '#{config.redis_namespace}:queue:post_receive' '{\"class\":\"PostReceive\",\"args\":[\"#{@repo_path}\",\"#{@oldrev}\",\"#{@newrev}\",\"#{@refname}\",\"#{@key_id}\"]}' > /dev/null 2>&1" - system(command) + queue = "#{config.redis_namespace}:queue:post_receive" + msg = JSON.dump({'class' => 'PostReceive', 'args' => [@repo_path, @oldrev, @newrev, @refname, @key_id]}) + system(*config.redis_command, 'rpush', queue, msg, err: '/dev/null', out: '/dev/null') end end |