Module: OverSIP::ProxiesConfig

Extended by:
Config::Validators, Logger
Defined in:
lib/oversip/proxies_config.rb

Constant Summary collapse

PROXY_CONFIG_VALIDATIONS = 
{
  :do_loose_routing           => :boolean,
  :use_dns                    => :boolean, 
  :use_dns_cache              => :boolean,
  :dns_cache_time             => [ :fixnum, [ :greater_equal_than, 300 ] ],
  :use_naptr                  => :boolean,
  :use_srv                    => :boolean,
  :transport_preference       => [ [ :choices, %w{tls tcp udp}], :multi_value, :non_empty ],
  :force_transport_preference => :boolean,
  :ip_type_preference         => [ [ :choices, %w{ipv4 ipv6}], :multi_value, :non_empty ],
  :dns_failover_on_503        => :boolean,
  :timer_B                    => [ :fixnum, [ :greater_equal_than, 2 ], [ :minor_equal_than, 64 ] ],
  :timer_C                    => [ :fixnum, [ :greater_equal_than, 8 ], [ :minor_equal_than, 180 ] ],
  :timer_F                    => [ :fixnum, [ :greater_equal_than, 2 ], [ :minor_equal_than, 64 ] ],
  :tls_validation             => :boolean
}

Constants included from Logger

Logger::SYSLOG_POSIXMQ_MAPPING

Constants included from Config::Validators

Config::Validators::DOMAIN_REGEXP, Config::Validators::TLS_PEM_CHAIN_REGEXP

Class Method Summary collapse

Methods included from Logger

close, fatal, fg_system_msg2str, init_logger_mq, load_methods, log_id, syslog_system_msg2str, syslog_user_msg2str

Methods included from Config::Validators

boolean, choices, domain, fixnum, greater_equal_than, greater_than, ipv4, ipv4_any, ipv6, ipv6_any, minor_equal_than, minor_than, port, readable_dir, readable_file, string, tls_pem_chain, tls_pem_private

Class Method Details

.load(proxies_yaml) ⇒ Object 



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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
 
# File 'lib/oversip/proxies_config.rb', line 48

def self.load proxies_yaml
  unless proxies_yaml.is_a? Hash
    fatal "invalid proxies configuration file, it is not a collection"
  end

  begin
    proxies_yaml.each do |proxy, conf|
      unless proxy.is_a? String
        fatal "proxy name is not a string (#{proxy.inspect})"
      end

      @proxies[proxy.to_sym] = @proxy_configuration.dup
      @proxies[proxy.to_sym].each do |parameter, default_value|
        @proxies[proxy.to_sym][parameter] = default_value.clone rescue default_value
      end

      PROXY_CONFIG_VALIDATIONS.each do |parameter, validations|
        values = proxies_yaml[proxy][parameter.to_s]
        validations = [ validations ]  unless validations.is_a?(Array)

        if values == nil
          if validations.include? :required
            fatal "#{proxy}[#{parameter}] requires a value"
          end
          next
        end

        if values.is_a? Array
          unless validations.include? :multi_value
            fatal "#{proxy}[#{parameter}] does not allow multiple values"
          end

          if validations.include? :non_empty and values.empty?
            fatal "#{proxy}[#{parameter}] does not allow empty values"
          end
        end

        values = ( values.is_a?(Array) ? values : [ values ] )

        values.each do |value|
          validations.each do |validation|

            if validation.is_a? Symbol
              args = []
            elsif validation.is_a? Array
              args = validation[1..-1]
              validation = validation[0]
            end

            next if [:required, :multi_value, :non_empty].include? validation

            unless send validation, value, *args
              fatal "#{proxy}[#{parameter}] has invalid value '#{::OverSIP::Config.humanize_value value}' (does not satisfy '#{validation}' validation requirement)"
            end
          end

          @proxies[proxy.to_sym][parameter] = ( validations.include?(:multi_value) ? values : values[0] )
        end

      end  # PROXY_CONFIG_VALIDATIONS[section].each
    end  # proxies_yaml.each

    post_process

  rescue OverSIP::ConfigurationError => e
    fatal "proxies configuration error: #{e.message}"
  rescue => e
    fatal e
  end

  ::OverSIP.proxies = @proxies
end

.log_id ⇒ Object 



8
9
10
 
# File 'lib/oversip/proxies_config.rb', line 8

def self.log_id
  @log_id ||= "ProxiesConfig"
end

.post_process ⇒ Object 



122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
 
# File 'lib/oversip/proxies_config.rb', line 122

def self.post_process
  @proxies.each_key do |proxy|
    # Add a string parameter with the proxy name itself.
    @proxies[proxy][:name] = proxy.to_s

    # If use_srv is not set then ensure use_naptr is also not set.
    @proxies[proxy][:use_naptr] = false  unless @proxies[proxy][:use_srv]

    # Convert transport values into Symbols.
    @proxies[proxy][:transport_preference] = @proxies[proxy][:transport_preference].map do |transport|
      transport.to_sym
    end

    # Ensure there are not duplicate transports.
    @proxies[proxy][:transport_preference].uniq!

    # Remove transports that are not supported.
    @proxies[proxy][:transport_preference].delete :tls  unless ::OverSIP.configuration[:sip][:sip_tls]
    @proxies[proxy][:transport_preference].delete :tcp  unless ::OverSIP.configuration[:sip][:sip_tcp]
    @proxies[proxy][:transport_preference].delete :udp  unless ::OverSIP.configuration[:sip][:sip_udp]

    # Convert IP type values into Symbols.
    @proxies[proxy][:ip_type_preference] = @proxies[proxy][:ip_type_preference].map do |ip_type|
      ip_type.to_sym
    end

    # Ensure there are not duplicate IP types.
    @proxies[proxy][:ip_type_preference].uniq!

    # Remove IP types that are not supported.
    @proxies[proxy][:ip_type_preference].delete :ipv4  unless ::OverSIP.configuration[:sip][:listen_ipv4]
    @proxies[proxy][:ip_type_preference].delete :ipv6  unless ::OverSIP.configuration[:sip][:listen_ipv6]

    # Add new parameters for fast access.
    @proxies[proxy][:has_sip_ipv4] = @proxies[proxy][:ip_type_preference].include?(:ipv4)
    @proxies[proxy][:has_sip_ipv6] = @proxies[proxy][:ip_type_preference].include?(:ipv6)
    @proxies[proxy][:has_sip_udp] = @proxies[proxy][:transport_preference].include?(:udp)
    @proxies[proxy][:has_sip_tcp] = @proxies[proxy][:transport_preference].include?(:tcp)
    @proxies[proxy][:has_sip_tls] = @proxies[proxy][:transport_preference].include?(:tls)

    # Add a hash for the DNS cache.
    @proxies[proxy][:dns_cache] = {}  if @proxies[proxy][:use_dns_cache]
  end
end