# HG changeset patch
# User Sylvain Thénault <sylvain.thenault@logilab.fr>
# Date 1288014162 -7200
# Node ID 5c20a005bddc41a2bc4cdd5b3eadecb7f017438c
# Parent  54847e2c4a50ccf4ae86f847bf784cc802f0ad86
[pyro source] when cleaning relations of an external entity being cleaned up, only delete local relationsd

diff -r 54847e2c4a50 -r 5c20a005bddc server/repository.py
--- a/server/repository.py	Mon Oct 25 15:41:13 2010 +0200
+++ b/server/repository.py	Mon Oct 25 15:42:42 2010 +0200
@@ -1088,17 +1088,16 @@
         hook.CleanupNewEidsCacheOp.get_instance(session).add_data(entity.eid)
         self.system_source.add_info(session, entity, source, extid, complete)
 
-    def delete_info(self, session, entity, sourceuri, extid):
+    def delete_info(self, session, entity, sourceuri, extid, scleanup=False):
         """called by external source when some entity known by the system source
         has been deleted in the external source
         """
         # mark eid as being deleted in session info and setup cache update
         # operation
         hook.CleanupDeletedEidsCacheOp.get_instance(session).add_data(entity.eid)
-        self._delete_info(session, entity, sourceuri, extid)
+        self._delete_info(session, entity, sourceuri, extid, scleanup)
 
-    def _delete_info(self, session, entity, sourceuri, extid):
-                     # attributes=None, relations=None):
+    def _delete_info(self, session, entity, sourceuri, extid, scleanup):
         """delete system information on deletion of an entity:
         * delete all remaining relations from/to this entity
         * call delete info on the system source which will transfer record from
@@ -1119,7 +1118,11 @@
                     rql = 'DELETE X %s Y WHERE X eid %%(x)s' % rtype
                 else:
                     rql = 'DELETE Y %s X WHERE X eid %%(x)s' % rtype
-                session.execute(rql, {'x': eid}, build_descr=False)
+                if scleanup:
+                    # source cleaning: only delete relations stored locally
+                    rql += ', NOT Y cw_source S, S name %(source)s'
+                session.execute(rql, {'x': eid, 'source': sourceuri},
+                                build_descr=False)
         self.system_source.delete_info(session, entity, sourceuri, extid)
 
     def locate_relation_source(self, session, subject, rtype, object):
diff -r 54847e2c4a50 -r 5c20a005bddc server/sources/pyrorql.py
--- a/server/sources/pyrorql.py	Mon Oct 25 15:41:13 2010 +0200
+++ b/server/sources/pyrorql.py	Mon Oct 25 15:42:42 2010 +0200
@@ -265,7 +265,8 @@
                     # entity has been deleted from external repository but is not known here
                     if eid is not None:
                         entity = session.entity_from_eid(eid, etype)
-                        repo.delete_info(session, entity, self.uri, extid)
+                        repo.delete_info(session, entity, self.uri, extid,
+                                         scleanup=True)
                 except:
                     self.exception('while updating %s with external id %s of source %s',
                                    etype, extid, self.uri)