From 3e8826d66c23cc439df0a589f4c7821d2dfca575 Mon Sep 17 00:00:00 2001
From: "Chris St. Pierre" <chris.a.st.pierre@gmail.com>
Date: Tue, 18 Sep 2012 13:40:11 -0400
Subject: deduplicated Packages code, more docs

---
 src/lib/Bcfg2/Server/Plugins/Packages/Pac.py | 59 +---------------------------
 1 file changed, 1 insertion(+), 58 deletions(-)

(limited to 'src/lib/Bcfg2/Server/Plugins/Packages/Pac.py')

diff --git a/src/lib/Bcfg2/Server/Plugins/Packages/Pac.py b/src/lib/Bcfg2/Server/Plugins/Packages/Pac.py
index 9a508daac..2418e6f2b 100644
--- a/src/lib/Bcfg2/Server/Plugins/Packages/Pac.py
+++ b/src/lib/Bcfg2/Server/Plugins/Packages/Pac.py
@@ -1,6 +1,4 @@
-import gzip
 import tarfile
-from Bcfg2.Compat import cPickle
 from Bcfg2.Server.Plugins.Packages.Collection import _Collection
 from Bcfg2.Server.Plugins.Packages.Source import Source
 
@@ -13,24 +11,6 @@ class PacSource(Source):
     basegroups = ['arch', 'parabola']
     ptype = 'pacman'
 
-    def __init__(self, basepath, xsource, config):
-        Source.__init__(self, basepath, xsource, config)
-        self.pkgnames = set()
-
-    def save_state(self):
-        cache = open(self.cachefile, 'wb')
-        cPickle.dump((self.pkgnames, self.deps, self.provides),
-                     cache, 2)
-        cache.close()
-
-    def load_state(self):
-        data = open(self.cachefile)
-        self.pkgnames, self.deps, self.provides = cPickle.load(data)
-
-    def filter_unknown(self, unknown):
-        filtered = set([u for u in unknown if u.startswith('choice')])
-        unknown.difference_update(filtered)
-
     def get_urls(self):
         if not self.rawurl:
             rv = []
@@ -65,7 +45,6 @@ class PacSource(Source):
             try:
                 self.debug_log("Packages: try to read %s" % fname)
                 tar = tarfile.open(fname, "r")
-                reader = gzip.GzipFile(fname)
             except:
                 self.logger.error("Packages: Failed to read file %s" % fname)
                 raise
@@ -76,40 +55,4 @@ class PacSource(Source):
                     self.debug_log("Packages: added %s" %
                                    tarinfo.name.rsplit("-", 2)[0])
             tar.close()
-
-        self.deps['global'] = dict()
-        self.provides['global'] = dict()
-        for barch in bdeps:
-            self.deps[barch] = dict()
-            self.provides[barch] = dict()
-        for pkgname in self.pkgnames:
-            pset = set()
-            for barch in bdeps:
-                if pkgname not in bdeps[barch]:
-                    bdeps[barch][pkgname] = []
-                pset.add(tuple(bdeps[barch][pkgname]))
-            if len(pset) == 1:
-                self.deps['global'][pkgname] = pset.pop()
-            else:
-                for barch in bdeps:
-                    self.deps[barch][pkgname] = bdeps[barch][pkgname]
-        provided = set()
-        for bprovided in list(bprov.values()):
-            provided.update(set(bprovided))
-        for prov in provided:
-            prset = set()
-            for barch in bprov:
-                if prov not in bprov[barch]:
-                    continue
-                prset.add(tuple(bprov[barch].get(prov, ())))
-            if len(prset) == 1:
-                self.provides['global'][prov] = prset.pop()
-            else:
-                for barch in bprov:
-                    self.provides[barch][prov] = bprov[barch].get(prov, ())
-        self.save_state()
-
-    def is_package(self, _, pkg):
-        return (pkg in self.pkgnames and
-                pkg not in self.blacklist and
-                (len(self.whitelist) == 0 or pkg in self.whitelist))
+        self.process_files(bdeps, bprov)
-- 
cgit v1.2.3-1-g7c22