Class: Lacquer::Varnish

Inherits:
Object
  • Object
show all
Defined in:
lib/lacquer/varnish.rb

Instance Method Summary collapse

Instance Method Details

#purge(*paths) ⇒ Object

Sends the command ‘url.purge path’



15
16
17
18
19
20
21
22
23
24
 
# File 'lib/lacquer/varnish.rb', line 15

def purge(*paths)
  paths.all? do |path|
    ActiveSupport::Notifications.instrument('purge.lacquer', path: path) do |payload|
      send_command(Lacquer.configuration.purge_command + " " + path.gsub('\\', '\\\\\\')).all? do |result|
        payload[:result] = result
        result =~ /200/
      end
    end
  end
end

#send_command(command) ⇒ Object

Sends commands over telnet to varnish servers listed in the config.



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
 
# File 'lib/lacquer/varnish.rb', line 27

def send_command(command)
  Lacquer.configuration.varnish_servers.collect do |server|
    retries = 0
    response = nil
    begin
      retries += 1
      connection = Net::Telnet.new(
        'Host' => server[:host],
        'Port' => server[:port],
        'Timeout' => server[:timeout] || 5)

      if(server[:secret])
        connection.waitfor("Match" => /^107/) do |authentication_request|
          matchdata = /^107 \d{2}\s*(.{32}).*$/m.match(authentication_request) # Might be a bit ugly regex, but it works great!
          salt = matchdata[1]
          if(salt.empty?)
            raise VarnishError, "Bad authentication request"
          end

          digest = OpenSSL::Digest::Digest.new('sha256')
          digest << salt
          digest << "\n"
          digest << server[:secret]
          digest << salt
          digest << "\n"

          connection.cmd("String" => "auth #{digest.to_s}", "Match" => /\d{3}/) do |auth_response|
            if(!(/^200/ =~ auth_response))
              raise AuthenticationError, "Could not authenticate"
            end
          end
        end
      end

      connection.cmd('String' => command, 'Match' => /\n\n/) {|r| response = r.split("\n").first.strip}
      connection.close if connection.respond_to?(:close)
    rescue Exception => e
      if retries < Lacquer.configuration.retries
        retry
      else
        if Lacquer.configuration.command_error_handler
          Lacquer.configuration.command_error_handler.call({
           :error_class   => "Varnish Error, retried #{Lacquer.configuration.retries} times",
           :error_message => "Error while trying to connect to #{server[:host]}:#{server[:port]}: #{e}",
           :parameters    => server,
           :response      => response })
        elsif e.kind_of?(Lacquer::AuthenticationError)
          raise e
        else
          raise VarnishError.new("Error while trying to connect to #{server[:host]}:#{server[:port]} #{e}")
        end
      end
    end
    response
  end
end

#stats ⇒ Object 



3
4
5
6
7
8
9
10
11
12
 
# File 'lib/lacquer/varnish.rb', line 3

def stats
  send_command('stats').collect do |stats|
    stats = stats.split("\n")
    stats.shift
    stats = stats.collect do |stat|
      stat = stat.strip.match(/(\d+)\s+(.+)$/)
      { :key => stat[2], :value => stat[1] } if stat
    end
  end
end