first pass at merb-gen flat

works ok, much to do

Author: jschoch

README

@@ -8,3 +8,5 @@ need to figure out what to do with min/max/avg etc
 
 
 wondering if gchart is slowing things down, adding gridlines and line widths would be nice
+adding min/max x axis labels would be good
+add candle chart for min/max/avg

README.txt

@@ -0,0 +1,10 @@
+Merb Flat
+==============
+
+An example of a small Merb application. Uses a single views directory and one
+controller file.
+
+Start with
+
+  merb
+  

Rakefile

@@ -0,0 +1,35 @@
+require 'rubygems'
+require 'rake/rdoctask'
+
+require 'merb-core'
+require 'merb-core/tasks/merb'
+
+include FileUtils
+
+# Load the basic runtime dependencies; this will include 
+# any plugins and therefore plugin rake tasks.
+init_env = ENV['MERB_ENV'] || 'rake'
+Merb.load_dependencies(:environment => init_env)
+     
+# Get Merb plugins and dependencies
+Merb::Plugins.rakefiles.each { |r| require r } 
+
+# Load any app level custom rakefile extensions from lib/tasks
+tasks_path = File.join(File.dirname(__FILE__), "lib", "tasks")
+rake_files = Dir["#{tasks_path}/*.rake"]
+rake_files.each{|rake_file| load rake_file }
+
+desc "Start runner environment"
+task :merb_env do
+  Merb.start_environment(:environment => init_env, :adapter => 'runner')
+end
+
+require 'spec/rake/spectask'
+require 'merb-core/test/tasks/spectasks'
+desc 'Default: run spec examples'
+task :default => 'spec'
+
+##############################################################################
+# ADD YOUR CUSTOM TASKS IN /lib/tasks
+# NAME YOUR RAKE FILES file_name.rake
+##############################################################################

application.rb

@@ -0,0 +1,24 @@
+class Rrdcrunchr < Merb::Controller
+
+  def _template_location(action, type = nil, controller = controller_name)
+    controller == "layout" ? "layout.#{action}.#{type}" : "#{action}.#{type}"
+  end
+
+  def index
+    @hosts = get_hosts.sort
+    @rrdtypes = get_rrdtypes.sort
+    #@hosts = get_hosts
+    #@rrdtypes = get_rrdtypes
+    @hosts.inspect
+    @rrdtypes.inspect
+    @rrdgroups = ["All"]
+    
+    render
+    
+  end
+
+  def foo
+    render
+  end
+  
+end

config/framework.rb

@@ -0,0 +1,7 @@
+Merb::Config[:framework] = {
+  :application => Merb.root / "application.rb",
+  :config => [Merb.root / "config", nil],
+  :public => [Merb.root / "public", nil],
+  :view   => Merb.root / "views"
+}
+

config/init.rb

@@ -0,0 +1,50 @@
+# Go to http://wiki.merbivore.com/pages/init-rb
+
+#  use_orm :none
+use_test :rspec
+use_template_engine :erb
+
+# Specify a specific version of a dependency
+# dependency "RedCloth", "> 3.0"
+dependency "merb-assets",  ">1.0"
+dependency "merb-more",  ">1.0"
+  require 'rubygems'
+#  require 'hpricot'
+  require 'erb' 
+  require 'yaml'
+  require 'gchart'
+
+CONF = YAML.load_file("./rcr.yaml")
+Merb::BootLoader.before_app_loads do
+  # This will get executed after dependencies have been loaded but before your app's classes have loaded.
+end
+ 
+Merb::BootLoader.after_app_loads do
+  # This will get executed after your app's classes have been loaded.
+    require 'lib/rrdcrunchr.rb'
+end
+
+# Move this to application.rb if you want it to be reloadable in dev mode.
+Merb::Router.prepare do
+  match('/').to(:controller => "rrdcrunchr", :action =>'index')
+  match('/foo').to(:controller => "rrdcrunchr", :action =>'foo')
+  default_routes
+end
+
+Merb::Config.use { |c|
+  c[:environment]         = 'production',
+  c[:framework]           = {},
+  c[:log_level]           = :debug,
+  c[:log_stream]          = STDOUT,
+  # or use file for logging:
+  # c[:log_file]          = Merb.root / "log" / "merb.log",
+  c[:use_mutex]           = false,
+  c[:session_store]       = 'cookie',
+  c[:session_id_key]      = '_rrdcrunchr_session_id',
+  c[:session_secret_key]  = 'ff7bd582e6f458507313c2392d6e1dae1f9dc184',
+  c[:exception_details]   = true,
+  c[:reload_classes]      = true,
+  c[:reload_templates]    = true,
+  c[:reload_time]         = 0.5
+  c[:reload_files] = true
+}

lib/rrdcrunchr.rb

@@ -0,0 +1,140 @@
+require 'rubygems'
+require 'gchart'
+
+def get_hosts
+  # probly want to do this at init
+  
+  paths = Dir[CONF['rrd_data_home']+"/*"].sort
+  #hosts = {}
+  hosts = ["All"]
+  #count = 0
+  for path in paths
+    p = path.split("/")
+    #hosts[p[-1]] = count
+    #count = count +1
+    hosts.push(p[-1])
+    puts "hosts found: #{p[-1]}"
+  end
+  
+  hosts
+end
+def get_rrdtypes
+  puts "Searching for RRD Types"
+  paths = Dir[CONF['rrd_data_home']+"/**/*.rrd"].sort
+  rrdtypes = ["All"]
+  dir_exclude = CONF['dir_exclude'].split(" ")
+  for path in paths
+    p = path.split("/")
+    if (rrdtypes.include?(p[-1]))
+      print "."
+    else
+      rrdtypes.push(p[-1]) unless dir_exclude.include?(p[-2])
+      print "*"
+    end
+  end
+  rrdtypes
+end
+
+def median (array, already_sorted=false)
+  return nil if array.empty?
+  array = array.sort unless already_sorted
+  m_pos = array.size / 2
+  return array.size % 2 == 1 ? array[m_pos] : mean (array[m_pos-1..m_pos])
+end
+def mean(array)
+  array.inject(0) { |sum, x| sum +=x } /array.size.to_f
+end
+
+def get_rrd(interval,rrd_file,rrd_type,resolution)
+  time = Time.now
+  start_time = ((time.tv_sec/resolution.to_i)*resolution.to_i)
+  puts "#{CONF['rrdtool_path']}/rrdtool fetch #{rrd_file} #{rrd_type} -e #{start_time} -r #{resolution} -s e-#{interval}m |#{CONF['awk_path']}/awk '{printf\"%s,\", $2}'"
+  rawdata = `#{CONF['rrdtool_path']}/rrdtool fetch #{rrd_file} #{rrd_type} -e #{start_time} -r #{resolution} -s e-#{interval}m |#{CONF['awk_path']}/awk '{printf"%s,", $2}'` 
+  datas = rawdata.split(",")
+  mdata = []
+  ymax =0
+  ymin = 100000000
+  for d in datas
+        #STDOUT.print "#{d} " unless  d.downcase =~ /nan/
+        stat = d.to_f
+        if (stat)
+                mdata.push(stat) unless d.downcase =~ /nan/
+        end
+        if (ymax < stat)
+                ymax = d.to_f
+        end
+        if (ymin > stat)
+                ymin = d.to_f
+        end
+  end
+  is_zero = false
+  stat_median = median(mdata)
+  if (stat_median == 0 and ymin.to_f == 0 && ymax.to_f == 0)
+        is_zero = true
+  end
+  [mdata,is_zero,ymin,ymax,stat_median]
+end
+
+
+def get_uri(rrd_file,interval,resolution,host)
+
+  # check exclude list
+  #
+
+  names = rrd_file.split("\/")
+  source = "http://chart.apis.google.com/chart"
+  type = "ls"
+  colour = "8198A2"
+  threshold_colour = "ff0000"
+
+  is_zero = false
+  min_data,is_zero,ymin,ymax,stat_median = get_rrd(interval,rrd_file,"MIN",resolution)
+  max_data,is_zero,ymin,ymax,stat_median = get_rrd(interval,rrd_file,"MAX",resolution)
+  avg_data,is_zero,ymin,ymax,stat_median = get_rrd(interval,rrd_file,"AVERAGE",resolution)
+
+  
+  # 80th percentile stuff, not needed right now
+
+  
+  all_data = []
+
+  if (min_data == avg_data && max_data == avg_data)
+  all_data = avg_data
+  else
+  all_data = [min_data,max_data,avg_data]
+  end
+  # :line_colors => 'FF0000,00FF00,666666',
+  uri = Gchart.line( :size => '1000x165', 
+      :title => "#{host} #{names[-1]}",
+      :bg => 'FFCCFF',
+      :line_colors => 'FF0000,00FF00,666666',
+      :axis_with_labels => ['x','y','r'],
+      :encoding => 'simple',
+      :data => all_data)
+
+  names = rrd_file.split("\/")
+  [uri,names[-1],ymin,ymax,stat_median,is_zero]
+end
+
+def draw_table(img_src,counter_name,ymin,ymax,stat_median,dir_name)
+  template = ERB.new <<-EOF
+<center>
+<table id=result border=0><tr>
+  <td id=counter><%= counter_name %></td>
+  <td rowspan=2 id=sparkline>
+  <img src=<%=img_src%>></a></td>
+  <td rowspan=2>
+  <div id=max><%= ymax.to_f %></div>
+        <div id=med><%= stat_median %></div>
+        <div id=min><%= ymin.to_f %></div></td><td rowspan=2>put my description here</td>
+</tr>
+<tr>
+<td id=filter><%= dir_name %></td>
+</tr>
+</table></center>
+
+  EOF
+  template.result(binding)
+  
+
+  end

log/merb.8080.pid

@@ -0,0 +1 @@
+15979