D-Net

import static eu.dnetlib.data.mapreduce.hbase.broker.mapping.EventFactory.asEvent;

import java.io.IOException;

import java.util.stream.Collectors;

import org.apache.commons.lang.StringUtils;

import com.google.common.collect.Lists;

import eu.dnetlib.broker.objects.OpenAireEventPayload;

import eu.dnetlib.data.mapreduce.hbase.broker.mapping.HighlightFactory;

import eu.dnetlib.data.mapreduce.hbase.broker.model.EventWrapper;

import eu.dnetlib.data.proto.FieldTypeProtos.StringField;

public class AbstractEventFactory { // Abstract of the publication

	public static List<EventWrapper> process(final Oaf current, final Oaf other, final float trust)

			throws IOException, InterruptedException, DocumentException {

		return new AbstractEventFactory().processAbstract(current, other, trust);

	}

	private List<EventWrapper> processAbstract(final Oaf current, final Oaf other, final float trust)

			throws IOException, InterruptedException, DocumentException {

		if (hasAbstract(other)) {

			// doProcessAbstract(context, current, other, Topic.MORE_ABSTRACT);

				events.add(doProcessAbstract(current, other, Topic.ENRICH_MISSING_ABSTRACT, trust));

			}

		}

		return events;

	}

	private EventWrapper doProcessAbstract(final Oaf current, final Oaf other, final Topic topic, final float trust)

			throws IOException, InterruptedException, DocumentException {

		final Oaf.Builder prototype = Oaf.newBuilder(current);

		final OpenAireEventPayload payload =

		return EventWrapper.newInstance(

				payload.getHighlight().getAbstracts().stream().filter(StringUtils::isNotBlank).sorted().collect(Collectors.joining(", ")),

				topic.getValue());

	}

		return oaf.getEntity().getResult().getMetadata().getDescriptionList()

	}