import java.util.concurrent.BlockingQueue

import org.antlr.stringtemplate.StringTemplate
import org.antlr.stringtemplate.StringTemplateGroup
import org.antlr.stringtemplate.language.DefaultTemplateLexer

import eu.dnetlib.enabling.manager.msro.hope.groovy.RunnableGroovy
import eu.dnetlib.hope.domains.common.LandingPage
import eu.dnetlib.hope.domains.common.OAIHeader
import eu.dnetlib.hope.domains.visual.LIDOCollection
import eu.dnetlib.hope.domains.visual.LidoDescription
import eu.dnetlib.hope.domains.visual.LidoPlace
import eu.dnetlib.hope.domains.visual.LidoTitle
import eu.dnetlib.hope.domains.visual.TypedSubjects
/**
 * DNetGroovy class for SSA F5055.
 * @author alessia
 *
 */
class SozArchLIDO5055 implements RunnableGroovy  {
	def String templatePath = "/var/lib/hope-scripts/templates"
	def SozArchUtils utils = new SozArchUtils()
	def BlockingQueue<String> resultsQueue, inputQueue;

	def String collectionID = 'F_5055'
	/**
	 * Driver namespace for elements in the OAI header.
	 */
	def dri = new groovy.xml.Namespace("http://www.driver-repository.eu/namespace/dri", 'dri')

	def generateCollectionRecord = { template, repoId, setSpec, dateOfCollection ->
		def String lPageURL = 'http://www.bild-video-ton.ch/archiv/images?Bilder.ssaBestand=F_5055 Gruppe Schweiz ohne Armee'
		def String providerName = 'Schweizerisches Sozialarchiv'
		def String abstractSum='''
Die Gruppe für eine Schweiz ohne Armee (GSoA) zählt zu den wichtigsten und mitgliederstärksten, friedenspolitischen Bewegungen. 
Seit 1982 hat sie mehrere Volksinitiativen zur Abstimmung gebracht, am spektakulärsten waren sicher die Armeeabschaffungsinitiative von 1989 und die Stop F/A-18-Initiative von 1993. 
Diese und andere Abstimmungen gingen zwar verloren; die Anliegen der GSoA mögen zwar (noch) nicht mehrheitsfähig sein, belebend für die Demokratie sind die Diskussionen über die Existenzberechtigung der Schweizer Armee oder über Rüstungskredite aber allemal. Zu einer relativ breiten Akzeptanz der friedenspolitischen Postulate in der Bevölkerung hat auch das Auftreten der GSoA beigetragen: Immer wieder gelang es ihr mit lauten, frechen oder komischen Auftritten die öffentliche Aufmerksamkeit in Beschlag zu nehmen. 
Die visuellen Zeugnisse davon sind nun digitalisiert und können recherchiert werden. 
Der Bestand umfasst mehr als 200 Fotos, Flyer und Pins.
'''
		def OAIHeader collOaiheader = new OAIHeader(dateOfCollection:dateOfCollection, repositoryId:repoId, setSpec:setSpec, identifier:collectionID, objIdentifier:repoId+"::"+collectionID)
		def LIDOCollection coll = new LIDOCollection(collectionID:collectionID,
				langCode:'ger', titles:[
					new LidoTitle(value:"Gruppe Schweiz ohne Armee (GSoA) - Groupe pour une Suisse sans armée (GSsA)")
				],
				abstractSummaries:[
					new LidoDescription(type:'abstract', value:abstractSum)
				],
				creationDates:['1985P20Y'], accumulationDates:['2009'], owners:[providerName],
				sizeItems:'326', itemType:'IMAGE', itemFormatStm:'',
				collItemLanguages:[
					'fre',
					'ger',
					'ita',
					'rus',
					'eng'
				],
				associatedPub:'http://www.findmittel.ch/Archive/archNeu/Ar452.html', subjects:[
					'Friedensbewegung; Antimilitarismus'
				],
				typedSubjects:[
					new TypedSubjects(type:'association', dates:['1984-2009'], places:[
						new LidoPlace(preferredName:'CH')
					])
				],
				repository:providerName,
				useRights:"Jede Art der Verwendung und der Reproduktion setzt eine Bewilligung und einen vereinbarten Zweck voraus. Jede weitere Nutzung bedarf der erneuten Zustimmung des Schweizerischen Sozialarchivs oder des jeweiligen Rechteinhabers.",
				accessRights:'Auf den Bestand oder auf Teile davon gewährt das Schweizerische Sozialarchiv öffentlichen, kostenlosen Zugang. Weitere Bestimmungen finden Sie auf unseren Websites.',
				europeanaType:'IMAGE', landingPage:new LandingPage(href:lPageURL, localID:lPageURL))
		def String collection = coll.getXML(template, collOaiheader, providerName, coll)
		return collection
	}

	@Override
	public void run() {
		def StringTemplateGroup group =  new StringTemplateGroup("visualGroup", templatePath, DefaultTemplateLexer.class);
		def StringTemplate template = group.getInstanceOf("visualTemplate");

		//iterates on the input xml to generate records contained by the collection created above
		def parser = new XmlParser(false, true);
		def String input;
		def c = 0;
		while(!((input = this.inputQueue.take()).equals("END"))){
			template.reset()
			def Node xmlRoot = parser.parseText(input)

			def Node oaiHeaderNode = xmlRoot.'**'.header[0]
			//Common OAI Header elements
			def dateOfCollection = oaiHeaderNode.'dri:dateOfCollection'.text()
			def repoId = oaiHeaderNode.'dri:repositoryId'.text()
			def setSpec = oaiHeaderNode.setSpec.text()
			//create collection from constants values from the mapping
			if(c == 0){
				def String collection = generateCollectionRecord(template, repoId, setSpec, dateOfCollection)
				resultsQueue.put(collection);
				c++
			}
			def Node sozRoot = xmlRoot.'**'.ImagicXML[0]
			def NodeList sozObjects = sozRoot.Update.Row
			println "Found "+sozObjects.size()+" rows"

			sozObjects.each {
				String lidoObject = utils.transformSozObjekt(it, template, dateOfCollection, repoId, setSpec, collectionID, utils.generateDefaultResourceWrap)
				resultsQueue.put(lidoObject);
				c++
				template.reset()
			}
		}
		println c +" lido objects enueued"
		this.resultsQueue.put("END")
		println "closedQueue"
	}

	@Override
	public void setResultsQueue(BlockingQueue<String> queue) {
		this.resultsQueue = queue

	}

	@Override
	public void setInputQueue(BlockingQueue<String> queue) {
		this.inputQueue = queue
	}

	/**
	 * TODO: calling the method from the run() does not work. Kinda groovy strange stuff, I do not know why.
	 */
	@Override
	public void closeResultQueue() {
		this.resultsQueue.put("END")
		println "closedQueue"
	}
	/**
	 * TODO: use this to set the repoId of the collection instead of the current trick
	 * {@inheritDoc}
	 * @see eu.dnetlib.enabling.manager.msro.hope.groovy.RunnableGroovy#setRepositoryId(java.lang.String)
	 */
	@Override
	public void setRepositoryId(String repoId) {}




}