summaryrefslogtreecommitdiffhomepage
path: root/applications/luci-statistics/luasrc/statistics/datatree.lua
blob: 957b230a96b35cbb36dd901d6f7622e21a61c8c4 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
module("luci.statistics.datatree", package.seeall)

local util = require("luci.util")
local sys  = require("luci.sys")
local fs   = require("luci.fs")
local uci  = require("luci.model.uci").Session()
local sections, names = uci:sections( "luci_statistics" )


Instance = util.class()

function Instance.__init__( self, host )
	self._host    = host or sections.collectd.Hostname or sys.hostname()
	self._libdir  = sections.collectd.PluginDir        or "/usr/lib/collectd"
	self._rrddir  = sections.collectd_rrdtool.DataDir  or "/tmp"

	self._libdir  = self._libdir:gsub("/$","")
	self._rrddir  = self._rrddir:gsub("/$","")
	self._plugins = { }

	self:_scan()
end

function Instance._mkpath( self, plugin, pinstance )
	local dir = self._rrddir .. "/" .. self._host

	if type(plugin) == "string" and plugin:len() > 0 then
		dir = dir .. "/" .. plugin

		if type(pinstance) == "string" and pinstance:len() > 0 then
			dir = dir .. "-" .. pinstance
		end
	end

	return dir
end

function Instance._notzero( self, table )
	for k in pairs(table) do
		return true
	end

	return false
end

function Instance._scan( self )
	for i, plugin in ipairs( fs.dir( self._libdir ) ) do
		if plugin:match("%w+.so") then
			self._plugins[ plugin:gsub(".so", "") ] = { }
		end
	end

	for plugin, instances in pairs( self._plugins ) do
		for i, dir in ipairs( fs.dir( self:_mkpath() ) ) do
			if dir:find( plugin .. "%-" ) or dir == plugin then
				local instance = ""

				if dir ~= plugin then
					instance = dir:gsub( plugin .. "%-", "", 1 )
				end

				instances[instance] = { }
			end
		end

		for instance, data_instances in pairs( instances ) do
			for i, file in ipairs( fs.dir( self:_mkpath( plugin, instance ) ) ) do
				if file:find("%.rrd") then
					file = file:gsub("%.rrd","")

					local data_type
					local data_instance

					if file:find("%-") then
						data_type     = file:gsub( "%-.+","" )
						data_instance = file:gsub( "[^%-]-%-", "", 1 )
					else
						data_type     = file
						data_instance = ""
					end

					if not data_instances[data_type] then
						data_instances[data_type] = { data_instance }
					else
						table.insert( data_instances[data_type], data_instance )
					end
				end
			end
		end
	end
end


function Instance.plugins( self )
	local rv = { }

	for plugin, val in pairs( self._plugins ) do
		if self:_notzero( val ) then
			table.insert( rv, plugin )
		end
	end

	return rv
end

function Instance.plugin_instances( self, plugin )
	local rv = { }

	for instance, val in pairs( self._plugins[plugin] ) do
		table.insert( rv, instance )
	end

	return rv
end

function Instance.data_types( self, plugin, instance )
	local rv = { }

	for type, val in pairs( self._plugins[plugin][instance] ) do
		table.insert( rv, type )
	end

	return rv
end

function Instance.data_instances( self, plugin, instance, type )
	local rv = { }

	for i, instance in ipairs( self._plugins[plugin][instance][type] ) do
		table.insert( rv, instance )
	end

	return rv
end