From 9f2ccf4a99b70a2a827ae159eaee1553f275dcd5 Mon Sep 17 00:00:00 2001
From: "(no author)" <(no author)@cd1c1023-2f26-0410-ae45-c471fc1f0318>
Date: Sun, 6 Jan 2008 19:20:00 +0000
Subject: [PATCH] - a small visual fix to equo search - world calculation cache
 is now kept updated in install/remove functions

git-svn-id: http://svn.sabayonlinux.org/projects/entropy/trunk@1016 cd1c1023-2f26-0410-ae45-c471fc1f0318
---
 client/text_query.py       |  2 +-
 libraries/databaseTools.py |  2 ++
 libraries/entropy.py       | 59 ++++++++++++++++++++++++++++++++++++++
 3 files changed, 62 insertions(+), 1 deletion(-)

diff --git a/client/text_query.py b/client/text_query.py
index e1e8a78be..d8d6fe89e 100644
--- a/client/text_query.py
+++ b/client/text_query.py
@@ -488,7 +488,7 @@ def searchPackage(packages, idreturn = False):
     foundPackages = {}
     dataInfo = set() # when idreturn is True
 
-    if (not idreturn) or (etpUi['quiet']):
+    if (not idreturn) and (not etpUi['quiet']):
         print_info(darkred(" @@ ")+darkgreen("Searching..."))
     # search inside each available database
     repoNumber = 0
diff --git a/libraries/databaseTools.py b/libraries/databaseTools.py
index ecdcaa025..7d1bf006f 100644
--- a/libraries/databaseTools.py
+++ b/libraries/databaseTools.py
@@ -3199,6 +3199,8 @@ class etpDatabase(TextInterface):
             raise exceptionTools.SystemDatabaseError("SystemDatabaseError: table extrainfo not found. Either does not exist or corrupted.")
 
     def tablesChecksum(self):
+        # NOTE: if you will add dependstable to the validation
+        # please have a look at EquoInterface.__install_package_into_database world calculation cache stuff
         import md5
         self.cursor.execute('select * from baseinfo')
         m = md5.new()
diff --git a/libraries/entropy.py b/libraries/entropy.py
index adb77eee2..69e82c45b 100644
--- a/libraries/entropy.py
+++ b/libraries/entropy.py
@@ -2058,7 +2058,32 @@ class PackageInterface:
     '''
     def __remove_package_from_database(self):
         self.error_on_not_prepared()
+
+        find = False
+        disk_cache = self.Entropy.dumpTools.loadobj(etpCache['world_update'])
+        if disk_cache != None:
+            try:
+                slot = self.Entropy.clientDbconn.retrieveSlot(self.infoDict['removeidpackage'])
+                key = self.Entropy.entropyTools.dep_getkey(self.infoDict['removeatom'])
+                matched = self.Entropy.atomMatch(key, matchSlot = slot)
+                if matched[0] != -1:
+                    dbconn = self.Entropy.openRepositoryDatabase(matched[1])
+                    atom = dbconn.retrieveAtom(matched[0])
+                    cached_item = (atom,matched)
+                    if cached_item in disk_cache['update']:
+                        find = True
+            except Exception,e:
+                self.Entropy.dumpTools.dumpobj(etpCache['world_update'], {})
+                print "DEBUG-rm: please REPORT %s: %s" % (str(Exception),str(e),)
+
         self.Entropy.clientDbconn.removePackage(self.infoDict['removeidpackage'])
+
+        if find:
+            disk_cache['update'].remove(cached_item)
+            db_digest = self.Entropy.clientDbconn.tablesChecksum()
+            disk_cache['db_digest'] = db_digest
+            self.Entropy.dumpTools.dumpobj(etpCache['world_update'], disk_cache)
+
         return 0
 
     '''
@@ -2231,6 +2256,40 @@ class PackageInterface:
         ctime = self.Entropy.entropyTools.getCurrentUnixTime()
         self.Entropy.clientDbconn.setDateCreation(idpk, str(ctime))
 
+        # update world calculation cache
+        disk_cache = self.Entropy.dumpTools.loadobj(etpCache['world_update'])
+        if disk_cache != None:
+            try:
+                atom = self.Entropy.clientDbconn.retrieveAtom(idpk)
+                slot = self.Entropy.clientDbconn.retrieveSlot(idpk)
+                cached_item = (atom,(self.infoDict['idpackage'],self.infoDict['repository']))
+                if cached_item in disk_cache['update']:
+                    disk_cache['update'].remove(cached_item)
+                    db_digest = self.Entropy.clientDbconn.tablesChecksum()
+                    disk_cache['db_digest'] = db_digest
+                    self.Entropy.dumpTools.dumpobj(etpCache['world_update'], disk_cache)
+                else:
+                    # add it, because can happen that a user firstly removes the package, then
+                    # decides to install a specific version which is not the latest
+                    key = self.Entropy.entropyTools.dep_getkey(atom)
+                    match = self.Entropy.atomMatch(key, matchSlot = slot)
+                    if (match[0] != -1) and (match != cached_item[1]):
+                        ldbconn = self.Entropy.openRepositoryDatabase(match[1])
+                        latest_atom = ldbconn.retrieveAtom(match[0])
+                        disk_cache['update'].add(latest_atom,match)
+                        # if you came from databaseTools.validateDatabase, this is the reason:
+                        # db_digest is the checksum of baseinfo and extrainfo, if you add dependstable
+                        # then you'll have to move this at the bottom of this function because, if you
+                        # read below, dependstable will be updated, so checksum won't never match,
+                        # the same for the condition above
+                        db_digest = self.Entropy.clientDbconn.tablesChecksum()
+                        disk_cache['db_digest'] = db_digest
+                        self.Entropy.dumpTools.dumpobj(etpCache['world_update'], disk_cache)
+            except Exception,e:
+                # invalidate cache
+                self.Entropy.dumpTools.dumpobj(etpCache['world_update'],{})
+                print "DEBUG: please REPORT %s: %s" % (str(Exception),str(e),)
+
         # add idpk to the installedtable
         self.Entropy.clientDbconn.removePackageFromInstalledTable(idpk)
         self.Entropy.clientDbconn.addPackageToInstalledTable(idpk,self.infoDict['repository'])