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
import groovy.util.XmlParser
/**
 * DNetGroovy class for SSA F5003.
 * @author alessia
 *
 */
class SozArchLIDO5003 implements RunnableGroovy  {
	def String templatePath = "/var/lib/hope-scripts/templates"
	def SozArchUtils utils = new SozArchUtils()
	def BlockingQueue<String> resultsQueue, inputQueue;

	def String collectionID = 'F_5003'
	/**
	 * 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_5003 Gewerkschaft Bau und Holz (GBH), Sektion Zürich'
		def String providerName = 'Schweizerisches Sozialarchiv'
		def String abstractSum="Hervorzuheben sind die sorgfältig gestalteten Alben, welche die kämpferischen und gemeinnützigen "+
				"Aktionen der Gewerkschaft in der ersten Jahrhunderthälfte des 20. Jahrhunderts dokumentieren. Vor allem das Album über die "+
				"Aussperrung der Holzarbeiter 1936 dokumentiert auf einzigartige Weise den Arbeitskampf in wirtschaftlich äusserst schwierigen "+
				"Zeiten (hohe Arbeitslosigkeit im Holz- und Bausektor). Ebenfalls überliefert sind Alben über das Engagement der Gewerkschaften "+
				"für die Opfer des Spanischen Bürgerkrieges (Patenschaften) und die St. Niklaus-Aktion im Volkshaus Zürich. "+
				"Die Dokumentationen über 1. Mai-Demonstrationen der 1930er Jahre wurden von den Fotohäusern Acklin und Zollinger in Zürich gemacht. "+
				"Sie wurden – soweit noch vorhanden – integral aufbewahrt, weil sie die abbilden, wie uniform und geschlossen wirkend dieser Anlass "+
				"und das Auftreten der Bau- und Holzarbeiter in jener Zeit war. - Einigermassen gut vertreten sind Fotos zum Thema Aus- und "+
				"Weiterbildung, darunter auch Ansichten vom Ausbildungszentrum für Bauarbeiter in Wetzikon. "+
				"Noch eine Bemerkung zur Autorenschaft der Fotos: Ein beachtlicher Teil der Fotos in diesem Bildarchiv aus den 1950er und 1960er "+
				"Jahren stammt vom Fotografen Hermann Freytag. Weiteres Material zum Gewerkschaftswirken findet sich in dessen Nachlass, "+
				"der sich ebenfalls im Sozialarchiv befindet."

		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:'Gewerkschaft Bau und Holz (GBH), Sektion Zürich')
				], abstractSummaries:[
					new LidoDescription(type:'abstract', value:abstractSum)
				],
				creationDates:['1933P63Y'], accumulationDates:['2003'], owners:[providerName],
				sizeItems:'92', itemType:'IMAGE', itemFormatStm:'Fotografie, Druck, Kunst',
				associatedPub:'http://findmittel.ch/archive/archNeu/Ar22.html',
				typedSubjects:[
					new TypedSubjects(type:'association', dates:['1900-1996'], places:[
						new LidoPlace(preferredName:'CH')
					])
				],
				subjects:['Gewerkschaften'], 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 StringTemplate template = null
		try{
			def StringTemplateGroup group =  new StringTemplateGroup("visualGroup", templatePath, DefaultTemplateLexer.class);
			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 collection5003 = generateCollectionRecord(template, repoId, setSpec, dateOfCollection)
					resultsQueue.put(collection5003);
					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"
		}catch(Exception e){
			println "An exception in groovy script: "+e.getMessage()
			this.resultsQueue.put("END")
			println "closedQueue"
		}
		finally{
			if(template)
				template.reset()
		}
	}

	@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) {}

}