D-Net

package eu.dnetlib.grid.process;

import java.util.List;

import java.util.Map;

import java.util.Objects;

import java.util.stream.Collectors;

import eu.dnetlib.grid.process.model.GridOrganization;

import eu.dnetlib.grid.process.utils.Datasource;

import eu.dnetlib.grid.process.utils.GridCleaner;

import eu.dnetlib.grid.process.utils.GridUtils;

public class GridOrganizationsProcess {

	private static final Datasource gridDs = new Datasource("openaire____::grid", "GRID - Global Research Identifier Database", "grid________");

	public static void main(final String[] args) {

	}

	protected static void processFile(final String jsonFile) throws Exception {

		final GridCleaner cleaner = new GridCleaner();

		final Map<String, String> parents = GridUtils.streamOrganizations(jsonFile)

				.filter(Objects::nonNull)

				.filter(o -> o.getStatus().equals("active"))

				.collect(Collectors.toMap(GridOrganization::getId, GridUtils::findShortName));

		GridUtils.streamOrganizations(jsonFile)

				.filter(Objects::nonNull)

				.filter(o -> o.getStatus().equals("active"))

				.map(cleaner)

				.map(org -> GridUtils.toProtos(org, parents, gridDs))

				.flatMap(List::stream)

				.map(s -> s) // TODO OAF -> JSON

				.forEach(System.out::println);

	}

}