Class: Net::Telnet
- Inherits:
-
Object
- Object
- Net::Telnet
- Defined in:
- lib/oxidized/input/telnet.rb
Instance Attribute Summary collapse
-
#output ⇒ Object
readonly
how to do this, without redefining the whole damn thing FIXME: we also need output (not sure I’m going to support this).
Instance Method Summary collapse
-
#oxidized_expect(options) ⇒ Object
rubocop:disable Metrics/PerceivedComplexity.
Instance Attribute Details
#output ⇒ Object (readonly)
how to do this, without redefining the whole damn thing FIXME: we also need output (not sure I’m going to support this)
79 80 81 |
# File 'lib/oxidized/input/telnet.rb', line 79 def output @output end |
Instance Method Details
#oxidized_expect(options) ⇒ Object
rubocop:disable Metrics/PerceivedComplexity
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 122 |
# File 'lib/oxidized/input/telnet.rb', line 81 def oxidized_expect() ## rubocop:disable Metrics/PerceivedComplexity model = @options["Model"] @log = @options["Log"] expects = [[:expect]].flatten time_out = [: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?) [:out]&.replace(line) return match if match end end end |