Method: Net::Telnet#oxidized_expect

Defined in:
lib/oxidized/input/telnet.rb

#oxidized_expect(options) ⇒ Object

rubocop:disable Metrics/PerceivedComplexity



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
120
121
 
# File 'lib/oxidized/input/telnet.rb', line 80

def oxidized_expect(options) ## rubocop:disable Metrics/PerceivedComplexity
  model    = @options["Model"]
  @log     = @options["Log"]

  expects  = [options[:expect]].flatten
  time_out = options[:timeout] || @options["Timeout"] || Oxidized.config.timeout?

  Timeout.timeout(time_out) do
    line = ""
    rest = ""
    buf  = ""
    loop do
      c = @sock.readpartial(1024 * 1024)
      @output = c
      c = rest + c

      if Integer(c.rindex(/#{IAC}#{SE}/no) || 0) <
         Integer(c.rindex(/#{IAC}#{SB}/no) || 0)
        buf = preprocess(c[0...c.rindex(/#{IAC}#{SB}/no)])
        rest = c[c.rindex(/#{IAC}#{SB}/no)..-1]
      elsif (pt = c.rindex(/#{IAC}[^#{IAC}#{AO}#{AYT}#{DM}#{IP}#{NOP}]?\z/no) ||
                 c.rindex(/\r\z/no))
        buf = preprocess(c[0...pt])
        rest = c[pt..-1]
      else
        buf = preprocess(c)
        rest = ''
      end
      if Oxidized.config.input.debug?
        @log.print buf
        @log.flush
      end
      line += buf
      line = model.expects line
      # match is a regexp object. we need to return that for logins to work.
      match = expects.find { |re| line.match re }
      # stomp on the out string object if we have one. (thus we were called by cmd?)
      options[:out]&.replace(line)
      return match if match
    end
  end
end