Merge pull request #1753 from katkamrachana/misc-updates

Update on Interactions

doc/deployer/del_has_thread_update.py

@@ -1,4 +1,5 @@
 from gnowsys_ndf.ndf.models import *
+from gnowsys_ndf.ndf.views.methods import create_gattribute
 twist_gst = node_collection.one({'_type': "GSystemType", 'name': "Twist"})
 has_thread_rt = node_collection.one({'_type': 'RelationType', 'name': 'has_thread'})
 reply_gst = node_collection.one({'_type': "GSystemType", 'name': "Reply"})
@@ -12,7 +13,7 @@
 del_thread_node_ids = [each_thr.right_subject for each_thr in del_has_thread_grel]
 # fetch thread only if it has any comments attached to it
 del_thread_cur = node_collection.find({'_id': {'$in': del_thread_node_ids}, 'author_set': {'$ne': []}})
-print "\ndel_thread_cur: ", del_thread_cur.count()
+print "\nTotal Old Threads holding comments references: ", del_thread_cur.count()
 
 # if yes find related/newly created thread obj ('PUBLISHED')
 # attach the comments to the newly created thread obj
@@ -24,16 +25,30 @@
 	# print "\n ObjectId(pub_has_thread_grel.right_subject): ", ObjectId(pub_has_thread_grel.right_subject)
 
 	triples_of_del_th = triple_collection.find({'subject': each_th_obj._id, '_type': 'GAttribute'})
-	triple_collection.collection.update({'subject': each_th_obj._id, '_type': 'GAttribute'},
-	{'$set': {'subject': ObjectId(pub_has_thread_grel.right_subject)}},upsert=False, multi=True)
+	print create_gattribute(ObjectId(pub_has_thread_grel.right_subject), 'release_response', True)
+	# triple_collection.collection.update({'subject': each_th_obj._id, '_type': 'GAttribute'},
+	# {'$set': {'subject': ObjectId(pub_has_thread_grel.right_subject)}},upsert=False, multi=True)
 	pub_thread_res = node_collection.collection.update({
 		'_id': ObjectId(pub_has_thread_grel.right_subject)},
 		{'$addToSet': {'author_set': {'$each': each_th_obj.author_set}}},
 		upsert=False, multi=False)
-	print "\npub_thread_res: ", pub_thread_res
+	print "\nPublished Thread updates result: ", pub_thread_res
 	del_thread_replies = node_collection.collection.update({
 		'prior_node': each_th_obj._id, 'member_of': reply_gst._id},
 		{'$set': {'prior_node': [ObjectId(pub_has_thread_grel.right_subject)],
 		'origin': [{u'thread_id': ObjectId(pub_has_thread_grel.right_subject)}]}},
 		upsert=False, multi=True)
-	print "\ndel_thread_replies: ", del_thread_replies
+	print "\nDeleted Thread updates result: ", del_thread_replies
+
+th = node_collection.find({'member_of': twist_gst._id})
+print "\n Total threads: ", th.count()
+th_ids = [e._id for e in th]
+rel_resp_at = node_collection.one({'_type': 'AttributeType', 'name': 'release_response'}) 
+tr = triple_collection.find({'attribute_type': rel_resp_at._id, 'subject': {'$in': th_ids}})
+th_with_rel_resp = [e.subject for e in tr ] 
+print "\n Threads having release_response set: ", len(th_with_rel_resp)
+th_ids_with_no_rel_resp = set(th_ids) - set(th_with_rel_resp)
+print "\n Threads NOT having release_response set: ", len(th_ids_with_no_rel_resp)
+th_ids_with_no_rel_resp = list(th_ids_with_no_rel_resp)
+for each_th_with_no_rel_resp in th_ids_with_no_rel_resp:
+	create_gattribute(ObjectId(each_th_with_no_rel_resp), 'release_response', True)