From dab1d03d81c538966d03fb9318a4588a9e803b44 Mon Sep 17 00:00:00 2001
From: Sol Jerome <sol.jerome@gmail.com>
Date: Sat, 24 Mar 2012 11:20:07 -0500
Subject: Allow to run directly from a git checkout (#1037)

Signed-off-by: Sol Jerome <sol.jerome@gmail.com>
---
 src/lib/Server/Plugins/Statistics.py | 161 -----------------------------------
 1 file changed, 161 deletions(-)
 delete mode 100644 src/lib/Server/Plugins/Statistics.py

(limited to 'src/lib/Server/Plugins/Statistics.py')

diff --git a/src/lib/Server/Plugins/Statistics.py b/src/lib/Server/Plugins/Statistics.py
deleted file mode 100644
index 265ef95a8..000000000
--- a/src/lib/Server/Plugins/Statistics.py
+++ /dev/null
@@ -1,161 +0,0 @@
-'''This file manages the statistics collected by the BCFG2 Server'''
-
-import binascii
-import copy
-import difflib
-import logging
-from lxml.etree import XML, SubElement, Element, XMLSyntaxError
-import lxml.etree
-import os
-from time import asctime, localtime, time, strptime, mktime
-import threading
-
-import Bcfg2.Server.Plugin
-
-
-class StatisticsStore(object):
-    """Manages the memory and file copy of statistics collected about client runs."""
-    __min_write_delay__ = 0
-
-    def __init__(self, filename):
-        self.filename = filename
-        self.element = Element('Dummy')
-        self.dirty = 0
-        self.lastwrite = 0
-        self.logger = logging.getLogger('Bcfg2.Server.Statistics')
-        self.ReadFromFile()
-
-    def WriteBack(self, force=0):
-        """Write statistics changes back to persistent store."""
-        if (self.dirty and (self.lastwrite + self.__min_write_delay__ <= time())) \
-                or force:
-            try:
-                fout = open(self.filename + '.new', 'w')
-            except IOError:
-                ioerr = sys.exc_info()[1]
-                self.logger.error("Failed to open %s for writing: %s" % (self.filename + '.new', ioerr))
-            else:
-                fout.write(lxml.etree.tostring(self.element, encoding='UTF-8', xml_declaration=True))
-                fout.close()
-                os.rename(self.filename + '.new', self.filename)
-                self.dirty = 0
-                self.lastwrite = time()
-
-    def ReadFromFile(self):
-        """Reads current state regarding statistics."""
-        try:
-            fin = open(self.filename, 'r')
-            data = fin.read()
-            fin.close()
-            self.element = XML(data)
-            self.dirty = 0
-        except (IOError, XMLSyntaxError):
-            self.logger.error("Creating new statistics file %s"%(self.filename))
-            self.element = Element('ConfigStatistics')
-            self.WriteBack()
-            self.dirty = 0
-
-    def updateStats(self, xml, client):
-        """Updates the statistics of a current node with new data."""
-
-        # Current policy:
-        # - Keep anything less than 24 hours old
-        #   - Keep latest clean run for clean nodes
-        #   - Keep latest clean and dirty run for dirty nodes
-        newstat = xml.find('Statistics')
-
-        if newstat.get('state') == 'clean':
-            node_dirty = 0
-        else:
-            node_dirty = 1
-
-        # Find correct node entry in stats data
-        # The following list comprehension should be guarenteed to return at
-        # most one result
-        nodes = [elem for elem in self.element.findall('Node') \
-                 if elem.get('name') == client]
-        nummatch = len(nodes)
-        if nummatch == 0:
-            # Create an entry for this node
-            node = SubElement(self.element, 'Node', name=client)
-        elif nummatch == 1 and not node_dirty:
-            # Delete old instance
-            node = nodes[0]
-            [node.remove(elem) for elem in node.findall('Statistics') \
-             if self.isOlderThan24h(elem.get('time'))]
-        elif nummatch == 1 and node_dirty:
-            # Delete old dirty statistics entry
-            node = nodes[0]
-            [node.remove(elem) for elem in node.findall('Statistics') \
-             if (elem.get('state') == 'dirty' \
-                 and self.isOlderThan24h(elem.get('time')))]
-        else:
-            # Shouldn't be reached
-            self.logger.error("Duplicate node entry for %s"%(client))
-
-        # Set current time for stats
-        newstat.set('time', asctime(localtime()))
-
-        # Add statistic
-        node.append(copy.copy(newstat))
-
-        # Set dirty
-        self.dirty = 1
-        self.WriteBack(force=1)
-
-    def isOlderThan24h(self, testTime):
-        """Helper function to determine if <time> string is older than 24 hours."""
-        now = time()
-        utime = mktime(strptime(testTime))
-        secondsPerDay = 60*60*24
-
-        return (now-utime) > secondsPerDay
-
-
-class Statistics(Bcfg2.Server.Plugin.Plugin,
-                 Bcfg2.Server.Plugin.ThreadedStatistics,
-                 Bcfg2.Server.Plugin.PullSource):
-    name = 'Statistics'
-
-    def __init__(self, core, datastore):
-        Bcfg2.Server.Plugin.Plugin.__init__(self, core, datastore)
-        Bcfg2.Server.Plugin.ThreadedStatistics.__init__(self, core, datastore)
-        Bcfg2.Server.Plugin.PullSource.__init__(self)
-        fpath = "%s/etc/statistics.xml" % datastore
-        self.data_file = StatisticsStore(fpath)
-
-    def handle_statistic(self, metadata, data):
-        self.data_file.updateStats(data, metadata.hostname)
-
-    def FindCurrent(self, client):
-        rt = self.data_file.element.xpath('//Node[@name="%s"]' % client)[0]
-        maxtime = max([strptime(stat.get('time')) for stat \
-                       in rt.findall('Statistics')])
-        return [stat for stat in rt.findall('Statistics') \
-                if strptime(stat.get('time')) == maxtime][0]
-
-    def GetExtra(self, client):
-        return [(entry.tag, entry.get('name')) for entry \
-                in self.FindCurrent(client).xpath('.//Extra/*')]
-
-    def GetCurrentEntry(self, client, e_type, e_name):
-        curr = self.FindCurrent(client)
-        entry = curr.xpath('.//Bad/%s[@name="%s"]' % (e_type, e_name))
-        if not entry:
-            raise Bcfg2.Server.Plugin.PluginExecutionError
-        cfentry = entry[-1]
-
-        owner = cfentry.get('current_owner', cfentry.get('owner'))
-        group = cfentry.get('current_group', cfentry.get('group'))
-        perms = cfentry.get('current_perms', cfentry.get('perms'))
-        if cfentry.get('sensitive') in ['true', 'True']:
-            raise Bcfg2.Server.Plugin.PluginExecutionError
-        elif 'current_bfile' in cfentry.attrib:
-            contents = binascii.a2b_base64(cfentry.get('current_bfile'))
-        elif 'current_bdiff' in cfentry.attrib:
-            diff = binascii.a2b_base64(cfentry.get('current_bdiff'))
-            contents = '\n'.join(difflib.restore(diff.split('\n'), 1))
-        else:
-            contents = None
-
-        return (owner, group, perms, contents)
-- 
cgit v1.2.3-1-g7c22