aboutsummaryrefslogtreecommitdiff
path: root/monitor.rb
diff options
context:
space:
mode:
authorImmae <immae@immae.eu>2014-06-18 23:50:55 +0200
committerImmae <immae@immae.eu>2014-06-18 23:50:55 +0200
commit7a1b77020cc139cc9240cd2c7ed2ae8990613d66 (patch)
tree00912cb19d534a768982a002b93dd4b8ae6395ad /monitor.rb
parentcfddfd90ca8df888683529fcf683958da0894b10 (diff)
downloadMonitor-7a1b77020cc139cc9240cd2c7ed2ae8990613d66.tar.gz
Monitor-7a1b77020cc139cc9240cd2c7ed2ae8990613d66.tar.zst
Monitor-7a1b77020cc139cc9240cd2c7ed2ae8990613d66.zip
classes in separate files
Diffstat (limited to 'monitor.rb')
-rw-r--r--monitor.rb272
1 files changed, 2 insertions, 270 deletions
diff --git a/monitor.rb b/monitor.rb
index 09f9e59..f61ce9b 100644
--- a/monitor.rb
+++ b/monitor.rb
@@ -6,6 +6,8 @@ require "inifile"
6require "open3" 6require "open3"
7require 'optparse' 7require 'optparse'
8require 'ostruct' 8require 'ostruct'
9require_relative 'buffer'
10require_relative 'windows'
9 11
10class IO 12class IO
11 def readline_nonblock 13 def readline_nonblock
@@ -40,276 +42,6 @@ class OptParse
40 end 42 end
41end 43end
42 44
43class List_Win
44 def initialize(inifile)
45 @params = inifile
46 @win = Ncurses::WINDOW.new(0, Ncurses.COLS()/4, 0, 0)
47 @win.border(*([0]*8))
48 @win.keypad(true)
49 @win.timeout(1000)
50 @win.refresh()
51 @entry = 0
52 end
53
54 def getch()
55 @win.getch()
56 end
57 def clear()
58 @win.clear()
59 end
60 def resize(x,y)
61 @win.resize(x,y)
62 end
63 def move(x,y)
64 @win.move(x,y)
65 end
66 def refresh()
67 @win.refresh()
68 end
69
70 def print_list(entry=nil)
71 if(not entry.nil?)
72 @entry = entry
73 end
74 i = 0
75 @params.each_section do |section|
76 if(@entry == i)
77 @win.attron(Ncurses::A_REVERSE)
78 end
79 @win.move(i+1,1)
80 print_line(@win,@params[section]['Name'])
81 if(@entry == i)
82 @win.attroff(Ncurses::A_REVERSE)
83 end
84 i = i+1
85 end
86 @win.border(*([0]*8))
87 @win.move(0,3)
88 @win.addstr("Menu")
89 @win.refresh()
90 end
91end
92
93class Buff_Win
94 def initialize(winsize,winpos,params)
95 @params = params
96 @win = Ncurses::WINDOW.new(0, winsize, 0, winpos)
97 @panel = Ncurses::Panel::PANEL.new(@win)
98 if(@params['Type'] == 'oneshot')
99 @buffer = Buffer.new(0)
100 else
101 @buffer = Buffer.new(@params['Buffer'].to_i)
102 end
103 @proc = nil
104 @curr_offset = 0
105 @hscroll = 0
106 update_date()
107
108 spawn_proc()
109 print_buffer()
110 end
111
112 def move_resize(winsize,winpos)
113 newwin = Ncurses::WINDOW.new(0, winsize, 0, winpos)
114 Ncurses::Panel.replace_panel(@panel, newwin)
115 Ncurses.delwin(@win)
116 @win = newwin
117 print_buffer()
118 end
119 def update_date()
120 @last_update = Time.now
121 @date = @last_update.strftime("%F %R:%S")
122 end
123
124 def win_border()
125 @win.border(*([0]*8))
126 win_header()
127 end
128 def win_header()
129 @win.move(0,3)
130 @win.addnstr(@params['Name'],@win.getmaxx-@date.length-10)
131 @win.move(0,@win.getmaxx-@date.length-2)
132 @win.addstr(@date)
133 end
134 def refresh()
135 @win.refresh()
136 end
137 def clear()
138 @win.clear()
139 end
140
141 def show_win()
142 Ncurses::Panel.top_panel(@panel)
143 Ncurses::Panel.update_panels
144 end
145
146 def hscroll(scroll=0)
147 @hscroll += scroll
148 if(@hscroll < 0)
149 @hscroll = 0
150 end
151 if(@hscroll > @buffer.maxlen()-@win.getmaxx+3)
152 @hscroll = @buffer.maxlen()-@win.getmaxx+3
153 end
154 print_buffer()
155 refresh()
156 end
157 def scroll(scroll=0,goto=nil,fact=nil)
158 if (not fact.nil?)
159 scroll = (fact * @win.getmaxy.to_f).to_i
160 elsif (not goto.nil?)
161 @curr_offset = (goto * @buffer.size()).to_i
162 scroll = 0
163 end
164 #@curr_offset -= @win.getmaxy/2
165 @curr_offset += scroll
166 if(@curr_offset < 0)
167 @curr_offset = 0
168 end
169 if(@curr_offset > @buffer.size()-@win.getmaxy+2)
170 @curr_offset = @buffer.size()-@win.getmaxy+2
171 end
172 print_buffer()
173 refresh()
174 end
175
176 def print_buffer()
177 #clear()
178 win_border()
179 j = 1
180 @buffer.yield(@win.getmaxy-2,@curr_offset) { |l,type|
181 @win.move(j,1)
182 if(type == 1) then @win.attron(Ncurses.COLOR_PAIR(1)) end
183 print_line(@win,l,hscroll=@hscroll)
184 if(type == 1) then @win.attroff(Ncurses.COLOR_PAIR(1)) end
185 j = j+1
186 }
187 if(@buffer.has_before?)
188 @win.move(2,@win.getmaxx-1)
189 @win.attron(Ncurses::A_REVERSE)
190 @win.addstr("↑")
191 @win.attroff(Ncurses::A_REVERSE)
192 end
193 if(@buffer.has_after?)
194 @win.move(@win.getmaxy-2,@win.getmaxx-1)
195 @win.attron(Ncurses::A_REVERSE)
196 @win.addstr("↓")
197 @win.attroff(Ncurses::A_REVERSE)
198 end
199 end
200
201 def proc_readlines()
202 begin
203 while true
204 @buffer.push(@proc.readline_nonblock)
205 update_date()
206 end
207 rescue IO::WaitReadable
208 end
209 end
210
211 def update(force=false)
212 if(@params['Type'] == 'continuous')
213 proc_readlines()
214 end
215 if(@params['Type'] == 'oneshot')
216 if(force or (Time.now - @last_update > @params['Periodic'].to_i))
217 @buffer.clear()
218 spawn_proc()
219 clear()
220 end
221 end
222 print_buffer()
223 end
224
225 def spawn_proc()
226 if(@params['Type'] == 'oneshot')
227 update_date()
228 Open3.popen3(@params["Command"]) { |i,o,e,t|
229 while ((not o.eof?) or (not e.eof?))
230 rs = IO.select([o,e],nil)[0]
231 r = (rs[0].eof?)? rs[1] : rs[0]
232
233 if r.fileno == o.fileno
234 @buffer.push(r.readline)
235 elsif r.fileno == e.fileno
236 @buffer.push(r.readline,type=1)
237 end
238 end
239 }
240 elsif(@params['Type'] == 'continuous')
241 @proc = IO.popen(@params["Command"])
242 proc_readlines()
243 end
244 end
245end
246
247class Buffer
248 def initialize(size)
249 @size = size
250 @buff = []
251 @buff_type = []
252 @current = 0
253 @wrap = false
254 @before = false
255 @after = false
256 end
257 def size()
258 return @buff.length
259 end
260 def maxlen()
261 maxlen = 0
262 @buff.each do |string|
263 if string.length > maxlen
264 maxlen = string.length
265 end
266 end
267 return maxlen
268 end
269
270 def push(string,type=0)
271 if(string.chomp.empty?) then string = " " end
272 string.split( /\r?\n/ ).each do |line|
273 @buff[@current] = line
274 @buff_type[@current] = type
275 if(@size > 0)
276 @current = (1+@current) % @size
277 else
278 @current = 1+@current
279 end
280 if(@current == 0) then @wrap = true end
281 end
282 end
283 def yield(size,offset=0,&block)
284 if(size < 0) then size = 0 end
285 range = Range.new(0,@current-1).to_a
286 if(@wrap)
287 range = Range.new(@current,@size-1).to_a + range
288 end
289 range = range.last(size+offset)[0,size]
290 @before = (size+offset < @buff.length)
291 @after = (offset != 0 and size < @buff.length)
292 if(block)
293 range.each do |i|
294 yield [@buff[i],@buff_type[i]]
295 end
296 else
297 return range.collect{|r| [@buff[r],@buff_type[r]]}
298 end
299 end
300 def has_after?()
301 return @after
302 end
303 def has_before?()
304 return @before
305 end
306 def clear()
307 @current = 0
308 @buff = []
309 @buff_type = []
310 end
311end
312
313def find_ini(option_inifile) 45def find_ini(option_inifile)
314 if(not option_inifile.nil?) 46 if(not option_inifile.nil?)
315 inifile = option_inifile 47 inifile = option_inifile