EDIT

/**

* Copyright (C) 2009 EDIT

* European Distributed Institute of Taxonomy

* http://www.e-taxonomy.eu

*

* The contents of this file are subject to the Mozilla Public License Version 1.1

* See LICENSE.TXT at the top of this package for the full license terms.

*/

package eu.etaxonomy.cdm.io.dwca.in;

import java.util.ArrayList;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;

import java.util.UUID;

import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;

import eu.etaxonomy.cdm.io.stream.IPartitionableConverter;

import eu.etaxonomy.cdm.io.stream.IReader;

import eu.etaxonomy.cdm.io.stream.ListReader;

import eu.etaxonomy.cdm.io.stream.MappedCdmBase;

import eu.etaxonomy.cdm.io.stream.PartitionableConverterBase;

import eu.etaxonomy.cdm.io.stream.StreamItem;

import eu.etaxonomy.cdm.io.stream.terms.TermUri;

import eu.etaxonomy.cdm.model.agent.Institution;

import eu.etaxonomy.cdm.model.agent.Person;

import eu.etaxonomy.cdm.model.common.CdmBase;

import eu.etaxonomy.cdm.model.permission.User;

import eu.etaxonomy.cdm.model.reference.Reference;

/**

 * @author a.mueller

 * @since 22.11.2011

 *

 */

public class EolAgent2CdmConverter extends PartitionableConverterBase<DwcaDataImportConfiguratorBase, DwcaDataImportStateBase<DwcaDataImportConfiguratorBase>>

				implements IPartitionableConverter<StreamItem, IReader<CdmBase>, String> {

	@SuppressWarnings("unused")

	private static final Logger logger = LogManager.getLogger(EolAgent2CdmConverter.class);

	private static final String CORE_ID = "coreId";

	/**

	 * @param state

	 */

	public EolAgent2CdmConverter(DwcaDataImportStateBase state) {

		super(state);

	}

	@Override

    public IReader<MappedCdmBase<? extends CdmBase>> map(StreamItem item ){

		List<MappedCdmBase<? extends CdmBase>> resultList = new ArrayList<>();

		Map<String, String> csv = item.map;

		Reference sourceReference = state.getTransactionalSourceReference();

		String sourceReferecenDetail = null;

		//TODO is taxon needed here here?

//		String id = csv.get(CORE_ID);

//		Taxon taxon = getTaxonBase(id, item, Taxon.class, state);

		String id = item.get(TermUri.DC_IDENTIFIER);

		String givenName = item.get(TermUri.FOAF_FIRST_NAME);

		String familyName = item.get(TermUri.FOAF_FAMILY_NAME);

		String name = item.get(TermUri.FOAF_NAME);

		String organization = item.get(TermUri.EOL_ORGANIZATION);

		String accountName = item.get(TermUri.FOAF_ACCOUNT_NAME);

		Institution institution = null;

		User user = null;

		if (isNotBlank(organization)){

			institution = Institution.NewInstance();

			institution.setName(organization);

			MappedCdmBase<Institution>  mcb = new MappedCdmBase<Institution>(TermUri.EOL_ORGANIZATION, id, institution);

			resultList.add(mcb);

		}

		if (isNotBlank(accountName)){

			user = User.NewInstance(accountName, UUID.randomUUID().toString());   //TODO

			MappedCdmBase<User>  mcb = new MappedCdmBase<User>(TermUri.FOAF_ACCOUNT_NAME, id, user);

			resultList.add(mcb);

		}

		if (isPerson(item)){

			Person person = Person.NewInstance();

			person.setGivenName(givenName);

			person.setFamilyName(familyName);

			if (isNotBlank(name) && ! name.equalsIgnoreCase(person.getTitleCache())){

				//TODO FOAF_NAME allows multiple names per object

				person.setTitleCache(name, true);

			}

			if (institution != null){

				person.addInstitutionalMembership(institution, null, null, null);

			}

			if (isNotBlank(accountName)){

			}

			MappedCdmBase<Person>  mcb = new MappedCdmBase<>(item.term, id, person);

			resultList.add(mcb);

		}else{

			//still unclear, what does Agent all include? Teams, organizations, ...?

			String message = "Agent type unclear. Agent not handled.";

			fireWarningEvent(message, item, 8);

		}

//		resultList.add(mcb);

		//return

		return new ListReader<>(resultList);

	}

	private boolean isPerson(StreamItem item) {

		String givenName = item.get(TermUri.FOAF_FIRST_NAME);

		String familyName = item.get(TermUri.FOAF_FAMILY_NAME);

		String accountName = item.get(TermUri.FOAF_ACCOUNT_NAME);

		if (isNotBlank(givenName) || isNotBlank(familyName) || isNotBlank(accountName) ){

			return true;

		}else{

			return false;

		}

	}

	@Override

	public String getSourceId(StreamItem item) {

		String id = item.get(CORE_ID);

		return id;

	}

//**************************** PARTITIONABLE ************************************************

	@Override

	protected void makeForeignKeysForItem(StreamItem item, Map<String, Set<String>> fkMap) {

		String value;

		String key;

		if ( hasValue(value = item.get(CORE_ID))){

			key = TermUri.DWC_TAXON.toString();

			Set<String> keySet = getKeySet(key, fkMap);

			keySet.add(value);

		}

	}

	@Override

	public final Set<String> requiredSourceNamespaces() {

		Set<String> result = new HashSet<>();

 		result.add(TermUri.DWC_TAXON.toString());

 		return result;

	}

//************************ STRING ************************************************/

	@Override

	public String toString(){

		return this.getClass().getName();

	}

}