D-Net

function migrate_community(communityPid, beta_db_name, prod_db_name) {

	print("migrate_community: "+communityPid+" - both dbs are here");

	var beta_community = beta_db.community.findOne({ pid: communityPid } );

	if(!beta_community) {

		print("ERROR: Community with pid: "+communityPid+" does not exist in (beta) database: "+ beta_db_name);

	var prod_communityOld = prod_db.community.findOne( { pid: communityPid } );

	var prod_communityOldId;

	if(prod_communityOld) {

		prod_communityOldId = prod_communityOld._id.str;

	// delete community from production db

	prod_db.community.remove({"pid" : communityPid});

	print("Community with pid: "+communityPid+" is deleted (if existed) from production db: "+prod_db_name);

	// migrate community pages

	//beta_community_pages = beta_db.community.findOne({ pid: communityPid } ).map( function(community) { return community.pages } );

	var beta_community_pages = beta_community.pages;

	var prod_community_pages = {}

	for (var beta_pageId in beta_community_pages) {

		//var prod_pageId = prod_db.community.find( { route: beta_db.page.find( { _id: beta_pageObjectId }).map( function(page) { return page.route; } ).toString() });

			var prod_page = prod_db.page.findOne( { route: beta_page.route } );

				prod_community_pages[prod_page._id.str] = beta_community_pages[beta_pageId];

	print("Community pages are ready to be migrated");

	// migrate community entities

	var beta_community_entities = beta_community.entities;

	var prod_community_entities = {}

	for (var beta_entityId in beta_community_entities) {

				prod_community_entities[prod_entity._id.str] = beta_community_entities[beta_entityId];

	print("Community entities are ready to be migrated");

 	prod_db.community.save({"name" : beta_community.name, "pid" : communityPid, "pages" : prod_community_pages, "entities" : prod_community_entities});

	print("Community is migrated");

	// delete community statistics from production db

	prod_db.statistics.remove({"pid" : communityPid});

	print("Statistics for community with pid: "+communityPid+" are deleted (if existed) from production db: "+prod_db_name);

	// migrate statistics for community

	var beta_statistics = beta_db.statistics.findOne({ pid: communityPid } );

	print("Statistics for community were migrated");

	// migrate subscribers of community

	var beta_communitySubscr = beta_db.communitySubscribers.findOne({ pid: communityPid } );

	if(beta_communitySubscr) {

		var beta_communitySubscribers = beta_communitySubscr.subscribers;

		var prod_communitySubscribers = [];

		var prod_communitySubscribersEmails = [];

		var prod_communitySubscr = prod_db.communitySubscribers.findOne({ "pid" : communityPid });

		if(prod_communitySubscr) {

			prod_communitySubscribers = prod_communitySubscr.subscribers;

			prod_communitySubscribersEmails = prod_communitySubscr.subscribers.map(function(subscriber){return subscriber.email});

		beta_communitySubscribers.forEach(function(beta_communitySubscriber) {

			var addInCommunity = true;

			// if user exists in community subscribers already, do nothing

			if(prod_communitySubscribersEmails.indexOf(beta_communitySubscriber.email) >= 0) {

				addInCommunity = false;

				var prod_subscriber = prod_db.subscriber.findOne({email: beta_communitySubscriber.email});

					prod_subscriber = {email: beta_communitySubscriber.email};

					print("subscriber "+beta_communitySubscriber.email+" added in production DB");

			if(addInCommunity) {

				var prod_communitySubscriber = prod_db.subscriber.findOne({email: beta_communitySubscriber.email});

				prod_communitySubscribers.push(prod_communitySubscriber);

		if(prod_communitySubscr) {

			prod_db.communitySubscribers.update({ "pid" : communityPid } , {$set: {subscribers : prod_communitySubscribers}});

			prod_db.communitySubscribers.insert({ "pid" : communityPid, "subscribers" : prod_communitySubscribers });

		print("subscribers of community were migrated");

		print("\nERROR: Subscribers not migrated. No CommunitySubscribers for this community on beta db: "+beta_db_name+"\n");

	// migrate divHelpContents of community

	var beta_communityId = beta_community._id.str;//beta_db.community.findOne( { pid: communityPid } )._id.str;

	var prod_communityId = prod_db.community.findOne( { pid: communityPid })._id.str;

	if(prod_communityOldId) {

		prod_db.divHelpContent.remove({"community": prod_communityOldId});

	beta_db.divHelpContent.find( { community: beta_communityId } ).forEach(function(beta_divHelpContent){//.map( function(divHelpContent) { return divHelpContent; } );

			var prod_divId = prod_db.divId.findOne( { name: beta_divId.name } );//._id.str;

				prod_db.divHelpContent.save({ "divId" : prod_divId._id.str, "community" : prod_communityId, "content" : beta_divHelpContent.content, "isActive" : beta_divHelpContent.isActive });

	print("divHelpContents of community were migrated");

	// migrate pageHelpContents of community

	if(prod_communityOldId) {

		prod_db.pageHelpContent.remove({"community": prod_communityOldId});

	beta_db.pageHelpContent.find( { community: beta_communityId } ).forEach(function(beta_pageHelpContent){

			var prod_page = prod_db.page.findOne( { route: beta_page.route } );//._id.str;

				prod_db.pageHelpContent.save({ "page" : prod_page._id.str, "community" : prod_communityId, "content" : beta_pageHelpContent.content, "placement": beta_pageHelpContent.placement, "order": beta_pageHelpContent.order, "isActive": beta_pageHelpContent.isActive, "isPriorTo": beta_pageHelpContent.isPriorTo });

	print("pageHelpContents of community were migrated");

	// migrate htmlPageContents of community

	if(prod_communityOldId) {

		prod_db.htmlPageContent.remove({"community": prod_communityOldId});

	}

	beta_db.htmlPageContent.find( { community: beta_communityId } ).forEach(function(beta_htmlPageContent){

		var beta_beta_htmlPageContent_page_ObjectId = ObjectId(beta_htmlPageContent.page);

		var beta_htmlPage = beta_db.page.findOne( { _id: beta_beta_htmlPageContent_page_ObjectId } );//.route;

		if(beta_htmlPage) {

			var prod_htmlPage = prod_db.page.findOne( { route: beta_htmlPage.route } );//._id.str;

			if(prod_htmlPage) {

				prod_db.htmlPageContent.save({ "page" : prod_htmlPage._id.str, "community" : prod_communityId, "content" : beta_htmlPageContent.content });

			} else {

				print("\nERROR: Page with route: "+beta_htmlPage.route+" does not exist on production db: "+prod_db_name+"\n");

			}

		} else {

			print("\nERROR: Page with id: "+beta_htmlPageContent.page+" (of htmlPageContent: "+beta_htmlPageContent._id.str+") does not exist on beta db: "+beta_db_name+"\n");

		}

	});

	print("htmlPageContents of community were migrated");

	// migrate notifications preferences of community

	var prod_notifications = prod_db.notifications.find({ communityPid: communityPid } );

	beta_db.notifications.find({ communityPid: communityPid } ).forEach(function(preference){

			prod_db.notifications.update({ managerEmail: preference.managerEmail }, {$set: {notifyForNewManagers: preference.notifyForNewManagers, notifyForNewSubscribers: preference.notifyForNewSubscribers}})

	print("Notification preferences of community were migrated");

migrate_community("egi", 'openaire_admin_copy', 'openaire_admin_prod');