D-Net

package eu.dnetlib.data.oai.store.mongo;

import java.io.IOException;

import java.time.LocalDateTime;

import java.time.ZoneId;

import java.time.format.DateTimeFormatter;

import java.util.Date;

import java.util.zip.ZipEntry;

import java.util.zip.ZipOutputStream;

import eu.dnetlib.data.information.oai.publisher.conf.OAIConfigurationReader;

import org.apache.commons.io.IOUtils;

import org.apache.commons.io.output.ByteArrayOutputStream;

import org.bson.types.Binary;

import org.junit.Before;

import org.junit.Test;

import org.springframework.core.io.ClassPathResource;

/**

 * RecordInfoGenerator Tester.

 *

 * @author <Authors name>

 * @version 1.0

 * @since <pre>Apr 6, 2016</pre>

 */

public class RecordInfoGeneratorTest {

	private RecordInfoGenerator gen = new RecordInfoGenerator();

	private String filePath = "/eu/dnetlib/data/oai/store/mongo/testRecord.xml";

	private Binary binaryXML;

	@Before

	public void before() throws Exception {

		String testRecord = IOUtils.toString(new ClassPathResource(filePath).getInputStream());

		binaryXML = createCompressRecord(testRecord);

	}

	/**

	 * Method: decompressRecord(final byte[] input)

	 */

	@Test

	public void testDecompressRecord() throws Exception {

		long timeStart = System.currentTimeMillis();

		String record = gen.decompressRecord(binaryXML.getData());

		long timeEnd = System.currentTimeMillis();

		System.out.println("Decompressed record in ms " + (timeEnd - timeStart));

		System.out.println(record);

	}

	@Test

	public void parseDatestamp(){

		String thedate = "2018-02-13T15:02:16.122Z";

		//Because DateTimeFormatter.ISO_INSTANT does not work

		DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss.SSSX");

		//DateTimeFormatter formatter = new DateTimeFormatterBuilder(DateTimeFormatter.ISO_INSTANT).appendInstant(3).toFormatter();

		LocalDateTime d = LocalDateTime.parse(thedate, dtf);

		Date utilDate = Date.from(d.atZone(ZoneId.systemDefault()).toInstant());

	}

	private Binary createCompressRecord(final String record) throws IOException {

		ByteArrayOutputStream os = new ByteArrayOutputStream();

		ZipOutputStream zos = new ZipOutputStream(os);

		ZipEntry entry = new ZipEntry(OAIConfigurationReader.BODY_FIELD);

		zos.putNextEntry(entry);

		zos.write(record.getBytes());

		zos.closeEntry();

		//zos.flush();

		zos.close();

		return new Binary(os.toByteArray());

	}

}