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 F5017.
 * @author alessia
 *
 */
class SozArchLIDO5014 implements RunnableGroovy  {
	def String templatePath = "/var/lib/hope-scripts/templates"
	def SozArchUtils utils = new SozArchUtils()
	def BlockingQueue<String> resultsQueue, inputQueue;

	def String collectionID = 'F_5014'
	/**
	 * 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_5014 Schweizerische Ausstellung für Frauenarbeit (SAFFA) 1958"
		def String providerName = 'Schweizerisches Sozialarchiv'
		def String abstractSum="Der Bestand umfasst über 400 Fotos und (zum Teil stark verunreinigte) Dias. Sie zeigen die Vorbereitungsarbeiten, den Eröffnungsumzug, die Ausstellungsräume und das Unterhaltungsangebot der SAFFA 1958."
		def OAIHeader collOaiheader = new OAIHeader(dateOfCollection:dateOfCollection, repositoryId:repoId, setSpec:setSpec, identifier:collectionID, objIdentifier:repoId+"::"+collectionID)
		def LIDOCollection coll5014 = new LIDOCollection(collectionID:collectionID,
				langCode:'ger', titles:[
					new LidoTitle(value:"Schweizerische Ausstellung für Frauenarbeit (SAFFA) 1958")
				],
				descriptions:[
					new LidoDescription(type:'custodial history', value:'Nachlieferung von Dr. Luzi Schucan, 2009', langCode:'ger'),
					new LidoDescription(type:'accrual policy', value:'Übernahme-Modalitäten aus Custodial History', langCode:'ger')
				],
				abstractSummaries:[
					new LidoDescription(type:'abstract', value:abstractSum)
				], collItemLanguages:['ger'],
				creationDates:['2004'], accumulationDates:['2004'], owners:[providerName],
				sizeItems:'402', itemType:'IMAGE', itemFormatStm:'', itemFormats:['Fotografie'],
				associatedPub:'http://findmittel.ch/archive/archNeu/Ar17.html',
				typedSubjects:[
					new TypedSubjects(type:'association', dates:['1958'], places:[
						new LidoPlace(preferredName:'CH')
					])
				],subjects:['Frauenbewegung'], 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 collection5014 = coll5014.getXML(template, collOaiheader, providerName, coll5014)
		return collection5014
	}

	@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 collection5014 = generateCollectionRecord(template, repoId, setSpec, dateOfCollection)
				resultsQueue.put(collection5014);
				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) {}




}